inteligr8/alfresco-community-repo
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-community-repo.git synced 2025-06-09 17:45:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixed the two tests that were failing in the continuous build. Disabled

Browse Source 
four really long winded AVM performance and stress tests.  This should speed
up the continuous build on the wcm branch.  The tests should probably be set up
to run periodically with other long running exhaustive performance, and stress tests.


git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/BRANCHES/WCM-DEV2/root@4293 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
Britt Park 2006-11-06 06:11:26 +00:00
parent 7fdf8130c8
commit 2c20af6d2b
6 changed files with 288 additions and 284 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

164
source/java/org/alfresco/repo/avm/AVMCrawlTest.java
View File

@ -35,87 +35,87 @@ public class AVMCrawlTest extends AVMServiceTestBase
*/ */
public void testCrawl() public void testCrawl()
{ {
int n = 1; // Number of Threads. // int n = 1; // Number of Threads.
int m = 1; // How many multiples of content to start with. // int m = 1; // How many multiples of content to start with.
long runTime = 120000; // 2 minutes // long runTime = 120000; // 2 minutes
fService.purgeAVMStore("main"); // fService.purgeAVMStore("main");
BulkLoader loader = new BulkLoader(); // BulkLoader loader = new BulkLoader();
loader.setAvmService(fService); // loader.setAvmService(fService);
for (int i = 0; i < m; i++) // for (int i = 0; i < m; i++)
{ // {
fService.createAVMStore("d" + i); // fService.createAVMStore("d" + i);
loader.recursiveLoad("source", "d" + i + ":/"); // loader.recursiveLoad("source", "d" + i + ":/");
fService.createSnapshot("d" + i, null, null); // fService.createSnapshot("d" + i, null, null);
} // }
long startTime = System.currentTimeMillis(); // long startTime = System.currentTimeMillis();
List<AVMCrawler> crawlers = new ArrayList<AVMCrawler>(); // List<AVMCrawler> crawlers = new ArrayList<AVMCrawler>();
List<Thread> threads = new ArrayList<Thread>(); // List<Thread> threads = new ArrayList<Thread>();
for (int i = 0; i < n; i++) // for (int i = 0; i < n; i++)
{ // {
crawlers.add(new AVMCrawler(fService)); // crawlers.add(new AVMCrawler(fService));
threads.add(new Thread(crawlers.get(i))); // threads.add(new Thread(crawlers.get(i)));
threads.get(i).start(); // threads.get(i).start();
} // }
while (true) // while (true)
{ // {
try // try
{ // {
Thread.sleep(5000); // Thread.sleep(5000);
// Check that none of the crawlers has errored out. // // Check that none of the crawlers has errored out.
for (AVMCrawler crawler : crawlers) // for (AVMCrawler crawler : crawlers)
{ // {
if (crawler.getError()) // if (crawler.getError())
{ // {
for (AVMCrawler craw : crawlers) // for (AVMCrawler craw : crawlers)
{ // {
craw.setDone(); // craw.setDone();
} // }
for (Thread thread : threads) // for (Thread thread : threads)
{ // {
try // try
{ // {
thread.join(); // thread.join();
} // }
catch (InterruptedException ie) // catch (InterruptedException ie)
{ // {
// Do nothing. // // Do nothing.
} // }
} // }
fail(); // fail();
} // }
} // }
} // }
catch (InterruptedException ie) // catch (InterruptedException ie)
{ // {
// Do nothing. // // Do nothing.
} // }
long now = System.currentTimeMillis(); // long now = System.currentTimeMillis();
if (now - startTime > runTime) // if (now - startTime > runTime)
{ // {
break; // break;
} // }
} // }
for (AVMCrawler crawler : crawlers) // for (AVMCrawler crawler : crawlers)
{ // {
crawler.setDone(); // crawler.setDone();
} // }
for (Thread thread : threads) // for (Thread thread : threads)
{ // {
try // try
{ // {
thread.join(); // thread.join();
} // }
catch (InterruptedException ie) // catch (InterruptedException ie)
{ // {
// Do nothing. // // Do nothing.
} // }
} // }
long ops = 0L; // long ops = 0L;
for (AVMCrawler crawler : crawlers) // for (AVMCrawler crawler : crawlers)
{ // {
ops += crawler.getOpCount(); // ops += crawler.getOpCount();
} // }
long time = System.currentTimeMillis() - startTime; // long time = System.currentTimeMillis() - startTime;
System.out.println("Ops/Sec: " + (ops * 1000L / time)); // System.out.println("Ops/Sec: " + (ops * 1000L / time));
} }
} }

158
source/java/org/alfresco/repo/avm/AVMStressTest.java
View File

