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 and Description |
---|---|
class |
NettyServerCnxn |
class |
NIOServerCnxn
This class handles communication with clients using NIO.
|
Modifier and Type | Field and Description |
---|---|
ServerCnxn |
Request.cnxn |
Modifier and Type | Field and Description |
---|---|
protected HashSet<ServerCnxn> |
ServerCnxnFactory.cnxns |
Modifier and Type | Method and Description |
---|---|
abstract Iterable<ServerCnxn> |
ServerCnxnFactory.getConnections() |
Iterable<ServerCnxn> |
NIOServerCnxnFactory.getConnections() |
Iterable<ServerCnxn> |
NettyServerCnxnFactory.getConnections() |
Modifier and Type | Method and Description |
---|---|
void |
ZooKeeperServer.closeSession(ServerCnxn cnxn,
RequestHeader requestHeader) |
void |
ZooKeeperServer.finishSessionInit(ServerCnxn cnxn,
boolean valid) |
void |
ZooKeeperServer.processConnectRequest(ServerCnxn cnxn,
ByteBuffer incomingBuffer) |
void |
ServerCnxnFactory.PacketProcessor.processPacket(ByteBuffer packet,
ServerCnxn src) |
void |
ZooKeeperServer.processPacket(ServerCnxn cnxn,
ByteBuffer incomingBuffer) |
void |
ServerCnxnFactory.registerConnection(ServerCnxn serverCnxn) |
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(String path,
ServerCnxn serverCnxn)
stat the path
|
void |
ServerCnxnFactory.unregisterConnection(ServerCnxn serverCnxn) |
Constructor and Description |
---|
ConnectionBean(ServerCnxn connection,
ZooKeeperServer zk) |
Request(ServerCnxn cnxn,
long sessionId,
int xid,
int type,
ByteBuffer bb,
List<Id> authInfo) |
Modifier and Type | Method and Description |
---|---|
KeeperException.Code |
IPAuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
byte[] authData) |
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 |
SASLAuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
byte[] authData) |
Modifier and Type | Method and Description |
---|---|
protected void |
LearnerZooKeeperServer.revalidateSession(ServerCnxn cnxn,
long sessionId,
int sessionTimeout) |
protected void |
LeaderZooKeeperServer.revalidateSession(ServerCnxn cnxn,
long sessionId,
int sessionTimeout) |
Copyright © 2013 The Apache Software Foundation