Home
last modified time | relevance | path

Searched refs:getWatcher (Results 1 – 25 of 58) sorted by relevance

123

/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/procedure/
H A DZKProcedureMemberRpcs.java139 for (String node : ZKUtil.listChildrenAndWatchForNewChildren(zkController.getWatcher(), in watchForAbortedProcedures()
155 runningProcedures = ZKUtil.listChildrenAndWatchForNewChildren(zkController.getWatcher(), in waitForNewProcedures()
189 if (ZKUtil.watchAndCheckExists(zkController.getWatcher(), abortZNode)) { in startNewSubprocedure()
202 byte[] data = ZKUtil.getData(zkController.getWatcher(), path); in startNewSubprocedure()
245 ZKUtil.createAndFailSilent(zkController.getWatcher(), acquiredZNode); in sendMemberAcquired()
250 if (ZKUtil.watchAndCheckExists(zkController.getWatcher(), reachedBarrier)) { in sendMemberAcquired()
273 ZKUtil.createAndFailSilent(zkController.getWatcher(), joinPath, in sendMemberCompleted()
297 ZKUtil.createAndFailSilent(zkController.getWatcher(), procAbortZNode, errorInfo); in sendMemberAborted()
316 byte[] data = ZKUtil.getData(zkController.getWatcher(), abortZNode); in abort()
H A DZKProcedureCoordinatorRpcs.java81 if (ZKUtil.watchAndCheckExists(zkProc.getWatcher(), abortNode)) { in sendGlobalBarrierAcquire()
98 ZKUtil.createWithParents(zkProc.getWatcher(), acquire, data); in sendGlobalBarrierAcquire()
103 if (ZKUtil.watchAndCheckExists(zkProc.getWatcher(), znode)) { in sendGlobalBarrierAcquire()
121 ZKUtil.createWithParents(zkProc.getWatcher(), reachedNode); in sendGlobalBarrierReached()
125 if (ZKUtil.watchAndCheckExists(zkProc.getWatcher(), znode)) { in sendGlobalBarrierReached()
126 byte[] dataFromMember = ZKUtil.getData(zkProc.getWatcher(), znode); in sendGlobalBarrierReached()
268 ZKUtil.createAndFailSilent(zkProc.getWatcher(), procAbortNode, errorInfo); in sendAbortToMembers()
287 byte[] data = ZKUtil.getData(zkProc.getWatcher(), abortNode); in abort()
/dports/www/nextcloud/nextcloud/lib/private/Preview/
H A DWatcherConnector.php55 private function getWatcher(): Watcher { function in OC\\Preview\\WatcherConnector
63 $this->getWatcher()->postWrite($node);
66 \OC_Hook::connect('\OCP\Versions', 'rollback', $this->getWatcher(), 'versionRollback');
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/
H A DTestMasterAddressTracker.java68 MasterAddressTracker.deleteIfEquals(addressTracker.getWatcher(), "some other string.")); in testDeleteIfEquals()
71 MasterAddressTracker.deleteIfEquals(addressTracker.getWatcher(), sn.toString())); in testDeleteIfEquals()
126 MasterAddressTracker.deleteIfEquals(addressTracker.getWatcher(), sn.toString())); in testMasterAddressTrackerFromZK()
146 MasterAddressTracker.deleteIfEquals(addressTracker.getWatcher(), sn.toString())); in testNoBackups()
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/zookeeper/
H A DTestZKLeaderManager.java85 public ZooKeeperWatcher getWatcher() { in getWatcher() method in TestZKLeaderManager.MockLeader
152 byte[] znodeData = ZKUtil.getData(currentLeader.getWatcher(), LEADER_ZNODE); in testLeaderSelection()
170 znodeData = ZKUtil.getData(currentLeader.getWatcher(), LEADER_ZNODE); in testLeaderSelection()
188 znodeData = ZKUtil.getData(currentLeader.getWatcher(), LEADER_ZNODE); in testLeaderSelection()
/dports/sysutils/kubectl/kubernetes-1.22.2/test/integration/apimachinery/
H A Dwatch_restart_test.go156 …getWatcher func(c *kubernetes.Clientset, secret *corev1.Secret) (watch.Interface, error, …
163 …getWatcher: func(c *kubernetes.Clientset, secret *corev1.Secret) (watch.Interface, error, func()) {
176 …getWatcher: func(c *kubernetes.Clientset, secret *corev1.Secret) (watch.Interface, error, func()) {
191 …getWatcher: func(c *kubernetes.Clientset, secret *corev1.Secret) (watch.Interface, error, func()) {
222 watcher, err, doneFn := tc.getWatcher(c, secret)
/dports/graphics/klatexformula/klatexformula-4.0.0/src/klftools/
H A Dklfdebug.h72 static KLFDebugObjectWatcher *getWatcher();
136 { KLFDebugObjectWatcher::getWatcher()->registerObjectRefInfo((qobj), #qobj) ; \
138 KLFDebugObjectWatcher::getWatcher(), SLOT(debugObjectDestroyedFromSender())); \
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/
H A DEnforceAuthenticationTest.java171 new ZooKeeper("127.0.0.1:" + clientPort, CONNECTION_TIMEOUT, getWatcher(countDownLatch), in testEnforceAuthNewBehaviour()
187 new ZooKeeper("127.0.0.1:" + clientPort, CONNECTION_TIMEOUT, getWatcher(countDownLatch), in testEnforceAuthNewBehaviour()
209 new ZooKeeper("127.0.0.1:" + clientPort, CONNECTION_TIMEOUT, getWatcher(countDownLatch), in testEnforceAuthenticationWithMultipleAuthSchemes()
248 private Watcher getWatcher(CountDownLatch countDownLatch) { in getWatcher() method in EnforceAuthenticationTest
/dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/
H A DZooKeeperListener.java83 public ZooKeeperWatcher getWatcher() { in getWatcher() method in ZooKeeperListener
/dports/www/owncloud/owncloud/lib/private/Files/Storage/
H A DStorage.php67 public function getWatcher($path = '', $storage = null); function
/dports/www/nextcloud/nextcloud/lib/private/Files/Storage/
H A DStorage.php70 public function getWatcher($path = '', $storage = null); function
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/mojo/public/java/system/src/org/chromium/mojo/system/
H A DCore.java172 public Watcher getWatcher(); in getWatcher() method
/dports/www/chromium-legacy/chromium-88.0.4324.182/mojo/public/java/system/src/org/chromium/mojo/system/
H A DCore.java183 public Watcher getWatcher(); in getWatcher() method
/dports/lang/spidermonkey78/firefox-78.9.0/devtools/server/actors/descriptors/watcher/
H A DFrameWatchers.jsm7 var EXPORTED_SYMBOLS = ["registerWatcher", "unregisterWatcher", "getWatcher"];
28 * DevToolsFrameParent to use getWatcher method in order to retrieve watcher
110 function getWatcher(parentConnectionPrefix) {
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/mojo/public/java/bindings/src/org/chromium/mojo/bindings/
H A DBindingsHelper.java194 return handle.getCore().getWatcher(); in getWatcherForHandle()
H A DExecutorFactory.java69 mWatcher = core.getWatcher(); in PipedExecutor()
/dports/www/chromium-legacy/chromium-88.0.4324.182/mojo/public/java/bindings/src/org/chromium/mojo/bindings/
H A DBindingsHelper.java194 return handle.getCore().getWatcher(); in getWatcherForHandle()
H A DExecutorFactory.java68 mWatcher = core.getWatcher(); in PipedExecutor()
/dports/lang/spidermonkey78/firefox-78.9.0/devtools/server/connectors/js-window-actor/
H A DDevToolsFrameParent.jsm12 const { getWatcher } = ChromeUtils.import(
65 const watcher = getWatcher(parentConnectionPrefix);
/dports/www/owncloud/owncloud/lib/private/Files/Storage/Wrapper/
H A DJail.php415 public function getWatcher($path = '', $storage = null) { function in OC\\Files\\Storage\\Wrapper\\Jail
419 return $this->getWrapperStorage()->getWatcher($this->getSourcePath($path), $storage);
H A DWrapper.php433 public function getWatcher($path = '', $storage = null) { function in OC\\Files\\Storage\\Wrapper\\Wrapper
437 return $this->getWrapperStorage()->getWatcher($path, $storage);
/dports/www/nextcloud/nextcloud/lib/private/Files/Storage/Wrapper/
H A DJail.php426 public function getWatcher($path = '', $storage = null) { function in OC\\Files\\Storage\\Wrapper\\Jail
430 return $this->getWrapperStorage()->getWatcher($this->getUnjailedPath($path), $storage);
H A DWrapper.php430 public function getWatcher($path = '', $storage = null) { function in OC\\Files\\Storage\\Wrapper\\Wrapper
434 return $this->getWrapperStorage()->getWatcher($path, $storage);
/dports/www/nextcloud/nextcloud/lib/public/Files/Storage/
H A DIStorage.php459 public function getWatcher(); function
/dports/www/nextcloud/nextcloud/apps-pkg/files_sharing/lib/
H A DSharedStorage.php405 public function getWatcher($path = '', $storage = null): Watcher { function in OCA\\Files_Sharing\\SharedStorage
415 return parent::getWatcher($path, $storage);

123