Package 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	Description
InputStream	inStream
OutputStream	outStream
Socket	socket
int	socketBufferSize
protected long	timeout

Constructor Summary

Constructors

Constructor	Description
OChannel(Socket iSocket, OContextConfiguration iConfig)

Method Summary

Modifier and Type	Method	Description
void	acquireReadLock()
void	acquireWriteLock()
void	close()
void	connected()
void	flush()
static String	getLocalIpAddress(boolean iFavoriteIp4)
OAdaptiveLock	getLockWrite()
void	releaseReadLock()
void	releaseWriteLock()
String	toString()
boolean	tryAcquireWriteLock(long iTimeout)
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 Details

socket

public volatile Socket socket

inStream

public InputStream inStream

outStream

public OutputStream outStream

socketBufferSize

public int socketBufferSize

timeout

protected long timeout

Constructor Details

OChannel

public OChannel(Socket iSocket,
 OContextConfiguration iConfig)
         throws IOException

Throws:

IOException

Method Details

getLocalIpAddress

public static String getLocalIpAddress(boolean iFavoriteIp4)
                                throws SocketException

Throws:

SocketException

acquireWriteLock

public void acquireWriteLock()

tryAcquireWriteLock

public boolean tryAcquireWriteLock(long iTimeout)

releaseWriteLock

public void releaseWriteLock()

acquireReadLock

public void acquireReadLock()

releaseReadLock

public void releaseReadLock()

flush

public void flush()
           throws IOException

Throws:

IOException

getLockWrite

public OAdaptiveLock getLockWrite()

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()