1. 包列表
  2. 类列表
  3. org.apache.zookeeper.server.admin.AdminServer.AdminServerException

Java 类org.apache.zookeeper.server.admin.AdminServer.AdminServerException 实例源码

项目：https-github.com-apache-zookeeper    文件：QuorumPeer.java    
@Override
public synchronized void start() {
    if (!getView().containsKey(myid)) {
        throw new RuntimeException("My id " + myid + " not in the peer list");
     }
    loadDataBase();
    startServerCnxnFactory();
    try {
        adminServer.start();
    } catch (AdminServerException e) {
        LOG.warn("Problem starting AdminServer", e);
        System.out.println(e);
    }
    startLeaderElection();
    super.start();
}
项目：https-github.com-apache-zookeeper    文件：QuorumPeerMain.java    
protected void initializeAndRun(String[] args)
    throws ConfigException, IOException, AdminServerException
{
    QuorumPeerConfig config = new QuorumPeerConfig();
    if (args.length == 1) {
        config.parse(args[0]);
    }

    // Start and schedule the the purge task
    DatadirCleanupManager purgeMgr = new DatadirCleanupManager(config
            .getDataDir(), config.getDataLogDir(), config
            .getSnapRetainCount(), config.getPurgeInterval());
    purgeMgr.start();

    if (args.length == 1 && config.isDistributed()) {
        runFromConfig(config);
    } else {
        LOG.warn("Either no config or no quorum defined in config, running "
                + " in standalone mode");
        // there is only server in the quorum -- run as standalone
        ZooKeeperServerMain.main(args);
    }
}
项目：https-github.com-apache-zookeeper    文件：ZooKeeperServerMain.java    
protected void initializeAndRun(String[] args)
    throws ConfigException, IOException, AdminServerException
{
    try {
        ManagedUtil.registerLog4jMBeans();
    } catch (JMException e) {
        LOG.warn("Unable to register log4j JMX control", e);
    }

    ServerConfig config = new ServerConfig();
    if (args.length == 1) {
        config.parse(args[0]);
    } else {
        config.parse(args);
    }

    runFromConfig(config);
}
项目：https-github.com-apache-zookeeper    文件：ZooKeeperServerMain.java    
/**
 * Shutdown the serving instance
 */
protected void shutdown() {
    if (containerManager != null) {
        containerManager.stop();
    }
    if (cnxnFactory != null) {
        cnxnFactory.shutdown();
    }
    if (secureCnxnFactory != null) {
        secureCnxnFactory.shutdown();
    }
    try {
        if (adminServer != null) {
            adminServer.shutdown();
        }
    } catch (AdminServerException e) {
        LOG.warn("Problem stopping AdminServer", e);
    }
}
项目：SecureKeeper    文件：QuorumPeer.java    
@Override
public synchronized void start() {
    if (!getView().containsKey(myid)) {
        throw new RuntimeException("My id " + myid + " not in the peer list");
     }
    loadDataBase();
    startServerCnxnFactory();
    try {
        adminServer.start();
    } catch (AdminServerException e) {
        LOG.warn("Problem starting AdminServer", e);
        System.out.println(e);
    }
    startLeaderElection();
    super.start();
}
项目：SecureKeeper    文件：QuorumPeerMain.java    
protected void initializeAndRun(String[] args)
    throws ConfigException, IOException, AdminServerException
{
    QuorumPeerConfig config = new QuorumPeerConfig();
    if (args.length == 1) {
        config.parse(args[0]);
    }

    // Start and schedule the the purge task
    DatadirCleanupManager purgeMgr = new DatadirCleanupManager(config
            .getDataDir(), config.getDataLogDir(), config
            .getSnapRetainCount(), config.getPurgeInterval());
    purgeMgr.start();

    if (args.length == 1 && config.isDistributed()) {
        runFromConfig(config);
    } else {
        LOG.warn("Either no config or no quorum defined in config, running "
                + " in standalone mode");
        // there is only server in the quorum -- run as standalone
        ZooKeeperServerMain.main(args);
    }
}
项目：SecureKeeper    文件：ZooKeeperServerMain.java    
protected void initializeAndRun(String[] args)
    throws ConfigException, IOException, AdminServerException
{
    try {
        ManagedUtil.registerLog4jMBeans();
    } catch (JMException e) {
        LOG.warn("Unable to register log4j JMX control", e);
    }

    ServerConfig config = new ServerConfig();
    if (args.length == 1) {
        config.parse(args[0]);
    } else {
        config.parse(args);
    }

    runFromConfig(config);
}
项目：SecureKeeper    文件：ZooKeeperServerMain.java    
/**
 * Shutdown the serving instance
 */
