org.apache.zookeeper.server
Class NIOServerCnxn

java.lang.Object
  org.apache.zookeeper.server.NIOServerCnxn

All Implemented Interfaces:

ServerCnxn, Watcher

public class NIOServerCnxn
extends Object
implements Watcher, ServerCnxn

This class handles communication with clients using NIO. There is one per client, but only one thread doing the communication.

Nested Class Summary

static class

NIOServerCnxn.Factory

Nested classes/interfaces inherited from interface org.apache.zookeeper.server.ServerCnxn

ServerCnxn.Stats

Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher

Watcher.Event

Field Summary

Fields inherited from interface org.apache.zookeeper.server.ServerCnxn

dumpCmd, enviCmd, getTraceMaskCmd, imok, me, reqsCmd, ruokCmd, setTraceMaskCmd, srstCmd, statCmd

Constructor Summary

NIOServerCnxn(ZooKeeperServer zk, SocketChannel sock, SelectionKey sk, NIOServerCnxn.Factory factory)

Method Summary

void	close()
void	disableRecv()
void	enableRecv()
void	finishSessionInit(boolean valid)
ArrayList<org.apache.zookeeper.data.Id>	getAuthInfo()
InetSocketAddress	getRemoteAddress()
long	getSessionId()
int	getSessionTimeout()
ServerCnxn.Stats	getStats()
void	process(WatchedEvent event)
void	sendResponse(org.apache.zookeeper.proto.ReplyHeader h, Record r, String tag)
void	setSessionId(long sessionId)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

NIOServerCnxn

public NIOServerCnxn(ZooKeeperServer zk,
                     SocketChannel sock,
                     SelectionKey sk,
                     NIOServerCnxn.Factory factory)
              throws IOException

Throws:

IOException

Method Detail

disableRecv

public void disableRecv()

enableRecv

public void enableRecv()

getSessionTimeout

public int getSessionTimeout()

Specified by:

getSessionTimeout in interface ServerCnxn

toString

public String toString()

Overrides:

toString in class Object

close

public void close()

Specified by:

close in interface ServerCnxn

sendResponse

public void sendResponse(org.apache.zookeeper.proto.ReplyHeader h,
                         Record r,
                         String tag)

Specified by:

sendResponse in interface ServerCnxn

process

public void process(WatchedEvent event)

Specified by:

process in interface ServerCnxn

Specified by:

process in interface Watcher

finishSessionInit

public void finishSessionInit(boolean valid)

Specified by:

finishSessionInit in interface ServerCnxn

getSessionId

public long getSessionId()

Specified by:

getSessionId in interface ServerCnxn

setSessionId

public void setSessionId(long sessionId)

Specified by:

setSessionId in interface ServerCnxn

getAuthInfo

public ArrayList<org.apache.zookeeper.data.Id> getAuthInfo()

Specified by:

getAuthInfo in interface ServerCnxn

getRemoteAddress

public InetSocketAddress getRemoteAddress()

Specified by:

getRemoteAddress in interface ServerCnxn

getStats

public ServerCnxn.Stats getStats()

Specified by:

getStats in interface ServerCnxn