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.ReceiverEntry.received_msgs |
protected Table<Message> |
UNICAST.ReceiverEntry.received_msgs |
protected Table<Message> |
UNICAST2.ReceiverEntry.received_msgs |
Modifier and Type | Method and Description |
---|---|
protected int |
UNICAST3.removeAndDeliver(AtomicBoolean processing,
Table<Message> win,
Address sender)
Try to remove as many messages as possible from the table as pass them up.
|
protected int |
UNICAST.removeAndDeliver(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)
Try to remove as many messages as possible and pass them up.
|
Constructor and Description |
---|
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 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,
String 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 © 2015 JBoss, a division of Red Hat. All rights reserved.