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:51 UTC
[32/50] [abbrv] helix git commit: Expose Callbacks that can let async
operation of ZkClient function
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/master
Commit: 10754cd32e39a60136d8b9f67c3332b9ee689735
Parents: f9b94bc
Author: Junkai Xue <jx...@linkedin.com>
Authored: Wed Apr 26 17:43:30 2017 -0700
Committer: Junkai Xue <jx...@linkedin.com>
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;