Package | Description |
---|---|
messif.algorithms |
Search algorithms base classes.
|
messif.netbucket |
Networked objects and buckets.
|
messif.netbucket.replication |
Replication support for remote buckets.
|
messif.netcreator |
Utilization of resources using on-demand requirements of distributed structures.
|
messif.network |
Message-based networking support.
|
Modifier and Type | Method and Description |
---|---|
NetworkNode |
DistributedAlgorithm.getThisNode()
Returns the network node of this distributed algorithm.
|
Modifier and Type | Method and Description |
---|---|
protected ReplyReceiver<? extends DistAlgReplyMessage> |
DistributedAlgorithm.navigationBeforeProcessing(AbstractOperation operation,
DistAlgRequestMessage request,
NetworkNode node)
Processes navigation before the local processing.
|
protected void |
DistributedAlgorithm.navigationNoProcessing(AbstractOperation operation,
DistAlgRequestMessage request,
NetworkNode node)
Processes navigation when there will be no local processing.
|
Modifier and Type | Method and Description |
---|---|
protected ReplyReceiver<? extends DistAlgReplyMessage> |
DistributedAlgorithm.navigationBeforeProcessing(AbstractOperation operation,
DistAlgRequestMessage request,
java.util.Collection<NetworkNode> nodes)
Processes navigation before the local processing.
|
protected void |
DistributedAlgorithm.navigationNoProcessing(AbstractOperation operation,
DistAlgRequestMessage request,
java.util.Collection<NetworkNode> nodes)
Processes navigation when there will be no local processing.
|
Modifier and Type | Method and Description |
---|---|
NetworkNode |
NetworkBucketDispatcher.getCurrentNetworkNode()
Returns the network node of this dispatcher.
|
NetworkNode |
RemoteBucket.getRemoteNetworkNode()
Returns the remote node on which the bucket resides.
|
Modifier and Type | Method and Description |
---|---|
RemoteBucket |
NetworkBucketDispatcher.createRemoteBucket(NetworkNode atNetworkNode)
Creates a bucket on a remote network node.
|
RemoteBucket |
NetworkBucketDispatcher.createRemoteBucket(NetworkNode atNetworkNode,
java.lang.Class<? extends LocalBucket> storageClass,
java.util.Map<java.lang.String,java.lang.Object> storageClassParams,
long capacity,
long softCapacity)
Creates a bucket on a remote network node.
|
RemoteBucket |
NetworkBucketDispatcher.createRemoteBucket(NetworkNode atNetworkNode,
long capacity,
long softCapacity)
Creates a bucket on a remote network node with default class and params is created
but with specified capacity and soft capacity.
|
protected <T extends BucketReplyMessage> |
NetworkBucketDispatcher.send(BucketRequestMessage<T> msg,
NetworkNode networkNode)
Sending method for bucket request messages.
|
void |
RemoteBucket.setRemoteNetworkNode(NetworkNode remoteNetworkNode)
Sets the remote node on which the bucket resides.
|
Constructor and Description |
---|
RemoteBucket(NetworkBucketDispatcher netbucketDisp,
int bucketID,
NetworkNode remoteNetworkNode,
long capacity)
Creates a new instance of RemoteBucket from parameters.
|
Modifier and Type | Method and Description |
---|---|
java.util.Set<NetworkNode> |
ReplicationBucket.getAllReplicaNodes()
Return set of all network nodes where this bucket has replicas
|
java.util.Set<NetworkNode> |
ReplicationNetworkBucketDispatcher.getAllReplicaNodes()
Return set of all network nodes where my buckets have some replicas
|
Modifier and Type | Method and Description |
---|---|
void |
ReplicationBucket.createReplica(NetworkNode atNetworkNode) |
void |
ReplicationNetworkBucketDispatcher.createReplica(NetworkNode atNetworkNode)
Methods to be executed on the replication buckets
|
boolean |
ReplicationBucket.removeReplica(NetworkNode atNetworkNode)
Remove replica of this bucket from given node.
|
boolean |
ReplicationNetworkBucketDispatcher.removeReplica(NetworkNode atNetworkNode)
Remove replica of this bucket from all bucket in this dispatcher.
|
void |
ReplicationBucket.replicaMigrated(NetworkNode origNode,
NetworkNode newNode)
Indicate that one of the replica was migrated
|
void |
ReplicationNetworkBucketDispatcher.replicaMigrated(NetworkNode origNode,
NetworkNode newNode)
One of the replicas (of potentially all buckets) has been migrated.
|
Modifier and Type | Field and Description |
---|---|
protected NetworkNode |
MessageActivateResponse.activatedNode |
protected NetworkNode |
CentralCreator.centralNode |
Modifier and Type | Field and Description |
---|---|
protected java.util.Set<NetworkNode> |
MessageActivate.netnodes
Message extensions
|
protected java.util.Set<NetworkNode> |
BroadcastCreator.pool
Internal data
|
protected java.util.Set<NetworkNode> |
CentralCreator.pool
Internal data
|
Modifier and Type | Method and Description |
---|---|
NetworkNode |
BroadcastCreator.create()
Initialize one of registered free servers, so they can be used
|
NetworkNode |
CentralCreator.create()
Initialize one of registered free servers, so they can be used
|
abstract NetworkNode |
NetworkNodeDispatcher.create()
Create methods
|
NetworkNode |
MessageActivateResponse.getActivatedNode() |
NetworkNode |
CentralCreator.getCentralNode() |
Modifier and Type | Method and Description |
---|---|
java.util.Set<NetworkNode> |
MessageActivate.getServerList() |
Modifier and Type | Method and Description |
---|---|
protected void |
BroadcastCreator.activate(java.util.Set<NetworkNode> newPool,
boolean sendUsed)
Internal handler used to change from passive (not used) to active (used) state
|
Constructor and Description |
---|
CentralCreator(MessageDispatcher messageDisp,
Startable[] startables,
NetworkNode centralNode)
Creates a new "slave" instance of CentralCreator
|
MessageActivateResponse(NetworkNode activatedNode,
MessageActivate activationMessage)
Creates a new instance of MessageActivateResponse from supplied data
|
Constructor and Description |
---|
MessageActivate(java.util.Set<NetworkNode> netnodes)
Creates a new instance of MessageInitUse from supplied data
|
Modifier and Type | Field and Description |
---|---|
protected NetworkNode |
MessageDispatcher.ourNetworkNode
Identification of this network node
|
Modifier and Type | Field and Description |
---|---|
protected static java.util.Map<java.net.InetAddress,java.util.Map<java.lang.Integer,NetworkNode>> |
NetworkNode.netnodeMappingTable
Mapping table for translating original host names (optionally plus ports) to new ones
|
Modifier and Type | Method and Description |
---|---|
NetworkNode |
Message.getDestination()
Returns the network node to which this message arrived.
|
NetworkNode |
NavigationElement.getDestination()
Returns the destination of the message for this particular hop.
|
NetworkNode |
MessageDispatcher.getNetworkNode()
Returns the network node identification of this message dispatcher.
|
NetworkNode |
Message.getOriginalSender()
Returns the network node, on which this message was created and from which it was sent in the begining.
|
NetworkNode |
Message.getSender()
Returns the network node from which this message arrived.
|
NetworkNode |
NavigationElement.getSender()
Returns the sender of the message for this particular hop.
|
NetworkNode |
MessageDispatcher.replyMessage(ReplyMessage msg)
Send the reply message, i.e. send the message to its original sender node.
|
static NetworkNode |
NetworkNode.valueOf(java.lang.String hostPortNode)
Creates a new instance of NetworkNode from string "host:port#node".
|
Modifier and Type | Method and Description |
---|---|
java.util.List<NetworkNode> |
Message.getSenderList()
Returns the list of senders stored in the navigation path and the actual sender.
|
Modifier and Type | Method and Description |
---|---|
protected void |
NavigationElement.addNotWaitingDestination(NetworkNode destination)
Adds the node to the list of forwarded nodes at this particular hop.
|
protected void |
NavigationElement.addWaitingDestination(NetworkNode destination)
Adds the node to the list of waiting nodes at this particular hop.
|
boolean |
NetworkNode.equalsIgnoreNodeID(NetworkNode node)
Compare the address and port of actual network node with other network node's host and port.
|
protected void |
MessageDispatcher.putMessageIntoStream(Message msg,
java.io.ObjectOutputStream stream,
NetworkNode destinationNode)
Packs the provided message into byte stream.
|
void |
MessageDispatcher.sendMessage(Message msg,
NetworkNode node)
Send the message to the specified network node.
|
void |
MessageDispatcher.sendMessage(Message msg,
NetworkNode node,
boolean willNotReply)
Send the message to the specified network node.
|
<E extends ReplyMessage> |
MessageDispatcher.sendMessageWaitReply(Message msg,
java.lang.Class<E> replyMessageClass,
boolean removeOnAccept,
NetworkNode node)
Send the message to the specified network node and wait for the replies.
|
<E extends ReplyMessage> |
MessageDispatcher.sendMessageWaitReply(Message msg,
java.lang.Class<E> replyMessageClass,
NetworkNode node)
Send the message to the specified network node and wait for the replies.
|
ReplyReceiver<? extends ReplyMessage> |
MessageDispatcher.sendMessageWaitReply(Message msg,
NetworkNode node)
Send the message to the specified network node and wait for the replies.
|
<E extends ReplyMessage> |
MessageDispatcher.sendMessageWaitSingleReply(Message msg,
java.lang.Class<E> replyMessageClass,
NetworkNode node)
Send the message to a network node and wait for a single reply.
|
<E extends ReplyMessage> |
MessageDispatcher.sendMessageWaitSingleReply(Message msg,
java.lang.Class<E> replyMessageClass,
NetworkNode node,
long timeout)
Send the message to a network node and wait for a single reply.
|
protected void |
NavigationElement.setReply(NetworkNode destination)
Sets this particular hop as a reply to the destination.
|
protected void |
NavigationElement.setSender(NetworkNode sender)
Sets the sender of the message for this particular hop.
|
Modifier and Type | Method and Description |
---|---|
void |
MessageDispatcher.sendMessage(Message msg,
java.util.Collection<NetworkNode> nodes)
Send the message to multiple network nodes.
|
void |
MessageDispatcher.sendMessage(Message msg,
java.util.Collection<NetworkNode> nodes,
boolean willNotReply)
Send the message to multiple network nodes.
|
<E extends ReplyMessage> |
MessageDispatcher.sendMessageWaitReply(Message msg,
java.lang.Class<E> replyMessageClass,
boolean removeOnAccept,
java.util.Collection<NetworkNode> nodes)
Send the message to multiple network nodes and wait for the replies.
|
<E extends ReplyMessage> |
MessageDispatcher.sendMessageWaitReply(Message msg,
java.lang.Class<E> replyMessageClass,
java.util.Collection<NetworkNode> nodes)
Send the message to multiple network nodes and wait for the replies.
|
ReplyReceiver<? extends ReplyMessage> |
MessageDispatcher.sendMessageWaitReply(Message msg,
java.util.Collection<NetworkNode> nodes)
Send the message to multiple network nodes and wait for the replies.
|
static void |
NetworkNode.setHostMappingTable(java.util.Map<java.net.InetAddress,java.util.Map<java.lang.Integer,NetworkNode>> netnodeMappingTable,
java.util.Map<java.lang.Integer,MessageDispatcher> messageDispMappingTable)
Setter method for the mapping table.
|
Constructor and Description |
---|
MessageDispatcher(NetworkNode localAddress)
Creates a new instance of MessageDispatcher with specified TCP/UDP port.
|
MessageDispatcher(NetworkNode localAddress,
int broadcastPort)
Creates a new instance of MessageDispatcher with specified TCP/UDP and broadcast ports.
|
NetworkNode(NetworkNode node)
Creates a copy of the provided NetworkNode.
|
NetworkNode(NetworkNode node,
boolean copyNodeID)
Creates a copy of the provided NetworkNode.
|
NetworkNode(NetworkNode node,
java.lang.Integer nodeID)
Creates a copy of the provided NetworkNode.
|