Categories:
Audio (13)
Biotech (29)
Bytecode (36)
Database (77)
Framework (7)
Game (7)
General (507)
Graphics (53)
I/O (35)
IDE (2)
JAR Tools (101)
JavaBeans (21)
JDBC (121)
JDK (426)
JSP (20)
Logging (108)
Mail (58)
Messaging (8)
Network (84)
PDF (97)
Report (7)
Scripting (84)
Security (32)
Server (121)
Servlet (26)
SOAP (24)
Testing (54)
Web (15)
XML (309)
Collections:
Other Resources:
Apache ZooKeeper 3.7.0 Server Source Code
Apache ZooKeeper is an open-source server which enables highly
reliable distributed coordination.
Apache ZooKeeper Server Source Code files are provided in the source packge (apache-zookeeper-3.7.0.tar.gz). You can download it at Apache ZooKeeper Website.
You can also browse Apache ZooKeeper Server Source Code below:
✍: FYIcenter.com
⏎ org/apache/zookeeper/server/watch/IWatchManager.java
/* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.zookeeper.server.watch; import java.io.PrintWriter; import org.apache.zookeeper.Watcher; import org.apache.zookeeper.Watcher.Event.EventType; public interface IWatchManager { /** * Add watch to specific path. * * @param path znode path * @param watcher watcher object reference * * @return true if the watcher added is not already present */ boolean addWatch(String path, Watcher watcher); /** * Add watch to specific path. * * @param path znode path * @param watcher watcher object reference * @param watcherMode the watcher mode to use * * @return true if the watcher added is not already present */ default boolean addWatch(String path, Watcher watcher, WatcherMode watcherMode) { if (watcherMode == WatcherMode.DEFAULT_WATCHER_MODE) { return addWatch(path, watcher); } throw new UnsupportedOperationException(); // custom implementations must defeat this } /** * Checks the specified watcher exists for the given path. * * @param path znode path * @param watcher watcher object reference * * @return true if the watcher exists, false otherwise */ boolean containsWatcher(String path, Watcher watcher); /** * Removes the specified watcher for the given path. * * @param path znode path * @param watcher watcher object reference * * @return true if the watcher successfully removed, false otherwise */ boolean removeWatcher(String path, Watcher watcher); /** * The entry to remove the watcher when the cnxn is closed. * * @param watcher watcher object reference */ void removeWatcher(Watcher watcher); /** * Distribute the watch event for the given path. * * @param path znode path * @param type the watch event type * * @return the watchers have been notified */ WatcherOrBitSet triggerWatch(String path, EventType type); /** * Distribute the watch event for the given path, but ignore those * suppressed ones. * * @param path znode path * @param type the watch event type * @param suppress the suppressed watcher set * * @return the watchers have been notified */ WatcherOrBitSet triggerWatch(String path, EventType type, WatcherOrBitSet suppress); /** * Get the size of watchers. * * @return the watchers number managed in this class. */ int size(); /** * Clean up the watch manager. */ void shutdown(); /** * Returns a watch summary. * * @return watch summary * @see WatchesSummary */ WatchesSummary getWatchesSummary(); /** * Returns a watch report. * * @return watch report * @see WatchesReport */ WatchesReport getWatches(); /** * Returns a watch report by path. * * @return watch report * @see WatchesPathReport */ WatchesPathReport getWatchesByPath(); /** * String representation of watches. Warning, may be large! * * @param pwriter the writer to dump the watches * @param byPath iff true output watches by paths, otw output * watches by connection * */ void dumpWatches(PrintWriter pwriter, boolean byPath); /** * Return the current number of recursive watchers * * @return qty */ default int getRecursiveWatchQty() { return 0; } }
⏎ org/apache/zookeeper/server/watch/IWatchManager.java
Or download all of them as a single archive file:
File name: zookeeper-server-3.7.0-fyi.zip File size: 871011 bytes Release date: 2021-05-17 Download
⇒ Apache ZooKeeper 3.7.0 Jute Source Code
⇐ Download Apache ZooKeeper 3.7.0 Source Package
2022-11-16, 24859👍, 0💬
Popular Posts:
A stream buffer is a stream-based representation of an XML infoset in Java. Stream buffers are desig...
XML Serializer, Release 2.7.1, allows you to write out XML, HTML etc. as a stream of characters from...
What Is poi-ooxml-5.2.3.jar? poi-ooxml-5.2.3.jar is one of the JAR files for Apache POI 5.2.3, which...
Jackson is "the Java JSON library" or "the best JSON parser for Java". Or simply as "JSON for Java"....
If you are a Java developer, it is very often that you need to use some 3rd party libraries to perfo...