Examples of org.apache.zookeeper.server.NIOServerCnxnFactory

org.apache.zookeeper.server.NIOServerCnxnFactory
NIOServerCnxnFactory implements a multi-threaded ServerCnxnFactory using NIO non-blocking socket calls. Communication between threads is handled via queues. - 1 accept thread, which accepts new connections and assigns to a selector thread - 1-N selector threads, each of which selects on 1/N of the connections. The reason the factory supports more than one selector thread is that with large numbers of connections, select() itself can become a performance bottleneck. - 0-M socket I/O worker threads, which perform basic socket reads and writes. If configured with 0 worker threads, the selector threads do the socket I/O directly. - 1 connection expiration thread, which closes idle connections; this is necessary to expire connections on which no session is established. Typical (default) thread counts are: on a 32 core machine, 1 accept thread, 1 connection expiration thread, 4 selector threads, and 64 worker threads.

        if (!started || activeZKServerIndex < 0) {
            return -1;
        }


        // Shutdown the current active one
        NIOServerCnxnFactory standaloneServerFactory =
                standaloneServerFactoryList.get(activeZKServerIndex);
        int clientPort = clientPortList.get(activeZKServerIndex);


        standaloneServerFactory.shutdown();
        if (!waitForServerDown(clientPort, CONNECTION_TIMEOUT)) {
            throw new IOException("Waiting for shutdown of standalone server");
        }


        // remove the current active zk server

View Full Code Here

            return;
        }


        int backupZKServerIndex = activeZKServerIndex + 1;
        // Shutdown the current active one
        NIOServerCnxnFactory standaloneServerFactory =
                standaloneServerFactoryList.get(backupZKServerIndex);
        int clientPort = clientPortList.get(backupZKServerIndex);


        standaloneServerFactory.shutdown();
        if (!waitForServerDown(clientPort, CONNECTION_TIMEOUT)) {
            throw new IOException("Waiting for shutdown of standalone server");
        }


        // remove this backup zk server

View Full Code Here

                tickTimeToUse = this.tickTime;
            } else {
                tickTimeToUse = TICK_TIME;
            }
            ZooKeeperServer server = new ZooKeeperServer(dir, dir, tickTimeToUse);
            NIOServerCnxnFactory standaloneServerFactory;
            while (true) {
                try {
                    standaloneServerFactory = new NIOServerCnxnFactory();
                    standaloneServerFactory.configure(
                            new InetSocketAddress(tentativePort),
                            configuration.getInt(HConstants.ZOOKEEPER_MAX_CLIENT_CNXNS,
                                    1000));
                } catch (BindException e) {
                    LOG.debug("Failed binding ZK Server to client port: " +
                            tentativePort);
                    // This port is already in use, try to use another.
                    tentativePort++;
                    continue;
                }
                break;
            }


            // Start up this ZK server
            standaloneServerFactory.startup(server);
            if (!waitForServerUp(tentativePort, CONNECTION_TIMEOUT)) {
                throw new IOException("Waiting for startup of standalone server");
            }


            // We have selected this port as a client port.

View Full Code Here

        tickTimeToUse = this.tickTime;
      } else {
        tickTimeToUse = TICK_TIME;
      }
      ZooKeeperServer server = new ZooKeeperServer(dir, dir, tickTimeToUse);
      NIOServerCnxnFactory standaloneServerFactory;
      while (true) {
        try {
          standaloneServerFactory = new NIOServerCnxnFactory();
          standaloneServerFactory.configure(
            new InetSocketAddress(tentativePort),
            configuration.getInt(HConstants.ZOOKEEPER_MAX_CLIENT_CNXNS,
              1000));
        } catch (BindException e) {
          LOG.debug("Failed binding ZK Server to client port: " +
              tentativePort, e);
          // We're told to use some port but it's occupied, fail
          if (defaultClientPort > 0) return -1;
          // This port is already in use, try to use another.
          tentativePort = selectClientPort();
          continue;
        }
        break;
      }


      // Start up this ZK server
      standaloneServerFactory.startup(server);
      if (!waitForServerUp(tentativePort, CONNECTION_TIMEOUT)) {
        throw new IOException("Waiting for startup of standalone server");
      }


      // We have selected this port as a client port.

