Java 类org.apache.zookeeper.server.ZooKeeperServer.State 实例源码

项目:fuck_zookeeper    文件:ZooKeeperServerShutdownHandler.java   
/**
 * This will be invoked when the server transition to a new server state.
 *
 * @param state new server state
 */
void handle(State state) {
    if (state == State.ERROR || state == State.SHUTDOWN) {
        shutdownLatch.countDown();
    }
}
项目:fuck_zookeeper    文件:ZooKeeperServerListenerImpl.java   
@Override
public void notifyStopping(String threadName, int exitCode) {
    //正确而又优雅的打日志的写法
    LOG.info("Thread {} exits, error code {}", threadName, exitCode);
    zkServer.setState(State.ERROR);
}
项目:https-github.com-apache-zookeeper    文件:ZooKeeperServerShutdownHandler.java   
/**
 * This will be invoked when the server transition to a new server state.
 *
 * @param state new server state
 */
void handle(State state) {
    if (state == State.ERROR || state == State.SHUTDOWN) {
        shutdownLatch.countDown();
    }
}
项目:https-github.com-apache-zookeeper    文件:ZooKeeperServerListenerImpl.java   
@Override
public void notifyStopping(String threadName, int exitCode) {
    LOG.info("Thread {} exits, error code {}", threadName, exitCode);
    zkServer.setState(State.ERROR);
}
项目:ZooKeeper    文件:ZooKeeperServerShutdownHandler.java   
/**
 * This will be invoked when the server transition to a new server state.
 *
 * @param state new server state
 */
void handle(State state) {
    if (state == State.ERROR || state == State.SHUTDOWN) {
        shutdownLatch.countDown();
    }
}
项目:ZooKeeper    文件:ZooKeeperServerListenerImpl.java   
@Override
public void notifyStopping(String threadName, int exitCode) {
    LOG.info("Thread {} exits, error code {}", threadName, exitCode);
    zkServer.setState(State.ERROR);
}
项目:StreamProcessingInfrastructure    文件:ZooKeeperServerShutdownHandler.java   
/**
 * This will be invoked when the server transition to a new server state.
 *
 * @param state new server state
 */
void handle(State state) {
    if (state == State.ERROR || state == State.SHUTDOWN) {
        shutdownLatch.countDown();
    }
}
项目:StreamProcessingInfrastructure    文件:ZooKeeperServerListenerImpl.java   
@Override
public void notifyStopping(String threadName, int exitCode) {
    LOG.info("Thread {} exits, error code {}", threadName, exitCode);
    zkServer.setState(State.ERROR);
}