com.orientechnologies.orient.enterprise.channel.binary

Class OChannelBinaryClient

java.lang.Object

com.orientechnologies.orient.enterprise.channel.OChannel

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

com.orientechnologies.orient.enterprise.channel.binary.OChannelBinaryAsynch

com.orientechnologies.orient.enterprise.channel.binary.OChannelBinaryClient

Direct Known Subclasses:

OChannelBinaryClientSynch

public class OChannelBinaryClient
extends OChannelBinaryAsynch

Field Summary

Fields

Modifier and Type	Field and Description
protected int	socketTimeout

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, lockRead, lockWrite, outStream, socket, socketBufferSize, timeout

Constructor Summary

Constructors

Constructor and Description
OChannelBinaryClient(String remoteHost, int remotePort, OContextConfiguration iConfig, int iProtocolVersion)
OChannelBinaryClient(String remoteHost, int remotePort, OContextConfiguration iConfig, int iProtocolVersion, ORemoteServerEventListener asynchEventListener)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
com.orientechnologies.common.concur.resource.OAdaptiveLock	getLockRead()
com.orientechnologies.common.concur.resource.OAdaptiveLock	getLockWrite()
short	getSrvProtocolVersion() Gets the major supported protocol version
boolean	isConnected() Tells if the channel is connected.

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

beginRequest, beginResponse, beginResponse, clearInput, endRequest, endResponse

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

flush, getBuffer, getMaxChunkSize, handleStatus, readByte, readBytes, readClusterPosition, readInt, readLong, readRID, readShort, readStatus, readString, readStringList, readStringSet, readVersion, writeByte, writeBytes, writeBytes, writeClusterPosition, writeCollectionString, writeInt, writeLong, writeRID, writeShort, writeString, writeVersion

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

acquireReadLock, acquireWriteLock, connected, releaseReadLock, releaseWriteLock, toString, updateMetricFlushes, updateMetricReceivedBytes, updateMetricTransmittedBytes

Methods inherited from class java.lang.Object

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

Field Detail

socketTimeout

protected final int socketTimeout

Constructor Detail

OChannelBinaryClient

public OChannelBinaryClient(String remoteHost,
                    int remotePort,
                    OContextConfiguration iConfig,
                    int iProtocolVersion)
                     throws IOException

Throws:

IOException

OChannelBinaryClient

public OChannelBinaryClient(String remoteHost,
                    int remotePort,
                    OContextConfiguration iConfig,
                    int iProtocolVersion,
                    ORemoteServerEventListener asynchEventListener)
                     throws IOException

Throws:

IOException

Method Detail

close

public void close()

Overrides:

close in class OChannelBinaryAsynch

isConnected

public boolean isConnected()

Tells if the channel is connected.

Returns:

true if it's connected, otherwise false.

getSrvProtocolVersion

public short getSrvProtocolVersion()

Gets the major supported protocol version

getLockRead

public com.orientechnologies.common.concur.resource.OAdaptiveLock getLockRead()

getLockWrite

public com.orientechnologies.common.concur.resource.OAdaptiveLock getLockWrite()