Package com.gigaspaces.lrmi.nio

Class CPeer

java.lang.Object

com.j_spaces.kernel.pool.Resource

com.gigaspaces.lrmi.ConnectionResource

com.gigaspaces.lrmi.BaseClientPeer

com.gigaspaces.lrmi.nio.CPeer

All Implemented Interfaces:

ClientPeer, Peer, IResource

public class CPeer
extends BaseClientPeer

CPeer is the LRMI over NIO Client Peer.

Since:

4.0

Author:

Igor Goldenberg

Constructor Summary

Constructors

Constructor	Description
CPeer(PAdapter pAdapter, ClientHandler handler, ClientConversationRunner clientConversationRunner, PlatformLogicalVersion serviceVersion)

Method Summary

Modifier and Type	Method	Description
void	afterInvoke()
void	clearAsyncContext()
void	close()
void	connect(String connectionURL, LRMIMethod lrmiMethod)	Connects to the remote server peer.
void	connectAsync(String connectionURL, LRMIMethod lrmiMethod)
void	connectSync(String connectionURL, LRMIMethod lrmiMethod)
void	disable()
void	disconnect()	Disconnects, effectively closes the connection.
boolean	equals(Object obj)
AsyncContext	getAsyncContext()
SocketChannel	getChannel()
IClassProvider	getClassProvider()
static LongAdder	getConnectionsCounter()
long	getGeneratedTraffic()
LRMIMonitoringModule	getMonitoringModule()
Reader	getReader()
long	getReceivedTraffic()
PlatformLogicalVersion	getServiceVersion()
Writer	getWriter()
int	hashCode()
void	init(ITransportConfig config)
Object	invoke(Object proxy, LRMIMethod lrmiMethod, Object[] args, ConnectionPool connPool)	Invokes a method on the remote object this peer is connected to.
protected boolean	isClosed()
boolean	sendKeepAlive()	Sends a dummy one way request to the server - to check if it's alive
String	toString()

Methods inherited from class com.gigaspaces.lrmi.BaseClientPeer

finalize, getConnectionURL, getConnectRetries, getObjectId, getProtocolAdapter, isConnected, setConnected, setConnectionURL, setConnectRetries, setObjectId

Methods inherited from class com.gigaspaces.lrmi.ConnectionResource

clear

Methods inherited from class com.j_spaces.kernel.pool.Resource

acquire, isAcquired, isFromPool, release, setAcquired, setFromPool

Methods inherited from class java.lang.Object

clone, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

CPeer

public CPeer(PAdapter pAdapter,
 ClientHandler handler,
 ClientConversationRunner clientConversationRunner,
 PlatformLogicalVersion serviceVersion)

Method Details

getConnectionsCounter

public static LongAdder getConnectionsCounter()

init

public void init(ITransportConfig config)

getMonitoringModule

public LRMIMonitoringModule getMonitoringModule()

Specified by:

getMonitoringModule in class ConnectionResource

connect

public void connect(String connectionURL,
 LRMIMethod lrmiMethod)
             throws MalformedURLException,
RemoteException

Description copied from interface: ClientPeer

Connects to the remote server peer.

Parameters:

connectionURL - usually of the form ://:/<remote-object-id-string>

Throws:

MalformedURLException - if the URL is not understood by the implementation

RemoteException

connectAsync

public void connectAsync(String connectionURL,
 LRMIMethod lrmiMethod)
                  throws MalformedURLException,
RemoteException

Throws:

MalformedURLException

RemoteException

connectSync

public void connectSync(String connectionURL,
 LRMIMethod lrmiMethod)
                 throws MalformedURLException,
RemoteException

Throws:

MalformedURLException

RemoteException

close

public void close()

Specified by:

close in class ConnectionResource

isClosed

protected boolean isClosed()

Specified by:

isClosed in class ConnectionResource

disconnect

public void disconnect()

Description copied from interface: Peer

Disconnects, effectively closes the connection.

getReader

public Reader getReader()

getChannel

public SocketChannel getChannel()

getWriter

public Writer getWriter()

afterInvoke

public void afterInvoke()

getClassProvider

public IClassProvider getClassProvider()

invoke

public Object invoke(Object proxy,
 LRMIMethod lrmiMethod,
 Object[] args,
 ConnectionPool connPool)
              throws ApplicationException,
ProtocolException,
RemoteException,
InterruptedException

Description copied from interface: ClientPeer

Invokes a method on the remote object this peer is connected to. This method should propagate the methodName, arguments and security context associated with this peer (if exists), in a protocol specific format to the remote server peer, and return the result to the caller.

lrmiMethod - contains necessary information about invocation remote call

args - arguments to the method

Throws:

ProtocolException - a result of a remote method invocation is thrown while unmarshalling the arguments or de/serialization request/reply packet.

RemoteException - failed to open/close connection with remote endpoint.

ApplicationException

InterruptedException

getGeneratedTraffic

public long getGeneratedTraffic()

Specified by:

getGeneratedTraffic in class ConnectionResource

getReceivedTraffic

public long getReceivedTraffic()

Specified by:

getReceivedTraffic in class ConnectionResource

disable

public void disable()

Specified by:

disable in class ConnectionResource

sendKeepAlive

public boolean sendKeepAlive()

Sends a dummy one way request to the server - to check if it's alive

Returns:

true if keep alive was sent successfully

getServiceVersion

public PlatformLogicalVersion getServiceVersion()

getAsyncContext

public AsyncContext getAsyncContext()

clearAsyncContext

public void clearAsyncContext()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object