|
|||||||||
| Home >> All >> org >> jgroups >> [ protocols overview ] | PREV PACKAGE NEXT PACKAGE | ||||||||
Package org.jgroups.protocols
Provides top-level public JGroups classes such as Channel, Message, etc.
See:
Description
| Interface Summary | |
| QUEUE.Observer | |
| Receiver | |
| Class Summary | |
| AUTOCONF | Senses the network configuration when it is initialized (in init()) and sends a CONFIG event up and down the stack. |
| BSH | Beanshell (www.beanshell.org) interpreter class. |
| BSH.BshHeader | |
| CAUSAL | Implements casual ordering layer using vector clocks. |
| CAUSAL.CausalHeader | |
| ClientGmsImpl | Client part of GMS. |
| COMPRESS | Compresses the payload of a message. |
| COMPRESS.CompressHeader | |
| CoordGmsImpl | |
| DEADLOCK | Tests the deadlock detection mechanism of RequestCorrelator. |
| DELAY | Delays incoming/outgoing messages by a random number of milliseconds (range between 0 and n where n is determined by the user). |
| Digest | Message digest, collecting the highest sequence number seen so far for each member, plus the messages that have higher seqnos than the ones given. |
| 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. |
| Discovery | The Discovery protocol layer retrieves the initial membership (used by the GMS when started by sending event FIND_INITIAL_MBRS down the stack). |
| DUMMY | |
| DUMMY_TP | Dummy transport, returns a fake local address and responds to CONNECT with CONNECT_OK. |
| ENCRYPT | ENCRYPT layer. |
| ENCRYPT.EncryptHeader | |
| ENCRYPT1_4 | ENCRYPT1_4 layer. |
| ENCRYPT1_4.EncryptHeader | |
| ENCRYPT14KeystoreTest | |
| ENCRYPTAsymmetricTest | |
| EXAMPLE | Example of a protocol layer. |
| ExampleHeader | |
| FC | Simple flow control protocol based on a credit system. |
| FC.FcHeader | |
| FD | Failure detection based on simple heartbeat protocol. |
| FD_PID | Process-ID based FD protocol. |
| FD_PID.FdHeader | |
| FD_PROB | Probabilistic failure detection protocol based on "A Gossip-Style Failure Detection Service" by Renesse, Minsky and Hayden. |
| FD_PROB.FdEntry | |
| FD_PROB.FdHeader | |
| FD_SIMPLE | Simple failure detection protocol. |
| FD_SIMPLE.FdHeader | |
| FD_SOCK | Failure detection protocol based on sockets. |
| FD_SOCK.ClientConnectionHandler | Handles a client connection; multiple client can connect at the same time |
| FD_SOCK.FdHeader | |
| FD.FdHeader | |
| FLOW_CONTROL | FLOW_CONTROL provides end-end congestion control and flow control. |
| FLOW_CONTROL.FCInfo | |
| 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 |
| FLUSH | The task of the FLUSH protocol is to flush all pending messages out of the system. |
| FlushRsp | |
| FRAG | Fragmentation layer. |
| FRAG.FragmentationList | A fragmentation list keeps a list of fragmentation tables sorted by an Address ( the sender ). |
| FRAG.FragmentationTable | Keeps track of the fragments that are received. |
| FRAG.FragmentationTable.Entry | inner class represents an entry for a message each entry holds an array of byte arrays sorted once all the byte buffer entries have been filled the fragmentation is considered complete. |
| FRAG2 | Fragmentation layer. |
| FRAG2.FragmentationList | A fragmentation list keeps a list of fragmentation tables sorted by an Address ( the sender ). |
| FRAG2.FragmentationTable | Keeps track of the fragments that are received. |
| FRAG2.FragmentationTable.Entry | inner class represents an entry for a message each entry holds an array of byte arrays sorted once all the byte buffer entries have been filled the fragmentation is considered complete. |
| FragHeader | |
| GMS | Group membership protocol. |
| GmsImpl | |
| HDRS | Example of a protocol layer. |
| HTOTAL | Implementation of UTO-TCP as designed by EPFL. |
| HTOTAL.HTotalHeader | |
| JMS | Implementation of the transport protocol using the Java Message Service (JMS). |
| JMS.JMSAddress | Simple org.jgroups.Address representing the JMS node ID or JMS topic group. |
| LOOPBACK | Makes copies of outgoing messages, swaps sender and receiver and sends the message back up the stack. |
| LOSS | Example of a protocol layer. |
| MERGE | Simple and stupid MERGE protocol (does not take into account state transfer). |
| MERGE.MergeHeader | |
| MERGE2 | Protocol to discover subgroups; e.g., existing due to a network partition (that healed). |
| MERGE3 | Protocol to discover subgroups; e.g., existing due to a network partition (that healed). |
| MERGE3.CoordAnnouncement | |
| MERGEFAST | The coordinator attaches a small header to each (or every nth) message. |
| MERGEFAST.MergefastHeader | |
| MessageAcks | class MessageAcks Used by sequencer to store cumulative acknowledgements of broadcast messages sent to the group in this view |
| MessageProtocolEXAMPLE | |
| MPING | Uses its own IP multicast socket to send and receive discovery requests/responses. |
| MyFrame | |
| NAKACK | Negative AcKnowledgement layer (NAKs), paired with positive ACKs. |
| NakAckHeader | |
| ParticipantGmsImpl | |
| PARTITIONER | This layer can be put on top of the bottommost layer and is useful to simulate partitions. |
| PARTITIONER.PartitionerHeader | The Partitioner header normally (type = NORMAL) contains just the partition number that is checked to discard messages received from other partitions. |
| PERF | Measures time taken by each protocol to process a message. |
| PERF_TP | Measures the time for a message to travel from the channel to the transport |
| PerfEntry | Entry specific for 1 protocol layer. |
| PerfHeader | Inserted by PERF into each message. |
| PerfObserver | Observes a protocol and adds its timings to the PerfHeader attached to each protocol. |
| PIGGYBACK | Combines multiple messages into a single large one. |
| PIGGYBACK.PiggybackHeader | |
| PING | The PING protocol layer retrieves the initial membership (used by the GMS when started by sending event FIND_INITIAL_MBRS down the stack). |
| PingHeader | |
| PingRsp | |
| PingSender | Sends num_ping_request GET_MBRS_REQ messages, distributed over timeout ms |
| PingWaiter | Class that waits for n PingRsp'es, or m milliseconds to return the initial membership |
| PRINTMETHODS | |
| PRINTOBJS | |
| QUEUE | Queuing layer. |
| RpcProtocolEXAMPLE | |
| SavedMessages | class SavedMessages Stores a set of messages along with their sequence id (assigned by the sequencer). |
| SHUFFLE | This layer shuffles upcoming messages, put it just above your bottom layer. |
| SIZE | Protocol which prints out the real size of a message. |
| SMACK | Simple Multicast ACK protocol. |
| SMACK.SmackHeader | |
| STABLE | Computes the broadcast messages that are stable; i.e., that have been received by all members. |
| STABLE.Times | Select next interval from list. |
| STATE_TRANSFER | State transfer layer. |
| STATE_TRANSFER_Test | It's an attemp to setup Junit test case template for Protocol regression. |
| StateTransferRequest | |
| STATS | Provides various stats |
| STATS.Entry | |
| TCP | TCP based protocol. |
| TCP_NIO | |
| TCPGOSSIP | The TCPGOSSIP protocol layer retrieves the initial membership (used by the GMS when started by sending event FIND_INITIAL_MBRS down the stack). |
| TcpHeader | |
| TCPPING | The TCPPING protocol layer retrieves the initial membership in answer to the GMS's FIND_INITIAL_MBRS event. |
| 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. |
| 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, ... |
| TOTAL_OLD.TotalHeader | class TotalHeader The header that is prepended to every message passed down through the TOTAL_OLD layer and removed (and processed) from every message passed up through the TOTAL_OLD layer |
| TOTAL_TOKEN | Total order implementation based on The Totem Single-Ring Ordering and Membership Protocol. |
| TOTAL_TOKEN.RingTokenHeader | |
| TOTAL_TOKEN.TotalTokenHeader | |
| TOTAL.Header | The header processed by the TOTAL layer and intended for TOTAL inter-stack communication |
| TotalRetransmissionThread | ************************************************************************** class TotalRetransmissionThread thread that handles retransmission for the TOTAL_OLD protocol ************************************************************************** |
| TP | Generic transport - specific implementations should extend this abstract class. |
| TpHeader | Generic transport header, used by TP. |
| TRACE | |
| TransportedVectorTime | Lighweight representation of the VectorTime clock suitable for network transport |
| TUNNEL | Replacement for UDP. |
| TunnelHeader | |
| UDP | IP multicast transport based on UDP. |
| UDP_NIO | Multicast transport. |
| UDP_NIO.Connector | Manages a multicast and unicast socket on a given interface (NIC). |
| UDP_NIO.ConnectorTable | Manages a bunch of Connectors |
| UDP_NIO.MulticastReceiver | |
| UDP_NIO.MyReceiver | |
| UDP_NIO.Unmarshaller | |
| UdpHeader | |
| UNICAST | Reliable unicast layer. |
| UNICAST.Entry | |
| UNICAST.UnicastHeader | |
| VectorTime | Vector timestamp used in CAUSAL order protocol stack |
| VERIFY_SUSPECT | Catches SUSPECT events traveling up the stack. |
| VERIFY_SUSPECT.VerifyHeader | |
| VIEW_ENFORCER | Used by a client until it becomes a member: all up messages are discarded until a VIEW_CHANGE is encountered. |
| VIEW_SYNC | Periodically sends the view to the group. |
| VIEW_SYNC.ViewSyncHeader | |
| WANPING | Similar to TCPPING, except that the initial host list is specified as a list of logical pipe names. |
| WANPIPE | Logical point-to-point link. |
| WANPIPE.LinkInfo | |
| WanPipeAddress | Logical address for a WAN pipe (logical link) |
Package org.jgroups.protocols Description
Provides top-level public JGroups classes such as Channel, Message, etc.
|
|||||||||
| Home >> All >> org >> jgroups >> [ protocols overview ] | PREV PACKAGE NEXT PACKAGE | ||||||||