|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.klomp.snark.PeerConnectionOut
class PeerConnectionOut
Field Summary | |
---|---|
(package private) long |
lastSent
|
Constructor Summary | |
---|---|
PeerConnectionOut(Peer peer,
DataOutputStream dout)
|
Method Summary | |
---|---|
(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()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
long lastSent
Constructor Detail |
---|
public PeerConnectionOut(Peer peer, DataOutputStream dout)
Method Detail |
---|
public void startup()
public void run()
run
in interface Runnable
public void disconnect()
void sendAlive()
void sendChoke(boolean choke)
void sendInterest(boolean interest)
void sendHave(int piece)
void sendBitfield(BitField bitfield)
void retransmitRequests(List<Request> requests)
void sendRequests(List<Request> requests)
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)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |