jgroup.relacs.mss
Class Mss

java.lang.Object
  extended by jgroup.relacs.mss.Mss
All Implemented Interfaces:
MssConstants, MssTag

public final class Mss
extends java.lang.Object
implements MssConstants, MssTag

The Mss class implements a Multi-Send Service.

Since:
Jgroup 1.2
Author:
Salvatore Cammarata, Alberto Montresor, Hein Meling

Field Summary
 
Fields inherited from interface jgroup.relacs.mss.MssConstants
ALL, EHANDLER_PRIORITY, HEADER_SIZE, MINIMUM_ALIVE_VALUE, MSS_HEADER_SIZE, MSSUSER_PRIORITY, NACKSUPPRESSION, NI_PRIORITY, OVERHEAD_SIZE, ROUTING_ENABLED, TRAILER_SIZE, UNDEF, UNREACHABLE
 
Fields inherited from interface jgroup.relacs.mss.MssTag
ASYN, CONGESTION, EXTERNFC, FWDROUTING, IAMALIVE, JG, LOCALFC, NACK, NOTLASTFRAGMENT, PING_OBJECT, QSYN, REMOTENACK, ROUTING, SENT, SENTNACK, SYN, TAGTYPE, TOPOLOGY
 
Constructor Summary
Mss(MssUser mssuser, DistributedSystemConfig dsc, TransportConfig tconf)
          Constructs a new Mss object.
 
Method Summary
 HostTable getHostTable()
          Returns the hosttable.
 void lreceive(Event event)
          Handles a message received by a local member
 void lsend(Event msg)
           
 void msend(byte tag, DaemonMsg msg)
          M-sends message msg to all the hosts in the hosttable.
 void msend(byte tag, DaemonMsg msg, EndPoint[] receivers)
          M-sends message msg to the hosts in the destination array receivers.
 void rreceive(java.net.DatagramPacket packet)
          Handles a message received from a remote host
 void send(byte tag, DaemonMsg msg, EndPoint receiver)
          Sends message the msg to a single host specified by receiver.
 java.lang.String toString()
          Returns a string containing the current content of the queues.
 void treceive(jgroup.relacs.mss.ScheduledEvent event)
          Handle expired timeout event
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

Mss

public Mss(MssUser mssuser,
           DistributedSystemConfig dsc,
           TransportConfig tconf)
    throws ConfigurationException,
           java.io.IOException
Constructs a new Mss object.

Parameters:
mssuser - The upper level layer, using this layer.
dsc - The distributed system configuration.
tconf - The transport parameter configuration.
Throws:
ConfigurationException - Thrown if the distributed system is incorrectly configured.
java.io.IOException - Thrown if there are problems at socket layer.
Method Detail

send

public void send(byte tag,
                 DaemonMsg msg,
                 EndPoint receiver)
Sends message the msg to a single host specified by receiver. This method is optimized for sending directly to the given receiver, bypassing the cluster leader.


msend

public void msend(byte tag,
                  DaemonMsg msg)
M-sends message msg to all the hosts in the hosttable. Only a single message is sent to each cluster leader, and from there sent to the corresponding members in that cluster.


msend

public void msend(byte tag,
                  DaemonMsg msg,
                  EndPoint[] receivers)
M-sends message msg to the hosts in the destination array receivers.


toString

public java.lang.String toString()
Returns a string containing the current content of the queues.

Overrides:
toString in class java.lang.Object

rreceive

public void rreceive(java.net.DatagramPacket packet)
Handles a message received from a remote host


lreceive

public void lreceive(Event event)
Handles a message received by a local member


treceive

public void treceive(jgroup.relacs.mss.ScheduledEvent event)
Handle expired timeout event


lsend

public void lsend(Event msg)

getHostTable

public HostTable getHostTable()
Returns the hosttable.



Copyright © 1998-2006 The Jgroup/ARM development team. All Rights Reserved.