@ -33,84 +33,84 @@ public class AVMStressTest extends AVMServiceTestBase
*/ */
public void testNThreads() public void testNThreads()
{ {
try // try
{ // {
int nCopies = 1; // int nCopies = 1;
int nThreads = 1; // int nThreads = 1;
BulkLoader loader = new BulkLoader(); // BulkLoader loader = new BulkLoader();
loader.setAvmService(fService); // loader.setAvmService(fService);
long start = System.currentTimeMillis(); // long start = System.currentTimeMillis();
for (int i = 0; i < nCopies; i++) // for (int i = 0; i < nCopies; i++)
{ // {
fService.createDirectory("main:/", "" + i); // fService.createDirectory("main:/", "" + i);
loader.recursiveLoad("source", "main:/" + i); // loader.recursiveLoad("source", "main:/" + i);
fService.createSnapshot("main", null, null); // fService.createSnapshot("main", null, null);
} // }
System.out.println("Load time: " + (System.currentTimeMillis() - start)); // System.out.println("Load time: " + (System.currentTimeMillis() - start));
List<AVMTester> testers = new ArrayList<AVMTester>(); // List<AVMTester> testers = new ArrayList<AVMTester>();
List<Thread> threads = new ArrayList<Thread>(); // List<Thread> threads = new ArrayList<Thread>();
for (int i = 0; i < nThreads; i++) // for (int i = 0; i < nThreads; i++)
{ // {
AVMTester tester // AVMTester tester
= new AVMTester(800, // create file. // = new AVMTester(800, // create file.
20, // create dir, // 20, // create dir,
0, // rename // 0, // rename
2, // create layered dir // 2, // create layered dir
5, // create layered file // 5, // create layered file
10, // remove node // 10, // remove node
20, // modify file. // 20, // modify file.
3200, // read file // 3200, // read file
10, // snapshot // 10, // snapshot
1000, // # ops // 1000, // # ops
fService); // fService);
tester.refresh(); // tester.refresh();
Thread thread = new Thread(tester); // Thread thread = new Thread(tester);
testers.add(tester); // testers.add(tester);
threads.add(thread); // threads.add(thread);
} // }
for (Thread thread : threads) // for (Thread thread : threads)
{ // {
thread.start(); // thread.start();
} // }
int exited = 0; // int exited = 0;
// long sampStart = System.currentTimeMillis(); // // long sampStart = System.currentTimeMillis();
while (exited != nThreads) // while (exited != nThreads)
{ // {
try // try
{ // {
Thread.sleep(2000); // Thread.sleep(2000);
for (int i = 0; i < nThreads; i++) // for (int i = 0; i < nThreads; i++)
{ // {
if (threads.get(i) == null) // if (threads.get(i) == null)
{ // {
continue; // continue;
} // }
threads.get(i).join(1000); // threads.get(i).join(1000);
if (!threads.get(i).isAlive()) // if (!threads.get(i).isAlive())
{ // {
threads.set(i, null); // threads.set(i, null);
if (testers.get(i).getError()) // if (testers.get(i).getError())
{ // {
for (AVMTester tester : testers) // for (AVMTester tester : testers)
{ // {
tester.setExit(); // tester.setExit();
} // }
fail(); // fail();
} // }
exited++; // exited++;
} // }
} // }
} // }
catch (InterruptedException e) // catch (InterruptedException e)
{ // {
// Do nothing. // // Do nothing.
} // }
} // }
} // }
catch (Exception e) // catch (Exception e)
{ // {
e.printStackTrace(System.err); // e.printStackTrace(System.err);
fail(); // fail();
} // }
} }
} }

186
source/java/org/alfresco/repo/avm/PurgeTest.java
View File

