com.orientechnologies.orient.enterprise.channel

Class OChannel

java.lang.Object

com.orientechnologies.orient.enterprise.channel.OChannel

Direct Known Subclasses:

OChannelBinary, OChannelText

public abstract class OChannel
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
InputStream	inStream
protected com.orientechnologies.common.concur.resource.OAdaptiveLock	lockRead
protected com.orientechnologies.common.concur.resource.OAdaptiveLock	lockWrite
OutputStream	outStream
Socket	socket
int	socketBufferSize
protected long	timeout

Constructor Summary

Constructors

Constructor and Description
OChannel(Socket iSocket, OContextConfiguration iConfig)

Method Summary

Methods

Modifier and Type	Method and Description
void	acquireReadLock()
void	acquireWriteLock()
void	close()
void	connected()
void	flush()
void	releaseReadLock()
void	releaseWriteLock()
String	toString()
protected void	updateMetricFlushes()
protected void	updateMetricReceivedBytes(int iDelta)
protected void	updateMetricTransmittedBytes(int iDelta)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

socket

public Socket socket

inStream

public InputStream inStream

outStream

public OutputStream outStream

lockRead

protected final com.orientechnologies.common.concur.resource.OAdaptiveLock lockRead

lockWrite

protected final com.orientechnologies.common.concur.resource.OAdaptiveLock lockWrite

timeout

protected long timeout

socketBufferSize

public int socketBufferSize

Constructor Detail

OChannel

public OChannel(Socket iSocket,
        OContextConfiguration iConfig)
         throws IOException

Throws:

IOException

Method Detail

acquireWriteLock

public void acquireWriteLock()

releaseWriteLock

public void releaseWriteLock()

acquireReadLock

public void acquireReadLock()

releaseReadLock

public void releaseReadLock()

flush

public void flush()
           throws IOException

Throws:

IOException

close

public void close()

connected

public void connected()

toString

public String toString()

Overrides:

toString in class Object

updateMetricTransmittedBytes

protected void updateMetricTransmittedBytes(int iDelta)

updateMetricReceivedBytes

protected void updateMetricReceivedBytes(int iDelta)

updateMetricFlushes

protected void updateMetricFlushes()