Package | Description |
---|---|
org.jgroups.debug |
Provides debug support, including testing, profiling, and a graphical view of a protocol stack.
|
org.jgroups.jmx | |
org.jgroups.jmx.protocols | |
org.jgroups.jmx.protocols.pbcast | |
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.protocols.obsolete | |
org.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
org.jgroups.stack |
Support for managing protocol stacks.
|
Modifier and Type | Method and Description |
---|---|
void |
ProtocolView.setProtocol(Protocol prot) |
void |
Simulator.setProtocolStack(Protocol[] stack) |
Constructor and Description |
---|
ProtocolTester(java.lang.String prot_spec,
Protocol harness) |
ProtocolView(Protocol p,
javax.swing.table.DefaultTableModel model,
int my_index) |
ProtocolView(Protocol p,
javax.swing.table.DefaultTableModel model,
int my_index,
boolean cummulative) |
Modifier and Type | Method and Description |
---|---|
void |
Protocol.attachProtocol(Protocol p) |
protected static Protocol |
JmxConfigurator.findProtocol(Protocol prot) |
Constructor and Description |
---|
Protocol(Protocol p) |
Modifier and Type | Method and Description |
---|---|
void |
Discovery.attachProtocol(Protocol p) |
void |
FC.attachProtocol(Protocol p) |
void |
FD.attachProtocol(Protocol p) |
void |
FD_SOCK.attachProtocol(Protocol p) |
void |
FRAG.attachProtocol(Protocol p) |
void |
FRAG2.attachProtocol(Protocol p) |
void |
MERGE2.attachProtocol(Protocol p) |
void |
MPING.attachProtocol(Protocol p) |
void |
PING.attachProtocol(Protocol p) |
void |
SEQUENCER.attachProtocol(Protocol p) |
void |
STATS.attachProtocol(Protocol p) |
void |
TCP.attachProtocol(Protocol p) |
void |
TP.attachProtocol(Protocol p) |
void |
TCPGOSSIP.attachProtocol(Protocol p) |
void |
TCPPING.attachProtocol(Protocol p) |
void |
TCP_NIO.attachProtocol(Protocol p) |
void |
UDP.attachProtocol(Protocol p) |
void |
UNICAST.attachProtocol(Protocol p) |
void |
VIEW_SYNC.attachProtocol(Protocol p) |
Constructor and Description |
---|
Discovery(Protocol p) |
FC(Protocol p) |
FD_SOCK(Protocol p) |
FD(Protocol p) |
FRAG(Protocol p) |
FRAG2(Protocol p) |
MERGE2(Protocol p) |
MPING(Protocol p) |
PING(Protocol p) |
SEQUENCER(Protocol p) |
STATS(Protocol p) |
TCP_NIO(Protocol p) |
TCP(Protocol p) |
TCPGOSSIP(Protocol p) |
TCPPING(Protocol p) |
TP(Protocol p) |
UDP(Protocol p) |
UNICAST(Protocol p) |
VIEW_SYNC(Protocol p) |
Modifier and Type | Method and Description |
---|---|
void |
FLUSH.attachProtocol(Protocol p) |
void |
GMS.attachProtocol(Protocol p) |
void |
NAKACK.attachProtocol(Protocol p) |
void |
STABLE.attachProtocol(Protocol p) |
void |
STATE_TRANSFER.attachProtocol(Protocol p) |
void |
STREAMING_STATE_TRANSFER.attachProtocol(Protocol p) |
Constructor and Description |
---|
FLUSH(Protocol p) |
GMS(Protocol p) |
NAKACK(Protocol p) |
STABLE(Protocol p) |
STATE_TRANSFER(Protocol p) |
STREAMING_STATE_TRANSFER(Protocol p) |
Modifier and Type | Class and Description |
---|---|
class |
AUTH
The AUTH protocol adds a layer of authentication to JGroups
|
class |
AUTOCONF
Senses the network configuration when it is initialized (in init()) and sends a CONFIG event up
and down the stack.
|
class |
BasicTCP
Shared base class for tcpip protocols
|
class |
BSH
Beanshell (www.beanshell.org) interpreter class.
|
class |
CAUSAL
Implements casual ordering layer using vector clocks.
|
class |
COMPRESS
Compresses the payload of a message.
|
class |
DEADLOCK
Tests the deadlock detection mechanism of RequestCorrelator.
|
class |
DELAY
Delays incoming/outgoing messages by a random number of milliseconds (range between 0 and n
where n is determined by the user).
|
class |
DISCARD
Discards 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.
|
class |
Discovery
The Discovery protocol layer retrieves the initial membership (used by the GMS when started
by sending event FIND_INITIAL_MBRS down the stack).
|
class |
DUMMY |
class |
DUMMY_TP
Dummy transport, returns a fake local address and responds to CONNECT with CONNECT_OK.
|
class |
ENCRYPT
ENCRYPT layer.
|
class |
EXAMPLE
Example of a protocol layer.
|
class |
FC
Simple flow control protocol based on a credit system.
|
class |
FD
Failure detection based on simple heartbeat protocol.
|
class |
FD_ICMP
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.
|
class |
FD_PID
Process-ID based FD protocol.
|
class |
FD_PING
Protocol which uses an executable (e.g.
|
class |
FD_PROB
Probabilistic failure detection protocol based on "A Gossip-Style Failure Detection Service"
by Renesse, Minsky and Hayden.
|
class |
FD_SIMPLE
Simple failure detection protocol.
|
class |
FD_SOCK
Failure detection protocol based on sockets.
|
class |
FLOW_CONTROL
FLOW_CONTROL provides end-end congestion control and flow control.
|
class |
FLOWCONTROL
Title: Flow control layer
Description: This layer limits the number of sent messages without a receive of an own message to MAXSENTMSGS,
just put this layer above GMS and you will get a more
Copyright: Copyright (c) 2000
Company: Computer Network Laboratory
|
class |
FRAG
Fragmentation layer.
|
class |
FRAG2
Fragmentation layer.
|
class |
HDRS
Example of a protocol layer.
|
class |
HTOTAL
Implementation of UTO-TCP as designed by EPFL.
|
class |
JMS
Implementation of the transport protocol using the Java Message Service (JMS).
|
class |
LOOPBACK
Makes copies of outgoing messages, swaps sender and receiver and sends the message back up the stack.
|
class |
LOSS
Example of a protocol layer.
|
class |
MERGE
Simple and stupid MERGE protocol (does not take into account state transfer).
|
class |
MERGE2
Protocol to discover subgroups; e.g., existing due to a network partition (that healed).
|
class |
MERGE3
Protocol to discover subgroups; e.g., existing due to a network partition (that healed).
|
class |
MERGEFAST
The coordinator attaches a small header to each (or every nth) message.
|
class |
MessageProtocolEXAMPLE |
class |
MPING
Uses its own IP multicast socket to send and receive discovery requests/responses.
|
class |
NAKACK
Negative AcKnowledgement layer (NAKs), paired with positive ACKs.
|
class |
PARTITIONER
This layer can be put on top of the bottommost layer and is useful to simulate partitions.
|
class |
PERF
Measures time taken by each protocol to process a message.
|
class |
PERF_TP
Measures the time for a message to travel from the channel to the transport
|
class |
PIGGYBACK
Combines multiple messages into a single large one.
|
class |
PING
The PING protocol layer retrieves the initial membership (used by the GMS when started
by sending event FIND_INITIAL_MBRS down the stack).
|
class |
PRINTMETHODS |
class |
PRINTOBJS |
class |
QUEUE
Queuing layer.
|
class |
RpcProtocolEXAMPLE |
class |
SEQUENCER
Implementation of total order protocol using a sequencer.
|
class |
SHUFFLE
This layer shuffles upcoming messages, put it just above your bottom layer.
|
class |
SIZE
Protocol which prints out the real size of a message.
|
class |
SMACK
Simple Multicast ACK protocol.
|
class |
STATE_TRANSFER
State transfer layer.
|
class |
STATS
Provides various stats
|
class |
TCP
TCP based protocol.
|
class |
TCP_NIO
Transport using NIO
|
class |
TCPGOSSIP
The TCPGOSSIP protocol layer retrieves the initial membership (used by the GMS when started
by sending event FIND_INITIAL_MBRS down the stack).
|
class |
TCPPING
The TCPPING protocol layer retrieves the initial membership in answer to the GMS's
FIND_INITIAL_MBRS event.
|
class |
TOTAL
Implements the total ordering layer using a message sequencer
The protocol guarantees that all bcast sent messages will be delivered in
the same order to all members.
|
class |
TOTAL_OLD
**************************************************************************
class TOTAL_OLD extends Protocol
TODO: (more comments)
Sequencer based total ordering protocol layer
- requires the following layers "below" it in the stack
(or layers with equivalent functionality):
GMS, FD, PING, UDP, ...
|
class |
TOTAL_TOKEN
Total order implementation based on
The Totem Single-Ring Ordering and Membership Protocol.
|
class |
TP
Generic transport - specific implementations should extend this abstract class.
|
class |
TRACE |
class |
TUNNEL
Replacement for UDP.
|
class |
UDP
IP multicast transport based on UDP.
|
class |
UNICAST
Reliable unicast layer.
|
class |
VERIFY_SUSPECT
Catches SUSPECT events traveling up the stack.
|
class |
VIEW_ENFORCER
Used by a client until it becomes a member: all up messages are discarded until a VIEW_CHANGE
is encountered.
|
class |
VIEW_SYNC
Periodically sends the view to the group.
|
class |
WANPING
Similar to TCPPING, except that the initial host list is specified as a list of logical pipe names.
|
class |
WANPIPE
Logical point-to-point link.
|
Constructor and Description |
---|
PingWaiter(long timeout,
int num_rsps,
Protocol parent,
PingSender ping_sender) |
Modifier and Type | Class and Description |
---|---|
class |
ENCRYPT1_4
ENCRYPT1_4 layer.
|
Modifier and Type | Class and Description |
---|---|
class |
FLUSH
Flush, as it name implies, forces group members to flush their pending messages
while blocking them to send any additional messages.
|
class |
GMS
Group membership protocol.
|
class |
PBCAST
Implementation of probabilistic broadcast.
|
class |
STABLE
Computes the broadcast messages that are stable; i.e., have been received by all members.
|
class |
STREAMING_STATE_TRANSFER
STREAMING_STATE_TRANSFER , as its name implies, allows a streaming
state transfer between two channel instances. |
Modifier and Type | Class and Description |
---|---|
class |
MessageProtocol
Based on Protocol, but incorporates RequestCorrelator and GroupRequest: the latter can
be used to mcast messages to all members and receive their reponses.
|
class |
ProtocolStack
A ProtocolStack manages a number of protocols layered above each other.
|
class |
RpcProtocol
Base class for group RMC peer protocols.
|
Modifier and Type | Field and Description |
---|---|
protected Protocol |
Protocol.down_prot |
protected Protocol |
Protocol.up_prot |
Modifier and Type | Method and Description |
---|---|
Protocol |
ProtocolStack.createProtocol(java.lang.String prot_spec)
Creates a new protocol given the protocol specification.
|
Protocol |
Configurator.createProtocol(java.lang.String prot_spec,
ProtocolStack stack)
Creates a new protocol given the protocol specification.
|
Protocol |
Configurator.findProtocol(Protocol prot_stack,
java.lang.String name) |
Protocol |
ProtocolStack.findProtocol(java.lang.String name)
Returns a given protocol or null if not found
|
Protocol |
Configurator.getBottommostProtocol(Protocol prot_stack) |
Protocol |
Protocol.getDownProtocol() |
Protocol |
Protocol.getUpProtocol() |
Protocol |
Configurator.setupProtocolStack(java.lang.String configuration,
ProtocolStack st)
The configuration string has a number of entries, separated by a ':' (colon).
|
Modifier and Type | Method and Description |
---|---|
Protocol |
Configurator.findProtocol(Protocol prot_stack,
java.lang.String name) |
Protocol |
Configurator.getBottommostProtocol(Protocol prot_stack) |
void |
Configurator.initProtocolStack(Protocol bottom_prot) |
void |
ProtocolStack.insertProtocol(Protocol prot,
int position,
java.lang.String neighbor_prot)
Inserts an already created (and initialized) protocol into the protocol list.
|
void |
Configurator.insertProtocol(Protocol prot,
int position,
java.lang.String neighbor_prot,
ProtocolStack stack)
Inserts an already created (and initialized) protocol into the protocol list.
|
void |
Protocol.setDownProtocol(Protocol down_prot) |
void |
ProtocolObserver.setProtocol(Protocol prot)
Called when a ProtocolObserver is attached to a protcol.
|
void |
Protocol.setUpProtocol(Protocol up_prot) |
void |
Configurator.startProtocolStack(Protocol bottom_prot) |
void |
Configurator.stopProtocolStack(Protocol start_prot) |
Copyright ? 1998-2006 Bela Ban. All Rights Reserved.