diff options
Diffstat (limited to 'src/BtPortMessage.cc')
| -rw-r--r-- | src/BtPortMessage.cc | 48 |
1 files changed, 23 insertions, 25 deletions
diff --git a/src/BtPortMessage.cc b/src/BtPortMessage.cc index 1382a5d0..99b0d699 100644 --- a/src/BtPortMessage.cc +++ b/src/BtPortMessage.cc @@ -53,16 +53,17 @@ namespace aria2 { const char BtPortMessage::NAME[] = "port"; BtPortMessage::BtPortMessage(uint16_t port) - : SimpleBtMessage(ID, NAME), - port_(port), - localNode_(nullptr), - routingTable_(nullptr), - taskQueue_(nullptr), - taskFactory_(nullptr) -{} + : SimpleBtMessage(ID, NAME), + port_(port), + localNode_(nullptr), + routingTable_(nullptr), + taskQueue_(nullptr), + taskFactory_(nullptr) +{ +} -std::unique_ptr<BtPortMessage> BtPortMessage::create -(const unsigned char* data, size_t dataLength) +std::unique_ptr<BtPortMessage> BtPortMessage::create(const unsigned char* data, + size_t dataLength) { bittorrent::assertPayloadLengthEqual(3, dataLength, NAME); bittorrent::assertID(ID, data, NAME); @@ -72,8 +73,8 @@ std::unique_ptr<BtPortMessage> BtPortMessage::create void BtPortMessage::doReceivedAction() { - if(taskFactory_ && taskQueue_) { - if(port_ == 0) { + if (taskFactory_ && taskQueue_) { + if (port_ == 0) { A2_LOG_DEBUG("Ignored port 0."); return; } @@ -86,15 +87,16 @@ void BtPortMessage::doReceivedAction() std::shared_ptr<DHTTask> task = taskFactory_->createPingTask(node); taskQueue_->addImmediateTask(task); } - if(routingTable_->getNumBucket() == 1) { + if (routingTable_->getNumBucket() == 1) { // initiate bootstrap A2_LOG_INFO("Dispatch node_lookup since too few buckets."); - taskQueue_->addImmediateTask - (taskFactory_->createNodeLookupTask(localNode_->getID())); + taskQueue_->addImmediateTask( + taskFactory_->createNodeLookupTask(localNode_->getID())); } - } else { - A2_LOG_INFO - ("DHT port message received while localhost didn't declare support it."); + } + else { + A2_LOG_INFO( + "DHT port message received while localhost didn't declare support it."); } } @@ -112,18 +114,14 @@ unsigned char* BtPortMessage::createMessage() return msg; } -size_t BtPortMessage::getMessageLength() { - return MESSAGE_LENGTH; -} +size_t BtPortMessage::getMessageLength() { return MESSAGE_LENGTH; } -std::string BtPortMessage::toString() const { +std::string BtPortMessage::toString() const +{ return fmt("%s port=%u", NAME, port_); } -void BtPortMessage::setLocalNode(DHTNode* localNode) -{ - localNode_ = localNode; -} +void BtPortMessage::setLocalNode(DHTNode* localNode) { localNode_ = localNode; } void BtPortMessage::setRoutingTable(DHTRoutingTable* routingTable) { |