Index

Overview

Package

Class

Use

Deprecated

Index

Home >> All >> org >> jgroups >> [ util overview ]

PREV NEXT

A B C D E F G H I L M N O P Q R S T U V W _

A

AckCollector - class org.jgroups.util.AckCollector.
AckCollector() - Constructor for class org.jgroups.util.AckCollector
AckCollector(ViewId, List) - Constructor for class org.jgroups.util.AckCollector
ack(Object) - Method in class org.jgroups.util.AckCollector
acquire() - Method in class org.jgroups.util.NullSync
activeThreads() - Static method in class org.jgroups.util.Util
add(Object) - Method in class org.jgroups.util.BoundedList: Adds an element at the tail.
add(Object) - Method in class org.jgroups.util.LinkedListQueue: adds an object to the tail of this queue If the queue has been closed with close(true) no exception will be thrown if the queue has not been flushed yet.
add(Object) - Method in class org.jgroups.util.List: Adds an object at the tail of the list.
add(Object) - Method in class org.jgroups.util.Queue: adds an object to the tail of this queue If the queue has been closed with close(true) no exception will be thrown if the queue has not been flushed yet.
add(Object) - Method in class org.jgroups.util.Queue2: adds an object to the tail of this queue If the queue has been closed with close(true) no exception will be thrown if the queue has not been flushed yet.
add(Runnable) - Method in class org.jgroups.util.Scheduler
add(TimeScheduler.IntTask) - Method in class org.jgroups.util.TimeScheduler.TaskQueue
add(TimeScheduler.Task, boolean) - Method in class org.jgroups.util.TimeScheduler: Add a task for execution at adjustable intervals
add(TimeScheduler.Task) - Method in class org.jgroups.util.TimeScheduler: Add a task for execution at adjustable intervals
addAll(Collection) - Method in class org.jgroups.util.Queue
addAll(List) - Method in class org.jgroups.util.Queue
addAtHead(Object) - Method in class org.jgroups.util.BoundedList: Adds an object to the head, removes an element from the tail if capacity has been exceeded
addAtHead(Object) - Method in class org.jgroups.util.LinkedListQueue: Adds a new object to the head of the queue basically (obj.equals(LinkedListQueue.remove(LinkedListQueue.add(obj)))) returns true If the queue has been closed with close(true) no exception will be thrown if the queue has not been flushed yet.
addAtHead(Object) - Method in class org.jgroups.util.List: Adds an object at the head of the list.
addAtHead(Object) - Method in class org.jgroups.util.Queue: Adds a new object to the head of the queue basically (obj.equals(queue.remove(queue.add(obj)))) returns true If the queue has been closed with close(true) no exception will be thrown if the queue has not been flushed yet.
addAtHead(Object) - Method in class org.jgroups.util.Queue2: Adds a new object to the head of the queue basically (obj.equals(queue.remove(queue.add(obj)))) returns true If the queue has been closed with close(true) no exception will be thrown if the queue has not been flushed yet.
addInternal(Object) - Method in class org.jgroups.util.Queue
addListener(Proxy.Relayer.Listener) - Method in class org.jgroups.util.Proxy.Relayer
addNotReceived(Address) - Method in class org.jgroups.util.RspList
addPrio(Runnable) - Method in class org.jgroups.util.Scheduler
addRsp(Address, Object) - Method in class org.jgroups.util.RspList
addSuspect(Address) - Method in class org.jgroups.util.RspList
add_condvar - Variable in class org.jgroups.util.Queue2: Signals to listeners when an element has been added
all_acks_received - Variable in class org.jgroups.util.AckCollector
array2String(long[]) - Static method in class org.jgroups.util.Util
array2String(int[]) - Static method in class org.jgroups.util.Util
array2String(boolean[]) - Static method in class org.jgroups.util.Util
assignTask(Runnable) - Method in class org.jgroups.util.ReusableThread: Assigns a task to the thread.
attempt(long) - Method in class org.jgroups.util.NullSync
available() - Method in class org.jgroups.util.ReusableThread
available_threads - Variable in class org.jgroups.util.ThreadPool

