Package com.orientechnologies.orient.enterprise.channel.binary

Class OChannelBinary

java.lang.Object

com.orientechnologies.orient.enterprise.channel.OChannel

com.orientechnologies.orient.enterprise.channel.binary.OChannelBinary

Direct Known Subclasses:

OChannelBinaryAsynchClient, OChannelBinaryServer, OChannelBinarySynchClient

public abstract class OChannelBinary
extends OChannel

Abstract representation of a channel.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	OChannelBinary.WrapStreams

Field Summary

Fields

Modifier and Type	Field	Description
protected final boolean	debug
protected DataInputStream	in
protected OChannelDataInput	inChannel
protected final int	maxChunkSize
protected DataOutputStream	out
protected OChannelDataOutput	outChannel

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

inStream, outStream, socket, socketBufferSize

Constructor Summary

Constructors

Constructor	Description
OChannelBinary(Socket socket, OContextConfiguration config)

Method Summary

Modifier and Type	Method	Description
void	clearInput()
void	close()
void	flush()
OChannelDataInput	getChannelDataInput()
OChannelDataOutput	getChannelDataOutput()
DataInputStream	getDataInput()
DataOutputStream	getDataOutput()
void	initChannels(OChannelBinary.WrapStreams stre)
protected void	initDebug()
void	setReadRequestTimeout()
void	setWaitRequestTimeout()
void	setWaitResponseTimeout()

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

acquireReadLock, acquireWriteLock, connected, getLocalIpAddress, getLockWrite, releaseReadLock, releaseWriteLock, toString, tryAcquireWriteLock, updateMetricFlushes, updateMetricReceivedBytes, updateMetricTransmittedBytes

Methods inherited from class java.lang.Object

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

Field Details

debug

protected final boolean debug

maxChunkSize

protected final int maxChunkSize

in

protected DataInputStream in

out

protected DataOutputStream out

inChannel

protected OChannelDataInput inChannel

outChannel

protected OChannelDataOutput outChannel

Constructor Details

OChannelBinary

public OChannelBinary(Socket socket,
 OContextConfiguration config)
               throws IOException

Throws:

IOException

Method Details

initDebug

protected void initDebug()

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

setWaitResponseTimeout

public void setWaitResponseTimeout()
                            throws SocketException

Throws:

SocketException

setWaitRequestTimeout

public void setWaitRequestTimeout()
                           throws SocketException

Throws:

SocketException

setReadRequestTimeout

public void setReadRequestTimeout()
                           throws SocketException

Throws:

SocketException

getChannelDataInput

public OChannelDataInput getChannelDataInput()

getChannelDataOutput

public OChannelDataOutput getChannelDataOutput()

initChannels

public void initChannels(OChannelBinary.WrapStreams stre)
                  throws IOException

Throws:

IOException