helix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [27/50] [abbrv] helix git commit: Minor fix on the asynchronous group callbacks.
Date Thu, 22 Jun 2017 22:57:46 GMT
Minor fix on the asynchronous group callbacks.


Project: http://git-wip-us.apache.org/repos/asf/helix/repo
Commit: http://git-wip-us.apache.org/repos/asf/helix/commit/fab5423f
Tree: http://git-wip-us.apache.org/repos/asf/helix/tree/fab5423f
Diff: http://git-wip-us.apache.org/repos/asf/helix/diff/fab5423f

Branch: refs/heads/master
Commit: fab5423f10a682362de308f1a837d57bf96ebb15
Parents: 7038c78
Author: Lei Xia <lxia@linkedin.com>
Authored: Thu Mar 30 16:12:07 2017 -0700
Committer: Lei Xia <lxia@linkedin.com>
Committed: Thu Mar 30 16:12:07 2017 -0700

----------------------------------------------------------------------
 .../src/main/java/org/apache/helix/manager/zk/CallbackHandler.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/helix/blob/fab5423f/helix-core/src/main/java/org/apache/helix/manager/zk/CallbackHandler.java
----------------------------------------------------------------------
diff --git a/helix-core/src/main/java/org/apache/helix/manager/zk/CallbackHandler.java b/helix-core/src/main/java/org/apache/helix/manager/zk/CallbackHandler.java
index 90df56d..380f299 100644
--- a/helix-core/src/main/java/org/apache/helix/manager/zk/CallbackHandler.java
+++ b/helix-core/src/main/java/org/apache/helix/manager/zk/CallbackHandler.java
@@ -170,7 +170,7 @@ public class CallbackHandler implements IZkChildListener, IZkDataListener
 
   public void enqueueTask(NotificationContext changeContext) throws Exception {
     //async mode only applicable to CALLBACK from ZK, During INIT and FINALIZE invoke the
callback's immediately.
-    if (asyncBatchModeEnabled && changeContext.getType() != NotificationContext.Type.CALLBACK)
{
+    if (asyncBatchModeEnabled && changeContext.getType() == NotificationContext.Type.CALLBACK)
{
       logger.info("Enqueuing callback");
       _queue.put(changeContext);
     } else {


Mime
View raw message