Package com.orientechnologies.orient.client.binary

Class OChannelBinaryAsynchClient

java.lang.Object

com.orientechnologies.orient.enterprise.channel.OChannel

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

com.orientechnologies.orient.client.binary.OChannelBinaryAsynchClient

public class OChannelBinaryAsynchClient
extends OChannelBinary

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
static final OLogger	logger
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
OChannelBinaryAsynchClient(String remoteHost, int remotePort, OContextConfiguration config, OSocketFactory factory, int iProtocolVersion)

Method Summary

Modifier and Type	Method	Description
void	clearInput()
void	close()
void	endRequest()
void	endResponse()
long	getLastUse()
String	getServerURL()
int	getSocketTimeout()
short	getSrvProtocolVersion()	Gets the major supported protocol version
boolean	isConnected()	Tells if the channel is connected.
boolean	isInUse()
void	markInUse()
void	markReturned()
protected void	sendHandshake(int iProtocolVersion)
void	setSocketTimeout(int socketTimeout)
boolean	tryLock()
void	unlock()
byte	waitResponse()

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

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

logger

public static final OLogger logger

srvProtocolVersion

protected final short srvProtocolVersion

Constructor Details

OChannelBinaryAsynchClient

public OChannelBinaryAsynchClient(String remoteHost,
 int remotePort,
 OContextConfiguration config,
 OSocketFactory factory,
 int iProtocolVersion)
                           throws IOException

Throws:

IOException

Method Details

sendHandshake

protected void sendHandshake(int iProtocolVersion)
                      throws IOException

Throws:

IOException

waitResponse

public byte waitResponse()
                  throws IOException,
SocketException

Throws:

IOException

SocketException

endResponse

public void endResponse()
                 throws IOException

Throws:

IOException

endRequest

public void endRequest()
                throws IOException

Throws:

IOException

close

public void close()

Overrides:

close in class OChannelBinary

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

getServerURL

public String getServerURL()

tryLock

public boolean tryLock()

unlock

public void unlock()

getSocketTimeout

public int getSocketTimeout()

setSocketTimeout

public void setSocketTimeout(int socketTimeout)

getLastUse

public long getLastUse()

markReturned

public void markReturned()

markInUse

public void markInUse()

isInUse

public boolean isInUse()