程序包 | 说明 |
---|---|
com.fr.third.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
com.fr.third.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
com.fr.third.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
限定符和类型 | 方法和说明 |
---|---|
protected void |
UNICAST3.handleXmitRequest(Address sender,
SeqnoList missing) |
protected void |
UNICAST2.handleXmitRequest(Address sender,
SeqnoList missing) |
protected void |
UNICAST3.retransmit(SeqnoList missing,
Address sender)
Sends a retransmit request to the given sender
|
void |
UNICAST2.retransmit(SeqnoList missing,
Address sender) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
NAKACK2.handleXmitReq(Address xmit_requester,
SeqnoList missing_msgs,
Address original_sender)
Retransmits messsages first_seqno to last_seqno from original_sender from xmit_table to xmit_requester,
called when XMIT_REQ is received.
|
protected void |
NAKACK2.retransmit(SeqnoList missing_msgs,
Address sender,
boolean multicast_xmit_request) |
限定符和类型 | 字段和说明 |
---|---|
protected SeqnoList |
Table.Missing.missing_elements |
限定符和类型 | 方法和说明 |
---|---|
SeqnoList |
SeqnoList.add(long... seqnos) |
SeqnoList |
SeqnoList.add(long seqno)
Adds a single seqno
|
SeqnoList |
SeqnoList.add(long from,
long to)
Adds a seqno range
|
SeqnoList |
Table.getMissing()
Returns a list of missing (= null) elements
|
SeqnoList |
RingBufferLockless.getMissing() |
SeqnoList |
RingBuffer.getMissing() |
protected SeqnoList |
Table.Missing.getMissingElements() |