inteligr8/alfresco-community-repo
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-community-repo.git synced 2025-07-24 17:32:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Debug build failure

Browse Source 
git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@4792 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
Andrew Hind
2007-01-11 14:56:53 +00:00
parent c396a5f453
commit 9b5c933612
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
source/java/org/alfresco/repo/node/ConcurrentNodeServiceTest.java
View File

@@ -40,7 +40,6 @@ import org.alfresco.service.namespace.NamespaceService;
import org.alfresco.service.namespace.QName; import org.alfresco.service.namespace.QName;
import org.alfresco.service.transaction.TransactionService; import org.alfresco.service.transaction.TransactionService;
import org.alfresco.util.ApplicationContextHelper; import org.alfresco.util.ApplicationContextHelper;
import org.apache.lucene.index.IndexWriter;
import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContext;
/** /**
@@ -145,6 +144,7 @@ public class ConcurrentNodeServiceTest extends TestCase
try try
{ {
runner.join(); runner.join();
System.out.println("Query thread has waited for " + runner.getName());
} }
catch (InterruptedException e) catch (InterruptedException e)
{ {
@@ -152,6 +152,9 @@ public class ConcurrentNodeServiceTest extends TestCase
} }
} }
// Make sure there is no pending commit we just hit
Thread.sleep(20000);
SearchService searcher = (SearchService) ctx.getBean(ServiceRegistry.SEARCH_SERVICE.getLocalName()); SearchService searcher = (SearchService) ctx.getBean(ServiceRegistry.SEARCH_SERVICE.getLocalName());
assertEquals(2 * ((count * repeats) + 1), searcher.selectNodes(rootNodeRef, "/*", null, assertEquals(2 * ((count * repeats) + 1), searcher.selectNodes(rootNodeRef, "/*", null,
getNamespacePrefixReolsver(""), false).size()); getNamespacePrefixReolsver(""), false).size());
@@ -185,6 +188,7 @@ public class ConcurrentNodeServiceTest extends TestCase
if (waiter != null) if (waiter != null)
{ {
System.out.println("Starting " + waiter.getName());
waiter.start(); waiter.start();
} }
try try
@@ -207,9 +211,11 @@ public class ConcurrentNodeServiceTest extends TestCase
try try
{ {
waiter.join(); waiter.join();
System.out.println("Thread " + this.getName() + " has waited for " +(waiter == null ? "null" : waiter.getName()));
} }
catch (InterruptedException e) catch (InterruptedException e)
{ {
System.err.println(e);
} }
} }
} }