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

Direct Known Subclasses:

OChannelBinaryAsynchClientSynch

public class OChannelBinaryAsynchClient
extends OChannelBinary

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)
OChannelBinaryAsynchClient(String remoteHost, int remotePort, String iDatabaseName, OContextConfiguration iConfig, int protocolVersion, ORemoteServerEventListener asynchEventListener)

Method Summary

Modifier and Type	Method and Description
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	endResponse()
String	getServerURL()
OAsynchChannelServiceThread	getServiceThread()
int	getSocketTimeout()
short	getSrvProtocolVersion() Gets the major supported protocol version
protected int	handleStatus(byte iResult, int iClientTxId)
boolean	isConnected() Tells if the channel is connected.
void	setSocketTimeout(int socketTimeout)
boolean	tryLock()
void	unlock()

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

drain, flush, getDataInput, getDataOutput, readBoolean, readByte, readBytes, readInt, readLong, readRID, readShort, readString, readVersion, 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

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

OChannelBinaryAsynchClient

public OChannelBinaryAsynchClient(String remoteHost,
                                  int remotePort,
                                  String iDatabaseName,
                                  OContextConfiguration iConfig,
                                  int protocolVersion,
                                  ORemoteServerEventListener asynchEventListener)
                           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

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

getServiceThread

public OAsynchChannelServiceThread getServiceThread()

handleStatus

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

Throws:

IOException

beginRequest

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

Throws:

IOException

getSocketTimeout

public int getSocketTimeout()

setSocketTimeout

public void setSocketTimeout(int socketTimeout)