commit dbad51d8a0763dc6ee21cee30d446c40e94c9ed8
author Keith Turner <kturner@apache.org> Wed Jan 03 12:44:16 2018 -0500
committer Keith Turner <kturner@apache.org> Wed Jan 03 12:44:16 2018 -0500
tree 3994c6f712684b69cfe45904b3a505f3e9525b9a
parent d45f1f77ba1f8501e27b66d2676d2ffb92525d56

fixes #992 sync tracking of notifications

modules/core/src/main/java/org/apache/fluo/core/worker/NotificationProcessor.java

diff --git a/modules/core/src/main/java/org/apache/fluo/core/worker/NotificationProcessor.java b/modules/core/src/main/java/org/apache/fluo/core/worker/NotificationProcessor.java
index 9466933..5dca687 100644
--- a/modules/core/src/main/java/org/apache/fluo/core/worker/NotificationProcessor.java
+++ b/modules/core/src/main/java/org/apache/fluo/core/worker/NotificationProcessor.java
@@ -124,7 +124,7 @@
       notify();
     }
 
-    public boolean requeue(RowColumn rowCol, FutureTask<?> ft) {
+    public synchronized boolean requeue(RowColumn rowCol, FutureTask<?> ft) {
       if (!queuedWork.containsKey(rowCol)) {
         return false;
       }
@@ -245,6 +245,7 @@
       return true;
     }
 
+    @Override
     public void close() {
       tracker.finishAddingNotifications(id);
     }