| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/ |
| H A D | ZooKeeperTest.java | 66 final ZooKeeper zk = createClient(); in testDeleteRecursive() local
80 final ZooKeeper zk = createClient(); in testDeleteRecursiveFail() local
137 final ZooKeeper zk = createClient(); in testDeleteRecursiveCli() local
167 final ZooKeeper zk = createClient(); in testDeleteRecursiveAsync() local
212 final ZooKeeper zk = createClient(); in testStatWhenPathDoesNotExist() local
226 final ZooKeeper zk = createClient(); in testParseWithExtraSpaces() local
237 final ZooKeeper zk = createClient(); in testParseWithQuotes() local
251 final ZooKeeper zk = createClient(); in testParseWithMixedQuotes() local
268 final ZooKeeper zk = createClient(); in testParseWithEmptyQuotes() local
280 final ZooKeeper zk = createClient(); in testParseWithMultipleQuotes() local
[all …]
|
| H A D | SaslAuthTest.java | 115 ZooKeeper zk = createClient(); in testAuth() local
126 ZooKeeper zk = createClient(); in testValidSaslIds() local
146 ZooKeeper zk = createClient(); in testInvalidSaslIds() local
171 ZooKeeper zk = new ZooKeeper(hostPort, CONNECTION_TIMEOUT, watcher); in testZKOperationsAfterClientSaslAuthFailure() local
198 private void setSaslFailureFlag(ZooKeeper zk) throws Exception { in setSaslFailureFlag()
213 ZooKeeper zk = null; in testThreadsShutdownOnAuthFailed() local
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/test/ |
| H A D | KeyAuthClientTest.java | 40 public void createNodePrintAcl(ZooKeeper zk, String path, String testName) { in createNodePrintAcl()
55 ZooKeeper zk = createClient(); in preAuth() local
74 ZooKeeper zk = createClient(); in missingAuth() local
92 ZooKeeper zk = createClient(); in validAuth() local
107 ZooKeeper zk = createClient(); in validAuth2() local
|
| H A D | ClientTest.java | 111 TestableZooKeeper zk = createClient(); in testTestability() local
126 ZooKeeper zk = null; in testACLs() local
203 ZooKeeper zk = null; in testNullAuthId() local
372 ZooKeeper zk = null; in performClientTest() local
503 ZooKeeper zk = null; in testSequentialNodeNames() local
542 ZooKeeper zk = null; in testSequentialNodeData() local
576 ZooKeeper zk = null; in testLargeNodeData() local
603 ZooKeeper zk = createClient(); in testPathValidation() local
687 ZooKeeper zk = createClient(); in testDeleteWithChildren() local
815 try (ZooKeeper zk = createClient()) { in testTryWithResources()
[all …]
|
| H A D | PersistentWatcherTest.java | 60 try (ZooKeeper zk = createClient(new CountdownWatcher(), hostPort)) { in testBasic()
69 try (ZooKeeper zk = createClient(new CountdownWatcher(), hostPort)) { in testNullWatch()
90 try (ZooKeeper zk = createClient(watcher, hostPort)) { in testDefaultWatcher()
107 try (ZooKeeper zk = createClient(watcher, hostPort)) { in testBasicAsync()
124 try (ZooKeeper zk = createClient(new CountdownWatcher(), hostPort)) { in testAsyncDefaultWatcher()
137 private void internalTestBasic(ZooKeeper zk) throws KeeperException, InterruptedException { in internalTestBasic()
157 try (ZooKeeper zk = createClient(new CountdownWatcher(), hostPort)) { in testRemoval()
174 try (ZooKeeper zk = createClient(new CountdownWatcher(), hostPort)) { in testDisconnect()
211 try (ZooKeeper zk = createClient(new CountdownWatcher(), hostPort)) { in testRootWatcher()
|
| H A D | PersistentRecursiveWatcherTest.java | 59 try (ZooKeeper zk = createClient(new CountdownWatcher(), hostPort)) { in testBasic()
68 try (ZooKeeper zk = createClient(new CountdownWatcher(), hostPort)) { in testBasicAsync()
81 private void internalTestBasic(ZooKeeper zk) throws KeeperException, InterruptedException { in internalTestBasic()
103 try (ZooKeeper zk = createClient(new CountdownWatcher(), hostPort)) { in testRemoval()
119 try (ZooKeeper zk = createClient(new CountdownWatcher(), hostPort)) { in testDisconnect()
156 try (ZooKeeper zk = createClient(new CountdownWatcher(), hostPort)) { in testRootWatcher()
|
| H A D | ZooKeeperTestClient.java | 64 …private void deleteZKDir(ZooKeeper zk, String nodeName) throws IOException, InterruptedException, … in deleteZKDir()
92 ZooKeeper zk = new ZooKeeper(hostPort, 10000, this); in checkRoot() local
117 ZooKeeper zk = new ZooKeeper(hostPort, 10000, this); in enode_test_1() local
166 ZooKeeper zk = new ZooKeeper(hostPort, 10000, this); in enode_test_2() local
334 ZooKeeper zk = new ZooKeeper(hostPort, 10000, this); in delete_create_get_set_test_1() local
393 private void deleteNodeIfExists(ZooKeeper zk, String nodeName) throws InterruptedException { in deleteNodeIfExists()
407 ZooKeeper zk = new ZooKeeper(hostPort, 10000, this); in create_get_stat_test() local
|
| H A D | OOMTest.java | 105 ZooKeeper zk = new ZooKeeper("127.0.0.1:" + port, CONNECTION_TIMEOUT, TEST_WATCHER); in utestExists() local
113 ZooKeeper zk = new ZooKeeper("127.0.0.1:" + port, CONNECTION_TIMEOUT, TEST_WATCHER); in utestPrep() local
121 ZooKeeper zk = new ZooKeeper("127.0.0.1:" + port, CONNECTION_TIMEOUT, TEST_WATCHER); in utestGet() local
130 ZooKeeper zk = new ZooKeeper("127.0.0.1:" + port, CONNECTION_TIMEOUT, TEST_WATCHER); in utestChildren() local
|
| H A D | ThrottledOpQuorumTest.java | 37 ZooKeeper zk = null; in testThrottledOpLeader() local
52 ZooKeeper zk = null; in testThrottledAclLeader() local
67 ZooKeeper zk = null; in testThrottledOpFollower() local
84 ZooKeeper zk = null; in testThrottledAclFollower() local
|
| H A D | QuorumTest.java | 131 ZooKeeper zk = new DisconnectableZooKeeper( in testLeaderShutdown() local
195 DisconnectableZooKeeper zk = new DisconnectableZooKeeper( in testSessionMoved() local
258 DisconnectableZooKeeper zk = new DisconnectableZooKeeper( in testSessionMovedWithMultiOp() local
296 …DisconnectableZooKeeper zk = new DisconnectableZooKeeper(hps[0], ClientBase.CONNECTION_TIMEOUT, ol… in testSessionMove() local
354 ZooKeeper zk = new ZooKeeper( in testFollowersStartAfterLeader() local
390 ZooKeeper zk = new ZooKeeper( in testMultiToFollower() local
|
| H A D | ClientHammerTest.java | 54 private final ZooKeeper zk; field in ClientHammerTest.BasicHammerThread
57 BasicHammerThread(String name, ZooKeeper zk, String prefix, int count) { in BasicHammerThread()
99 ZooKeeper zk = parent.createClient(); in run() local
132 ZooKeeper zk = createClient(); in runHammer() local
165 ZooKeeper zk = createClient(); in testHammerSuper() local
219 ZooKeeper zk = createClient(); in verifyHammer() local
|
| H A D | AuthTest.java | 83 ZooKeeper zk = createClient(); in testBadAuthNotifiesWatch() local
99 ZooKeeper zk = createClient(); in testBadAuthThenSendOtherCommands() local
116 ZooKeeper zk = createClient(); in testSuper() local
161 ZooKeeper zk = createClient(); in testSuperACL() local
183 ZooKeeper zk = createClient(); in testOrdinaryACL() local
|
| H A D | SessionTest.java | 113 DisconnectableZooKeeper zk = new DisconnectableZooKeeper(HOSTPORT, timeout, watcher); in createClient() local
175 DisconnectableZooKeeper zk = createClient(); in testSession() local
236 …DisconnectableZooKeeper zk = new DisconnectableZooKeeper(hostPorts[0], CONNECTION_TIMEOUT, new MyW… in testSessionMove() local
284 ZooKeeper zk = createClient(TIMEOUT, watcher); in testSessionStateNoDupStateReporting() local
310 DisconnectableZooKeeper zk = createClient(TICK_TIME * 4); in testSessionTimeoutAccess() local
357 DisconnectableZooKeeper zk = createClient(timeout); in testMinMaxSessionTimeout() local
|
| H A D | WatcherTest.java | 102 ZooKeeper zk = null; in testWatcherCorrectness() local
150 ZooKeeper zk = null; in testWatcherDisconnectOnClose() local
235 TestableZooKeeper zk = createClient(watcher, hostPort, 6000); in testWatchAutoResetWithPending() local
287 ZooKeeper zk = null; in testWatcherAutoResetWithGlobal() local
296 ZooKeeper zk = null; in testWatcherAutoResetWithLocal() local
318 …private void testWatcherAutoReset(ZooKeeper zk, MyWatcher globalWatcher, MyWatcher localWatcher) t… in testWatcherAutoReset()
|
| H A D | SaslAuthDesignatedClientTest.java | 82 ZooKeeper zk = createClient(); in testAuth() local
95 ZooKeeper zk = createClient(); in testSaslConfig() local
114 ZooKeeper zk = createClient(); in testReadAccessUser() local
|
| H A D | LoadFromLogTest.java | 66 ZooKeeper zk = createZKClient(hostPort); in testLoad() local
109 ZooKeeper zk = createZKClient(hostPort); in testLoadFailure() local
166 ZooKeeper zk = createZKClient(hostPort); in testRestore() local
220 ZooKeeper zk = createZKClient(hostPort); in testRestoreWithTransactionErrors() local
274 ZooKeeper zk = createZKClient(hostPort); in testReloadSnapshotWithMissingParent() local
|
| H A D | AsyncOps.java | 76 protected final ZooKeeper zk; field in AsyncOps.AsyncCB
136 StringCB(ZooKeeper zk) { in StringCB()
222 ACLCB(ZooKeeper zk) { in ACLCB()
286 ChildrenCB(ZooKeeper zk) { in ChildrenCB()
371 Children2CB(ZooKeeper zk) { in Children2CB()
460 Create2CB(ZooKeeper zk) { in Create2CB()
543 DataCB(ZooKeeper zk) { in DataCB()
595 StatCB(ZooKeeper zk) { in StatCB()
696 VoidCB(ZooKeeper zk) { in VoidCB()
761 ZooKeeper zk; field in AsyncOps.MultiCB
[all …]
|
| H A D | ResponseCacheTest.java | 59 ZooKeeper zk = createClient(); in testResponseCache() local
77 public void performCacheTest(ZooKeeper zk, String path, boolean useCache) throws Exception { in performCacheTest()
175 private void createPath(String path, ZooKeeper zk) throws Exception { in createPath()
179 … private void checkPath(String path, ZooKeeper zk, int expectedNumberOfChildren) throws Exception { in checkPath()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/server/quorum/auth/ |
| H A D | QuorumAuthUpgradeTest.java | 95 ZooKeeper zk = new ZooKeeper(connectStr, ClientBase.CONNECTION_TIMEOUT, watcher); in testNullAuthLearnerServer() local
114 ZooKeeper zk = new ZooKeeper(connectStr, ClientBase.CONNECTION_TIMEOUT, watcher); in testAuthLearnerAgainstNullAuthServer() local
133 ZooKeeper zk = new ZooKeeper(connectStr, ClientBase.CONNECTION_TIMEOUT, watcher); in testAuthLearnerAgainstNoAuthRequiredServer() local
154 ZooKeeper zk = new ZooKeeper(connectStr, ClientBase.CONNECTION_TIMEOUT, watcher); in testAuthLearnerServer() local
186 ZooKeeper zk = new ZooKeeper(connectStr, ClientBase.CONNECTION_TIMEOUT, watcher); in testRollingUpgrade() local
230 ZooKeeper zk, in restartServer()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/server/ |
| H A D | ZxidRolloverTest.java | 104 ZooKeeper zk = getClient(idx); in checkClientConnected() local
142 ZooKeeper zk = getClient(idx); in checkClientDisconnected() local
229 private int createNodes(ZooKeeper zk, int start, int count) throws Exception { in createNodes()
247 private void checkNodes(ZooKeeper zk, int start, int count) throws Exception { in checkNodes()
264 ZooKeeper zk = getClient((idxLeader == 1 ? 2 : 1)); in testSimpleRolloverFollower() local
276 ZooKeeper zk = getClient(idxFollower); in testRolloverThenRestart() local
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-client/zookeeper-client-c/tests/ |
| H A D | TestClient.cc | 394 zhandle_t *zk = createClient(&ctx); in testServersResolutionDelay() local
650 zhandle_t *zk = createClient(&ctx); in testAcl() local
783 zhandle_t *zk = createClient(&ctx); in testCreate() local
810 zhandle_t *zk = createClient(&ctx); in testCreateContainer() local
823 zhandle_t *zk = createClient(&ctx); in testCreateTtl() local
841 zhandle_t *zk = createClient(&ctx); in testGetChildren2() local
896 zhandle_t *zk = createClient(&ctx); in testNullData() local
918 zhandle_t *zk = createClient(&ctx); in testPath() local
956 zhandle_t *zk = createClient(&ctx); in testPathValidation() local
1011 zhandle_t *zk, *zk_ch; in testChroot() local
[all …]
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/ |
| H A D | ZKUtil.java | 56 ZooKeeper zk, in deleteRecursive()
74 ZooKeeper zk, in deleteRecursive()
91 …private static boolean deleteInBatch(ZooKeeper zk, List<String> tree, int batchSize) throws Interr… in deleteInBatch()
139 ZooKeeper zk, in deleteRecursive()
186 ZooKeeper zk, in listSubTreeBFS()
214 ZooKeeper zk, in visitSubTreeDFS()
227 ZooKeeper zk, in visitSubTreeDFSHelper()
|
| /dports/science/libxc/libxc-5.0.0/src/ |
| H A D | util.c | 352 double **zk, LDA_OUT_PARAMS_NO_EXC(double **)) in internal_counters_lda_random() argument
373 double **zk, LDA_OUT_PARAMS_NO_EXC(double **)) in internal_counters_lda_next() argument
394 double **zk, LDA_OUT_PARAMS_NO_EXC(double **)) in internal_counters_lda_prev() argument
416 double **zk, GGA_OUT_PARAMS_NO_EXC(double **)) in internal_counters_gga_random() argument
451 double **zk, GGA_OUT_PARAMS_NO_EXC(double **)) in internal_counters_gga_next() argument
485 double **zk, GGA_OUT_PARAMS_NO_EXC(double **)) in internal_counters_gga_prev() argument
520 double **zk, MGGA_OUT_PARAMS_NO_EXC(double **)) in internal_counters_mgga_random() argument
614 double **zk, MGGA_OUT_PARAMS_NO_EXC(double **)) in internal_counters_mgga_next() argument
708 double **zk, MGGA_OUT_PARAMS_NO_EXC(double **)) in internal_counters_mgga_prev() argument
|
| /dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ |
| H A D | ReplicationFactory.java | 33 public static ReplicationQueues getReplicationQueues(final ZooKeeperWatcher zk, in getReplicationQueues()
38 public static ReplicationQueuesClient getReplicationQueuesClient(final ZooKeeperWatcher zk, in getReplicationQueuesClient()
43 public static ReplicationPeers getReplicationPeers(final ZooKeeperWatcher zk, Configuration conf, in getReplicationPeers()
|
| /dports/net-mgmt/zabbix5-java/zabbix-5.0.19/src/libs/zbxsysinfo/solaris/ |
| H A D | diskio.c | 38 static int get_kstat_io(const char *name, zbx_kstat_t *zk, char **error) in get_kstat_io()
111 zbx_kstat_t zk; in VFS_DEV_READ_BYTES() local
127 zbx_kstat_t zk; in VFS_DEV_READ_OPERATIONS() local
143 zbx_kstat_t zk; in VFS_DEV_WRITE_BYTES() local
159 zbx_kstat_t zk; in VFS_DEV_WRITE_OPERATIONS() local
|