protected void shutdown() {
    if (containerManager != null) {
        containerManager.stop();
    }
    if (cnxnFactory != null) {
        cnxnFactory.shutdown();
    }
    if (secureCnxnFactory != null) {
        secureCnxnFactory.shutdown();
    }
    try {
        adminServer.shutdown();
    } catch (AdminServerException e) {
        LOG.warn("Problem stopping AdminServer", e);
    }
}
项目：SecureKeeper    文件：QuorumPeer.java    
@Override
public synchronized void start() {
    if (!getView().containsKey(myid)) {
        throw new RuntimeException("My id " + myid + " not in the peer list");
     }
    loadDataBase();
    startServerCnxnFactory();
    try {
        adminServer.start();
    } catch (AdminServerException e) {
        LOG.warn("Problem starting AdminServer", e);
        System.out.println(e);
    }
    startLeaderElection();
    super.start();
}
项目：SecureKeeper    文件：QuorumPeerMain.java    
protected void initializeAndRun(String[] args)
    throws ConfigException, IOException, AdminServerException
{
    QuorumPeerConfig config = new QuorumPeerConfig();
    if (args.length == 1) {
        config.parse(args[0]);
    }

    // Start and schedule the the purge task
    DatadirCleanupManager purgeMgr = new DatadirCleanupManager(config
            .getDataDir(), config.getDataLogDir(), config
            .getSnapRetainCount(), config.getPurgeInterval());
    purgeMgr.start();

    if (args.length == 1 && config.isDistributed()) {
        runFromConfig(config);
    } else {
        LOG.warn("Either no config or no quorum defined in config, running "
                + " in standalone mode");
        // there is only server in the quorum -- run as standalone
        ZooKeeperServerMain.main(args);
    }
}
项目：SecureKeeper    文件：ZooKeeperServerMain.java    
protected void initializeAndRun(String[] args)
    throws ConfigException, IOException, AdminServerException
{
    try {
        ManagedUtil.registerLog4jMBeans();
    } catch (JMException e) {
        LOG.warn("Unable to register log4j JMX control", e);
    }

    ServerConfig config = new ServerConfig();
    if (args.length == 1) {
        config.parse(args[0]);
    } else {
        config.parse(args);
    }

    runFromConfig(config);
}
项目：SecureKeeper    文件：ZooKeeperServerMain.java    
/**
 * Shutdown the serving instance
 */
protected void shutdown() {
    if (containerManager != null) {
        containerManager.stop();
    }
    if (cnxnFactory != null) {
        cnxnFactory.shutdown();
    }
    if (secureCnxnFactory != null) {
        secureCnxnFactory.shutdown();
    }
    try {
        adminServer.shutdown();
    } catch (AdminServerException e) {
        LOG.warn("Problem stopping AdminServer", e);
    }
}
项目：https-github.com-apache-zookeeper    文件：QuorumPeer.java    
public void shutdown() {
    running = false;
    if (leader != null) {
        leader.shutdown("quorum Peer shutdown");
    }
    if (follower != null) {
        follower.shutdown();
    }
    shutdownServerCnxnFactory();
    if(udpSocket != null) {
        udpSocket.close();
    }

    try {
        adminServer.shutdown();
    } catch (AdminServerException e) {
        LOG.warn("Problem stopping AdminServer", e);
    }

    if(getElectionAlg() != null){
        this.interrupt();
        getElectionAlg().shutdown();
    }
    try {
        zkDb.close();
    } catch (IOException ie) {
        LOG.warn("Error closing logs ", ie);
    }
}
项目：https-github.com-apache-zookeeper    文件：ReconfigDuringLeaderSyncTest.java    
@Override
public void runFromConfig(QuorumPeerConfig config)
        throws IOException, AdminServerException {
    quorumPeer = new CustomQuorumPeer(config.getQuorumVerifier().getAllMembers(), config.getDataDir(),
            config.getDataLogDir(), config.getClientPortAddress().getPort(), config.getElectionAlg(),
            config.getServerId(), config.getTickTime(), config.getInitLimit(), config.getSyncLimit());
    quorumPeer.setConfigFileName(config.getConfigFilename());
    quorumPeer.start();
    try {
        quorumPeer.join();
    } catch (InterruptedException e) {
        LOG.warn("Quorum Peer interrupted", e);
    }
}
项目：https-github.com-apache-zookeeper    文件：JettyAdminServerTest.java    
/**
 * Tests that we can start and query a JettyAdminServer.
 */
