com.orientechnologies.orient.enterprise.channel

Class OChannel

java.lang.Object

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

com.orientechnologies.orient.enterprise.channel.OChannel

Direct Known Subclasses:

OChannelBinary, OChannelText

public abstract class OChannel
extends OListenerManger<OChannelListener>

Field Summary

Fields

Modifier and Type	Field and Description
InputStream	inStream
OutputStream	outStream
Socket	socket
int	socketBufferSize
protected long	timeout

Constructor Summary

Constructors

Constructor and Description
OChannel(Socket iSocket, OContextConfiguration iConfig)

Method Summary

Modifier and Type	Method and Description
void	acquireReadLock()
void	acquireWriteLock()
void	close()
void	connected()
void	flush()
static String	getLocalIpAddress(boolean iFavoriteIp4)
String	getLocalSocketAddress()
OAdaptiveLock	getLockRead()
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 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

socket

public volatile Socket socket

inStream

public InputStream inStream

outStream

public OutputStream outStream

socketBufferSize

public int socketBufferSize

timeout

protected long timeout

Constructor Detail

OChannel

public OChannel(Socket iSocket,
                OContextConfiguration iConfig)
         throws IOException

Throws:

IOException

Method Detail

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

getLockRead

public OAdaptiveLock getLockRead()

getLockWrite

public OAdaptiveLock getLockWrite()

close

public void close()

connected

public void connected()

toString

public String toString()

Overrides:

toString in class Object

getLocalSocketAddress

public String getLocalSocketAddress()

updateMetricTransmittedBytes

protected void updateMetricTransmittedBytes(int iDelta)

updateMetricReceivedBytes

protected void updateMetricReceivedBytes(int iDelta)

updateMetricFlushes

protected void updateMetricFlushes()