B

BUFSIZE - Static variable in class org.jgroups.util.Proxy
BoundedList - class org.jgroups.util.BoundedList.: A bounded subclass of List, oldest elements are removed once max capacity is exceeded
BoundedList() - Constructor for class org.jgroups.util.BoundedList
BoundedList(int) - Constructor for class org.jgroups.util.BoundedList
Buffer - class org.jgroups.util.Buffer.: Buffer with an offset and length.
Buffer(byte[], int, int) - Constructor for class org.jgroups.util.Buffer
bottom() - Method in class org.jgroups.util.Stack
buf - Variable in class org.jgroups.util.Buffer
buf - Variable in class org.jgroups.util.TimedWriter.WriterThread
byteBufferToMessageList(byte[], int, int) - Static method in class org.jgroups.util.Util

C

Command - interface org.jgroups.util.Command.: The Command patttern (see Gamma et al.).
CondVar - class org.jgroups.util.CondVar.: Class that checks on a condition and - if condition doesn't match the expected result - waits until the result matches the expected result, or a timeout occurs.
CondVar(String, Object) - Constructor for class org.jgroups.util.CondVar
CondVar(String, Object, Object) - Constructor for class org.jgroups.util.CondVar
ContextObjectInputStream - class org.jgroups.util.ContextObjectInputStream.: ObjectInputStream which sets a contact classloader for reading bytes into objects.
ContextObjectInputStream(InputStream) - Constructor for class org.jgroups.util.ContextObjectInputStream: Creates a new instance of MarshalledValueOutputStream
cancelled() - Method in interface org.jgroups.util.TimeScheduler.Task
check(URI) - Method in class org.jgroups.util.Proxy: Checks whether a URI is http(s)://:
checkForLinux() - Static method in class org.jgroups.util.Util
checkForSolaris() - Static method in class org.jgroups.util.Util
checkForWindows() - Static method in class org.jgroups.util.Util
classCache - Static variable in class org.jgroups.util.ContextObjectInputStream: A class wide cache of proxy classes populated by resolveProxyClass
clear() - Method in class org.jgroups.util.TimeScheduler.TaskQueue
clone() - Method in class org.jgroups.util.List
close(boolean) - Method in class org.jgroups.util.LinkedListQueue: Marks the queues as closed.
close(Selector, SocketChannel, SocketChannel) - Method in class org.jgroups.util.Proxy
close(Socket, Socket) - Static method in class org.jgroups.util.Proxy
close(Socket) - Static method in class org.jgroups.util.Proxy
close(boolean) - Method in class org.jgroups.util.Queue: Marks the queues as closed.
close(boolean) - Method in class org.jgroups.util.Queue2: Marks the queues as closed.
closeInputStream(InputStream) - Static method in class org.jgroups.util.Util
closeOutputStream(OutputStream) - Static method in class org.jgroups.util.Util
closed - Variable in class org.jgroups.util.LinkedListQueue
closed() - Method in class org.jgroups.util.LinkedListQueue: returns true if the Queue has been closed however, this method will return false if the queue has been closed using the close(true) method and the last element has yet not been received.
closed - Variable in class org.jgroups.util.Queue
closed() - Method in class org.jgroups.util.Queue: returns true if the Queue has been closed however, this method will return false if the queue has been closed using the close(true) method and the last element has yet not been received.
closed - Variable in class org.jgroups.util.Queue2
closed() - Method in class org.jgroups.util.Queue2: returns true if the Queue has been closed however, this method will return false if the queue has been closed using the close(true) method and the last element has yet not been received.
collectionToByteBuffer(Collection) - Static method in class org.jgroups.util.Util
compareTo(Object) - Method in class org.jgroups.util.TimeScheduler.IntTask
completed - Variable in class org.jgroups.util.TimedWriter
computeFragOffsets(int, int, int) - Static method in class org.jgroups.util.Util: Given a buffer and a fragmentation size, compute a list of fragmentation offset/length pairs, and return them in a list.
computeFragOffsets(byte[], int) - Static method in class org.jgroups.util.Util
concurrent_processing - Variable in class org.jgroups.util.Scheduler: Process items on the queue concurrently.
cond - Variable in class org.jgroups.util.CondVar
conf - Static variable in class org.jgroups.util.MagicObjectInputStream
conf - Static variable in class org.jgroups.util.MagicObjectOutputStream
connectionClosed() - Method in class org.jgroups.util.Proxy.Connection
connectionClosed() - Method in interface org.jgroups.util.Proxy.Relayer.Listener
contains(Object) - Method in class org.jgroups.util.List
contains(Address) - Method in class org.jgroups.util.RspList
copy() - Method in class org.jgroups.util.Buffer
copy() - Method in class org.jgroups.util.List
copy() - Method in class org.jgroups.util.Stack
crash() - Static method in class org.jgroups.util.Util
createDatagramSocket(InetAddress, int) - Static method in class org.jgroups.util.Util: Creates a DatagramSocket bound to addr.
createSSLServerSocket(InetSocketAddress) - Method in class org.jgroups.util.Proxy.SocketAcceptor
createSSLSocket(InetSocketAddress) - Method in class org.jgroups.util.Proxy.SocketAcceptor
createServerSocket(InetSocketAddress) - Method in class org.jgroups.util.Proxy.SocketAcceptor
createServerSocket(int) - Static method in class org.jgroups.util.Util: Finds first available port starting at start_port and returns server socket
createServerSocket(InetAddress, int) - Static method in class org.jgroups.util.Util
createSocket(InetSocketAddress) - Method in class org.jgroups.util.Proxy.SocketAcceptor
createSocket(InetAddress, InetAddress, int, long) - Method in class org.jgroups.util.TimedWriter: Tries to create a socket to remote_peer:remote_port.
curr - Variable in class org.jgroups.util.List.ListEnumerator
current_index - Variable in class org.jgroups.util.ThreadPool
current_task - Variable in class org.jgroups.util.Scheduler

