Field Detail

• LOG

  private static final org.apache.commons.logging.Log LOG

• TICK_TIME

  private static final int TICK_TIME

  See Also:

  Constant Field Values

• CONNECTION_TIMEOUT

  private static final int CONNECTION_TIMEOUT

  See Also:

  Constant Field Values

• started

  private boolean started

• defaultClientPort

  private int defaultClientPort

  The default port. If zero, we use a random port.

• standaloneServerFactoryList

  private List<org.apache.zookeeper.server.NIOServerCnxnFactory> standaloneServerFactoryList

• zooKeeperServers

  private List<org.apache.zookeeper.server.ZooKeeperServer> zooKeeperServers

• clientPortList

  private List<Integer> clientPortList

• activeZKServerIndex

  private int activeZKServerIndex

• tickTime

  private int tickTime

• configuration

  private org.apache.hadoop.conf.Configuration configuration

Constructor Detail

• MiniZooKeeperCluster

  public MiniZooKeeperCluster()

• MiniZooKeeperCluster

  public MiniZooKeeperCluster(org.apache.hadoop.conf.Configuration configuration)

Method Detail

• addClientPort

  public void addClientPort(int clientPort)

  Add a client port to the list.

  Parameters:

  clientPort - the specified port

• getClientPortList

  public List<Integer> getClientPortList()

  Get the list of client ports.

  Returns:

  clientPortList the client port list

• hasValidClientPortInList

  private boolean hasValidClientPortInList(int index)

  Check whether the client port in a specific position of the client port list is valid.

  Parameters:

  index - the specified position

• setDefaultClientPort

  public void setDefaultClientPort(int clientPort)

• selectClientPort

  private int selectClientPort(int seedPort)

  Selects a ZK client port.

  Parameters:

  seedPort - the seed port to start with; -1 means first time.

• setTickTime

  public void setTickTime(int tickTime)

• getBackupZooKeeperServerNum

  public int getBackupZooKeeperServerNum()

• getZooKeeperServerNum

  public int getZooKeeperServerNum()

• setupTestEnv

  private static void setupTestEnv()

• startup

  public int startup(File baseDir)
              throws IOException,
                     InterruptedException

  Throws:

  IOException

  InterruptedException

• startup

  public int startup(File baseDir,
            int numZooKeeperServers)
              throws IOException,
                     InterruptedException

  Parameters:

  baseDir -

  numZooKeeperServers -

  Returns:

  ClientPort server bound to, -1 if there was a binding problem and we couldn't pick another port.

  Throws:

  IOException

  InterruptedException

• createDir

  private void createDir(File dir)
                  throws IOException

  Throws:

  IOException

• shutdown

  public void shutdown()
                throws IOException

  Throws:

  IOException

• killCurrentActiveZooKeeperServer

  public int killCurrentActiveZooKeeperServer()
                                       throws IOException,
                                              InterruptedException

  Returns:

  clientPort return clientPort if there is another ZK backup can run when killing the current active; return -1, if there is no backups.

  Throws:

  IOException

  InterruptedException

• killOneBackupZooKeeperServer

  public void killOneBackupZooKeeperServer()
                                    throws IOException,
                                           InterruptedException

  Kill one back up ZK servers

  Throws:

  IOException

  InterruptedException

• waitForServerDown

  private static boolean waitForServerDown(int port,
                          long timeout)
                                    throws IOException

  Throws:

  IOException

• waitForServerUp

  private static boolean waitForServerUp(int port,
                        long timeout)
                                  throws IOException

  Throws:

  IOException

• getClientPort

  public int getClientPort()