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 | Field and Description |
---|---|
protected MessageDispatcher |
DistributedAlgorithm.messageDisp
Message dispatcher for this distributed algorithm
|
Modifier and Type | Method and Description |
---|---|
MessageDispatcher |
DistributedAlgorithm.getMessageDispatcher()
Returns the message dispatcher of this distributed algorithm.
|
Constructor and Description |
---|
DistributedAlgorithm(java.lang.String algorithmName,
MessageDispatcher parentDispatcher,
int nodeID)
Creates a new instance of DistributedAlgorithm with a higher-level message dispatcher queue.
|
Constructor and Description |
---|
NetworkBucketDispatcher(MessageDispatcher messageDisp,
int maxBuckets,
long bucketCapacity,
java.lang.Class<? extends LocalBucket> defaultBucketClass)
Creates a new instance of NetworkBucketDispatcher only with a maximal capacity specification.
|
NetworkBucketDispatcher(MessageDispatcher messageDisp,
int maxBuckets,
long bucketCapacity,
long bucketSoftCapacity,
long bucketLowOccupation,
boolean bucketOccupationAsBytes,
java.lang.Class<? extends LocalBucket> defaultBucketClass)
Creates a new instance of NetworkBucketDispatcher with full specification of default values.
|
NetworkBucketDispatcher(MessageDispatcher messageDisp,
int maxBuckets,
long bucketCapacity,
long bucketSoftCapacity,
long bucketLowOccupation,
boolean bucketOccupationAsBytes,
java.lang.Class<? extends LocalBucket> defaultBucketClass,
java.util.Map<java.lang.String,java.lang.Object> defaultBucketClassParams)
Creates a new instance of NetworkBucketDispatcher with full specification of default values.
|
Constructor and Description |
---|
ReplicationNetworkBucketDispatcher(MessageDispatcher messageDisp,
int maxBuckets,
long bucketCapacity,
boolean replicateBucketsEqually,
java.lang.Class<? extends LocalBucket> defaultBucketClass)
Creates a new instance of ReplicationNetworkBucketDispatcher
|
ReplicationNetworkBucketDispatcher(MessageDispatcher messageDisp,
int maxBuckets,
long bucketCapacity,
long bucketSoftCapacity,
long bucketLowOccupation,
boolean bucketOccupationAsBytes,
java.lang.Class<? extends LocalBucket> defaultBucketClass,
boolean replicateBucketsEqually)
Creates a new instance of ReplicationNetworkBucketDispatcher
|
Modifier and Type | Field and Description |
---|---|
protected MessageDispatcher |
NetworkNodeDispatcher.messageDisp
Internal variables
|
Modifier and Type | Method and Description |
---|---|
void |
BroadcastCreator.setMessageDispatcher(MessageDispatcher messageDisp) |
void |
CentralCreator.setMessageDispatcher(MessageDispatcher messageDisp) |
void |
NetworkNodeDispatcher.setMessageDispatcher(MessageDispatcher messageDisp)
Setter of message dispatcher for deserialization method
|
Constructor and Description |
---|
BroadcastCreator(MessageDispatcher messageDisp,
Startable[] startables)
Creates a new "passive" or "active" instance of NetworkNodePool
|
CentralCreator(MessageDispatcher messageDisp)
Creates a new "master" instance of CentralCreator
|
CentralCreator(MessageDispatcher messageDisp,
Startable[] startables,
NetworkNode centralNode)
Creates a new "slave" instance of CentralCreator
|
NetworkNodeDispatcher(MessageDispatcher messageDisp,
Startable[] startables)
Creates a new instance of NetworkNodeCreator
|
Modifier and Type | Field and Description |
---|---|
protected MessageDispatcher |
SocketThreadTCP.messageDispatcher |
protected MessageDispatcher |
SocketThreadUDP.messageDispatcher |
protected MessageDispatcher |
MessageDispatcher.topMessageDispatcher
Top most message dispatcher in the hierarchy
|
Modifier and Type | Field and Description |
---|---|
protected static java.util.Map<java.lang.Integer,MessageDispatcher> |
NetworkNode.messageDispMappingTable
Mapping table for translating parent message dispatchers - key is port and value is a top-level dispatcher for that port
|
Modifier and Type | Method and Description |
---|---|
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(MessageDispatcher parentDispatcher,
int nodeID)
Creates a new server instance of MessageDispatcher connected to a higher level dispatcher.
|
SocketThreadTCP(java.net.ServerSocket socket,
MessageDispatcher messageDispatcher)
Creates a new instance of SocketThreadTCP
|
SocketThreadUDP(java.net.DatagramSocket socket,
MessageDispatcher messageDispatcher)
Creates a new instance of SocketThreadUDP
|