Repository: helix Updated Branches: refs/heads/helix-0.6.x f9b94bc9b -> 10754cd32
Expose Callbacks that can let async operation of ZkClient function Current async related operation in ZkClient cannot be utilized as the input arguments are the Callbacks hidden in ZkAsyncCallbacks class. Project: http://git-wip-us.apache.org/repos/asf/helix/repo Commit: http://git-wip-us.apache.org/repos/asf/helix/commit/10754cd3 Tree: http://git-wip-us.apache.org/repos/asf/helix/tree/10754cd3 Diff: http://git-wip-us.apache.org/repos/asf/helix/diff/10754cd3 Branch: refs/heads/helix-0.6.x Commit: 10754cd32e39a60136d8b9f67c3332b9ee689735 Parents: f9b94bc Author: Junkai Xue <[email protected]> Authored: Wed Apr 26 17:43:30 2017 -0700 Committer: Junkai Xue <[email protected]> Committed: Wed Apr 26 17:43:30 2017 -0700 ---------------------------------------------------------------------- .../org/apache/helix/manager/zk/ZkAsyncCallbacks.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/helix/blob/10754cd3/helix-core/src/main/java/org/apache/helix/manager/zk/ZkAsyncCallbacks.java ---------------------------------------------------------------------- diff --git a/helix-core/src/main/java/org/apache/helix/manager/zk/ZkAsyncCallbacks.java b/helix-core/src/main/java/org/apache/helix/manager/zk/ZkAsyncCallbacks.java index a0279ff..25c93d7 100644 --- a/helix-core/src/main/java/org/apache/helix/manager/zk/ZkAsyncCallbacks.java +++ b/helix-core/src/main/java/org/apache/helix/manager/zk/ZkAsyncCallbacks.java @@ -32,7 +32,7 @@ import org.apache.zookeeper.data.Stat; public class ZkAsyncCallbacks { private static Logger LOG = Logger.getLogger(ZkAsyncCallbacks.class); - static class GetDataCallbackHandler extends DefaultCallback implements DataCallback { + public static class GetDataCallbackHandler extends DefaultCallback implements DataCallback { byte[] _data; Stat _stat; @@ -51,7 +51,7 @@ public class ZkAsyncCallbacks { } } - static class SetDataCallbackHandler extends DefaultCallback implements StatCallback { + public static class SetDataCallbackHandler extends DefaultCallback implements StatCallback { Stat _stat; @Override @@ -72,7 +72,7 @@ public class ZkAsyncCallbacks { } } - static class ExistsCallbackHandler extends DefaultCallback implements StatCallback { + public static class ExistsCallbackHandler extends DefaultCallback implements StatCallback { Stat _stat; @Override @@ -90,7 +90,7 @@ public class ZkAsyncCallbacks { } - static class CreateCallbackHandler extends DefaultCallback implements StringCallback { + public static class CreateCallbackHandler extends DefaultCallback implements StringCallback { @Override public void processResult(int rc, String path, Object ctx, String name) { callback(rc, path, ctx); @@ -102,7 +102,7 @@ public class ZkAsyncCallbacks { } } - static class DeleteCallbackHandler extends DefaultCallback implements VoidCallback { + public static class DeleteCallbackHandler extends DefaultCallback implements VoidCallback { @Override public void processResult(int rc, String path, Object ctx) { callback(rc, path, ctx); @@ -118,7 +118,7 @@ public class ZkAsyncCallbacks { /** * Default callback for zookeeper async api */ - static abstract class DefaultCallback { + public static abstract class DefaultCallback { AtomicBoolean _lock = new AtomicBoolean(false); int _rc = -1;
