helix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [32/50] [abbrv] helix git commit: Expose Callbacks that can let async operation of ZkClient function
Date Thu, 22 Jun 2017 22:57:51 GMT
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 <jxue@linkedin.com>
Authored: Wed Apr 26 17:43:30 2017 -0700
Committer: Junkai Xue <jxue@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;
 


Mime
View raw message