@Test
public void testJettyAdminServer() throws AdminServerException, IOException {
    JettyAdminServer server = new JettyAdminServer();;
    try {
        server.start();
        queryAdminServer(jettyAdminPort);
    } finally {
        server.shutdown();
    }
}
项目：SecureKeeper    文件：QuorumPeer.java    
public void shutdown() {
    running = false;
    if (leader != null) {
        leader.shutdown("quorum Peer shutdown");
    }
    if (follower != null) {
        follower.shutdown();
    }
    shutdownServerCnxnFactory();
    if(udpSocket != null) {
        udpSocket.close();
    }

    try {
        adminServer.shutdown();
    } catch (AdminServerException e) {
        LOG.warn("Problem stopping AdminServer", e);
    }

    if(getElectionAlg() != null){
        this.interrupt();
        getElectionAlg().shutdown();
    }
    try {
        zkDb.close();
    } catch (IOException ie) {
        LOG.warn("Error closing logs ", ie);
    }
}
项目：SecureKeeper    文件：JettyAdminServerTest.java    
/**
 * Tests that we can start and query a JettyAdminServer.
 */
@Test
public void testJettyAdminServer() throws AdminServerException, IOException {
    JettyAdminServer server = new JettyAdminServer();;
    try {
        server.start();
        queryAdminServer(jettyAdminPort);
    } finally {
        server.shutdown();
    }
}
项目：SecureKeeper    文件：QuorumPeer.java    
public void shutdown() {
    running = false;
    if (leader != null) {
        leader.shutdown("quorum Peer shutdown");
    }
    if (follower != null) {
        follower.shutdown();
    }
    shutdownServerCnxnFactory();
    if(udpSocket != null) {
        udpSocket.close();
    }

    try {
        adminServer.shutdown();
    } catch (AdminServerException e) {
        LOG.warn("Problem stopping AdminServer", e);
    }

    if(getElectionAlg() != null){
        this.interrupt();
        getElectionAlg().shutdown();
    }
    try {
        zkDb.close();
    } catch (IOException ie) {
        LOG.warn("Error closing logs ", ie);
    }
}
项目：SecureKeeper    文件：JettyAdminServerTest.java    
/**
 * Tests that we can start and query a JettyAdminServer.
 */
@Test
public void testJettyAdminServer() throws AdminServerException, IOException {
    JettyAdminServer server = new JettyAdminServer();;
    try {
        server.start();
        queryAdminServer(jettyAdminPort);
    } finally {
        server.shutdown();
    }
}
项目：SecureKeeper    文件：ZooKeeperServerMain.java    
/**
 * Run from a ServerConfig.
 * @param config ServerConfig to use.
 * @throws IOException
 * @throws AdminServerException
 */
