com.orientechnologies.orient.enterprise.channel.binary

Class OChannelBinary

java.lang.Object

com.orientechnologies.common.listener.OListenerManger<OChannelListener>

com.orientechnologies.orient.enterprise.channel.OChannel

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

All Implemented Interfaces:

OChannelDataInput, OChannelDataOutput

Direct Known Subclasses:

OChannelBinaryAsynchClient, OChannelBinaryClientAbstract, OChannelBinaryServer

public abstract class OChannelBinary
extends OChannel
implements OChannelDataInput, OChannelDataOutput

Abstract representation of a channel.

Author:

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

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, outStream, socket, socketBufferSize, timeout

Constructor Summary

Constructors

Constructor and Description
OChannelBinary(Socket iSocket, OContextConfiguration iConfig)

Method Summary

Modifier and Type	Method and Description
void	clearInput()
void	close()
void	flush()
DataInputStream	getDataInput()
DataOutputStream	getDataOutput()
boolean	readBoolean()
byte	readByte()
byte[]	readBytes()
int	readInt()
long	readLong()
ORecordId	readRID()
short	readShort()
String	readString()
int	readVersion()
void	setReadRequestTimeout()
void	setWaitRequestTimeout()
void	setWaitResponseTimeout()
OChannelBinary	writeBoolean(boolean iContent)
OChannelBinary	writeByte(byte iContent)
OChannelBinary	writeBytes(byte[] iContent)
OChannelBinary	writeBytes(byte[] iContent, int iLength)
OChannelBinary	writeInt(int iContent)
OChannelBinary	writeLong(long iContent)
void	writeRID(ORID iRID)
OChannelBinary	writeShort(short iContent)
OChannelBinary	writeString(String iContent)
void	writeVersion(int version)

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

debug

protected final boolean debug

in

public DataInputStream in

out

public DataOutputStream out

Constructor Detail

OChannelBinary

public OChannelBinary(Socket iSocket,
                      OContextConfiguration iConfig)
               throws IOException

Throws:

IOException

Method Detail

readByte

public byte readByte()
              throws IOException

Specified by:

readByte in interface OChannelDataInput

Throws:

IOException

readBoolean

public boolean readBoolean()
                    throws IOException

Specified by:

readBoolean in interface OChannelDataInput

Throws:

IOException

readInt

public int readInt()
            throws IOException

Specified by:

readInt in interface OChannelDataInput

Throws:

IOException

readLong

public long readLong()
              throws IOException

Specified by:

readLong in interface OChannelDataInput

Throws:

IOException

readShort

public short readShort()
                throws IOException

Specified by:

readShort in interface OChannelDataInput

Throws:

IOException

readString

public String readString()
                  throws IOException

Specified by:

readString in interface OChannelDataInput

Throws:

IOException

readBytes

public byte[] readBytes()
                 throws IOException

Specified by:

readBytes in interface OChannelDataInput

Throws:

IOException

readRID

public ORecordId readRID()
                  throws IOException

Specified by:

readRID in interface OChannelDataInput

Throws:

IOException

readVersion

public int readVersion()
                throws IOException

Specified by:

readVersion in interface OChannelDataInput

Throws:

IOException

writeByte

public OChannelBinary writeByte(byte iContent)
                         throws IOException

Specified by:

writeByte in interface OChannelDataOutput

Throws:

IOException

writeBoolean

public OChannelBinary writeBoolean(boolean iContent)
                            throws IOException

Specified by:

writeBoolean in interface OChannelDataOutput

Throws:

IOException

writeInt

public OChannelBinary writeInt(int iContent)
                        throws IOException

Specified by:

writeInt in interface OChannelDataOutput

Throws:

IOException

writeLong

public OChannelBinary writeLong(long iContent)
                         throws IOException

Specified by:

writeLong in interface OChannelDataOutput

Throws:

IOException

writeShort

public OChannelBinary writeShort(short iContent)
                          throws IOException

Specified by:

writeShort in interface OChannelDataOutput

Throws:

IOException

writeString

public OChannelBinary writeString(String iContent)
                           throws IOException

Specified by:

writeString in interface OChannelDataOutput

Throws:

IOException

writeBytes

public OChannelBinary writeBytes(byte[] iContent)
                          throws IOException

Specified by:

writeBytes in interface OChannelDataOutput

Throws:

IOException

writeBytes

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

Specified by:

writeBytes in interface OChannelDataOutput

Throws:

IOException

writeRID

public void writeRID(ORID iRID)
              throws IOException

Specified by:

writeRID in interface OChannelDataOutput

Throws:

IOException

writeVersion

public void writeVersion(int version)
                  throws IOException

Specified by:

writeVersion in interface OChannelDataOutput

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

getDataOutput

public DataOutputStream getDataOutput()

Specified by:

getDataOutput in interface OChannelDataOutput

getDataInput

public DataInputStream getDataInput()

Specified by:

getDataInput in interface OChannelDataInput

setWaitResponseTimeout

public void setWaitResponseTimeout()
                            throws SocketException

Throws:

SocketException

setWaitRequestTimeout

public void setWaitRequestTimeout()
                           throws SocketException

Throws:

SocketException

setReadRequestTimeout

public void setReadRequestTimeout()
                           throws SocketException

Throws:

SocketException