|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.klomp.snark.PeerState
class PeerState
Field Summary | |
---|---|
(package private) BitField |
bitfield
the pieces the peer has |
(package private) boolean |
choked
|
(package private) boolean |
choking
|
(package private) PeerConnectionIn |
in
|
(package private) boolean |
interested
|
(package private) boolean |
interesting
|
(package private) PeerListener |
listener
Fixme, used by Peer.disconnect() to get to the coordinator |
(package private) PeerConnectionOut |
out
|
static int |
PARTSIZE
|
Constructor Summary | |
---|---|
PeerState(Peer peer,
PeerListener listener,
MetaInfo metainfo,
PeerConnectionIn in,
PeerConnectionOut out)
|
Method Summary | |
---|---|
(package private) void |
addRequest()
Adds a new request to the outstanding requests list. |
(package private) void |
bitfieldMessage(byte[] bitmap)
|
(package private) void |
cancelMessage(int piece,
int begin,
int length)
|
(package private) void |
cancelPiece(int piece)
Tell the other side that we are no longer interested in any of the outstanding requests (if any) for this piece. |
(package private) void |
chokeMessage(boolean choke)
|
(package private) void |
extensionMessage(int id,
byte[] bs)
|
(package private) Request |
getOutstandingRequest(int piece,
int begin,
int length)
Called when a piece message is being processed by the incoming connection. |
(package private) String |
getRequests()
debug |
(package private) void |
haveMessage(int piece)
|
(package private) void |
havePiece(int piece)
We now have this piece. |
(package private) void |
interestedMessage(boolean interest)
|
(package private) boolean |
isRequesting(int piece)
Deprecated. deadlocks |
(package private) void |
keepAlive()
|
(package private) void |
keepAliveMessage()
|
byte[] |
loadData(int piece,
int begin,
int length)
This is the callback that PeerConnectionOut calls |
(package private) void |
pieceMessage(Request req)
Called when a full chunk (i.e. |
(package private) void |
portMessage(int port)
|
(package private) void |
requestMessage(int piece,
int begin,
int length)
|
(package private) void |
retransmitRequests()
|
(package private) List<PartialPiece> |
returnPartialPieces()
Get partial pieces, give them back to PeerCoordinator. |
(package private) void |
setChoking(boolean choke)
|
(package private) void |
setInteresting(boolean interest)
|
void |
setMetaInfo(MetaInfo meta)
Switch from magnet mode to normal mode. |
(package private) void |
unknownMessage(int type,
byte[] bs)
|
(package private) void |
uploaded(int size)
Called when some bytes have left the outgoing connection. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
final PeerListener listener
boolean interesting
boolean choking
boolean interested
boolean choked
BitField bitfield
final PeerConnectionIn in
final PeerConnectionOut out
public static final int PARTSIZE
Constructor Detail |
---|
PeerState(Peer peer, PeerListener listener, MetaInfo metainfo, PeerConnectionIn in, PeerConnectionOut out)
metainfo
- null if in magnet modeMethod Detail |
---|
void keepAliveMessage()
void chokeMessage(boolean choke)
void interestedMessage(boolean interest)
void haveMessage(int piece)
void bitfieldMessage(byte[] bitmap)
void requestMessage(int piece, int begin, int length)
public byte[] loadData(int piece, int begin, int length)
loadData
in interface DataLoader
void uploaded(int size)
void pieceMessage(Request req)
Request getOutstandingRequest(int piece, int begin, int length)
List<PartialPiece> returnPartialPieces()
void cancelMessage(int piece, int begin, int length)
void extensionMessage(int id, byte[] bs)
public void setMetaInfo(MetaInfo meta)
meta
- non-nullvoid portMessage(int port)
void unknownMessage(int type, byte[] bs)
void havePiece(int piece)
void cancelPiece(int piece)
boolean isRequesting(int piece)
void addRequest()
By getOustandingRequest() when the first part of a chunk comes in By havePiece() when somebody got a new piece completed By chokeMessage() when we receive an unchoke By setInteresting() when we are now interested By PeerCoordinator.updatePiecePriorities()
void setInteresting(boolean interest)
void setChoking(boolean choke)
void keepAlive()
void retransmitRequests()
String getRequests()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |