Review Board 1.7.22


ZOOKEEPER-442: need a way to remove watches that are no longer of interest

Review Request #15256 - Created Nov. 6, 2013 and updated

Rakesh R
ZOOKEEPER-442
Reviewers
zookeeper
fpj, mahadev
zookeeper
Added APIs to remove watches that are not needed anymore. If the removal completes successfully it is guaranteed that the watcher won't be notified.
Added unit test cases to see the client behaviors
http://svn.apache.org/repos/asf/zookeeper/trunk/src/zookeeper.jute
Revision 1533155 New Change
[20] 210 lines
[+20]
211
    }
211
    }
212
    class GetACLResponse {
212
    class GetACLResponse {
213
        vector<org.apache.zookeeper.data.ACL> acl;
213
        vector<org.apache.zookeeper.data.ACL> acl;
214
        org.apache.zookeeper.data.Stat stat;
214
        org.apache.zookeeper.data.Stat stat;
215
    }
215
    }

    
   
216
    class RemoveWatchesRequest {

    
   
217
        ustring path;

    
   
218
        int type;

    
   
219
    }
216
}
220
}
217

    
   
221

   
218
module org.apache.zookeeper.server.quorum {
222
module org.apache.zookeeper.server.quorum {
219
    class LearnerInfo {
223
    class LearnerInfo {
220
        long serverid;
224
        long serverid;
[+20] [20] 75 lines
http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/ClientCnxn.java
Revision 1533155 New Change
 
http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/KeeperException.java
Revision 1533155 New Change
 
http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/WatchDeregistration.java
New File
 
http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/Watcher.java
Revision 1533155 New Change
 
http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/ZooDefs.java
Revision 1533155 New Change
 
http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/ZooKeeper.java
Revision 1533155 New Change
 
http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/DataTree.java
Revision 1533155 New Change
 
http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/FinalRequestProcessor.java
Revision 1533155 New Change
 
http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/PrepRequestProcessor.java
Revision 1533155 New Change
 
http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/Request.java
Revision 1533155 New Change
 
http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/WatchManager.java
Revision 1533155 New Change
 
http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/ZKDatabase.java
Revision 1533155 New Change
 
http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/test/org/apache/zookeeper/RemoveWatchesTest.java
New File
 
  1. http://svn.apache.org/repos/asf/zookeeper/trunk/src/zookeeper.jute: Loading...
  2. http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/ClientCnxn.java: Loading...
  3. http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/KeeperException.java: Loading...
  4. http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/WatchDeregistration.java: Loading...
  5. http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/Watcher.java: Loading...
  6. http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/ZooDefs.java: Loading...
  7. http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/ZooKeeper.java: Loading...
  8. http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/DataTree.java: Loading...
  9. http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/FinalRequestProcessor.java: Loading...
  10. http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/PrepRequestProcessor.java: Loading...
  11. http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/Request.java: Loading...
  12. http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/WatchManager.java: Loading...
  13. http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/ZKDatabase.java: Loading...
  14. http://svn.apache.org/repos/asf/zookeeper/trunk/src/java/test/org/apache/zookeeper/RemoveWatchesTest.java: Loading...