View Full Code Here

      return;
    }


    // shut down all the zk servers
    for (int i = 0; i < standaloneServerFactoryList.size(); i++) {
      NIOServerCnxnFactory standaloneServerFactory =
        standaloneServerFactoryList.get(i);
      int clientPort = clientPortList.get(i);


      standaloneServerFactory.shutdown();
      if (!waitForServerDown(clientPort, CONNECTION_TIMEOUT)) {
        throw new IOException("Waiting for shutdown of standalone server");
      }
    }
    for (ZooKeeperServer zkServer: zooKeeperServers) {

View Full Code Here

    if (!started || activeZKServerIndex < 0 ) {
      return -1;
    }


    // Shutdown the current active one
    NIOServerCnxnFactory standaloneServerFactory =
      standaloneServerFactoryList.get(activeZKServerIndex);
    int clientPort = clientPortList.get(activeZKServerIndex);


    standaloneServerFactory.shutdown();
    if (!waitForServerDown(clientPort, CONNECTION_TIMEOUT)) {
      throw new IOException("Waiting for shutdown of standalone server");
    }


    zooKeeperServers.get(activeZKServerIndex).getZKDatabase().close();

View Full Code Here

      return ;
    }


    int backupZKServerIndex = activeZKServerIndex+1;
    // Shutdown the current active one
    NIOServerCnxnFactory standaloneServerFactory =
      standaloneServerFactoryList.get(backupZKServerIndex);
    int clientPort = clientPortList.get(backupZKServerIndex);


    standaloneServerFactory.shutdown();
    if (!waitForServerDown(clientPort, CONNECTION_TIMEOUT)) {
      throw new IOException("Waiting for shutdown of standalone server");
    }


    zooKeeperServers.get(backupZKServerIndex).getZKDatabase().close();

View Full Code Here


        System.out.println("Starting ZooKeeper");
        ZooKeeperServer zk_server = new ZooKeeperServer();
        zk_server.setTickTime(500);
        zk_server.setTxnLogFactory(new FileTxnSnapLog(new File(data_dir(), "zk-log"), new File(data_dir(), "zk-data")));
        connector = new NIOServerCnxnFactory();
        connector.configure(new InetSocketAddress(0), 100);
        connector.startup(zk_server);
        System.out.println("ZooKeeper started");
    }

View Full Code Here

        tickTimeToUse = this.tickTime;
      } else {
        tickTimeToUse = TICK_TIME;
      }
      ZooKeeperServer server = new ZooKeeperServer(dir, dir, tickTimeToUse);
      NIOServerCnxnFactory standaloneServerFactory;
      while (true) {
        try {
          standaloneServerFactory = new NIOServerCnxnFactory();
          standaloneServerFactory.configure(
            new InetSocketAddress(tentativePort),
            configuration.getInt(HConstants.ZOOKEEPER_MAX_CLIENT_CNXNS,
              1000));
        } catch (BindException e) {
          LOG.debug("Failed binding ZK Server to client port: " +
              tentativePort);
          // This port is already in use, try to use another.
          tentativePort++;
          continue;
        }
        break;
      }


      // Start up this ZK server
      standaloneServerFactory.startup(server);
      if (!waitForServerUp(tentativePort, CONNECTION_TIMEOUT)) {
        throw new IOException("Waiting for startup of standalone server");
      }


      // We have selected this port as a client port.

View Full Code Here

    if (!started) {
      return;
    }
    // shut down all the zk servers
    for (int i = 0; i < standaloneServerFactoryList.size(); i++) {
      NIOServerCnxnFactory standaloneServerFactory =
        standaloneServerFactoryList.get(i);
      int clientPort = clientPortList.get(i);


      standaloneServerFactory.shutdown();
      if (!waitForServerDown(clientPort, CONNECTION_TIMEOUT)) {
        throw new IOException("Waiting for shutdown of standalone server");
      }
    }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.apache.zookeeper.server.NIOServerCnxnFactory

com.greplin.zookeeper.EmbeddedZookeeperServer

io.fabric8.groups.GroupTest

io.fabric8.process.spring.boot.registry.ZooKeeperProcessRegistries

io.fabric8.test.zookeeper.jgroups.support.ZooKeeperUtils$SimpleServer

io.fabric8.zookeeper.bootstrap.ZooKeeperServerFactory

io.fabric8.zookeeper.spring.ZKServerFactoryBean

io.fabric8.zookeeper.utils.ZookeeperImportUtilsTest

org.apache.activemq.leveldb.test.ElectingLevelDBStoreTest

org.apache.activemq.leveldb.test.ZooKeeperTestSupport

org.apache.activemq.partition.ZooKeeperPartitionBrokerTest

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.