public class NIOServerCnxn extends java.lang.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,
java.nio.channels.SocketChannel sock,
java.nio.channels.SelectionKey sk,
NIOServerCnxn.Factory factory) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
disableRecv() |
void |
enableRecv() |
void |
finishSessionInit(boolean valid) |
java.util.ArrayList<Id> |
getAuthInfo() |
java.net.InetSocketAddress |
getRemoteAddress() |
long |
getSessionId() |
int |
getSessionTimeout() |
ServerCnxn.Stats |
getStats() |
void |
process(WatchedEvent event) |
void |
sendCloseSession() |
void |
sendResponse(ReplyHeader h,
org.apache.jute.Record r,
java.lang.String tag) |
void |
setSessionId(long sessionId) |
java.lang.String |
toString() |
public NIOServerCnxn(ZooKeeperServer zk, java.nio.channels.SocketChannel sock, java.nio.channels.SelectionKey sk, NIOServerCnxn.Factory factory) throws java.io.IOException
java.io.IOException
public void sendCloseSession()
sendCloseSession
in interface ServerCnxn
public void disableRecv()
public void enableRecv()
public int getSessionTimeout()
getSessionTimeout
in interface ServerCnxn
public java.lang.String toString()
toString
in class java.lang.Object
public void close()
public void sendResponse(ReplyHeader h, org.apache.jute.Record r, java.lang.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 java.util.ArrayList<Id> getAuthInfo()
getAuthInfo
in interface ServerCnxn
public java.net.InetSocketAddress getRemoteAddress()
getRemoteAddress
in interface ServerCnxn
public ServerCnxn.Stats getStats()
getStats
in interface ServerCnxn
Copyright © 2016 The Apache Software Foundation