| 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  | 
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 | 
|---|---|
Iterable<ServerCnxn> | 
NettyServerCnxnFactory.getConnections()  | 
abstract Iterable<ServerCnxn> | 
ServerCnxnFactory.getConnections()  | 
Iterable<ServerCnxn> | 
NIOServerCnxnFactory.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 | 
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 | 
X509AuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
                    byte[] authData)  | 
KeeperException.Code | 
IPAuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
                    byte[] authData)  | 
KeeperException.Code | 
DigestAuthenticationProvider.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 | 
SASLAuthenticationProvider.handleAuthentication(ServerCnxn cnxn,
                    byte[] authData)  | 
| 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)  | 
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 | 
LearnerZooKeeperServer.revalidateSession(ServerCnxn cnxn,
                 long sessionId,
                 int sessionTimeout)  | 
protected void | 
LeaderZooKeeperServer.revalidateSession(ServerCnxn cnxn,
                 long sessionId,
                 int sessionTimeout)  | 
Copyright © 2008–2021 The Apache Software Foundation. All rights reserved.