Home
last modified time | relevance | path

Searched refs:MyWatcher (Results 1 – 25 of 29) sorted by relevance

12

/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/
H A DRemoveWatchesTest.java136 MyWatcher w1 = new MyWatcher("/node1", 1); in testRemoveSingleWatcher()
139 MyWatcher w2 = new MyWatcher("/node2", 1); in testRemoveSingleWatcher()
168 MyWatcher w1 = new MyWatcher("/node1", 1); in testMultipleDataWatchers()
171 MyWatcher w2 = new MyWatcher("/node1", 1); in testMultipleDataWatchers()
199 MyWatcher w1 = new MyWatcher("/node1", 1); in testMultipleChildWatchers()
202 MyWatcher w2 = new MyWatcher("/node1", 1); in testMultipleChildWatchers()
235 MyWatcher w1 = new MyWatcher("/node1", 2); in testRemoveAllWatchers()
236 MyWatcher w2 = new MyWatcher("/node1", 2); in testRemoveAllWatchers()
261 MyWatcher w1 = new MyWatcher("/node1", 1); in testRemoveAllDataWatchers()
262 MyWatcher w2 = new MyWatcher("/node1", 1); in testRemoveAllDataWatchers()
[all …]
H A DRemoveWatchesCmdTest.java76 MyWatcher myWatcher = new MyWatcher("/testnode1", expectedEvents, 2); in testRemoveWatchesWithNoPassedOptions()
110 MyWatcher myWatcher = new MyWatcher("/testnode1", expectedEvents, 1); in testRemoveNodeDataChangedWatches()
135 MyWatcher myWatcher1 = new MyWatcher("/testnode1", expectedEvents, 1); in testRemoveNodeCreatedWatches()
136 MyWatcher myWatcher2 = new MyWatcher("/testnode1/testnode2", expectedEvents, 1); in testRemoveNodeCreatedWatches()
167 MyWatcher myWatcher = new MyWatcher("/testnode1", expectedEvents, 1); in testRemoveNodeChildrenChangedWatches()
191 MyWatcher myWatcher = new MyWatcher("/testnode1", expectedEvents, 1); in testRemoveNodeDeletedWatches()
278 private static class MyWatcher implements Watcher { class in RemoveWatchesCmdTest
285 MyWatcher(String path, List<EventType> expectedEvents, int count) { in MyWatcher() method in RemoveWatchesCmdTest.MyWatcher
H A DSaslAuthTest.java96 MyWatcher watcher = new MyWatcher(); in createClient()
100 private class MyWatcher extends CountdownWatcher { class in SaslAuthTest
212 MyWatcher watcher = new MyWatcher(); in testThreadsShutdownOnAuthFailed()
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/test/
H A DChrootTest.java40 private static class MyWatcher implements Watcher { class in ChrootTest
46 public MyWatcher(String path) { in MyWatcher() method in ChrootTest.MyWatcher
86 MyWatcher w1 = new MyWatcher("/ch1"); in testChrootSynchronous()
88 MyWatcher w2 = new MyWatcher("/ch1/ch2"); in testChrootSynchronous()
91 MyWatcher w3 = new MyWatcher("/ch2"); in testChrootSynchronous()
95 MyWatcher w4 = new MyWatcher("/ch1"); in testChrootSynchronous()
97 MyWatcher w5 = new MyWatcher("/"); in testChrootSynchronous()
H A DWatcherTest.java104 MyWatcher watcher = new MyWatcher(); in testWatcherCorrectness()
154 MyWatcher connWatcher = new MyWatcher(); in testWatcherDisconnectOnClose()
195 MyWatcher w1 = new MyWatcher(); in testWatcherCount()
198 MyWatcher w2 = new MyWatcher(); in testWatcherCount()
231 MyWatcher[] watches = new MyWatcher[COUNT]; in testWatchAutoResetWithPending()
233 MyWatcher watcher = new MyWatcher(); in testWatchAutoResetWithPending()
239 watches[i] = new MyWatcher(); in testWatchAutoResetWithPending()
249 watches[i] = new MyWatcher(); in testWatchAutoResetWithPending()
288 MyWatcher watcher = new MyWatcher(); in testWatcherAutoResetWithGlobal()
297 MyWatcher watcher = new MyWatcher(); in testWatcherAutoResetWithLocal()
[all …]
H A DDisconnectedWatcherTest.java44 private class MyWatcher extends CountdownWatcher { class in DisconnectedWatcherTest
63 private MyWatcher watcher2;
71 watcher2 = new MyWatcher(); in setUp()
104 MyWatcher childWatcher = new MyWatcher(); in testChildWatcherAutoResetWithChroot()
171 MyWatcher childWatcher = new MyWatcher(); in testDeepChildWatcherAutoResetWithChroot()
210 MyWatcher childWatcher = new MyWatcher(); in testManyChildWatchersAutoReset()
H A DDigestAuthDisabledTest.java50 MyWatcher watcher = new MyWatcher(); in createClient()
54 private class MyWatcher extends CountdownWatcher { class in DigestAuthDisabledTest
H A DSaslAuthDesignatedServerTest.java61 private class MyWatcher extends CountdownWatcher { class in SaslAuthDesignatedServerTest
87 MyWatcher watcher = new MyWatcher(); in testAuth()
H A DSaslSuperUserTest.java103 MyWatcher watcher = new MyWatcher(); in createClient()
107 private class MyWatcher extends CountdownWatcher { class in SaslSuperUserTest
H A DSessionTest.java153 private class MyWatcher implements Watcher { class in SessionTest
156 public MyWatcher(String name) { in MyWatcher() method in SessionTest.MyWatcher
186 …zk = new DisconnectableZooKeeper(HOSTPORT, CONNECTION_TIMEOUT, new MyWatcher("testSession"), zk.ge… in testSession()
236 …leZooKeeper zk = new DisconnectableZooKeeper(hostPorts[0], CONNECTION_TIMEOUT, new MyWatcher("0")); in testSessionMove()
243 … % hostPorts.length], CONNECTION_TIMEOUT, new MyWatcher(Integer.toString( in testSessionMove()
H A DSaslAuthFailTest.java65 private class MyWatcher extends CountdownWatcher { class in SaslAuthFailTest
91 try (ZooKeeper ignored = createClient(new MyWatcher(), hostPort)) { in testBadSaslAuthNotifiesWatch()
H A DClientTest.java243 private class MyWatcher extends CountdownWatcher { class in ClientTest
268 MyWatcher[] watchers = new MyWatcher[100]; in testMutipleWatcherObjs()
269 MyWatcher[] watchers2 = new MyWatcher[watchers.length]; in testMutipleWatcherObjs()
271 watchers[i] = new MyWatcher(); in testMutipleWatcherObjs()
272 watchers2[i] = new MyWatcher(); in testMutipleWatcherObjs()
374 MyWatcher watcher = new MyWatcher(); in performClientTest()
H A DAuthTest.java64 MyWatcher watcher = new MyWatcher(); in createClient()
68 private class MyWatcher extends CountdownWatcher { class in AuthTest
/dports/devel/gdcm/gdcm-3.0.10/Examples/Csharp/
H A DScanDirectory.cs23 public class MyWatcher : SimpleSubjectWatcher class
25 public MyWatcher(Subject s):base(s,"Override String"){} in MyWatcher() method in MyWatcher
56 MyWatcher watcher = new MyWatcher(s); in Main()
H A DBasicAnonymizer.cs30 public class MyWatcher : SimpleSubjectWatcher class
32 public MyWatcher(Subject s):base(s,"Override String"){} in MyWatcher() method in MyWatcher
107 MyWatcher watcher = new MyWatcher(ano); in Main()
H A DClinicalTrialIdentificationWorkflow.cs45 public class MyWatcher : SimpleSubjectWatcher class
47 public MyWatcher(Subject s):base(s,"Override String"){} in MyWatcher() method in MyWatcher
219 MyWatcher watcher = new MyWatcher(ano); in Main()
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-contrib/zookeeper-contrib-rest/src/test/java/org/apache/zookeeper/server/jersey/
H A DBase.java29 import org.apache.zookeeper.server.jersey.SetTest.MyWatcher;
68 zk = new ZooKeeper(ZKHOSTPORT, 30000, new MyWatcher()); in setUp()
83 ZooKeeper zk = new ZooKeeper(ZKHOSTPORT, 30000, new MyWatcher()); in createBaseZNode()
H A DDeleteTest.java53 public static class MyWatcher implements Watcher { class in DeleteTest
/dports/devel/gdcm/gdcm-3.0.10/Examples/Java/
H A DFileAnonymize.java23 public static class MyWatcher extends SimpleSubjectWatcher class in FileAnonymize
25 public MyWatcher(Subject s) { super(s,"Override String"); } in MyWatcher() method in FileAnonymize.MyWatcher
H A DScanDirectory.java36 public static class MyWatcher extends SimpleSubjectWatcher class in ScanDirectory
38 public MyWatcher(Subject s) { super(s,"Override String"); } in MyWatcher() method in ScanDirectory.MyWatcher
205 MyWatcher watcher = new MyWatcher(s); in main()
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-contrib/zookeeper-contrib-rest/src/main/java/org/apache/zookeeper/server/jersey/
H A DZooKeeperService.java56 private static class MyWatcher implements Watcher { class in ZooKeeperService
60 public MyWatcher(String contextPath) { in MyWatcher() method in ZooKeeperService.MyWatcher
216 zk = new ZooKeeper(e.getHostPort(), 30000, new MyWatcher( in getClient()
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/server/quorum/
H A DLeaderMetricsTest.java46 private class MyWatcher implements Watcher { class in LeaderMetricsTest
77 zk.exists("/test", new MyWatcher()); in testLeaderMetrics()
/dports/science/InsightToolkit/ITK-5.0.1/Modules/ThirdParty/GDCM/src/gdcm/Source/MessageExchangeDefinition/
H A DgdcmCompositeNetworkFunctions.cxx318 class MyWatcher : public SimpleSubjectWatcher class
325 …MyWatcher(Subject * s, const char *comment = "", size_t n = 1):SimpleSubjectWatcher(s,comment),nfi… in MyWatcher() function in gdcm::MyWatcher
362 MyWatcher watcher(ps, "cstore", files.size() ); in CStore()
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-it/src/main/java/org/apache/zookeeper/test/system/
H A DInstanceContainer.java49 private final class MyWatcher implements Watcher { class in InstanceContainer
52 MyWatcher(String myNode, DataCallback dc) { in MyWatcher() method in InstanceContainer.MyWatcher
283 Watcher watcher = new MyWatcher(myNode, dc); in processResult()
/dports/devel/gdcm/gdcm-3.0.10/Source/MessageExchangeDefinition/
H A DgdcmCompositeNetworkFunctions.cxx318 class MyWatcher : public SimpleSubjectWatcher class
325 …MyWatcher(Subject * s, const char *comment = "", size_t n = 1):SimpleSubjectWatcher(s,comment),nfi… in MyWatcher() function in gdcm::MyWatcher
362 MyWatcher watcher(ps, "cstore", files.size() ); in CStore()

12