/* */ #include "UnchokeMessage.h" #include "PeerInteraction.h" #include "PeerMessageUtil.h" #include "DlAbortEx.h" UnchokeMessage* UnchokeMessage::create(const char* data, int dataLength) { if(dataLength != 1) { throw new DlAbortEx("invalid payload size for %s, size = %d. It should be %d", "unchoke", dataLength, 1); } int id = PeerMessageUtil::getId(data); if(id != ID) { throw new DlAbortEx("invalid ID=%d for %s. It should be %d.", id, "unchoke", ID); } UnchokeMessage* unchokeMessage = new UnchokeMessage(); return unchokeMessage; } void UnchokeMessage::receivedAction() { peer->peerChoking = false; } bool UnchokeMessage::sendPredicate() const { return peer->amChoking; } const char* UnchokeMessage::getMessage() { if(!inProgress) { /** * len --- 1, 4bytes * id --- 1, 1byte * total: 5bytes */ PeerMessageUtil::createPeerMessageString(msg, sizeof(msg), 1, ID); } return msg; } int UnchokeMessage::getMessageLength() { return sizeof(msg); } void UnchokeMessage::onSendComplete() { peer->amChoking = false; } string UnchokeMessage::toString() const { return "unchoke"; }