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 |
Supports probabilistic broadcasts.
|
Modifier and Type | Field and Description |
---|---|
protected Table<Message> |
UNICAST3.Entry.msgs |
protected Table<Message> |
UNICAST.ReceiverEntry.received_msgs |
protected Table<Message> |
SEQUENCER2.received_msgs |
protected Table<Message> |
UNICAST2.ReceiverEntry.received_msgs |
Modifier and Type | Method and Description |
---|---|
protected void |
UNICAST3.processInternalMessage(Table<Message> win,
Address sender) |
protected int |
UNICAST.removeAndDeliver(java.util.concurrent.atomic.AtomicBoolean processing,
Table<Message> win,
Address sender)
Deprecated.
Try to remove as many messages as possible from the table as pass them up.
|
protected void |
SEQUENCER2.removeAndDeliver(java.util.concurrent.atomic.AtomicBoolean processing,
Table<Message> win,
Address sender) |
protected void |
UNICAST3.removeAndDeliver(java.util.concurrent.atomic.AtomicBoolean processing,
Table<Message> win,
Address sender)
Try to remove as many messages as possible from the table as pass them up.
|
protected void |
UNICAST2.removeAndPassUp(Table<Message> win,
Address sender)
Deprecated.
Try to remove as many messages as possible and pass them up.
|
Constructor and Description |
---|
Entry(short conn_id,
Table<Message> msgs) |
ReceiverEntry(Table<Message> received_msgs,
short recv_conn_id) |
ReceiverEntry(Table<Message> received_msgs,
short recv_conn_id) |
ReceiverEntry(Table<Message> received_msgs,
short recv_conn_id) |
Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.ConcurrentMap<Address,Table<Message>> |
NAKACK2.xmit_table
Map to store sent and received messages (keyed by sender)
|
Modifier and Type | Method and 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.
|
Modifier and Type | Method and Description |
---|---|
protected void |
NAKACK2.removeAndPassUp(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) |
Copyright © 1998-2020 Red Hat. All Rights Reserved.