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

Direct Known Subclasses:

OChannelBinaryAsynchClient, OChannelBinaryClientAbstract, OChannelBinaryServer

public abstract class OChannelBinary
extends OChannel

Abstract representation of a channel.

Author:

Luca Garulli

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	drain()
void	flush()
DataInputStream	getDataInput()
DataOutputStream	getDataOutput()
boolean	readBoolean()
byte	readByte()
byte[]	readBytes()
int	readInt()
long	readLong()
ORecordId	readRID()
short	readShort()
String	readString()
int	readVersion()
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

Throws:

IOException

readBoolean

public boolean readBoolean()
                    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

readRID

public ORecordId readRID()
                  throws IOException

Throws:

IOException

readVersion

public int readVersion()
                throws IOException

Throws:

IOException

writeByte

public OChannelBinary writeByte(byte iContent)
                         throws IOException

Throws:

IOException

writeBoolean

public OChannelBinary writeBoolean(boolean 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

writeRID

public void writeRID(ORID iRID)
              throws IOException

Throws:

IOException

writeVersion

public void writeVersion(int 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

getDataOutput

public DataOutputStream getDataOutput()

getDataInput

public DataInputStream getDataInput()

drain

public void drain()
           throws IOException

Throws:

IOException