D

DIAG_GROUP - Static variable in class org.jgroups.util.Util
debug - Static variable in class org.jgroups.util.Proxy
debug() - Method in class org.jgroups.util.Queue2: Dumps internal state @remove
decrementSize() - Method in class org.jgroups.util.Queue: Doesn't need to be synchronized; is always called from synchronized methods
decrementSize() - Method in class org.jgroups.util.Queue2
defragmentBuffer(byte[][]) - Static method in class org.jgroups.util.Util: Concatenates smaller fragments into entire buffers.
deletePool() - Method in class org.jgroups.util.ThreadPool
dest - Variable in class org.jgroups.util.Proxy.SocketAcceptor
destroy() - Method in class org.jgroups.util.ThreadPool
determineLeftMembers(Vector, Vector) - Static method in class org.jgroups.util.Util: Returns all members that left between 2 views.
doWait() - Method in class org.jgroups.util.CondVar
doWait(long) - Method in class org.jgroups.util.CondVar
doWait() - Method in class org.jgroups.util.Promise
doWait(long) - Method in class org.jgroups.util.Promise
done() - Method in class org.jgroups.util.ReusableThread
doubleWrite(byte[], OutputStream) - Static method in class org.jgroups.util.Util: Makes sure that we detect when a peer connection is in the closed state (not closed while we send data, but before we send data).
doubleWrite(byte[], int, int, OutputStream) - Static method in class org.jgroups.util.Util: Makes sure that we detect when a peer connection is in the closed state (not closed while we send data, but before we send data).
dump() - Method in class org.jgroups.util.List
dumpQueue(Queue) - Static method in class org.jgroups.util.Util: Debugging method used to dump the content of a protocol queue in a condensed form.
dumpStack(boolean) - Static method in class org.jgroups.util.Util
dumpTaskQueue() - Method in class org.jgroups.util.TimeScheduler

E

