Modifier and Type | Field and Description |
---|---|
(package private) long |
lastSent |
Constructor and Description |
---|
PeerConnectionOut(Peer peer,
DataOutputStream dout) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
cancelRequest(int piece,
int begin,
int length)
Called by the PeerState when the other side doesn't want this
request to be handled anymore.
|
(package private) void |
cancelRequestMessages()
Remove all Request messages from the queue.
|
void |
disconnect() |
(package private) int |
queuedBytes() |
(package private) void |
retransmitRequests(List<Request> requests) |
void |
run()
Continuesly monitors for more outgoing messages that have to be send.
|
(package private) void |
sendAlive() |
(package private) void |
sendAllowedFast(int piece)
Unused
|
(package private) void |
sendBitfield(BitField bitfield) |
(package private) void |
sendCancel(Request req) |
(package private) void |
sendChoke(boolean choke) |
(package private) void |
sendExtension(int id,
byte[] bytes) |
(package private) void |
sendHave(int piece) |
(package private) void |
sendInterest(boolean interest) |
(package private) void |
sendPiece(int piece,
int begin,
int length,
byte[] bytes)
Queue a piece message with the data already loaded from disk
Also add a timeout.
|
(package private) void |
sendPiece(int piece,
int begin,
int length,
DataLoader loader)
Queue a piece message with a callback to load the data
from disk when required.
|
(package private) void |
sendPort(int port) |
(package private) void |
sendReject(int piece,
int begin,
int length) |
(package private) void |
sendRequest(Request req) |
(package private) void |
sendRequests(List<Request> requests) |
(package private) void |
sendSuggest(int piece)
Unused
|
void |
startup() |
public PeerConnectionOut(Peer peer, DataOutputStream dout)
public void startup()
public void run()
public void disconnect()
void sendAlive()
void sendChoke(boolean choke)
void sendInterest(boolean interest)
void sendHave(int piece)
void sendBitfield(BitField bitfield)
void sendRequest(Request req)
int queuedBytes()
void sendPiece(int piece, int begin, int length, DataLoader loader)
void sendPiece(int piece, int begin, int length, byte[] bytes)
void sendCancel(Request req)
void cancelRequestMessages()
void cancelRequest(int piece, int begin, int length)
void sendExtension(int id, byte[] bytes)
void sendPort(int port)
void sendSuggest(int piece)
void sendReject(int piece, int begin, int length)
void sendAllowedFast(int piece)