Uses of Interface
com.orientechnologies.orient.enterprise.channel.binary.OChannelDataInput

Packages that use OChannelDataInput

Package	Description
com.orientechnologies.orient.client.binary
com.orientechnologies.orient.client.remote
com.orientechnologies.orient.client.remote.message
com.orientechnologies.orient.client.remote.message.push
com.orientechnologies.orient.core.serialization.serializer.result.binary
com.orientechnologies.orient.enterprise.channel.binary

Uses of OChannelDataInput in com.orientechnologies.orient.client.binary

Classes in com.orientechnologies.orient.client.binary that implement OChannelDataInput

Modifier and Type	Class and Description
class	OChannelBinaryAsynchClient
class	OChannelBinaryClientAbstract Abstract implementation of binary channel.
class	OChannelBinarySynchClient Synchronous implementation of binary channel.

Uses of OChannelDataInput in com.orientechnologies.orient.client.remote

Methods in com.orientechnologies.orient.client.remote with parameters of type OChannelDataInput

Modifier and Type	Method and Description
void	OBinaryRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OBinaryResponse.read(OChannelDataInput network, OStorageRemoteSession session)
OBonsaiCollectionPointer	OCollectionNetworkSerializer.readCollectionPointer(OChannelDataInput client)

Uses of OChannelDataInput in com.orientechnologies.orient.client.remote.message

Methods in com.orientechnologies.orient.client.remote.message with parameters of type OChannelDataInput