ExposedBufferedInputStream - class org.jgroups.util.ExposedBufferedInputStream.
ExposedBufferedInputStream(InputStream) - Constructor for class org.jgroups.util.ExposedBufferedInputStream: Creates a BufferedInputStream and saves its argument, the input stream in, for later use.
ExposedBufferedInputStream(InputStream, int) - Constructor for class org.jgroups.util.ExposedBufferedInputStream: Creates a BufferedInputStream with the specified buffer size, and saves its argument, the input stream in, for later use.
ExposedBufferedOutputStream - class org.jgroups.util.ExposedBufferedOutputStream.
ExposedBufferedOutputStream(OutputStream) - Constructor for class org.jgroups.util.ExposedBufferedOutputStream: Creates a new buffered output stream to write data to the specified underlying output stream.
ExposedBufferedOutputStream(OutputStream, int) - Constructor for class org.jgroups.util.ExposedBufferedOutputStream: Creates a new buffered output stream to write data to the specified underlying output stream with the specified buffer size.
ExposedByteArrayInputStream - class org.jgroups.util.ExposedByteArrayInputStream.
ExposedByteArrayInputStream(byte[]) - Constructor for class org.jgroups.util.ExposedByteArrayInputStream: Creates a ByteArrayInputStream so that it uses buf as its buffer array.
ExposedByteArrayInputStream(byte[], int, int) - Constructor for class org.jgroups.util.ExposedByteArrayInputStream: Creates ByteArrayInputStream that uses buf as its buffer array.
ExposedByteArrayOutputStream - class org.jgroups.util.ExposedByteArrayOutputStream.: Extends ByteArrayOutputStream, but exposes the internal buffer.
ExposedByteArrayOutputStream() - Constructor for class org.jgroups.util.ExposedByteArrayOutputStream
ExposedByteArrayOutputStream(int) - Constructor for class org.jgroups.util.ExposedByteArrayOutputStream
ExposedDataOutputStream - class org.jgroups.util.ExposedDataOutputStream.
ExposedDataOutputStream(OutputStream) - Constructor for class org.jgroups.util.ExposedDataOutputStream: Creates a new data output stream to write data to the specified underlying output stream.
elementAt(int) - Method in class org.jgroups.util.RspList
elements() - Method in class org.jgroups.util.List
empty() - Method in class org.jgroups.util.Stack
endMarker - Static variable in class org.jgroups.util.LinkedListQueue: if the queue closes during the runtime an endMarker object is added to the end of the queue to indicate that the queue will close automatically when the end marker is encountered This allows for a "soft" close.
endMarker - Static variable in class org.jgroups.util.Queue: if the queue closes during the runtime an endMarker object is added to the end of the queue to indicate that the queue will close automatically when the end marker is encountered This allows for a "soft" close.
endMarker - Static variable in class org.jgroups.util.Queue2: if the queue closes during the runtime an endMarker object is added to the end of the queue to indicate that the queue will close automatically when the end marker is encountered This allows for a "soft" close.
execute() - Method in interface org.jgroups.util.Command
executor - Variable in class org.jgroups.util.Proxy

F

f - Static variable in class org.jgroups.util.Util
fileExists(String) - Static method in class org.jgroups.util.Util
find(Address) - Method in class org.jgroups.util.RspList
fragmentBuffer(byte[], int, int) - Static method in class org.jgroups.util.Util: Fragments a byte buffer into smaller fragments of (max.) frag_size.
fragmentBuffer(byte[], int) - Static method in class org.jgroups.util.Util

G

