You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@helix.apache.org by jx...@apache.org on 2017/06/22 22:57:46 UTC
[27/50] [abbrv] helix git commit: Minor fix on the asynchronous group
callbacks.
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 <lx...@linkedin.com>
Authored: Thu Mar 30 16:12:07 2017 -0700
Committer: Lei Xia <lx...@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 {