Home
last modified time | relevance | path

Searched refs:EPHEMERAL_SEQUENTIAL (Results 1 – 13 of 13) sorted by relevance

/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/
H A DCreateMode.java48 EPHEMERAL_SEQUENTIAL(3, true, true, false, false), enumConstant
124 return CreateMode.EPHEMERAL_SEQUENTIAL; in fromFlag()
157 return CreateMode.EPHEMERAL_SEQUENTIAL; in fromFlag()
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/test/
H A DFollowerResyncConcurrencyTest.java219 zk3.create("/mybar", null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL); in followerResyncCrashTest()
237 …reate("/mytestfoo", null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL, (rc, path,… in followerResyncCrashTest()
264 …zk3.create("/mybar", null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL, (rc, path… in followerResyncCrashTest()
301 …2.create("/newbaz", null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL, (rc, path,… in followerResyncCrashTest()
391 zk2.create("/mybar", null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL); in testResyncByDiffAfterFollowerCrashes()
401 …reate("/mytestfoo", null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL, (rc, path,… in testResyncByDiffAfterFollowerCrashes()
427 …zk2.create("/mybar", null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL, (rc, path… in testResyncByDiffAfterFollowerCrashes()
455 …3.create("/newbaz", null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL, (rc, path,… in testResyncByDiffAfterFollowerCrashes()
H A DTestHammer.java41 …name = zk.create("/testFile-", new byte[16], Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL); in main()
H A DCreateModeTest.java54 cm = CreateMode.EPHEMERAL_SEQUENTIAL; in testBasicCreateMode()
H A DMultiOperationTest.java210 … Op.create("multi1/", new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL.toFlag()), in testInvalidPath()
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-recipes/zookeeper-recipes-lock/src/main/java/org/apache/zookeeper/recipes/lock/
H A DWriteLock.java21 import static org.apache.zookeeper.CreateMode.EPHEMERAL_SEQUENTIAL;
196 id = zookeeper.create(dir + "/" + prefix, data, getAcl(), EPHEMERAL_SEQUENTIAL); in findPrefixInChildren()
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/cli/
H A DCreateCommand.java95 flags = CreateMode.EPHEMERAL_SEQUENTIAL; in exec()
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-recipes/zookeeper-recipes-election/src/main/java/org/apache/zookeeper/recipes/leader/
H A DLeaderElectionSupport.java176 CreateMode.EPHEMERAL_SEQUENTIAL)); in makeOffer()
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/lock/
H A DZKInterProcessLockBase.java233 metadata, CreateMode.EPHEMERAL_SEQUENTIAL); in createLockZNode()
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-contrib/zookeeper-contrib-rest/src/main/java/org/apache/zookeeper/server/jersey/resources/
H A DZNodeResource.java322 createMode = CreateMode.EPHEMERAL_SEQUENTIAL; in createZNode()
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-it/src/main/java/org/apache/zookeeper/test/system/
H A DGenerateLoad.java340 CreateMode.EPHEMERAL_SEQUENTIAL); in run()
/dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/
H A DRecoverableZooKeeper.java556 case EPHEMERAL_SEQUENTIAL: in create()
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/coordination/
H A DZKSplitLogManagerCoordination.java269 CreateMode.EPHEMERAL_SEQUENTIAL, new CreateRescanAsyncCallback(), Long.valueOf(retries)); in rescan()