@ -30,35 +30,35 @@ public class PurgeTest extends AVMServiceTestBase
*/ */
public void testPurgeVersion() public void testPurgeVersion()
{ {
try // try
{ // {
setupBasicTree(); // setupBasicTree();
BulkLoader loader = new BulkLoader(); // BulkLoader loader = new BulkLoader();
loader.setAvmService(fService); // loader.setAvmService(fService);
long start = System.currentTimeMillis(); // long start = System.currentTimeMillis();
loader.recursiveLoad("source/web", "main:/"); // loader.recursiveLoad("source/web", "main:/");
System.err.println("Load time: " + (System.currentTimeMillis() - start) + "ms"); // System.err.println("Load time: " + (System.currentTimeMillis() - start) + "ms");
fService.createSnapshot("main", null, null); // fService.createSnapshot("main", null, null);
System.err.println("Load time + snapshot: " + (System.currentTimeMillis() - start) + "ms"); // System.err.println("Load time + snapshot: " + (System.currentTimeMillis() - start) + "ms");
fService.purgeVersion(2, "main"); // fService.purgeVersion(2, "main");
fReaper.activate(); // fReaper.activate();
while (fReaper.isActive()) // while (fReaper.isActive())
{ // {
try // try
{ // {
Thread.sleep(2000); // Thread.sleep(2000);
} // }
catch (InterruptedException e) // catch (InterruptedException e)
{ // {
// Do nothing. // // Do nothing.
} // }
} // }
} // }
catch (Exception e) // catch (Exception e)
{ // {
e.printStackTrace(System.err); // e.printStackTrace(System.err);
fail(); // fail();
} // }
} }
/** /**
@ -66,37 +66,37 @@ public class PurgeTest extends AVMServiceTestBase
*/ */
public void testPurgeOlderVersion() public void testPurgeOlderVersion()
{ {
try // try
{ // {
setupBasicTree(); // setupBasicTree();
BulkLoader loader = new BulkLoader(); // BulkLoader loader = new BulkLoader();
loader.setAvmService(fService); // loader.setAvmService(fService);
long start = System.currentTimeMillis(); // long start = System.currentTimeMillis();
loader.recursiveLoad("source", "main:/"); // loader.recursiveLoad("source", "main:/");
System.err.println("Load time: " + (System.currentTimeMillis() - start) + "ms"); // System.err.println("Load time: " + (System.currentTimeMillis() - start) + "ms");
fService.createSnapshot("main", null, null); // fService.createSnapshot("main", null, null);
System.err.println("Load time + snapshot: " + (System.currentTimeMillis() - start) + "ms"); // System.err.println("Load time + snapshot: " + (System.currentTimeMillis() - start) + "ms");
fService.removeNode("main:/source/java/org/alfresco", "repo"); // fService.removeNode("main:/source/java/org/alfresco", "repo");
fService.createSnapshot("main", null, null); // fService.createSnapshot("main", null, null);
fService.purgeVersion(2, "main"); // fService.purgeVersion(2, "main");
fReaper.activate(); // fReaper.activate();
while (fReaper.isActive()) // while (fReaper.isActive())
{ // {
try // try
{ // {
Thread.sleep(2000); // Thread.sleep(2000);
} // }
catch (InterruptedException e) // catch (InterruptedException e)
{ // {
// Do nothing. // // Do nothing.
} // }
} // }
} // }
catch (Exception e) // catch (Exception e)
{ // {
e.printStackTrace(System.err); // e.printStackTrace(System.err);
fail(); // fail();
} // }
} }
/** /**
@ -104,38 +104,38 @@ public class PurgeTest extends AVMServiceTestBase
*/ */
public void testPurgeStore() public void testPurgeStore()
{ {
try // try
{ // {
setupBasicTree(); // setupBasicTree();
BulkLoader loader = new BulkLoader(); // BulkLoader loader = new BulkLoader();
loader.setAvmService(fService); // loader.setAvmService(fService);
long start = System.currentTimeMillis(); // long start = System.currentTimeMillis();
loader.recursiveLoad("source", "main:/"); // loader.recursiveLoad("source", "main:/");
System.err.println("Load time: " + (System.currentTimeMillis() - start) + "ms"); // System.err.println("Load time: " + (System.currentTimeMillis() - start) + "ms");
fService.createSnapshot("main", null, null); // fService.createSnapshot("main", null, null);
System.err.println("Load time + snapshot: " + (System.currentTimeMillis() - start) + "ms"); // System.err.println("Load time + snapshot: " + (System.currentTimeMillis() - start) + "ms");
fService.createLayeredDirectory("main:/source", "main:/", "layer"); // fService.createLayeredDirectory("main:/source", "main:/", "layer");
fService.removeNode("main:/layer/java/org/alfresco", "repo"); // fService.removeNode("main:/layer/java/org/alfresco", "repo");
fService.createFile("main:/layer/java/org/alfresco", "goofy").close(); // fService.createFile("main:/layer/java/org/alfresco", "goofy").close();
fService.createSnapshot("main", null, null); // fService.createSnapshot("main", null, null);
fService.purgeAVMStore("main"); // fService.purgeAVMStore("main");
fReaper.activate(); // fReaper.activate();
while (fReaper.isActive()) // while (fReaper.isActive())
{ // {
try // try
{ // {
Thread.sleep(2000); // Thread.sleep(2000);
} // }
catch (InterruptedException e) // catch (InterruptedException e)
{ // {
// Do nothing. // // Do nothing.
} // }
} // }
} // }
catch (Exception e) // catch (Exception e)
{ // {
e.printStackTrace(System.err); // e.printStackTrace(System.err);
fail(); // fail();
} // }
} }
} }

