Package | Description |
---|---|
groovyx.gpars.actor.impl |
This package holds classes some non-public aspects of actor implementation.
|
groovyx.gpars.actor.remote | |
groovyx.gpars.dataflow.expression | |
groovyx.gpars.dataflow.stream | |
groovyx.gpars.remote |
This package holds classes implementing the remoting interface for actors, dataflows and agents.
|
groovyx.gpars.remote.message |
This package holds message classes for the remote actors implementation.
|
groovyx.gpars.remote.netty |
This package holds implementation-specific classes implementing the remote actors functionality on top of Netty.
|
groovyx.gpars.serial |
This package holds classes used for actor identification in the network.
|
Modifier and Type | Method and Description |
---|---|
void |
MessageStream.SendTo.execute(RemoteConnection conn) |
Modifier and Type | Method and Description |
---|---|
void |
RemoteActor.StopActorMsg.execute(RemoteConnection conn) |
void |
RemoteActor.TerminateActorMsg.execute(RemoteConnection conn) |
Modifier and Type | Method and Description |
---|---|
void |
DataflowExpression.BindDataflow.execute(RemoteConnection conn)
Performs the actual bind on the remote host
|
Modifier and Type | Method and Description |
---|---|
void |
DataflowStreamWriteAdapter.BindDataflowStream.execute(RemoteConnection conn) |
Modifier and Type | Field and Description |
---|---|
private java.util.ArrayList<RemoteConnection> |
RemoteHost.connections |
Modifier and Type | Method and Description |
---|---|
RemoteConnection |
RemoteHost.getConnection() |
Modifier and Type | Method and Description |
---|---|
void |
RemoteHost.addConnection(RemoteConnection connection) |
void |
RemoteHost.removeConnection(RemoteConnection connection) |
Modifier and Type | Method and Description |
---|---|
void |
CloseConnectionMsg.execute(RemoteConnection conn) |
void |
HostIdMsg.execute(RemoteConnection conn) |
void |
RemoteActorReplyMsg.execute(RemoteConnection conn) |
void |
RemoteActorRequestMsg.execute(RemoteConnection conn) |
void |
RemoteAgentGetValMsg.execute(RemoteConnection conn) |
void |
RemoteAgentReplyMsg.execute(RemoteConnection conn) |
void |
RemoteAgentRequestMsg.execute(RemoteConnection conn) |
void |
RemoteAgentSendClosureMessage.execute(RemoteConnection conn) |
void |
RemoteAgentSendMessage.execute(RemoteConnection conn) |
void |
RemoteDataflowBroadcastReplyMsg.execute(RemoteConnection conn) |
void |
RemoteDataflowBroadcastRequestMsg.execute(RemoteConnection conn) |
void |
RemoteDataflowQueueEnqueueValueMsg.execute(RemoteConnection conn) |
void |
RemoteDataflowQueueReplyMsg.execute(RemoteConnection conn) |
void |
RemoteDataflowQueueRequestMsg.execute(RemoteConnection conn) |
void |
RemoteDataflowQueueValueRequestMsg.execute(RemoteConnection conn) |
void |
RemoteDataflowVariableReplyMsg.execute(RemoteConnection conn) |
void |
RemoteDataflowVariableRequestMsg.execute(RemoteConnection conn) |
Modifier and Type | Class and Description |
---|---|
class |
NettyRemoteConnection
Connection using Netty
|
Modifier and Type | Field and Description |
---|---|
private RemoteConnection |
RemoteObjectDecoder.connection |
private RemoteConnection |
RemoteObjectEncoder.connection |
private RemoteConnection |
NettyHandler.remoteConnection |
Modifier and Type | Method and Description |
---|---|
protected RemoteConnection |
NettyChannelInitializer.getRemoteConnection(io.netty.channel.Channel channel) |
Modifier and Type | Method and Description |
---|---|
void |
ConnectListener.onConnect(RemoteConnection connection) |
Constructor and Description |
---|
NettyHandler(RemoteConnection remoteConnection) |
RemoteObjectDecoder(RemoteConnection connection)
Creates a new encoder.
|
RemoteObjectEncoder(RemoteConnection connection)
Creates a new encoder.
|
Modifier and Type | Method and Description |
---|---|
void |
SerialHandle.RemoteSerialHandle.ReleaseHandle.execute(RemoteConnection conn) |
abstract void |
SerialMsg.execute(RemoteConnection conn) |
protected void |
SerialMsg.updateRemoteHost(RemoteConnection connection) |