com.orientechnologies.orient.enterprise.channel.binary

Class OChannelBinary

java.lang.Object

com.orientechnologies.orient.enterprise.channel.OChannel

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

Direct Known Subclasses:

OChannelBinaryAsynch, OChannelBinaryServer

public abstract class OChannelBinary
extends OChannel

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	debug
DataInputStream	in
DataOutputStream	out

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

inStream, lockRead, lockWrite, outStream, socket, socketBufferSize, timeout

Constructor Summary

Constructors

Constructor and Description
OChannelBinary(Socket iSocket, OContextConfiguration iConfig)

Method Summary

Methods

Modifier and Type	Method and Description
void	clearInput()
void	close()
void	flush()
byte[]	getBuffer()
int	getMaxChunkSize()
protected int	handleStatus(byte iResult, int iClientTxId)
byte	readByte()
byte[]	readBytes()
OClusterPosition	readClusterPosition()
int	readInt()
long	readLong()
ORecordId	readRID()
short	readShort()
int	readStatus()
String	readString()
List<String>	readStringList()
Set<String>	readStringSet()
ORecordVersion	readVersion()
OChannelBinary	writeByte(byte iContent)
OChannelBinary	writeBytes(byte[] iContent)
OChannelBinary	writeBytes(byte[] iContent, int iLength)
OChannelBinary	writeClusterPosition(OClusterPosition clusterPosition)
OChannelBinary	writeCollectionString(Collection<String> iCollection)
OChannelBinary	writeInt(int iContent)
OChannelBinary	writeLong(long iContent)
void	writeRID(ORID iRID)
OChannelBinary	writeShort(short iContent)
OChannelBinary	writeString(String iContent)
void	writeVersion(ORecordVersion version)

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

Field Detail

in

public DataInputStream in

out

public DataOutputStream out

debug

protected final boolean debug

Constructor Detail

OChannelBinary

public OChannelBinary(Socket iSocket,
              OContextConfiguration iConfig)
               throws IOException

Throws:

IOException

Method Detail

readByte

public byte readByte()
              throws IOException

Throws:

IOException

readInt

public int readInt()
            throws IOException

Throws:

IOException

readLong

public long readLong()
              throws IOException

Throws:

IOException

readShort

public short readShort()
                throws IOException

Throws:

IOException

readString

public String readString()
                  throws IOException

Throws:

IOException

readBytes

public byte[] readBytes()
                 throws IOException

Throws:

IOException

readStringList

public List<String> readStringList()
                            throws IOException

Throws:

IOException

readStringSet

public Set<String> readStringSet()
                          throws IOException

Throws:

IOException

readRID

public ORecordId readRID()
                  throws IOException

Throws:

IOException

readClusterPosition

public OClusterPosition readClusterPosition()
                                     throws IOException

Throws:

IOException

writeClusterPosition

public OChannelBinary writeClusterPosition(OClusterPosition clusterPosition)
                                    throws IOException

Throws:

IOException

readVersion

public ORecordVersion readVersion()
                           throws IOException

Throws:

IOException

writeByte

public OChannelBinary writeByte(byte iContent)
                         throws IOException

Throws:

IOException

writeInt

public OChannelBinary writeInt(int iContent)
                        throws IOException

Throws:

IOException

writeLong

public OChannelBinary writeLong(long iContent)
                         throws IOException

Throws:

IOException

writeShort

public OChannelBinary writeShort(short iContent)
                          throws IOException

Throws:

IOException

writeString

public OChannelBinary writeString(String iContent)
                           throws IOException

Throws:

IOException

writeBytes

public OChannelBinary writeBytes(byte[] iContent)
                          throws IOException

Throws:

IOException

writeBytes

public OChannelBinary writeBytes(byte[] iContent,
                        int iLength)
                          throws IOException

Throws:

IOException

writeCollectionString

public OChannelBinary writeCollectionString(Collection<String> iCollection)
                                     throws IOException

Throws:

IOException

writeRID

public void writeRID(ORID iRID)
              throws IOException

Throws:

IOException

writeVersion

public void writeVersion(ORecordVersion version)
                  throws IOException

Throws:

IOException

clearInput

public void clearInput()
                throws IOException

Throws:

IOException

flush

public void flush()
           throws IOException

Overrides:

flush in class OChannel

Throws:

IOException

close

public void close()

Overrides:

close in class OChannel

readStatus

public int readStatus()
               throws IOException

Throws:

IOException

handleStatus

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

Throws:

IOException

getBuffer

public byte[] getBuffer()

getMaxChunkSize

public int getMaxChunkSize()