com.orientechnologies.orient.enterprise.channel.text

Class OChannelText

java.lang.Object

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

com.orientechnologies.orient.enterprise.channel.OChannel

com.orientechnologies.orient.enterprise.channel.text.OChannelText

Direct Known Subclasses:

OChannelTextServer

public class OChannelText
extends OChannel

Field Summary

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

inStream, outStream, socket, socketBufferSize, timeout

Constructor Summary

Constructors

Constructor and Description
OChannelText(Socket iSocket, OContextConfiguration iConfig)

Method Summary

Modifier and Type	Method and Description
byte	read()
int	read(byte[] iBuffer, int iStartingPosition, int iContentLength)
byte[]	readBytes(int iTotal)
OChannelText	writeBytes(byte[] iContent)

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

acquireReadLock, acquireWriteLock, close, connected, flush, getLocalIpAddress, 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

Constructor Detail

OChannelText

public OChannelText(Socket iSocket,
                    OContextConfiguration iConfig)
             throws IOException

Throws:

IOException

Method Detail

read

public int read(byte[] iBuffer,
                int iStartingPosition,
                int iContentLength)
         throws IOException

Parameters:

iBuffer - byte[] to fill

iStartingPosition - Offset to start to fill the buffer

iContentLength - Length of expected content to read

Returns:

total of bytes read

Throws:

IOException

read

public byte read()
          throws IOException

Throws:

IOException

readBytes

public byte[] readBytes(int iTotal)
                 throws IOException

Throws:

IOException

writeBytes

public OChannelText writeBytes(byte[] iContent)
                        throws IOException

Throws:

IOException