|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object com.aelitis.azureus.core.peermanager.utils.OutgoingBTHaveMessageAggregator
public class OutgoingBTHaveMessageAggregator
Utility class to enable write aggregation of BT Have messages, in order to save bandwidth by not wasting a whole network packet on a single small 9-byte message, and instead pad them onto other messages.
Constructor Summary | |
---|---|
OutgoingBTHaveMessageAggregator(OutgoingMessageQueue outgoing_message_q,
byte _bt_have_version,
byte _az_have_version)
Create a new aggregator, which will send messages out the given queue. |
Method Summary | |
---|---|
void |
destroy()
Destroy the aggregator, along with any pending messages. |
void |
forceSendOfPending()
Force send of any aggregated/pending have messages. |
boolean |
hasPending()
Are there Haves messages pending? |
void |
queueHaveMessage(int piece_number,
boolean force)
Queue a new have message for aggregated sending. |
void |
setHaveVersion(byte bt_version,
byte az_version)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public OutgoingBTHaveMessageAggregator(OutgoingMessageQueue outgoing_message_q, byte _bt_have_version, byte _az_have_version)
outgoing_message_q
- Method Detail |
---|
public void setHaveVersion(byte bt_version, byte az_version)
public void queueHaveMessage(int piece_number, boolean force)
piece_number
- of the have messageforce
- if true, send this and any other pending haves right awaypublic void destroy()
public void forceSendOfPending()
public boolean hasPending()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |