Package org.jgroups.util


package org.jgroups.util
Provides useful functionality which cannot be assigned to any particular other package.
  • 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.
    The Command patttern (see Gamma et al.).
    ObjectInputStream which sets a contact classloader for reading bytes into objects.
    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.
     
    Blocking queue which can only process 1 message per service concurrently, establishing FIFO order per sender.
    Lists all network interfaces on a system
    Open addressing based implementation of a hashmap (not supporting the Map interface though) for message headers.
    Lazily names threads: whenever the address or cluster name is changed, all threads are renamed
    Uses magic numbers for class descriptors
    Uses magic numbers for class descriptors
    Title: JGroups Communications Description: Contact me at mail@filip.net Copyright: Copyright (c) 2002 Company: www.filip.net
    A mutable version of Digest (which is immutable
    Maintains a pool of ExposedDataOutputStreams.
    Maintains a list of ports used on this host, associated with time stamps.
    Allows a thread to submit an asynchronous request and to wait for the result.
    Redirects incoming TCP connections to other hosts/ports.
    Elements are added at the tail and removed from the head.
     
     
    Similar to AckCollector, but collects responses, not just acks.
    Reusable thread class.
    class that represents a response from a communication
    Contains responses from all members.
    Implementation of a priority scheduler.
     
    Provides callback for use with a Scheduler.
    Maintains the highest received and highest delivered seqno per member
    ShutdownRejectedExecutionHandler is a decorator RejectedExecutionHandler used in all JGroups ThreadPoolExecutor(s).
    Queue as described in http://jira.jboss.com/jira/browse/JGRP-376.
    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.
    ThreadPoolExecutor subclass that implements @{link ThreadManager}.
    Maintains a set of ReusableThreads.
    Waits until the buffer has been written to the output stream, or until timeout msecs have elapsed, whichever comes first.
    Fixed-delay invalid input: '&' fixed-rate single thread scheduler
    The interface that submitted tasks must implement
    Triple<V1,V2,V3>
    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.
    Tuple<V1,V2>
    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.
    Vector which cannot be modified
    Collection of various utility routines that can not be assigned to other classes.