jgroup.relacs.mss
Class Mss

java.lang.Object
  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.