summaryrefslogtreecommitdiff
path: root/src/PeerMessageUtil.h
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2006-05-10 12:30:26 +0000
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2006-05-10 12:30:26 +0000
commitef6c1d53a3c874e8dcbd57233f8eb3c2326be01d (patch)
treee462fc211239a6ad4b6487f49d1111a3c27748f8 /src/PeerMessageUtil.h
parentebfdbefb7fb60c5c6fa8c5c1cf4b2380d2505c54 (diff)
* src/PeerInteractionCommand.h
(checkInactiveConnection): Removed. * src/PeerInteractionCommand.cc (executeInternal): Removed following function calls: detectMessageFlooding(), checkLongTimePeerChoking and checkInactiveConnection(). (checkInactiveConnection): Removed. (detectMessageFlooding): Removed function call to checkInactiveConnection(). * src/PeerMessageUtil.h (createChokeMessage): New function. Overload. (createUnchokeMessage): New function. Overload. (createInterestedMessage): New function. Overload. (createNotInterestedMessage): New function. Overload. (createHaveMessage): New function. Overload. (createBitfieldMessage): New function. Overload. (createRequestMessage): New function. Overload. (createCancelMessage): New function. Overload. (createPieceMessage): New function. Overload. (createKeepAliveMessage): New function. Overload. * src/PeerMessageUtil.cc (createChokeMessage): New function. Overload. (createUnchokeMessage): New function. Overload. (createInterestedMessage): New function. Overload. (createNotInterestedMessage): New function. Overload. (createHaveMessage): New function. Overload. (createBitfieldMessage): New function. Overload. (createRequestMessage): New function. Overload. (createCancelMessage): New function. Overload. (createPieceMessage): New function. Overload. (createKeepAliveMessage): New function. Overload. * src/SendMessageQueue.cc (createRequestMessage): Use PeerMessageUtil. (createCancelMessage): Use PeerMessageUtil. (createPieceMessage): Use PeerMessageUtil. (createHaveMessage): Use PeerMessageUtil. (createChokeMessage): Use PeerMessageUtil. (createUnchokeMessage): Use PeerMessageUtil. (createInterestedMessage): Use PeerMessageUtil. (createNotInterestedMessage): Use PeerMessageUtil. (createBitfieldMessage): Use PeerMessageUtil. (createKeepAliveMessage): Use PeerMessageUtil.
Diffstat (limited to 'src/PeerMessageUtil.h')
-rw-r--r--src/PeerMessageUtil.h22
1 files changed, 19 insertions, 3 deletions
diff --git a/src/PeerMessageUtil.h b/src/PeerMessageUtil.h
index d4175b84..05a564a1 100644
--- a/src/PeerMessageUtil.h
+++ b/src/PeerMessageUtil.h
@@ -50,7 +50,8 @@ public:
static ChokeMessage* createChokeMessage(const char* msg, int len);
static UnchokeMessage* createUnchokeMessage(const char* msg, int len);
static InterestedMessage* createInterestedMessage(const char* msg, int len);
- static NotInterestedMessage* createNotInterestedMessage(const char* msg, int len);
+ static NotInterestedMessage* createNotInterestedMessage(const char* msg,
+ int len);
static HaveMessage* createHaveMessage(const char* msg, int len);
static BitfieldMessage* createBitfieldMessage(const char* msg, int len);
static RequestMessage* createRequestMessage(const char* msg, int len);
@@ -58,14 +59,29 @@ public:
static PieceMessage* createPieceMessage(const char* msg, int len);
static PortMessage* createPortMessage(const char* msg, int len);
+ static ChokeMessage* createChokeMessage();
+ static UnchokeMessage* createUnchokeMessage();
+ static InterestedMessage* createInterestedMessage();
+ static NotInterestedMessage* createNotInterestedMessage();
+ static HaveMessage* createHaveMessage(int index);
+ static BitfieldMessage* createBitfieldMessage();
+ static RequestMessage* createRequestMessage(int index, int begin,
+ int length, int blockIndex);
+ static CancelMessage* createCancelMessage(int index, int begin, int length);
+ static PieceMessage* createPieceMessage(int index, int begin, int length);
+ static KeepAliveMessage* createKeepAliveMessage();
+
static void checkIndex(int index, int pieces);
static void checkBegin(int begin, int pieceLength);
static void checkLength(int length);
static void checkRange(int begin, int length, int pieceLength);
- static void checkBitfield(const unsigned char* bitfield, int bitfieldLength, int pieces);
+ static void checkBitfield(const unsigned char* bitfield,
+ int bitfieldLength,
+ int pieces);
static HandshakeMessage* createHandshakeMessage(const char* msg, int length);
- static void checkHandshake(const HandshakeMessage* message, const unsigned char* infoHash);
+ static void checkHandshake(const HandshakeMessage* message,
+ const unsigned char* infoHash);
};
#endif // _D_PEER_MESSAGE_UTIL_H_