Package | Description |
---|---|
messif.algorithms |
Search algorithms base classes.
|
messif.netbucket |
Networked objects and buckets.
|
messif.netcreator |
Utilization of resources using on-demand requirements of distributed structures.
|
messif.network |
Message-based networking support.
|
Modifier and Type | Class and Description |
---|---|
class |
DistAlgReplyMessage
Reply message for the
DistributedAlgorithm . |
class |
DistAlgRequestMessage
Request message for the
DistributedAlgorithm . |
Modifier and Type | Method and Description |
---|---|
protected java.util.Collection<Statistics<?>> |
DistributedAlgorithm.setupMessageStatistics(Message msg)
Given a just-arrived message, this method registers (binds) DC, DC.Savings and BlockReads statistics
for current thread.
|
Modifier and Type | Class and Description |
---|---|
class |
BucketCreateReplyMessage
Message for returning results of a remote bucket creation.
|
class |
BucketCreateRequestMessage
Message for requesting creation of a remote bucket.
|
class |
BucketExceptionReplyMessage
Message for returning exception thrown while manipulating objects on a remote bucket.
|
class |
BucketManipulationReplyMessage |
class |
BucketManipulationRequestMessage
NetworkBucketDispatcher message that can request several operations to be performed with
the specified bucket:
add given objects,
add ALL objects from a specified local bucket
remove objects (by locator or equal),
find and return stored objects (specified by locator, key or return ALL objects).
|
class |
BucketProcessQueryReplyMessage
Message for returning results of a query processed on a remote bucket.
|
class |
BucketProcessQueryRequestMessage
Message requesting to process a query on a remote bucket.
|
class |
BucketRemoveReplyMessage
Message for returning results of a remote bucket removal.
|
class |
BucketRemoveRequestMessage |
class |
BucketReplyMessage
Generic message for returning results of an object manipulation on a remote bucket.
|
class |
BucketRequestMessage<T extends BucketReplyMessage>
Generic message for requesting an object manipulation on a remote bucket.
|
class |
BucketSplitReplyMessage
Message for returning results of a remote bucket split.
|
class |
BucketSplitRequestMessage
Message requesting to split a bucket creating new ones.
|
Modifier and Type | Class and Description |
---|---|
class |
MessageActivate |
class |
MessageActivateResponse |
class |
MessageImHere |
class |
MessageImUsed |
Modifier and Type | Class and Description |
---|---|
class |
ReplyMessage
The ancestor of all reply messages that are returned back during communication with other network nodes.
|
Modifier and Type | Method and Description |
---|---|
protected Message |
MessageDispatcher.getMessageFromStream(java.io.ObjectInputStream stream)
Unpacks a message from the byte stream.
|
Modifier and Type | Method and Description |
---|---|
boolean |
InvokingReceiver.acceptMessage(Message msg,
boolean allowSuperclass)
Accepts the message if a there is a method for the message's class.
|
boolean |
MessageDispatcher.acceptMessage(Message msg,
boolean allowSuperclass)
Offers a message to this message dispatcher, i.e. run through the dispatcher's list
of registered receivers and offer the message to them.
|
boolean |
Receiver.acceptMessage(Message msg,
boolean allowSuperclass)
Offers a message to this receiver for acceptance.
|
boolean |
ReplyReceiver.acceptMessage(Message msg,
boolean allowSuperclass)
The
Receiver interface method. |
protected void |
InvokingReceiver.processMessage(Message msg,
java.lang.reflect.Method method)
Invoke the method associtated with the accepted message.
|
protected void |
QueueInvokingReceiver.processMessage(Message msg,
java.lang.reflect.Method method)
Put the accepted message and the associated method to the queue.
|
protected void |
ThreadInvokingReceiver.processMessage(Message msg,
java.lang.reflect.Method method)
Run a separate thread that invokes the accepted message's method.
|
protected void |
MessageDispatcher.putMessageIntoStream(Message msg,
java.io.ObjectOutputStream stream,
NetworkNode destinationNode)
Packs the provided message into byte stream.
|
protected void |
MessageDispatcher.receiveMessage(Message msg)
Process a message received through sockets.
|
void |
MessageDispatcher.sendMessage(Message msg)
Send the message to all network nodes (that are listening for broadcast on the same port).
|
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.
|
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,
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,
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,
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,
NetworkNode node)
Send the message to the specified network node 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.
|
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.
|
Constructor and Description |
---|
ReplyMessage(Message message)
Creates a new instance of ReplyMessage.
|