Package org.jgroups.protocols
package org.jgroups.protocols
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
-
ClassDescriptionThe AUTH protocol adds a layer of authentication to JGroupsAuthHeader is a holder object for the token that is passed from the joiner to the coordinatorSenses the network configuration when it is initialized (in init()) and sends a CONFIG event up and down the stack.All messages up the stack have to go through a barrier (read lock, RL).Shared base class for tcpip protocolsBeanshell (www.beanshell.org) interpreter class.Implements casual ordering layer using vector clocks.Compresses the payload of a message.Delays incoming/outgoing messages by a random number of milliseconds (range between 0 and n where n is determined by the user).Discards 2 JOIN-REQs then accepts 1, then discards 2 more and so onDiscards up or down messages based on a percentage; e.g., setting property 'up' to 0.1 causes 10% of all up messages to be discarded.Discards a message whose sequence number (in the payload, as a Long) matches seqno 2 times, before passing it up.The Discovery protocol layer retrieves the initial membership (used by the GMS when started by sending event FIND_INITIAL_MBRS down the stack).Dummy transport, returns a fake local address and responds to CONNECT.Duplicates outgoing or incoming messages by copying themENCRYPT layer.Example of a protocol layer.Simple flow control protocol based on a credit system.Failure detection based on simple heartbeat protocol.Failure detection based on simple heartbeat protocol.Protocol which uses InetAddress.isReachable() to check whether a given host is up or not, taking 1 argument; the host name of the host to be pinged.Protocol which uses an executable (e.g.Simple failure detection protocol.Failure detection protocol based on sockets.Fragmentation layer.Fragmentation layer.Example of a protocol layer.Implementation of UTO-TCP as designed by EPFL.Implementation of the transport protocol using the Java Message Service (JMS).Simple
Address
representing the JMS node ID or JMS topic group.Makes copies of outgoing messages, swaps sender and receiver and sends the message back up the stack.Protocol to discover subgroups; e.g., existing due to a network partition (that healed).Protocol to discover subgroups; e.g., existing due to a network partition (that healed).The coordinator attaches a small header to each (or every nth) message.Uses its own IP multicast socket to send and receive discovery requests/responses.Protocol to simulate a partition.Measures the time for a message to travel from the channel to the transportThe PING protocol layer retrieves the initial membership (used by the GMS when started by sending event FIND_INITIAL_MBRS down the stack).Implementation of total order protocol using a sequencer.Simple flow control protocol.Loopback transport shared by all channels within the same VM.This layer shuffles upcoming messages, put it just above your bottom layer.Protocol which prints out the real size of a message.Simple Multicast ACK protocol.Provides various statsTCP based protocol.Transport using NIOThe TCPGOSSIP protocol layer retrieves the initial membership (used by the GMS when started by sending event FIND_INITIAL_MBRS down the stack).The TCPPING protocol layer retrieves the initial membership in answer to the GMS's FIND_INITIAL_MBRS event.Generic transport - specific implementations should extend this abstract class.Generic transport header, used by TP.Lighweight representation of the VectorTime clock suitable for network transportReplacement for UDP.IP multicast transport based on UDP.Reliable unicast layer.Catches SUSPECT events traveling up the stack.Periodically sends the view to the group.