Uses of Class
org.jgroups.util.Buffer
-
Packages that use Buffer Package Description org.jgroups.protocols Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.org.jgroups.util Provides useful functionality which cannot be assigned to any particular other package. -
-
Uses of Buffer in org.jgroups.protocols
Fields in org.jgroups.protocols declared as Buffer Modifier and Type Field Description protected Buffer<Message>
ReliableMulticast.Entry. buf
protected Buffer<Message>
ReliableUnicast.Entry. buf
protected Buffer<Message>
ReliableMulticast. local_xmit_table
Methods in org.jgroups.protocols with type parameters of type Buffer Modifier and Type Method Description <T extends Buffer<Message>>
TReliableMulticast. getBuf(Address sender)
Returns the receive window for sender; only used for testing.Methods in org.jgroups.protocols that return Buffer Modifier and Type Method Description protected Buffer<Message>
ReliableMulticast.Entry. buf()
Buffer<Message>
ReliableUnicast.Entry. buf()
protected abstract Buffer<Message>
ReliableUnicast. createBuffer(long initial_seqno)
protected Buffer<Message>
UNICAST4. createBuffer(long seqno)
protected Buffer<Message>
NAKACK3. createXmitWindow(long initial_seqno)
protected Buffer<Message>
NAKACK4. createXmitWindow(long initial_seqno)
protected abstract Buffer<Message>
ReliableMulticast. createXmitWindow(long initial_seqno)
protected Buffer<Message>
ReliableMulticast. sendBuf()
Methods in org.jgroups.protocols with parameters of type Buffer Modifier and Type Method Description protected boolean
NAKACK4. addToSendBuffer(Buffer<Message> win, long seq, Message msg, java.util.function.Predicate<Message> filter, boolean dont_block)
protected boolean
ReliableMulticast. addToSendBuffer(Buffer<Message> win, long seq, Message msg, java.util.function.Predicate<Message> filter, boolean dont_block)
Adds the message to the send buffer.protected boolean
ReliableUnicast. addToSendBuffer(Buffer<Message> win, long seq, Message msg, java.util.function.Predicate<Message> filter, boolean dont_block)
Adds the message to the send buffer.protected void
ReliableMulticast. removeAndDeliver(Buffer<Message> win, ReliableMulticast.Entry e, Address sender, boolean loopback, AsciiString cluster)
Efficient way of checking whether another thread is already processing messages from sender.protected void
ReliableMulticast. send(Message msg, Buffer<Message> win, boolean dont_loopback_set)
protected void
NAKACK4. sendAck(Address to, Buffer<Message> win)
protected void
ReliableMulticast. sendAck(Address to, Buffer<Message> win)
protected static long
ReliableMulticast. sizeOfAllMessages(Buffer<Message> win, boolean include_headers)
Method parameters in org.jgroups.protocols with type arguments of type Buffer Modifier and Type Method Description protected static int
ReliableUnicast. accumulate(java.util.function.ToIntFunction<Buffer<Message>> func, java.util.Collection<? extends ReliableUnicast.Entry>... entries)
Constructors in org.jgroups.protocols with parameters of type Buffer Constructor Description Entry(Buffer<Message> buf)
Entry(short conn_id, Buffer<Message> buf)
ReceiverEntry(Buffer<Message> received_msgs, short recv_conn_id, Address real_dest)
-
Uses of Buffer in org.jgroups.util
Subclasses of Buffer in org.jgroups.util Modifier and Type Class Description class
DynamicBuffer<T>
Copy ofTable
.class
FixedBuffer<T>
Ring buffer of fixed capacity.Methods in org.jgroups.util that return Buffer Modifier and Type Method Description Buffer<T>
Buffer. highestDelivered(long seqno)
Only used internally on a state transfer (setting the digest).
-