com.orientechnologies.orient.client.binary

Class OChannelBinarySynchClient

java.lang.Object

com.orientechnologies.common.listener.OListenerManger<OChannelListener>

com.orientechnologies.orient.enterprise.channel.OChannel

com.orientechnologies.orient.enterprise.channel.binary.OChannelBinary

com.orientechnologies.orient.client.binary.OChannelBinaryClientAbstract

com.orientechnologies.orient.client.binary.OChannelBinarySynchClient

All Implemented Interfaces:

OChannelDataInput, OChannelDataOutput

public class OChannelBinarySynchClient
extends OChannelBinaryClientAbstract

Synchronous implementation of binary channel.

Field Summary

Fields inherited from class com.orientechnologies.orient.client.binary.OChannelBinaryClientAbstract

currentSessionId, currentStatus, serverURL, socketTimeout, srvProtocolVersion

Fields inherited from class com.orientechnologies.orient.enterprise.channel.binary.OChannelBinary

debug, in, out

Fields inherited from class com.orientechnologies.orient.enterprise.channel.OChannel

inStream, outStream, socket, socketBufferSize, timeout

Constructor Summary

Constructors

Constructor and Description
OChannelBinarySynchClient(String remoteHost, int remotePort, String iDatabaseName, OContextConfiguration iConfig, int protocolVersion)

Method Summary

Modifier and Type	Method and Description
void	beginRequest(byte iCommand, int sessionId, byte[] token)
byte[]	beginResponse(boolean token)

Methods inherited from class com.orientechnologies.orient.client.binary.OChannelBinaryClientAbstract

clearInput, getServerURL, getSrvProtocolVersion, handleStatus, isConnected, setReadResponseTimeout, throwSerializedException, tryLock, unlock

Methods inherited from class com.orientechnologies.orient.enterprise.channel.binary.OChannelBinary

close, flush, getDataInput, getDataOutput, readBoolean, readByte, readBytes, readInt, readLong, readRID, readShort, readString, readVersion, setReadRequestTimeout, setWaitRequestTimeout, setWaitResponseTimeout, writeBoolean, writeByte, writeBytes, writeBytes, writeInt, writeLong, writeRID, writeShort, writeString, writeVersion

Methods inherited from class com.orientechnologies.orient.enterprise.channel.OChannel

acquireReadLock, acquireWriteLock, connected, getLocalIpAddress, getLocalSocketAddress, getLockRead, getLockWrite, releaseReadLock, releaseWriteLock, toString, tryAcquireWriteLock, updateMetricFlushes, updateMetricReceivedBytes, updateMetricTransmittedBytes

Methods inherited from class com.orientechnologies.common.listener.OListenerManger

browseListeners, getListenersCopy, registerListener, resetListeners, unregisterListener

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

OChannelBinarySynchClient

public OChannelBinarySynchClient(String remoteHost,
                                 int remotePort,
                                 String iDatabaseName,
                                 OContextConfiguration iConfig,
                                 int protocolVersion)
                          throws IOException

Throws:

IOException

Method Detail

beginRequest

public void beginRequest(byte iCommand,
                         int sessionId,
                         byte[] token)
                  throws IOException

Throws:

IOException

beginResponse

public byte[] beginResponse(boolean token)
                     throws IOException

Throws:

IOException