Package com.orientechnologies.orient.server.network.protocol.binary

Class ONetworkProtocolBinary

java.lang.Object

java.lang.Thread

com.orientechnologies.common.thread.OSoftThread

com.orientechnologies.orient.server.network.protocol.ONetworkProtocol

com.orientechnologies.orient.server.network.protocol.binary.ONetworkProtocolBinary

All Implemented Interfaces:

OService, Runnable

public class ONetworkProtocolBinary
extends ONetworkProtocol

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected OChannelBinary	channel
protected int	clientTxId
protected OLogger.Level	logClientExceptions
protected final boolean	logClientFullStackTrace
protected boolean	okSent
protected int	requestType

Fields inherited from class com.orientechnologies.orient.server.network.protocol.ONetworkProtocol

server

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ONetworkProtocolBinary(OServer server)
ONetworkProtocolBinary(OServer server, String iThreadName)

Method Summary

Modifier and Type	Method	Description
protected void	afterOperationRequest(OClientConnection connection)
protected void	beginResponse()
protected void	checkServerAccess(String iResource, OClientConnection connection)
void	config(OServerNetworkListener iListener, OServer iServer, Socket iSocket, OContextConfiguration iConfig)
protected void	endResponse()
protected void	execute()
OBinaryRequestExecutor	executor(OClientConnection connection)
OChannelBinary	getChannel()
static byte[]	getRecordBytes(OClientConnection connection, ORecord iRecord)
static String	getRecordSerializerName(OClientConnection connection)
String	getRemoteAddress()
int	getRequestType()
String	getType()
int	getVersion()
protected void	handleConnectionError(OClientConnection connection, Throwable e)
void	initVariables(OServer server, OChannelBinary channel)	Internal varialbe injection useful for testing.
OBinaryPushResponse	push(OBinaryPushRequest request)
protected void	sendError(OClientConnection connection, int iClientTxId, Throwable t)
protected void	sendErrorOrDropConnection(OClientConnection connection, int iClientTxId, Throwable t)
protected void	sendOk(OClientConnection connection, int iClientTxId)
protected void	setDataCommandInfo(OClientConnection connection, String iCommandInfo)
void	setHandshakeInfo(HandshakeInfo handshakeInfo)
boolean	shouldReadToken(OClientConnection connection, int requestType)
void	shutdown()
void	startup()
protected static int	trimCsvSerializedContent(OClientConnection connection, byte[] stream)
static void	writeIdentifiable(OChannelBinary channel, OClientConnection connection, OIdentifiable o)	Write a OIdentifiable instance using this format: - 2 bytes: class id [-2=no record, -3=rid, -1=no class id, > -1 = valid] - 1 byte: record type [d,b,f] - 2 bytes: cluster id - 8 bytes: position in cluster - 4 bytes: record version - x bytes: record content

Methods inherited from class com.orientechnologies.orient.server.network.protocol.ONetworkProtocol

getListeningAddress, getServer

Methods inherited from class com.orientechnologies.common.thread.OSoftThread

afterExecution, beforeExecution, isShutdownFlag, run, sendShutdown, setDumpExceptions, softShutdown

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.common.util.OService

getName

Field Details

logClientExceptions

protected OLogger.Level logClientExceptions

logClientFullStackTrace

protected final boolean logClientFullStackTrace

channel

protected OChannelBinary channel

requestType

protected volatile int requestType

clientTxId

protected int clientTxId

okSent

protected boolean okSent

Constructor Details

ONetworkProtocolBinary

public ONetworkProtocolBinary(OServer server)

ONetworkProtocolBinary

public ONetworkProtocolBinary(OServer server,
 String iThreadName)

Method Details

initVariables

public void initVariables(OServer server,
 OChannelBinary channel)

Internal varialbe injection useful for testing.

config

public void config(OServerNetworkListener iListener,
 OServer iServer,
 Socket iSocket,
 OContextConfiguration iConfig)
            throws IOException

Specified by:

config in class ONetworkProtocol

Throws:

IOException

startup

public void startup()

Specified by:

startup in interface OService

Overrides:

startup in class OSoftThread

shutdown

public void shutdown()

Specified by:

shutdown in interface OService

Overrides:

shutdown in class OSoftThread

execute

protected void execute()
                throws Exception

Specified by:

execute in class OSoftThread

Throws:

Exception

setHandshakeInfo

public void setHandshakeInfo(HandshakeInfo handshakeInfo)

shouldReadToken

public boolean shouldReadToken(OClientConnection connection,
 int requestType)

afterOperationRequest

protected void afterOperationRequest(OClientConnection connection)

checkServerAccess

protected void checkServerAccess(String iResource,
 OClientConnection connection)

sendError

protected void sendError(OClientConnection connection,
 int iClientTxId,
 Throwable t)
                  throws IOException

Throws:

IOException

beginResponse

protected void beginResponse()

endResponse

protected void endResponse()
                    throws IOException

Throws:

IOException

setDataCommandInfo

protected void setDataCommandInfo(OClientConnection connection,
 String iCommandInfo)

sendOk

protected void sendOk(OClientConnection connection,
 int iClientTxId)
               throws IOException

Throws:

IOException

handleConnectionError

protected void handleConnectionError(OClientConnection connection,
 Throwable e)

getRecordSerializerName

public static String getRecordSerializerName(OClientConnection connection)

getVersion

public int getVersion()

Specified by:

getVersion in class ONetworkProtocol

getChannel

public OChannelBinary getChannel()

Specified by:

getChannel in class ONetworkProtocol

writeIdentifiable

public static void writeIdentifiable(OChannelBinary channel,
 OClientConnection connection,
 OIdentifiable o)
                              throws IOException

Write a OIdentifiable instance using this format:
- 2 bytes: class id [-2=no record, -3=rid, -1=no class id, > -1 = valid]
- 1 byte: record type [d,b,f]
- 2 bytes: cluster id
- 8 bytes: position in cluster
- 4 bytes: record version
- x bytes: record content

Parameters:

channel - TODO

Throws:

IOException

getType

public String getType()

Specified by:

getType in class ONetworkProtocol

sendErrorOrDropConnection

protected void sendErrorOrDropConnection(OClientConnection connection,
 int iClientTxId,
 Throwable t)
                                  throws IOException

Throws:

IOException

getRecordBytes

public static byte[] getRecordBytes(OClientConnection connection,
 ORecord iRecord)

trimCsvSerializedContent

protected static int trimCsvSerializedContent(OClientConnection connection,
 byte[] stream)

getRequestType

public int getRequestType()

getRemoteAddress

public String getRemoteAddress()

executor

public OBinaryRequestExecutor executor(OClientConnection connection)

Specified by:

executor in class ONetworkProtocol

push

public OBinaryPushResponse push(OBinaryPushRequest request)
                         throws IOException

Throws:

IOException