Package | Description |
---|---|
org.apache.zookeeper.server |
ZooKeeper server theory of operation
ZooKeeperServer is designed to work in standalone mode and also
be extensible so that it can be used to implement the quorum based
version of ZooKeeper.
|
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 |
---|---|
abstract Iterable<ServerCnxn> |
ServerCnxnFactory.getConnections() |
Iterable<ServerCnxn> |
NettyServerCnxnFactory.getConnections() |
Iterable<ServerCnxn> |
NIOServerCnxnFactory.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 |
EnsembleAuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
byte[] authData) |
KeeperException.Code |
SASLAuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
byte[] authData) |
KeeperException.Code |
IPAuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
byte[] authData) |
KeeperException.Code |
ServerAuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
byte[] authData) |
KeeperException.Code |
DigestAuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
byte[] authData) |
KeeperException.Code |
X509AuthenticationProvider.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.