0001305: Possible lock up during extraction. If the max number of loc…

…ks are reached on a batch the extract method can hang forever
JumpMind · Jul 1, 2013 · 9c56589 · 9c56589
1 parent d9aaf3f
commit 9c56589
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java
@@ -126,7 +126,7 @@ public class DataExtractorService extends AbstractService implements IDataExtrac
 
     private IStagingManager stagingManager;
 
-    private Map<Long, Semaphore> locks = new HashMap<Long, Semaphore>();
+    private Map<String, Semaphore> locks = new HashMap<String, Semaphore>();
 
     public DataExtractorService(IParameterService parameterService,
             ISymmetricDialect symmetricDialect, IOutgoingBatchService outgoingBatchService,
@@ -558,7 +558,7 @@ public OutgoingBatch extractOutgoingBatch(ProcessInfo processInfo, Node targetNo
                             lock = locks.get(semaphoreKey);
                             if (lock == null) {
                                 lock = new Semaphore(maxPermits);
-                                locks.put(currentBatch.getBatchId(), lock);
+                                locks.put(semaphoreKey, lock);
                             }
                             try {
                                 lock.acquire();