com.orientechnologies.orient.client.binary

Class OChannelBinaryAsynchClient

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.OChannelBinaryAsynchClient

All Implemented Interfaces:

OChannelDataInput, OChannelDataOutput

public class OChannelBinaryAsynchClient
extends OChannelBinary

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	OChannelBinaryAsynchClient.ExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected short	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
OChannelBinaryAsynchClient(String remoteHost, int remotePort, String iDatabaseName, OContextConfiguration iConfig, int iProtocolVersion)

Method Summary

Modifier and Type	Method and Description
void	beginRequest(byte iCommand, OStorageRemoteNodeSession nodeSession)
void	beginRequest(byte iCommand, OStorageRemoteSession session)
byte[]	beginResponse(int iRequesterId, boolean token)
byte[]	beginResponse(int iRequesterId, long iTimeout, boolean token)
void	clearInput()
void	close()
void	endRequest()
void	endResponse()
long	getLastUse()
String	getServerURL()
int	getSocketTimeout()
short	getSrvProtocolVersion() Gets the major supported protocol version
void	handleException(Throwable throwable)
int	handleStatus(byte iResult, int iClientTxId)
int	handleStatus(byte iResult, int iClientTxId, OChannelBinaryAsynchClient.ExceptionHandler exceptionHandler)
boolean	isConnected() Tells if the channel is connected.
boolean	isInUse()
void	markInUse()
void	markReturned()
void	setSocketTimeout(int socketTimeout)
boolean	tryLock()
void	unlock()

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

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, 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

Field Detail

srvProtocolVersion

protected final short srvProtocolVersion

Constructor Detail

OChannelBinaryAsynchClient

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

Throws:

IOException

Method Detail

beginResponse

public byte[] beginResponse(int iRequesterId,
                            boolean token)
                     throws IOException

Throws:

IOException

beginResponse

public byte[] beginResponse(int iRequesterId,
                            long iTimeout,
                            boolean token)
                     throws IOException

Throws:

IOException

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()

handleStatus

public int handleStatus(byte iResult,
                        int iClientTxId,
                        OChannelBinaryAsynchClient.ExceptionHandler exceptionHandler)
                 throws IOException

Throws:

IOException

handleStatus

public int handleStatus(byte iResult,
                        int iClientTxId)
                 throws IOException

Throws:

IOException

handleException

public void handleException(Throwable throwable)

beginRequest

public void beginRequest(byte iCommand,
                         OStorageRemoteSession session)
                  throws IOException

Throws:

IOException

beginRequest

public void beginRequest(byte iCommand,
                         OStorageRemoteNodeSession nodeSession)
                  throws IOException

Throws:

IOException

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()