Uses of Package
org.jgroups.util

Packages that use org.jgroups.util
Package
Description
Provides top-level public JGroups classes such as Channel, Message, etc.
 
Provides building blocks that are layered on top of channels.
 
 
 
Provides ways to configure a protocol stack.
Provides demonstrations of JGroups functionality.
 
Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.
Supports probabilistic broadcasts.
Support for managing protocol stacks.
Provides useful functionality which cannot be assigned to any particular other package.
  • Classes in org.jgroups.util used by org.jgroups
    Class
    Description
    Buffer with an offset and length.
    Open addressing based implementation of a hashmap (not supporting the Map interface though) for message headers.
    Factory to create various types of sockets.
    Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
  • Class
    Description
    Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
  • Class
    Description
    Buffer with an offset and length.
    The Command patttern (see Gamma et al.).
    A listener that is called back when a future is done.
    A sub-interface of a Future, that allows for listeners to be attached so that observers can be notified when the future completes.
    Allows a thread to submit an asynchronous request and to wait for the result.
    class that represents a response from a communication
    Contains responses from all members.
    Factory to create various types of sockets.
    Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
     
  • Class
    Description
    A listener that is called back when a future is done.
    A sub-interface of a Future, that allows for listeners to be attached so that observers can be notified when the future completes.
    Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
  • Class
    Description
    Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
  • Class
    Description
    Simple class that holds an immutable reference to another object (or to null).
    Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
  • Class
    Description
    Holds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate holder object for the values, and don't want to pass the values as a list or array.
  • Class
    Description
    Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
  • Class
    Description
    Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
  • Class
    Description
    Cache which removes its elements after a certain time
     
    A bounded subclass of LinkedList, oldest elements are removed once max capacity is exceeded.
    Buffer with an offset and length.
    Maintains credits for senders, when credits fall below 0, a sender blocks until new credits have been received.
    Allows a thread to submit an asynchronous request and to wait for the result.
    Factory to create various types of sockets.
    Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
     
    Timer-like interface which allows for execution of tasks.
    Logical address which is unique over space and time.
  • Class
    Description
    Collects acks from a number of nodes, waits for all acks.
    A bounded subclass of LinkedList, oldest elements are removed once max capacity is exceeded.
    A message digest, which is used by the PBCAST layer for gossiping (also used by NAKACK for keeping track of current seqnos for all members).
    ID to uniquely identify a merge
     
    Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
    Timer-like interface which allows for execution of tasks.
  • Class
    Description
    Keeps track of a single message to retransmit
    Factory to create various types of sockets.
     
    Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
     
    Timer-like interface which allows for execution of tasks.
    Holds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate holder object for the values, and don't want to pass the values as a list or array.
  • Class
    Description
    Subclass of UUID which adds a string as payload.
     
    Buffer with an offset and length.
    Thread factory mainly responsible for naming of threads.
    A message digest, which is used by the PBCAST layer for gossiping (also used by NAKACK for keeping track of current seqnos for all members).
    Class keeping track of the lowest and highest sequence numbers delivered, and the highest sequence numbers received, per member.
    Extends ByteArrayOutputStream, but exposes the internal buffer.
     
    A listener that is called back when a future is done.
    Simple task wrapper, always executed by at most 1 thread.
    Open addressing based implementation of a hashmap (not supporting the Map interface though) for message headers.
    ID to uniquely identify a merge
    A sub-interface of a Future, that allows for listeners to be attached so that observers can be notified when the future completes.
    Subclass of UUID which adds a string as payload.
    Elements are added at the tail and removed from the head.
     
     
    class that represents a response from a communication
    Contains responses from all members.
    Keeps track of a single message to retransmit
    Factory to create various types of sockets.
     
    Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
    An object that can alter the state of a thread when it receives a callback from a ThreadManager notifying it that the thread has been created or released from use.
     
    An object that manages threads and provides callbacks to a ThreadDecorator to allow it to alter their state.
    Timer-like interface which allows for execution of tasks.
    Simple task wrapper, always executed by at most 1 thread.
    Subclass of UUID which adds 3 strings (siteId, rackId and machineId)as payload.
    Holds 3 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate holder object for the values, and don't want to pass the values as a list or array.
    Holds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate holder object for the values, and don't want to pass the values as a list or array.
     
    Logical address which is unique over space and time.