Uses of Class
org.jgroups.util.Table
-
Packages that use Table Package Description org.jgroups.protocols Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.org.jgroups.protocols.pbcast -
-
Uses of Table in org.jgroups.protocols
Fields in org.jgroups.protocols declared as Table Modifier and Type Field Description protected Table<Message>
UNICAST3.Entry. msgs
protected Table<Message>
SEQUENCER2. received_msgs
Methods in org.jgroups.protocols that return Table Modifier and Type Method Description protected Table
UNICAST3. createTable(long seqno)
Methods in org.jgroups.protocols with parameters of type Table Modifier and Type Method Description protected void
UNICAST3. processInternalMessage(Table<Message> win, Address sender)
protected void
SEQUENCER2. removeAndDeliver(Table<Message> win, Address sender)
protected void
UNICAST3. removeAndDeliver(Table<Message> win, Address sender)
Try to remove as many messages as possible from the table as pass them up.Method parameters in org.jgroups.protocols with type arguments of type Table Modifier and Type Method Description protected static int
UNICAST3. accumulate(java.util.function.ToIntFunction<Table> func, java.util.Collection<? extends UNICAST3.Entry>... entries)
Constructors in org.jgroups.protocols with parameters of type Table Constructor Description Entry(short conn_id, Table<Message> msgs)
ReceiverEntry(Table<Message> received_msgs, short recv_conn_id)
-
Uses of Table in org.jgroups.protocols.pbcast
Fields in org.jgroups.protocols.pbcast with type parameters of type Table Modifier and Type Field Description protected java.util.concurrent.ConcurrentMap<Address,Table<Message>>
NAKACK2. xmit_table
Map to store sent and received messages (keyed by sender)Methods in org.jgroups.protocols.pbcast that return Table Modifier and Type Method Description protected Table<Message>
NAKACK2. createTable(long initial_seqno)
Table<Message>
NAKACK2. getWindow(Address sender)
Returns the receive window for sender; only used for testing.Methods in org.jgroups.protocols.pbcast with parameters of type Table Modifier and Type Method Description protected void
NAKACK2. removeAndDeliver(Table<Message> buf, Address sender, boolean loopback, AsciiString cluster_name)
Efficient way of checking whether another thread is already processing messages from sender.protected static long
NAKACK2. sizeOfAllMessages(Table<Message> buf, boolean include_headers)
-