Package com.orientechnologies.orient.server.distributed

Class ORemoteServerChannel

java.lang.Object

com.orientechnologies.orient.server.distributed.ORemoteServerChannel

public class ORemoteServerChannel
extends Object

Remote server channel.

Author:

Luca Garulli

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ORemoteServerChannel.ORemoteClientOperation<T>

Constructor Summary

Constructors

Constructor	Description
ORemoteServerChannel(ORemoteServerAvailabilityCheck check, ONodeId localNode, ONodeId iServer, String iURL, String user, String passwd, int currentProtocolVersion, ExecutorService exec)

Method Summary

Modifier and Type	Method	Description
void	beginRequest(OChannelDataOutput output, byte iCommand, int sessionId, byte[] token)
void	checkReconnect()
void	close()
void	connect()
Date	getCreatedOn()
int	getDistributedProtocolVersion()
ONodeId	getServer()
protected static int	handleStatus(byte iResult, int iClientTxId, OChannelDataInput input, int srvProtocolVersion)
protected <T> T	networkOperation(byte operationId, ORemoteServerChannel.ORemoteClientOperation<T> operation, String errorMessage, int maxRetry, boolean autoReconnect)
protected byte[]	readResponse(OChannelDataInput input, int srvProtocolVersion)
void	sendBinaryRequest(OBinaryRequest request)
void	sendConnect()
void	sendMessage(ONetworkMessage message)
void	sendRequest(ODistributedRequest request)
void	sendResponse(ODistributedResponse response)
protected static void	throwSerializedException(byte[] serializedException)

Methods inherited from class java.lang.Object

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

Constructor Details

ORemoteServerChannel

public ORemoteServerChannel(ORemoteServerAvailabilityCheck check,
 ONodeId localNode,
 ONodeId iServer,
 String iURL,
 String user,
 String passwd,
 int currentProtocolVersion,
 ExecutorService exec)

Method Details

connect

public void connect()

getDistributedProtocolVersion

public int getDistributedProtocolVersion()

sendBinaryRequest

public void sendBinaryRequest(OBinaryRequest request)

checkReconnect

public void checkReconnect()

sendMessage

public void sendMessage(ONetworkMessage message)

sendRequest

public void sendRequest(ODistributedRequest request)

sendResponse

public void sendResponse(ODistributedResponse response)

sendConnect

public void sendConnect()
                 throws IOException

Throws:

IOException

readResponse

protected byte[] readResponse(OChannelDataInput input,
 int srvProtocolVersion)
                       throws IOException

Throws:

IOException

close

public void close()

beginRequest

public void beginRequest(OChannelDataOutput output,
 byte iCommand,
 int sessionId,
 byte[] token)
                  throws IOException

Throws:

IOException

networkOperation

protected <T> T networkOperation(byte operationId,
 ORemoteServerChannel.ORemoteClientOperation<T> operation,
 String errorMessage,
 int maxRetry,
 boolean autoReconnect)

getServer

public ONodeId getServer()

getCreatedOn

public Date getCreatedOn()

handleStatus

protected static int handleStatus(byte iResult,
 int iClientTxId,
 OChannelDataInput input,
 int srvProtocolVersion)
                           throws IOException

Throws:

IOException

throwSerializedException

protected static void throwSerializedException(byte[] serializedException)
                                        throws IOException

Throws:

IOException