54
source/java/org/alfresco/repo/avm/SimultaneousLoadTest.java
View File

@ -30,33 +30,33 @@ public class SimultaneousLoadTest extends AVMServiceTestBase
*/ */
public void testSimultaneousLoad() public void testSimultaneousLoad()
{ {
try // try
{ // {
int n = 1; // int n = 1;
int m = 1; // int m = 1;
fReaper.setInactiveBaseSleep(60000); // fReaper.setInactiveBaseSleep(60000);
for (int i = 0; i < n; i++) // for (int i = 0; i < n; i++)
{ // {
fService.createDirectory("main:/", "d" + i); // fService.createDirectory("main:/", "d" + i);
} // }
fService.createSnapshot("main", null, null); // fService.createSnapshot("main", null, null);
Thread [] threads = new Thread[n]; // Thread [] threads = new Thread[n];
for (int i = 0; i < n; i++) // for (int i = 0; i < n; i++)
{ // {
Loader loader = new Loader("/Users/britt/stuff/" + i, "main:/d" + i, m); // Loader loader = new Loader("/Users/britt/stuff/" + i, "main:/d" + i, m);
threads[i] = new Thread(loader); // threads[i] = new Thread(loader);
threads[i].start(); // threads[i].start();
} // }
for (int i = 0; i < n; i++) // for (int i = 0; i < n; i++)
{ // {
threads[i].join(); // threads[i].join();
} // }
} // }
catch (Exception e) // catch (Exception e)
{ // {
e.printStackTrace(System.err); // e.printStackTrace(System.err);
fail(); // fail();
} // }
} }
private class Loader implements Runnable private class Loader implements Runnable

1
source/java/org/alfresco/repo/dictionary/DictionaryDAOTest.java
View File

@ -88,6 +88,7 @@ public class DictionaryDAOTest extends TestCase
bootstrapModels.add("alfresco/model/dictionaryModel.xml"); bootstrapModels.add("alfresco/model/dictionaryModel.xml");
bootstrapModels.add("alfresco/model/systemModel.xml"); bootstrapModels.add("alfresco/model/systemModel.xml");
bootstrapModels.add("alfresco/model/contentModel.xml"); bootstrapModels.add("alfresco/model/contentModel.xml");
bootstrapModels.add("alfresco/model/wcmModel.xml");
bootstrapModels.add("alfresco/model/applicationModel.xml"); bootstrapModels.add("alfresco/model/applicationModel.xml");
bootstrapModels.add("org/alfresco/repo/security/authentication/userModel.xml"); bootstrapModels.add("org/alfresco/repo/security/authentication/userModel.xml");

9
source/java/org/alfresco/repo/security/permissions/impl/model/PermissionModelTest.java
View File

@ -79,7 +79,8 @@ public class PermissionModelTest extends AbstractPermissionTest
Set<PermissionReference> grantees = permissionModelDAO.getGranteePermissions(new SimplePermissionReference(QName.createQName("cm", "cmobject", Set<PermissionReference> grantees = permissionModelDAO.getGranteePermissions(new SimplePermissionReference(QName.createQName("cm", "cmobject",
namespacePrefixResolver), "Coordinator")); namespacePrefixResolver), "Coordinator"));
assertEquals(59, grantees.size()); // NB This has gone from 59 to 63, I believe, because of the for new WCM roles.
assertEquals(63, grantees.size());
} }
public void testIncludePermissionGroups6() public void testIncludePermissionGroups6()
@ -94,11 +95,13 @@ public class PermissionModelTest extends AbstractPermissionTest
{ {
Set<PermissionReference> granters = permissionModelDAO.getGrantingPermissions(new SimplePermissionReference(QName.createQName("sys", "base", Set<PermissionReference> granters = permissionModelDAO.getGrantingPermissions(new SimplePermissionReference(QName.createQName("sys", "base",
namespacePrefixResolver), "ReadProperties")); namespacePrefixResolver), "ReadProperties"));
assertEquals(10, granters.size()); // NB This has gone from 10 to 14 because of the new WCM roles, I believe.
assertEquals(14, granters.size());
granters = permissionModelDAO.getGrantingPermissions(new SimplePermissionReference(QName.createQName("sys", "base", granters = permissionModelDAO.getGrantingPermissions(new SimplePermissionReference(QName.createQName("sys", "base",
namespacePrefixResolver), "_ReadProperties")); namespacePrefixResolver), "_ReadProperties"));
assertEquals(11, granters.size()); // NB 11 to 15 as above.
assertEquals(15, granters.size());
} }
public void testGlobalPermissions() public void testGlobalPermissions()