Package com.orientechnologies.orient.client.binary

Class OChannelBinarySynchClient

java.lang.Object

com.orientechnologies.orient.enterprise.channel.OChannel

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

com.orientechnologies.orient.client.binary.OChannelBinarySynchClient

public class OChannelBinarySynchClient
extends OChannelBinary

Synchronous implementation of binary channel.

Nested Class Summary

Nested classes/interfaces inherited from class com.orientechnologies.orient.enterprise.channel.binary.OChannelBinary

OChannelBinary.WrapStreams

Field Summary

Fields

Modifier and Type	Field	Description
protected final int	socketTimeout
protected final short	srvProtocolVersion

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

debug, in, inChannel, maxChunkSize, out, outChannel

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

inStream, outStream, socket, socketBufferSize

Constructor Summary

Constructors

Constructor	Description
OChannelBinarySynchClient(OSocketFactory factory, String remoteHost, int remotePort, OContextConfiguration iConfig, int protocolVersion)

Method Summary

Modifier and Type	Method	Description
void	clearInput()
short	getSrvProtocolVersion()	Gets the major supported protocol version
boolean	isConnected()	Tells if the channel is connected.
protected void	setReadResponseTimeout()
boolean	tryLock()
void	unlock()

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

close, flush, getChannelDataInput, getChannelDataOutput, getDataInput, getDataOutput, initChannels, initDebug, setReadRequestTimeout, setWaitRequestTimeout, setWaitResponseTimeout

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

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

Methods inherited from class java.lang.Object

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

Field Details

socketTimeout

protected final int socketTimeout

srvProtocolVersion

protected final short srvProtocolVersion

Constructor Details

OChannelBinarySynchClient

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

Throws:

IOException

Method Details

clearInput

public void clearInput()
                throws IOException

Overrides:

clearInput in class OChannelBinary

Throws:

IOException

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

tryLock

public boolean tryLock()

unlock

public void unlock()

setReadResponseTimeout

protected void setReadResponseTimeout()
                               throws SocketException

Throws:

SocketException