org.apache.zookeeper
Class ClientCnxn

java.lang.Object
  org.apache.zookeeper.ClientCnxn

public class ClientCnxn
extends Object

This class manages the socket i/o for the client. ClientCnxn maintains a list of available servers to connect to and "transparently" switches servers it is connected to as needed.

Field Summary

static int

packetLen

Constructor Summary

ClientCnxn(String hosts, int sessionTimeout, ZooKeeper zooKeeper, ClientWatchManager watcher)
Creates a connection object.

ClientCnxn(String hosts, int sessionTimeout, ZooKeeper zooKeeper, ClientWatchManager watcher, long sessionId, byte[] sessionPasswd)
Creates a connection object.

Method Summary

void	addAuthInfo(String scheme, byte[] auth)
void	close() Close the connection, which includes; send session disconnect to the server, shutdown the send/event threads.
void	disconnect() Shutdown the send/event threads.
static boolean	getDisableAutoResetWatch() tests use this to check on reset of watches
long	getSessionId()
byte[]	getSessionPasswd()
static void	setDisableAutoResetWatch(boolean b) tests use this to set the auto reset
void	start()
org.apache.zookeeper.proto.ReplyHeader	submitRequest(org.apache.zookeeper.proto.RequestHeader h, Record request, Record response, org.apache.zookeeper.ZooKeeper.WatchRegistration watchRegistration)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

packetLen

public static final int packetLen

Constructor Detail

ClientCnxn

public ClientCnxn(String hosts,
                  int sessionTimeout,
                  ZooKeeper zooKeeper,
                  ClientWatchManager watcher)
           throws IOException

Creates a connection object. The actual network connect doesn't get established until needed. The start() instance method must be called subsequent to construction.

Parameters:

hosts - a comma separated list of hosts that can be connected to.

sessionTimeout - the timeout for connections.

zooKeeper - the zookeeper object that this connection is related to.

watcher - watcher for this connection

Throws:

IOException

ClientCnxn

public ClientCnxn(String hosts,
                  int sessionTimeout,
                  ZooKeeper zooKeeper,
                  ClientWatchManager watcher,
                  long sessionId,
                  byte[] sessionPasswd)
           throws IOException

Creates a connection object. The actual network connect doesn't get established until needed. The start() instance method must be called subsequent to construction.

Parameters:

hosts - a comma separated list of hosts that can be connected to.

sessionTimeout - the timeout for connections.

zooKeeper - the zookeeper object that this connection is related to.

watcher - watcher for this connection

sessionId - session id if re-establishing session

sessionPasswd - session passwd if re-establishing session

Throws:

IOException

Method Detail

getSessionId

public long getSessionId()

getSessionPasswd

public byte[] getSessionPasswd()

toString

public String toString()

Overrides:

toString in class Object

getDisableAutoResetWatch

public static boolean getDisableAutoResetWatch()

tests use this to check on reset of watches

Returns:

if the auto reset of watches are disabled

setDisableAutoResetWatch

public static void setDisableAutoResetWatch(boolean b)

tests use this to set the auto reset

Parameters:

b - the vaued to set disable watches to

start

public void start()

disconnect

public void disconnect()

Shutdown the send/event threads. This method should not be called directly - rather it should be called as part of close operation. This method is primarily here to allow the tests to verify disconnection behavior.

close

public void close()
           throws IOException

Close the connection, which includes; send session disconnect to the server, shutdown the send/event threads.

Throws:

IOException

submitRequest

public org.apache.zookeeper.proto.ReplyHeader submitRequest(org.apache.zookeeper.proto.RequestHeader h,
                                                            Record request,
                                                            Record response,
                                                            org.apache.zookeeper.ZooKeeper.WatchRegistration watchRegistration)
                                                     throws InterruptedException

Throws:

InterruptedException

addAuthInfo

public void addAuthInfo(String scheme,
                        byte[] auth)