| 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 |
OClientConnectionManager.disconnect(OClientConnection iConnection) |
ONetworkProtocolData |
OTokenHandler.getProtocolDataFromToken(OClientConnection oClientConnection,
OToken token) |
OClientSessions |
OClientConnectionManager.getSession(OClientConnection connection) |
void |
OClientConnectionManager.kill(OClientConnection connection)
Disconnects and kill the associated network manager.
|
void |
OClientSessions.removeConnection(OClientConnection conn) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
ONetworkProtocolBinary.addCluster(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.afterOperationRequest(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.checkServerAccess(String iResource,
OClientConnection connection) |
protected void |
ONetworkProtocolBinary.cleanOutRecord(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.closeDatabase(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.command(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.commit(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.configGet(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.configList(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.configSet(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.connect(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.countClusters(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.countDatabaseRecords(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.createDatabase(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.createRecord(OClientConnection connection) |
protected ORecord |
ONetworkProtocolBinary.createRecord(OClientConnection connection,
ORecordId rid,
byte[] buffer,
byte recordType) |
protected void |
ONetworkProtocolBinary.deleteRecord(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.distributedCluster(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.dropDatabase(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.endResponse(OClientConnection connection) |
protected boolean |
ONetworkProtocolBinary.executeRequest(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.existsDatabase(OClientConnection connection) |
void |
ONetworkProtocolBinary.fillRecord(OClientConnection connection,
ORecordId rid,
byte[] buffer,
int version,
ORecord record) |
protected void |
ONetworkProtocolBinary.freezeDatabase(OClientConnection connection) |
byte[] |
ONetworkProtocolBinary.getRecordBytes(OClientConnection connection,
ORecord iRecord) |
String |
ONetworkProtocolBinary.getRecordSerializerName(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.handleConnectionError(OClientConnection connection,
Throwable e) |
protected void |
ONetworkProtocolBinary.hideRecord(OClientConnection connection) |
void |
ONetworkProtocolBinary.importDatabase(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.openDatabase(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.rangeCluster(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.readConnectionData(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.readRecord(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.readRecordIfVersionIsNotLatest(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.readRecordMetadata(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.releaseDatabase(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.reloadDatabase(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.removeCluster(OClientConnection connection) |
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.sendResponse(OClientConnection connection,
ODocument iResponse) |
void |
ONetworkProtocolBinary.serializeValue(OClientConnection connection,
OAbstractCommandResultListener listener,
Object result,
boolean load,
boolean isRecordResultSet) |
protected void |
ONetworkProtocolBinary.setDataCommandInfo(OClientConnection connection,
String iCommandInfo) |
protected void |
ONetworkProtocolBinary.shutdownConnection(OClientConnection connection) |
protected void |
ONetworkProtocolBinary.sizeDatabase(OClientConnection connection) |
protected int |
ONetworkProtocolBinary.trimCsvSerializedContent(OClientConnection connection,
byte[] stream) |
protected void |
ONetworkProtocolBinary.updateRecord(OClientConnection connection)
VERSION MANAGEMENT:
-1 : DOCUMENT UPDATE, NO VERSION CONTROL -2 : DOCUMENT UPDATE, NO VERSION CONTROL, NO VERSION INCREMENT -3 : DOCUMENT ROLLBACK, DECREMENT VERSION >-1 : MVCC CONTROL, RECORD UPDATE AND VERSION INCREMENT <-3 : WRONG VERSION VALUE |
protected int |
ONetworkProtocolBinary.updateRecord(OClientConnection connection,
ORecordId rid,
byte[] buffer,
int version,
byte recordType,
boolean updateContent) |
void |
ONetworkProtocolBinary.writeIdentifiable(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,
ONetworkProtocolBinary iNetworkProtocolBinary,
int txId,
OCommandResultListener wrappedResultListener) |
OLiveCommandResultListener(OServer server,
OClientConnection connection,
int sessionId,
OCommandResultListener wrappedResultListener) |
| Modifier and Type | Field and Description |
|---|---|
OClientConnection |
OHttpResponse.connection |
protected OClientConnection |
ONetworkProtocolHttpAbstract.connection |
| Constructor and Description |
|---|
OHttpResponse(OutputStream iOutStream,
String iHttpVersion,
String[] iAdditionalHeaders,
String iResponseCharSet,
String iServerInfo,
String iSessionId,
String iCallbackFunction,
boolean iKeepAlive,
OClientConnection connection) |
| 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) |
| Constructor and Description |
|---|
OTransactionOptimisticProxy(OClientConnection connection,
ONetworkProtocolBinary protocolBinary) |
Copyright © 2009–2025 OrientDB. All rights reserved.