GetNetworkInterfaces - class org.jgroups.util.GetNetworkInterfaces.: Lists all network interfaces on a system
GetNetworkInterfaces() - Constructor for class org.jgroups.util.GetNetworkInterfaces
get() - Method in class org.jgroups.util.CondVar
get(Address) - Method in class org.jgroups.util.RspList
getAllAvailableInterfaces() - Static method in class org.jgroups.util.Util
getBuf() - Method in class org.jgroups.util.Buffer
getCapacity() - Method in class org.jgroups.util.ExposedByteArrayOutputStream
getConcurrentProcessing() - Method in class org.jgroups.util.Scheduler
getContents() - Method in class org.jgroups.util.LinkedListQueue: returns a vector with all the objects currently in the queue
getContents() - Method in class org.jgroups.util.List
getContents() - Method in class org.jgroups.util.Queue2: returns a vector with all the objects currently in the queue
getFirst() - Method in class org.jgroups.util.Queue: Returns the first element.
getFirst() - Method in class org.jgroups.util.Queue2: Returns the first element.
getFirst() - Method in class org.jgroups.util.RspList
getFirst() - Method in class org.jgroups.util.TimeScheduler.TaskQueue
getFirstNonLoopbackAddress() - Static method in class org.jgroups.util.Util
getHostname() - Static method in class org.jgroups.util.Util
getJavaVersion() - Static method in class org.jgroups.util.Util
getLast() - Method in class org.jgroups.util.Queue: Returns the last element.
getLast() - Method in class org.jgroups.util.Queue2: Returns the last element.
getLength() - Method in class org.jgroups.util.Buffer
getLock() - Method in class org.jgroups.util.CondVar
getMissing() - Method in class org.jgroups.util.AckCollector
getOffset() - Method in class org.jgroups.util.Buffer
getRawBuffer() - Method in class org.jgroups.util.ExposedByteArrayOutputStream
getReceived() - Method in class org.jgroups.util.AckCollector
getResourceAsStream(String, Class) - Static method in class org.jgroups.util.Util
getResult() - Method in class org.jgroups.util.Promise
getResult(long) - Method in class org.jgroups.util.Promise: Returns the result, but never throws a TimeoutException; returns null instead.
getResultWithTimeout(long) - Method in class org.jgroups.util.Promise: Blocks until a result is available, or timeout milliseconds have elapsed
getResults() - Method in class org.jgroups.util.RspList: Returns the results from non-suspected members that are not null.
getSender() - Method in class org.jgroups.util.Rsp
getStackTrace(Throwable) - Static method in class org.jgroups.util.Util
getSuspectedMembers() - Method in class org.jgroups.util.RspList
getSuspendInterval() - Method in class org.jgroups.util.TimeScheduler
getThread() - Method in class org.jgroups.util.ThreadPool
getValue() - Method in class org.jgroups.util.Rsp
getViewId() - Method in class org.jgroups.util.AckCollector

H

handleConnection(SocketChannel, SocketChannel) - Method in class org.jgroups.util.Proxy
handleView(View) - Method in class org.jgroups.util.AckCollector
hasMoreElements() - Method in class org.jgroups.util.List.ListEnumerator
hasResult - Variable in class org.jgroups.util.Promise
hasResult() - Method in class org.jgroups.util.Promise: Checks whether result is available.
head - Variable in class org.jgroups.util.List
head - Variable in class org.jgroups.util.Queue
head - Variable in class org.jgroups.util.Queue2
help() - Static method in class org.jgroups.util.Proxy
high - Variable in class org.jgroups.util.Range

I

IGNORE_BIND_ADDRESS_PROPERTY - Static variable in class org.jgroups.util.Util
i - Variable in class org.jgroups.util.TimedWriter.WriterThread
in - Variable in class org.jgroups.util.Proxy.Relayer
in_sock - Variable in class org.jgroups.util.Proxy.Relayer
in_to_out - Variable in class org.jgroups.util.Proxy.Connection
isAlive() - Method in class org.jgroups.util.ReusableThread
isBindAddressPropertyIgnored() - Static method in class org.jgroups.util.Util
isEmpty() - Method in class org.jgroups.util.TimeScheduler.TaskQueue
isReceived(Address) - Method in class org.jgroups.util.RspList
isSuspected(Address) - Method in class org.jgroups.util.RspList
is_ssl - Variable in class org.jgroups.util.Proxy.MyInetSocketAddress

L

