java.lang.Runnable
class PeerConnectionOut
extends java.lang.Object
implements java.lang.Runnable
修飾子とタイプ | フィールド | 説明 |
---|---|---|
(package private) long |
lastSent |
コンストラクタ | 説明 |
---|---|
PeerConnectionOut(Peer peer,
java.io.DataOutputStream dout) |
修飾子とタイプ | メソッド | 説明 |
---|---|---|
(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(java.util.List<Request> requests) |
|
void |
run() |
Continuesly monitors for more outgoing messages that have to be send.
|
(package private) void |
sendAlive() |
|
(package private) void |
sendBitfield(BitField bitfield) |
|
(package private) void |
sendCancel(Request req) |
send cancel
|
(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,
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(java.util.List<Request> requests) |
|
void |
startup() |
public PeerConnectionOut(Peer peer, java.io.DataOutputStream dout)
public void startup()
public void run()
run
インタフェース内 java.lang.Runnable
public void disconnect()
void sendAlive()
void sendChoke(boolean choke)
void sendInterest(boolean interest)
void sendHave(int piece)
void sendBitfield(BitField bitfield)
void retransmitRequests(java.util.List<Request> requests)
void sendRequests(java.util.List<Request> requests)
void sendRequest(Request req)
int queuedBytes()
void sendPiece(int piece, int begin, int length, DataLoader loader)
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 sendReject(int piece, int begin, int length)