|
|||||||||
| Home >> All >> org >> jgroups >> [ protocols overview ] | PREV NEXT | ||||||||
Uses of Package
org.jgroups.protocols
| Classes in org.jgroups.protocols used by org.jgroups.protocols | |
| DEADLOCK
Tests the deadlock detection mechanism of RequestCorrelator. |
|
| 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. |
|
| Discovery
The Discovery protocol layer retrieves the initial membership (used by the GMS when started by sending event FIND_INITIAL_MBRS down the stack). |
|
| FC.FcHeader
|
|
| FD_PID.Monitor
An instance of this class will be added to the TimeScheduler to be scheduled to be run every timeout msecs. |
|
| FD_PROB.FdHeader
|
|
| FD_SIMPLE.HeartbeatTask
|
|
| FD_SOCK.BroadcastTask
Task that periodically broadcasts a list of suspected members to the group. |
|
| FD_SOCK.ServerSocketHandler
Handles the server-side of a client-server socket connection. |
|
| FD.Broadcaster
Task that periodically broadcasts a list of suspected members to the group. |
|
| FD.BroadcastTask
|
|
| FD.Monitor
|
|
| FlushRsp
|
|
| 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. |
|
| 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. |
|
| GMS
Group membership protocol. |
|
| GmsImpl
|
|
| MERGE2.FindSubgroups
Task periodically executing (if role is coordinator). |
|
| MERGE3.CoordinatorAnnouncer
|
|
| MessageAcks
class MessageAcks Used by sequencer to store cumulative acknowledgements of broadcast messages sent to the group in this view |
|
| MessageAcks.Entry
class Entry (inner class) object type to store cumulative acknowledgements using a member's Address and the sequence id of a message |
|
| MyFrame
|
|
| NAKACK.NAKer
|
|
| NAKACK.NAKer.LastMessageRetransmitter
|
|
| NAKACK.OutOfBander
|
|
| NakAckHeader
|
|
| 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. |
|
| PIGGYBACK.Packer
|
|
| PING
The PING protocol layer retrieves the initial membership (used by the GMS when started by sending event FIND_INITIAL_MBRS down the stack). |
|
| 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 |
|
| QUEUE.Observer
|
|
| Receiver
|
|
| SavedMessages
class SavedMessages Stores a set of messages along with their sequence id (assigned by the sequencer). |
|
| STABLE.Task
The gossiping task |
|
| STABLE.Times
Select next interval from list. |
|
| STATE_TRANSFER_Test.Coordinator
|
|
| TCP
TCP based protocol. |
|
| 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_TOKEN.TokenTransmitter
TokenTransimitter thread transmits the token to the next member in the logical ring as well as it receives token from the previous member in the ring. |
|
| 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. |
|
| TP.Bundler
|
|
| TP.Bundler.BundlingTimer
|
|
| TP.DiagnosticsHandler
|
|
| TP.IncomingMessageHandler
|
|
| TP.IncomingPacketHandler
This thread fetches byte buffers from the packet_queue, converts them into messages and passes them up to the higher layer (done in handleIncomingUdpPacket()). |
|
| TP.OutgoingPacketHandler
This thread fetches byte buffers from the outgoing_packet_queue, converts them into messages and sends them using the unicast or multicast socket |
|
| TpHeader
Generic transport header, used by TP. |
|
| TransportedVectorTime
Lighweight representation of the VectorTime clock suitable for network transport |
|
| TUNNEL.Reconnector
|
|
| UDP_NIO.Connector
Manages a multicast and unicast socket on a given interface (NIC). |
|
| UDP_NIO.Connector.SenderThread
|
|
| UDP_NIO.ConnectorTable
Manages a bunch of Connectors |
|
| UDP_NIO.PacketHandler
This thread fetches byte buffers from the packet_queue, converts them into messages and passes them up to the higher layer (done in handleIncomingUdpPacket()). |
|
| UDP_NIO.Unmarshaller
|
|
| UDP.UcastReceiver
|
|
| UdpHeader
|
|
| VectorTime
Vector timestamp used in CAUSAL order protocol stack |
|
| VIEW_SYNC.ViewSendTask
Periodically multicasts a View_SYNC message |
|
|
|||||||||
| Home >> All >> org >> jgroups >> [ protocols overview ] | PREV NEXT | ||||||||