Modifier and Type | Method and Description |
---|---|
void |
OrientDBDistributed.coordinatedRequest(OClientConnection connection,
int requestType,
int clientTxId,
OChannelBinary channel) |
Modifier and Type | Method and Description |
---|---|
void |
OGraphServerHandler.onAfterClientRequest(OClientConnection connection,
byte requestType) |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<Integer,OClientConnection> |
OClientConnectionManager.connections |
Modifier and Type | Method and Description |
---|---|
OClientConnection |
OClientConnectionManager.connect(ONetworkProtocol iProtocol)
Create a connection.
|
OClientConnection |
OClientConnectionManager.connect(ONetworkProtocol iProtocol,
OClientConnection connection,
byte[] tokenBytes,
OTokenHandler handler)
Create a connection.
|
OClientConnection |
OClientConnectionManager.getConnection(int iChannelId,
ONetworkProtocol protocol)
Retrieves the connection by id.
|
OClientConnection |
OClientConnectionManager.getConnection(String iAddress)
Retrieves the connection by address/port.
|
OClientConnection |
OClientConnectionManager.reConnect(ONetworkProtocol iProtocol,
byte[] tokenBytes,
OToken token) |
Modifier and Type | Method and Description |
---|---|
List<OClientConnection> |
OClientSessions.getConnections() |
List<OClientConnection> |
OClientConnectionManager.getConnections() |
Modifier and Type | Method and Description |
---|---|
void |
OClientSessions.addConnection(OClientConnection conn) |
OClientConnection |
OClientConnectionManager.connect(ONetworkProtocol iProtocol,
OClientConnection connection,
byte[] tokenBytes,
OTokenHandler handler)
Create a connection.
|
void |
OServerAware.coordinatedRequest(OClientConnection connection,
int requestType,
int clientTxId,
OChannelBinary channel) |
void |
OClientConnectionManager.disconnect(OClientConnection iConnection) |
ONetworkProtocolData |
OTokenHandler.getProtocolDataFromToken(OClientConnection oClientConnection,
OToken token) |
static byte[] |
OConnectionBinaryExecutor.getRecordBytes(OClientConnection connection,
ORecord iRecord) |
OClientSessions |
OClientConnectionManager.getSession(OClientConnection connection) |
void |
OClientConnectionManager.kill(OClientConnection connection)
Disconnects and kill the associated network manager.
|
void |
OClientSessions.removeConnection(OClientConnection conn) |
Constructor and Description |
---|
OConnectionBinaryExecutor(OClientConnection connection,
OServer server) |
OConnectionBinaryExecutor(OClientConnection connection,
OServer server,
HandshakeInfo handshakeInfo) |
Modifier and Type | Method and Description |
---|---|
abstract OBinaryRequestExecutor |
ONetworkProtocol.executor(OClientConnection connection) |
Modifier and Type | Method and Description |
---|---|
protected void |
ONetworkProtocolBinary.afterOperationRequest(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.checkServerAccess(String iResource,
OClientConnection connection) |
OBinaryRequestExecutor |
ONetworkProtocolBinary.executor(OClientConnection connection) |
static byte[] |
ONetworkProtocolBinary.getRecordBytes(OClientConnection connection,
ORecord iRecord) |
static String |
ONetworkProtocolBinary.getRecordSerializerName(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.handleConnectionError(OClientConnection connection,
Throwable e) |
protected void |
ONetworkProtocolBinary.sendError(OClientConnection connection,
int iClientTxId,
Throwable t) |
protected void |
ONetworkProtocolBinary.sendErrorOrDropConnection(OClientConnection connection,
int iClientTxId,
Throwable t) |
protected void |
ONetworkProtocolBinary.sendOk(OClientConnection connection,
int iClientTxId) |
protected void |
ONetworkProtocolBinary.setDataCommandInfo(OClientConnection connection,
String iCommandInfo) |
boolean |
ONetworkProtocolBinary.shouldReadToken(OClientConnection connection,
int requestType) |
protected static int |
ONetworkProtocolBinary.trimCsvSerializedContent(OClientConnection connection,
byte[] stream) |
static void |
ONetworkProtocolBinary.writeIdentifiable(OChannelBinary channel,
OClientConnection connection,
OIdentifiable o)
Write a OIdentifiable instance using this format:
- 2 bytes: class id [-2=no record, -3=rid, -1=no class id, > -1 = valid] - 1 byte: record type [d,b,f] - 2 bytes: cluster id - 8 bytes: position in cluster - 4 bytes: record version - x bytes: record content |
Constructor and Description |
---|
OAsyncCommandResultListener(OClientConnection connection,
OCommandResultListener wrappedResultListener) |
OLiveCommandResultListener(OServer server,
OClientConnection connection,
OCommandResultListener wrappedResultListener) |
Modifier and Type | Field and Description |
---|---|
protected OClientConnection |
ONetworkProtocolHttpAbstract.connection |
Modifier and Type | Method and Description |
---|---|
OClientConnection |
OHttpResponse.getConnection() |
OClientConnection |
ONetworkProtocolHttpAbstract.getConnection() |
Modifier and Type | Method and Description |
---|---|
OBinaryRequestExecutor |
ONetworkProtocolHttpDb.executor(OClientConnection connection) |
void |
OHttpResponse.setConnection(OClientConnection connection) |
Constructor and Description |
---|
OHttpResponse(OutputStream iOutStream,
String iHttpVersion,
String[] iAdditionalHeaders,
String iResponseCharSet,
String iServerInfo,
String iSessionId,
String iCallbackFunction,
boolean iKeepAlive,
OClientConnection connection,
OContextConfiguration contextConfiguration) |
OHttpResponseImpl(OutputStream iOutStream,
String iHttpVersion,
String[] iAdditionalHeaders,
String iResponseCharSet,
String iServerInfo,
String iSessionId,
String iCallbackFunction,
boolean iKeepAlive,
OClientConnection connection,
OContextConfiguration contextConfiguration) |
Modifier and Type | Method and Description |
---|---|
static void |
OServerPluginHelper.invokeHandlerCallbackOnAfterClientRequest(OServer iServer,
OClientConnection connection,
byte iRequestType) |
static void |
OServerPluginHelper.invokeHandlerCallbackOnBeforeClientRequest(OServer iServer,
OClientConnection connection,
byte iRequestType) |
static void |
OServerPluginHelper.invokeHandlerCallbackOnClientConnection(OServer iServer,
OClientConnection connection) |
static void |
OServerPluginHelper.invokeHandlerCallbackOnClientDisconnection(OServer iServer,
OClientConnection connection) |
static void |
OServerPluginHelper.invokeHandlerCallbackOnClientError(OServer iServer,
OClientConnection connection,
Throwable iThrowable) |
void |
OServerPluginAbstract.onAfterClientRequest(OClientConnection iConnection,
byte iRequestType) |
void |
OServerPlugin.onAfterClientRequest(OClientConnection iConnection,
byte iRequestType)
Callback invoked after a client request is processed.
|
void |
OServerPluginAbstract.onBeforeClientRequest(OClientConnection iConnection,
byte iRequestType) |
void |
OServerPlugin.onBeforeClientRequest(OClientConnection iConnection,
byte iRequestType)
Callback invoked before a client request is processed.
|
void |
OServerPluginAbstract.onClientConnection(OClientConnection iConnection) |
void |
OServerPlugin.onClientConnection(OClientConnection iConnection)
Callback invoked when a client connection begins.
|
void |
OServerPluginAbstract.onClientDisconnection(OClientConnection iConnection) |
void |
OServerPlugin.onClientDisconnection(OClientConnection iConnection)
Callback invoked when a client connection ends.
|
void |
OServerPluginAbstract.onClientError(OClientConnection iConnection,
Throwable iThrowable) |
void |
OServerPlugin.onClientError(OClientConnection iConnection,
Throwable iThrowable)
Callback invoked when a client connection has errors.
|
Modifier and Type | Method and Description |
---|---|
ONetworkProtocolData |
OTokenHandlerImpl.getProtocolDataFromToken(OClientConnection connection,
OToken token) |
ONetworkProtocolData |
OrientTokenHandler.getProtocolDataFromToken(OClientConnection oClientConnection,
OToken token) |
Copyright © 2009–2020 OrientDB. All rights reserved.