Package | Description |
---|---|
org.apache.zookeeper.server |
ZooKeeper server theory of operation
|
org.apache.zookeeper.server.auth | |
org.apache.zookeeper.server.quorum |
Modifier and Type | Class | Description |
---|---|---|
class |
NettyServerCnxn |
|
class |
NIOServerCnxn |
This class handles communication with clients using NIO.
|
Modifier and Type | Field | Description |
---|---|---|
ServerCnxn |
Request.cnxn |
Modifier and Type | Field | Description |
---|---|---|
protected java.util.HashSet<ServerCnxn> |
ServerCnxnFactory.cnxns |
|
protected java.util.concurrent.ConcurrentMap<java.lang.Long,ServerCnxn> |
ServerCnxnFactory.sessionMap |
Modifier and Type | Method | Description |
---|---|---|
java.lang.Iterable<ServerCnxn> |
NettyServerCnxnFactory.getConnections() |
|
java.lang.Iterable<ServerCnxn> |
NIOServerCnxnFactory.getConnections() |
|
abstract java.lang.Iterable<ServerCnxn> |
ServerCnxnFactory.getConnections() |
Modifier and Type | Method | Description |
---|---|---|
void |
ServerCnxnFactory.addSession(long sessionId,
ServerCnxn cnxn) |
|
void |
ZooKeeperServer.closeSession(ServerCnxn cnxn,
RequestHeader requestHeader) |
|
void |
ZooKeeperServer.finishSessionInit(ServerCnxn cnxn,
boolean valid) |
|
void |
ZooKeeperServer.processConnectRequest(ServerCnxn cnxn,
java.nio.ByteBuffer incomingBuffer) |
|
void |
ServerCnxnFactory.PacketProcessor.processPacket(java.nio.ByteBuffer packet,
ServerCnxn src) |
|
void |
ZooKeeperServer.processPacket(ServerCnxn cnxn,
java.nio.ByteBuffer incomingBuffer) |
|
void |
ServerCnxnFactory.registerConnection(ServerCnxn serverCnxn) |
|
void |
NettyServerCnxnFactory.removeCnxn(ServerCnxn cnxn) |
|
void |
ZKDatabase.removeCnxn(ServerCnxn cnxn) |
remove a cnxn from the datatree
|
void |
ZooKeeperServer.reopenSession(ServerCnxn cnxn,
long sessionId,
byte[] passwd,
int sessionTimeout) |
|
protected void |
ZooKeeperServer.revalidateSession(ServerCnxn cnxn,
long sessionId,
int sessionTimeout) |
|
Stat |
ZKDatabase.statNode(java.lang.String path,
ServerCnxn serverCnxn) |
stat the path
|
void |
ServerCnxnFactory.unregisterConnection(ServerCnxn serverCnxn) |
Constructor | Description |
---|---|
ConnectionBean(ServerCnxn connection,
ZooKeeperServer zk) |
|
Request(ServerCnxn cnxn,
long sessionId,
int xid,
int type,
java.nio.ByteBuffer bb,
java.util.List<Id> authInfo) |
Modifier and Type | Method | Description |
---|---|---|
KeeperException.Code |
AuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
byte[] authData) |
This method is called when a client passes authentication data for this
scheme.
|
KeeperException.Code |
DigestAuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
byte[] authData) |
|
KeeperException.Code |
IPAuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
byte[] authData) |
|
KeeperException.Code |
SASLAuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
byte[] authData) |
Modifier and Type | Method | Description |
---|---|---|
protected void |
LeaderZooKeeperServer.revalidateSession(ServerCnxn cnxn,
long sessionId,
int sessionTimeout) |
|
protected void |
LearnerZooKeeperServer.revalidateSession(ServerCnxn cnxn,
long sessionId,
int sessionTimeout) |
Copyright © 2018 The Apache Software Foundation