public void runFromConfig(ServerConfig config) throws IOException, AdminServerException {
    LOG.info("Starting server");
    FileTxnSnapLog txnLog = null;
    try {
        // Note that this thread isn't going to be doing anything else,
        // so rather than spawning another thread, we will just call
        // run() in this thread.
        // create a file logger url from the command line args
        txnLog = new FileTxnSnapLog(config.dataLogDir, config.dataDir);
        ZooKeeperServer zkServer = new ZooKeeperServer( txnLog,
                config.tickTime, config.minSessionTimeout, config.maxSessionTimeout, null);

        // Start Admin server
        adminServer = AdminServerFactory.createAdminServer();
        adminServer.setZooKeeperServer(zkServer);
        adminServer.start();

        boolean needStartZKServer = true;
        if (config.getClientPortAddress() != null) {
            cnxnFactory = ServerCnxnFactory.createFactory();
            cnxnFactory.configure(config.getClientPortAddress(), config.getMaxClientCnxns(), false);
            cnxnFactory.startup(zkServer);
            // zkServer has been started. So we don't need to start it again in secureCnxnFactory.
            needStartZKServer = false;
        }
        if (config.getSecureClientPortAddress() != null) {
            secureCnxnFactory = ServerCnxnFactory.createFactory();
            secureCnxnFactory.configure(config.getSecureClientPortAddress(), config.getMaxClientCnxns(), true);
            secureCnxnFactory.startup(zkServer, needStartZKServer);
        }

        containerManager = new ContainerManager(zkServer.getZKDatabase(), zkServer.firstProcessor,
                Integer.getInteger("znode.container.checkIntervalMs", (int) TimeUnit.MINUTES.toMillis(1)),
                Integer.getInteger("znode.container.maxPerMinute", 10000)
        );
        containerManager.start();

        if (cnxnFactory != null) {
            cnxnFactory.join();
        }
        if (secureCnxnFactory != null) {
            secureCnxnFactory.join();
        }

        if (zkServer.isRunning()) {
            zkServer.shutdown();
        }
    } catch (InterruptedException e) {
        // warn, but generally this is ok
        LOG.warn("Server interrupted", e);
    } finally {
        if (txnLog != null) {
            txnLog.close();
        }
    }
}
项目：SecureKeeper    文件：ZooKeeperServerMain.java    
/**
 * Run from a ServerConfig.
 * @param config ServerConfig to use.
 * @throws IOException
 * @throws AdminServerException
 */
public void runFromConfig(ServerConfig config) throws IOException, AdminServerException {
    LOG.info("Starting server");
    FileTxnSnapLog txnLog = null;
    try {
        // Note that this thread isn't going to be doing anything else,
        // so rather than spawning another thread, we will just call
        // run() in this thread.
        // create a file logger url from the command line args
        txnLog = new FileTxnSnapLog(config.dataLogDir, config.dataDir);
        ZooKeeperServer zkServer = new ZooKeeperServer( txnLog,
                config.tickTime, config.minSessionTimeout, config.maxSessionTimeout, null);

        // Start Admin server
        adminServer = AdminServerFactory.createAdminServer();
        adminServer.setZooKeeperServer(zkServer);
        adminServer.start();

        boolean needStartZKServer = true;
        if (config.getClientPortAddress() != null) {
            cnxnFactory = ServerCnxnFactory.createFactory();
            cnxnFactory.configure(config.getClientPortAddress(), config.getMaxClientCnxns(), false);
            cnxnFactory.startup(zkServer);
            // zkServer has been started. So we don't need to start it again in secureCnxnFactory.
            needStartZKServer = false;
        }
        if (config.getSecureClientPortAddress() != null) {
            secureCnxnFactory = ServerCnxnFactory.createFactory();
            secureCnxnFactory.configure(config.getSecureClientPortAddress(), config.getMaxClientCnxns(), true);
            secureCnxnFactory.startup(zkServer, needStartZKServer);
        }

        containerManager = new ContainerManager(zkServer.getZKDatabase(), zkServer.firstProcessor,
                Integer.getInteger("znode.container.checkIntervalMs", (int) TimeUnit.MINUTES.toMillis(1)),
                Integer.getInteger("znode.container.maxPerMinute", 10000)
        );
        containerManager.start();

        if (cnxnFactory != null) {
            cnxnFactory.join();
        }
        if (secureCnxnFactory != null) {
            secureCnxnFactory.join();
        }

        if (zkServer.isRunning()) {
            zkServer.shutdown();
        }
    } catch (InterruptedException e) {
        // warn, but generally this is ok
        LOG.warn("Server interrupted", e);
    } finally {
        if (txnLog != null) {
            txnLog.close();
        }
    }
}