Package | Description |
---|---|
org.apache.zookeeper.server |
ZooKeeper server theory of operation
|
org.apache.zookeeper.server.auth | |
org.apache.zookeeper.server.command | |
org.apache.zookeeper.server.quorum |
Modifier and Type | Class and Description |
---|---|
class |
DumbWatcher
A empty watcher implementation used in bench and unit test.
|
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 Set<ServerCnxn> |
ServerCnxnFactory.cnxns |
Modifier and Type | Method and Description |
---|---|
ServerCnxn |
Request.getConnection() |
Modifier and Type | Method and Description |
---|---|
Iterable<ServerCnxn> |
NIOServerCnxnFactory.getConnections() |
Iterable<ServerCnxn> |
NettyServerCnxnFactory.getConnections() |
abstract Iterable<ServerCnxn> |
ServerCnxnFactory.getConnections() |
Modifier and Type | Method and Description |
---|---|
void |
ServerCnxnFactory.addSession(long sessionId,
ServerCnxn cnxn) |
void |
ZooKeeperServer.checkACL(ServerCnxn cnxn,
List<ACL> acl,
int perm,
List<Id> ids,
String path,
List<ACL> setAcls)
Grant or deny authorization to an operation on a node as a function of:
|
void |
ZooKeeperServer.closeSession(ServerCnxn cnxn,
RequestHeader requestHeader) |
void |
ZooKeeperServer.finishSessionInit(ServerCnxn cnxn,
boolean valid) |
void |
ZooKeeperServer.processConnectRequest(ServerCnxn cnxn,
ByteBuffer incomingBuffer) |
void |
ZooKeeperServer.processPacket(ServerCnxn cnxn,
ByteBuffer incomingBuffer) |
void |
ServerCnxnFactory.registerConnection(ServerCnxn serverCnxn) |
void |
ZKDatabase.removeCnxn(ServerCnxn cnxn)
remove a cnxn from the datatree
|
void |
ServerCnxnFactory.removeCnxnFromSessionMap(ServerCnxn cnxn) |
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 |
---|---|
ServerCnxn |
ServerAuthenticationProvider.ServerObjs.getCnxn() |
Modifier and Type | Method and Description |
---|---|
KeeperException.Code |
X509AuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
byte[] authData) |
KeeperException.Code |
SASLAuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
byte[] authData) |
KeeperException.Code |
EnsembleAuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
byte[] authData) |
KeeperException.Code |
ServerAuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
byte[] authData) |
KeeperException.Code |
DigestAuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
byte[] authData) |
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.
|
Constructor and Description |
---|
ServerObjs(ZooKeeperServer zks,
ServerCnxn cnxn) |
Modifier and Type | Field and Description |
---|---|
protected ServerCnxn |
AbstractFourLetterCommand.serverCnxn |
Modifier and Type | Method and Description |
---|---|
boolean |
CommandExecutor.execute(ServerCnxn serverCnxn,
PrintWriter pwriter,
int commandCode,
ZooKeeperServer zkServer,
ServerCnxnFactory factory)
This class decides which command to be executed and then executes
|
Constructor and Description |
---|
AbstractFourLetterCommand(PrintWriter pw,
ServerCnxn serverCnxn) |
CnxnStatResetCommand(PrintWriter pw,
ServerCnxn serverCnxn) |
ConsCommand(PrintWriter pw,
ServerCnxn serverCnxn) |
DigestCommand(PrintWriter pw,
ServerCnxn serverCnxn) |
DirsCommand(PrintWriter pw,
ServerCnxn serverCnxn) |
DumpCommand(PrintWriter pw,
ServerCnxn serverCnxn) |
IsroCommand(PrintWriter pw,
ServerCnxn serverCnxn) |
NopCommand(PrintWriter pw,
ServerCnxn serverCnxn,
String msg) |
RuokCommand(PrintWriter pw,
ServerCnxn serverCnxn) |
SetTraceMaskCommand(PrintWriter pw,
ServerCnxn serverCnxn,
long trace) |
StatCommand(PrintWriter pw,
ServerCnxn serverCnxn,
int len) |
StatResetCommand(PrintWriter pw,
ServerCnxn serverCnxn) |
WatchCommand(PrintWriter pw,
ServerCnxn serverCnxn,
int len) |
Modifier and Type | Method and Description |
---|---|
protected void |
LeaderZooKeeperServer.revalidateSession(ServerCnxn cnxn,
long sessionId,
int sessionTimeout) |
protected void |
LearnerZooKeeperServer.revalidateSession(ServerCnxn cnxn,
long sessionId,
int sessionTimeout) |
Copyright © 2008–2020 The Apache Software Foundation. All rights reserved.