LinkedListQueue - class org.jgroups.util.LinkedListQueue.: LinkedListQueue implementation based on java.util.Queue.
LinkedListQueue() - Constructor for class org.jgroups.util.LinkedListQueue: creates an empty queue
List - class org.jgroups.util.List.: Doubly-linked list.
List() - Constructor for class org.jgroups.util.List
List.Element - class org.jgroups.util.List.Element.
List.Element(Object) - Constructor for class org.jgroups.util.List.Element
List.ListEnumerator - class org.jgroups.util.List.ListEnumerator.
List.ListEnumerator(List.Element) - Constructor for class org.jgroups.util.List.ListEnumerator
l - Variable in class org.jgroups.util.LinkedListQueue
length - Variable in class org.jgroups.util.Buffer
listener - Variable in class org.jgroups.util.Scheduler
listeners - Variable in class org.jgroups.util.Proxy.Relayer
loadClass(String, Class) - Static method in class org.jgroups.util.Util: Tries to load the class from the current thread's context class loader.
local - Variable in class org.jgroups.util.Proxy
local - Variable in class org.jgroups.util.TimedWriter.SocketCreator
local_port - Variable in class org.jgroups.util.Proxy
lock - Variable in class org.jgroups.util.CondVar
lock() - Method in class org.jgroups.util.ReentrantLatch: Lock the latch.
locked - Variable in class org.jgroups.util.ReentrantLatch
log - Static variable in class org.jgroups.util.ExposedBufferedInputStream
log - Static variable in class org.jgroups.util.LinkedListQueue
log - Static variable in class org.jgroups.util.MagicObjectInputStream
log - Static variable in class org.jgroups.util.MagicObjectOutputStream
log(String, String) - Static method in class org.jgroups.util.Proxy
log(String) - Static method in class org.jgroups.util.Proxy
log - Static variable in class org.jgroups.util.Queue
log - Static variable in class org.jgroups.util.Queue2
log - Static variable in class org.jgroups.util.ReusableThread
log - Static variable in class org.jgroups.util.Scheduler
log - Static variable in class org.jgroups.util.ThreadPool
log - Static variable in class org.jgroups.util.TimeScheduler
log - Static variable in class org.jgroups.util.TimedWriter
loop(Selector) - Method in class org.jgroups.util.Proxy: We handle only non-SSL connections
low - Variable in class org.jgroups.util.Range

M

MAX_NUM - Variable in class org.jgroups.util.ThreadPool

MAX_PORT - Static variable in class org.jgroups.util.Util

MAX_THREAD_POOL_SIZE - Static variable in class org.jgroups.util.Proxy

MagicObjectInputStream - class org.jgroups.util.MagicObjectInputStream.

Uses magic numbers for class descriptors

MagicObjectInputStream(InputStream) - Constructor for class org.jgroups.util.MagicObjectInputStream

MagicObjectOutputStream - class org.jgroups.util.MagicObjectOutputStream.

Uses magic numbers for class descriptors

MagicObjectOutputStream(OutputStream) - Constructor for class org.jgroups.util.MagicObjectOutputStream

Marshaller - class org.jgroups.util.Marshaller.

Marshaller() - Constructor for class org.jgroups.util.Marshaller

mConfigurator - Static variable in class org.jgroups.util.Marshaller

The class configurator maps classes to magic numbers

main(String[]) - Static method in class org.jgroups.util.GetNetworkInterfaces

main(String[]) - Static method in class org.jgroups.util.List

main(String[]) - Static method in class org.jgroups.util.Proxy

main(String[]) - Static method in class org.jgroups.util.TimedWriter

main(String[]) - Static method in class org.jgroups.util.Util

mapping_file - Variable in class org.jgroups.util.Proxy

mappings - Variable in class org.jgroups.util.Proxy

match(Object, Object) - Method in class org.jgroups.util.CondVar

match(Object, Object) - Static method in class org.jgroups.util.Util

match(long[], long[]) - Static method in class org.jgroups.util.Util

max_capacity - Variable in class org.jgroups.util.BoundedList

memStats(boolean) - Static method in class org.jgroups.util.Util

missing_acks - Variable in class org.jgroups.util.AckCollector

List