Modifier and Type	Method and Description
void	OBinaryPushResponse.read(OChannelDataInput channel)
void	OPushSchemaRequest.read(OChannelDataInput network)
void	OPushSequencesRequest.read(OChannelDataInput network)
void	OPushFunctionsRequest.read(OChannelDataInput network)
void	OPushIndexManagerRequest.read(OChannelDataInput network)
void	OPushStorageConfigurationRequest.read(OChannelDataInput network)
void	OPushDistributedConfigurationRequest.read(OChannelDataInput network)
void	OLiveQueryPushRequest.read(OChannelDataInput network)
void	OBinaryPushRequest.read(OChannelDataInput network)
void	ORollbackTransactionRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OSubscribeSchemaRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	ODistributedConnectRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OOpenRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OSetGlobalConfigurationRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OCloseQueryRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OSBTCreateTreeRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OGetRecordMetadataRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OShutdownRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OReopenRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OFloorPhysicalPositionsRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OGetClusterDataRangeRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OSubscribeFunctionsRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OSubscribeMetadataRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OReloadRequest37.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OSubscribeIndexManagerRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	ODropClusterRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OSubscribeDistributedConfigurationRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OSubscribeStorageConfigurationRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OCountRecordsRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OCommandRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OReloadRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OQueryNextPageRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OSubscribeSequencesRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OUpdateRecordRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OReadRecordRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OConnect37Request.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OListGlobalConfigurationsRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OListDatabasesRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OCommit38Request.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OUnsubscribeLiveQueryRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OIncrementalBackupRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OLockRecordRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OFetchTransactionRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	ODistributedStatusRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OQueryRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OCleanOutRecordRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OHigherPhysicalPositionsRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OLowerPhysicalPositionsRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OGetSizeRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OImportRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OSubscribeLiveQueryRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OBeginTransaction38Request.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OSBTFetchEntriesMajorRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OFetchTransaction38Request.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OCommitRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OConnectRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OExperimentalRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OCountRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OUnlockRecordRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OServerInfoRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OCreateRecordRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OOpen37Request.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OCreateDatabaseRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	ODeleteRecordRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OSBTFirstKeyRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OSBTGetRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OReleaseDatabaseRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OAddClusterRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OBatchOperationsRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OCloseRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OSBTGetRealBagSizeRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OSubscribeRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	ODropDatabaseRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OGetGlobalConfigurationRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OExistsDatabaseRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OBeginTransactionRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OCeilingPhysicalPositionsRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OCommit37Request.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OFreezeDatabaseRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OReadRecordIfVersionIsNotLatestRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OUnsubscribeRequest.read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
void	OReloadResponse37.read(OChannelDataInput network, OStorageRemoteSession session)
void	OFetchTransaction38Response.read(OChannelDataInput network, OStorageRemoteSession session)
void	OListGlobalConfigurationsResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OErrorResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OSBTFetchEntriesMajorResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OFreezeDatabaseResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OAddClusterResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OError37Response.read(OChannelDataInput network, OStorageRemoteSession session)
void	OCommandResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OHideRecordResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OShutdownResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OExperimentalResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OFloorPhysicalPositionsResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OSubscribeIndexManagerResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OCountResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OSubscribeSchemaResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OListDatabasesResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OIncrementalBackupResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OCeilingPhysicalPositionsResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OGetGlobalConfigurationResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	ODistributedStatusResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	ODropClusterResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OFetchTransactionResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OUnsubscribeResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	ORollbackTransactionResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OReopenResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OExistsDatabaseResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OSubscribeDistributedConfigurationResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OCountRecordsResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OReloadResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OGetRecordMetadataResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OBatchOperationsResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OUnlockRecordResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OGetClusterDataRangeResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OUnsubscribLiveQueryResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OLockRecordResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OCleanOutRecordResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OServerInfoResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OCommit37Response.read(OChannelDataInput network, OStorageRemoteSession session)
void	OCloseQueryResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OImportResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OSubscribeResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OGetSizeResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OSBTFirstKeyResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OSBTGetRealBagSizeResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	ODeleteRecordResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OOpenResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OHigherPhysicalPositionsResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OConnectResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OSBTGetResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	ODistributedConnectResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OCreateRecordResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OSetGlobalConfigurationResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OLowerPhysicalPositionsResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OReadRecordResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OSubscribeFunctionsResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OSubscribeStorageConfigurationResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OSBTCreateTreeResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OReleaseDatabaseResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OQueryResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OReadRecordIfVersionIsNotLatestResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OOpen37Response.read(OChannelDataInput network, OStorageRemoteSession session)
void	OCommitResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OCreateDatabaseResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OBeginTransactionResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OUpdateRecordResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OSubscribeMetadataResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OSubscribeSequencesResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	OSubscribeLiveQueryResponse.read(OChannelDataInput network, OStorageRemoteSession session)
void	ODropDatabaseResponse.read(OChannelDataInput network, OStorageRemoteSession session)
static ORawPair<String[],int[]>	OMessageHelper.readClustersArray(OChannelDataInput network)
static Map<UUID,OBonsaiCollectionPointer>	OMessageHelper.readCollectionChanges(OChannelDataInput network)
static OIdentifiable	OMessageHelper.readIdentifiable(OChannelDataInput network, ORecordSerializer serializer)
static OPhysicalPosition[]	OMessageHelper.readPhysicalPositions(OChannelDataInput network)
static OResultInternal	OMessageHelper.readResult(OChannelDataInput channel)
protected Object	OCommandResponse.readSynchResult(OChannelDataInput network, ODatabaseDocument database, List<ORecord> temporaryResults)

Uses of OChannelDataInput in com.orientechnologies.orient.client.remote.message.push

Methods in com.orientechnologies.orient.client.remote.message.push with parameters of type OChannelDataInput

Modifier and Type	Method and Description
void	OStorageConfigurationPayload.read(OChannelDataInput network)

Uses of OChannelDataInput in com.orientechnologies.orient.core.serialization.serializer.result.binary

Methods in com.orientechnologies.orient.core.serialization.serializer.result.binary with parameters of type OChannelDataInput

Modifier and Type	Method and Description
OResultInternal	OResultSerializerNetwork.fromStream(OChannelDataInput channel)

Uses of OChannelDataInput in com.orientechnologies.orient.enterprise.channel.binary

Classes in com.orientechnologies.orient.enterprise.channel.binary that implement OChannelDataInput

Modifier and Type	Class and Description
class	OChannelBinary Abstract representation of a channel.
class	OChannelBinaryServer