com.gigaspaces.lrmi.nio

Class PAdapter

java.lang.Object

com.gigaspaces.lrmi.nio.PAdapter

All Implemented Interfaces:

ProtocolAdapter<CPeer>

public class PAdapter
extends Object
implements ProtocolAdapter<CPeer>

An NIO based implementation of LRMI Protocol Adapter The basic design is as follows: There will be a single 'pivot' object at the server side, that will act as a local proxy for all server peers in the server JVM. The pivot is in charge of all connection management and invocation dispatching. See Pivot documentation for more details.

Since:

4.0

Author:

Igor Goldenberg

Nested Class Summary

Nested classes/interfaces inherited from interface com.gigaspaces.lrmi.ProtocolAdapter

ProtocolAdapter.Side

Constructor Summary

Constructors

Constructor and Description
PAdapter()

Method Summary

Modifier and Type	Method and Description
int	countRemoteObjectConnections(long objectId)
InetSocketAddress	getBindInetSocketAddress()
IClassProvider	getClassProvider()
ClientPeerInvocationHandler	getClientInvocationHandler(String connectionURL, ITransportConfig config, PlatformLogicalVersion serviceVersion) Returns the remote method invocation handler ClientPeerInvocationHandler which represents remote object specified by the supplied c and connection URL.
CPeer	getClientPeer(PlatformLogicalVersion serviceVersion) Returns an un-connected client peer.
String	getHostName()
LRMIMonitoringDetailsImpl	getMonitoringDetails()
String	getName() Returns the unique name of this protocol adapter.
Pivot	getPivot()
int	getPort()
List<ITransportConnection>	getRemoteObjectConnectionsList(long objectId)
void	init(ITransportConfig config, ProtocolAdapter.Side initSide) Initializes the protocol adapter according to the supplied properties.
ServerPeer	newServerPeer(long objectId, ClassLoader objectClassLoader, String serviceDetails) Construct and returns a server peer for the specified object id.
void	shutdown() Shutdown this Protocol Adapter, freeing excess resources.

Methods inherited from class java.lang.Object

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

Constructor Detail

PAdapter

public PAdapter()

Method Detail

init

public void init(ITransportConfig config,
                 ProtocolAdapter.Side initSide)
          throws RemoteException,
                 ConfigurationException

Description copied from interface: ProtocolAdapter

Initializes the protocol adapter according to the supplied properties.

Specified by:

init in interface ProtocolAdapter<CPeer>

Throws:

RemoteException - if init. failed.

ConfigurationException

getClassProvider

public IClassProvider getClassProvider()

Specified by:

getClassProvider in interface ProtocolAdapter<CPeer>

getPort

public int getPort()

Specified by:

getPort in interface ProtocolAdapter<CPeer>

getHostName

public String getHostName()

Specified by:

getHostName in interface ProtocolAdapter<CPeer>

getName

public String getName()

Description copied from interface: ProtocolAdapter

Returns the unique name of this protocol adapter.

Specified by:

getName in interface ProtocolAdapter<CPeer>

Returns:

the unique name of this protocol adapter.

getBindInetSocketAddress

public InetSocketAddress getBindInetSocketAddress()

Returns:

the INetSocketAddress this ProtocolAdapter bind to.

getClientPeer

public CPeer getClientPeer(PlatformLogicalVersion serviceVersion)

Description copied from interface: ProtocolAdapter

Returns an un-connected client peer.

Specified by:

getClientPeer in interface ProtocolAdapter<CPeer>

newServerPeer

public ServerPeer newServerPeer(long objectId,
                                ClassLoader objectClassLoader,
                                String serviceDetails)

Description copied from interface: ProtocolAdapter

Construct and returns a server peer for the specified object id.

Specified by:

newServerPeer in interface ProtocolAdapter<CPeer>

Parameters:

objectId - The exported remote objectId.

objectClassLoader - the exported object class loader

getPivot

public Pivot getPivot()

shutdown

public void shutdown()

Description copied from interface: ProtocolAdapter

Shutdown this Protocol Adapter, freeing excess resources.

Specified by:

shutdown in interface ProtocolAdapter<CPeer>

getRemoteObjectConnectionsList

public List<ITransportConnection> getRemoteObjectConnectionsList(long objectId)

Specified by:

getRemoteObjectConnectionsList in interface ProtocolAdapter<CPeer>

Parameters:

objectId - The exported remote objectId.

Returns:

the Transport connection info list for the supplied remote objectID.

countRemoteObjectConnections

public int countRemoteObjectConnections(long objectId)

Specified by:

countRemoteObjectConnections in interface ProtocolAdapter<CPeer>

getClientInvocationHandler

public ClientPeerInvocationHandler getClientInvocationHandler(String connectionURL,
                                                              ITransportConfig config,
                                                              PlatformLogicalVersion serviceVersion)

Description copied from interface: ProtocolAdapter

Returns the remote method invocation handler ClientPeerInvocationHandler which represents remote object specified by the supplied c and connection URL. The returned ClientPeerInvocationHandler maintains a pool of connections(sockets) to the remote object.

Specified by:

getClientInvocationHandler in interface ProtocolAdapter<CPeer>

Parameters:

connectionURL - the connectionURL to the remoteObj provided by ServerPeer.

config - the client configuration.

Returns:

the remote method invocation handler.

getMonitoringDetails

public LRMIMonitoringDetailsImpl getMonitoringDetails()

Specified by:

getMonitoringDetails in interface ProtocolAdapter<CPeer>