org.apache.zookeeper.server
public class NIOServerCnxn extends Object implements Watcher, ServerCnxn
Modifier and Type | Class and Description |
---|---|
static class |
NIOServerCnxn.Factory |
ServerCnxn.Stats
Watcher.Event
me
Constructor and Description |
---|
NIOServerCnxn(ZooKeeperServer zk,
SocketChannel sock,
SelectionKey sk,
NIOServerCnxn.Factory factory) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
disableRecv() |
void |
enableRecv() |
void |
finishSessionInit(boolean valid) |
ArrayList<Id> |
getAuthInfo() |
InetSocketAddress |
getRemoteAddress() |
long |
getSessionId() |
int |
getSessionTimeout() |
ServerCnxn.Stats |
getStats() |
void |
process(WatchedEvent event) |
void |
sendCloseSession() |
void |
sendResponse(ReplyHeader h,
org.apache.jute.Record r,
String tag) |
void |
setSessionId(long sessionId) |
String |
toString() |
public NIOServerCnxn(ZooKeeperServer zk, SocketChannel sock, SelectionKey sk, NIOServerCnxn.Factory factory) throws IOException
IOException
public void sendCloseSession()
sendCloseSession
in interface ServerCnxn
public void disableRecv()
public void enableRecv()
public int getSessionTimeout()
getSessionTimeout
in interface ServerCnxn
public void close()
public void sendResponse(ReplyHeader h, org.apache.jute.Record r, String tag)
sendResponse
in interface ServerCnxn
public void process(WatchedEvent event)
process
in interface ServerCnxn
process
in interface Watcher
public void finishSessionInit(boolean valid)
finishSessionInit
in interface ServerCnxn
public long getSessionId()
getSessionId
in interface ServerCnxn
public void setSessionId(long sessionId)
setSessionId
in interface ServerCnxn
public ArrayList<Id> getAuthInfo()
getAuthInfo
in interface ServerCnxn
public InetSocketAddress getRemoteAddress()
getRemoteAddress
in interface ServerCnxn
public ServerCnxn.Stats getStats()
getStats
in interface ServerCnxn
Copyright © 2014 The Apache Software Foundation