com.orientechnologies.orient.enterprise.channel.binary

Class OChannelBinaryAsynch

java.lang.Object

com.orientechnologies.orient.enterprise.channel.OChannel

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

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

Direct Known Subclasses:

OChannelBinaryClient

public class OChannelBinaryAsynch
extends OChannelBinary

Implementation that supports multiple client requests.

Author:

Luca Garulli (l.garulli--at--orientechnologies.com)

Field Summary

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
OChannelBinaryAsynch(Socket iSocket, OContextConfiguration iConfig)

Method Summary

Methods

Modifier and Type	Method and Description
void	beginRequest()
void	beginResponse(int iRequesterId)
void	beginResponse(int iRequesterId, long iTimeout)
void	clearInput()
void	close()
void	endRequest()
void	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

Constructor Detail

OChannelBinaryAsynch

public OChannelBinaryAsynch(Socket iSocket,
                    OContextConfiguration iConfig)
                     throws IOException

Throws:

IOException

Method Detail

beginRequest

public void beginRequest()

endRequest

public void endRequest()
                throws IOException

Throws:

IOException

beginResponse

public void beginResponse(int iRequesterId)
                   throws IOException

Throws:

IOException

beginResponse

public void beginResponse(int iRequesterId,
                 long iTimeout)
                   throws IOException

Throws:

IOException

endResponse

public void endResponse()

close

public void close()

Overrides:

close in class OChannelBinary

clearInput

public void clearInput()
                throws IOException

Overrides:

clearInput in class OChannelBinary

Throws:

IOException