| /dports/www/aria2/aria2-1.36.0/src/ |
| H A D | PeerInitiateConnectionCommand.cc | 87 c->setPeerStorage(peerStorage_); in executeInternal()
94 pieceStorage_, peerStorage_, getSocket(), in executeInternal()
103 if (peerStorage_->isPeerAvailable() && btRuntime_->lessThanEqMinPeers()) { in prepareForNextPeer()
105 std::shared_ptr<Peer> peer = peerStorage_->checkoutPeer(ncuid); in prepareForNextPeer()
110 command->setPeerStorage(peerStorage_); in prepareForNextPeer()
120 peerStorage_->returnPeer(getPeer()); in onAbort()
131 peerStorage_ = peerStorage; in setPeerStorage()
|
| H A D | InitiatorMSEHandshakeCommand.cc | 172 btRuntime_, pieceStorage_, peerStorage_, getSocket(), in executeInternal()
202 if (peerStorage_->isPeerAvailable() && btRuntime_->lessThanEqMinPeers()) { in tryNewPeer()
204 std::shared_ptr<Peer> peer = peerStorage_->checkoutPeer(ncuid); in tryNewPeer()
209 command->setPeerStorage(peerStorage_); in tryNewPeer()
240 command->setPeerStorage(peerStorage_); in prepareForNextPeer()
252 peerStorage_->returnPeer(getPeer()); in onAbort()
264 peerStorage_ = peerStorage; in setPeerStorage()
|
| H A D | BtNotInterestedMessage.cc | 45 : ZeroBtMessage(ID, NAME), peerStorage_(nullptr) in BtNotInterestedMessage()
64 peerStorage_->executeChoke(); in doReceivedAction()
70 peerStorage_ = peerStorage; in setPeerStorage()
|
| H A D | DHTGetPeersCommand.cc | 106 peerStorage_); in execute()
115 static_cast<int>(peerStorage_->countAllPeer()))) { in execute()
119 static_cast<unsigned long>(peerStorage_->countAllPeer()), in execute()
150 peerStorage_ = ps; in setPeerStorage()
|
| H A D | BtInterestedMessage.cc | 45 : ZeroBtMessage(ID, NAME), peerStorage_(nullptr) in BtInterestedMessage()
68 peerStorage_->executeChoke(); in doReceivedAction()
74 peerStorage_ = peerStorage; in setPeerStorage()
|
| H A D | PeerChokeCommand.cc | 54 if (peerStorage_->chokeRoundIntervalElapsed()) { in execute()
55 peerStorage_->executeChoke(); in execute()
69 peerStorage_ = peerStorage; in setPeerStorage()
|
| H A D | ActivePeerConnectionCommand.cc | 133 for (; num && peerStorage_->isPeerAvailable(); --num) { in makeNewConnections()
135 std::shared_ptr<Peer> peer = peerStorage_->checkoutPeer(ncuid); in makeNewConnections()
142 command->setPeerStorage(peerStorage_); in makeNewConnections()
165 peerStorage_ = peerStorage; in setPeerStorage()
|
| H A D | DefaultExtensionMessageFactory.cc | 62 : peerStorage_{nullptr}, in DefaultExtensionMessageFactory()
73 : peerStorage_{nullptr}, in DefaultExtensionMessageFactory()
105 m->setPeerStorage(peerStorage_); in createMessage()
179 peerStorage_ = peerStorage; in setPeerStorage()
|
| H A D | UTPexExtensionMessage.cc | 64 peerStorage_{nullptr},
130 peerStorage_->addPeer(freshPeers_); in doReceivedAction()
131 peerStorage_->addPeer(droppedPeers_); in doReceivedAction()
192 peerStorage_ = peerStorage; in setPeerStorage()
|
| H A D | PeerInteractionCommand.cc | 94 peerStorage_{peerStorage},
382 if (peerStorage_->isPeerAvailable() && btRuntime_->lessThanEqMinPeers()) { in prepareForNextPeer()
384 std::shared_ptr<Peer> peer = peerStorage_->checkoutPeer(ncuid); in prepareForNextPeer()
389 command->setPeerStorage(peerStorage_); in prepareForNextPeer()
400 peerStorage_->returnPeer(getPeer()); in onAbort()
|
| H A D | DefaultBtMessageFactory.cc | 77 peerStorage_{nullptr},
111 m->setPeerStorage(peerStorage_); in createBtMessage()
117 m->setPeerStorage(peerStorage_); in createBtMessage()
157 m->setPeerStorage(peerStorage_); in createBtMessage()
435 peerStorage_ = peerStorage; in setPeerStorage()
|
| H A D | TrackerWatcherCommand.cc | 277 if (!peerStorage_->isPeerAvailable()) { in addConnection()
281 std::shared_ptr<Peer> peer = peerStorage_->checkoutPeer(ncuid); in addConnection()
288 command->setPeerStorage(peerStorage_); in addConnection()
415 peerStorage_ = peerStorage; in setPeerStorage()
|
| H A D | DHTPeerLookupTask.cc | 80 peerStorage_->addPeer(message->getValues()); in onReceivedInternal()
125 peerStorage_ = ps; in setPeerStorage()
|
| H A D | DefaultBtAnnounce.h | 67 std::shared_ptr<PeerStorage> peerStorage_; variable
92 return peerStorage_; in getPeerStorage()
|
| H A D | DefaultBtAnnounce.cc | 348 peerStorage_->addPeer(peers); in processAnnounceResponse()
359 peerStorage_->addPeer(peers); in processAnnounceResponse()
381 peerStorage_->addPeer(std::make_shared<Peer>(elem.first, elem.second)); in processUDPTrackerResponse()
414 peerStorage_ = peerStorage; in setPeerStorage()
|
| H A D | BtPieceMessage.cc | 76 peerStorage_(nullptr) in BtPieceMessage()
142 peerStorage_->addBadPeer(getPeer()->getIPAddress()); in doReceivedAction()
332 peerStorage_ = peerStorage; in setPeerStorage()
|
| H A D | BtNotInterestedMessage.h | 47 PeerStorage* peerStorage_;
|
| H A D | BtInterestedMessage.h | 47 PeerStorage* peerStorage_;
|
| H A D | PeerChokeCommand.h | 52 std::shared_ptr<PeerStorage> peerStorage_; variable
|
| H A D | DefaultBtInteractive.cc | 134 for (auto& peer : peerStorage_->getUsedPeers()) { in receiveHandshake()
511 auto& usedPeers = peerStorage_->getUsedPeers(); in addPeerExchangeMessage()
518 auto& droppedPeers = peerStorage_->getDroppedPeers(); in addPeerExchangeMessage()
631 peerStorage_ = peerStorage; in setPeerStorage()
|
| H A D | DHTPeerLookupTask.h | 53 std::shared_ptr<PeerStorage> peerStorage_; variable
|
| /dports/www/aria2/aria2-1.36.0/test/ |
| H A D | DefaultBtAnnounceTest.cc | 45 std::shared_ptr<MockPeerStorage> peerStorage_; member in aria2::DefaultBtAnnounceTest
78 peerStorage_.reset(new MockPeerStorage()); in setUp()
153 btAnnounce.setPeerStorage(peerStorage_); in testNoMoreAnnounce()
249 btAnnounce.setPeerStorage(peerStorage_); in testGetAnnounceUrl()
333 btAnnounce.setPeerStorage(peerStorage_); in testGetAnnounceUrl_withQuery()
358 btAnnounce.setPeerStorage(peerStorage_); in testGetAnnounceUrl_externalIP()
390 btAnnounce.setPeerStorage(peerStorage_); in testIsAllAnnounceFailed()
437 btAnnounce.setPeerStorage(peerStorage_); in testURLOrderInStoppedEvent()
489 btAnnounce.setPeerStorage(peerStorage_); in testURLOrderInCompletedEvent()
574 an.setPeerStorage(peerStorage_); in testProcessAnnounceResponse()
[all …]
|
| H A D | UTPexExtensionMessageTest.cc | 35 std::unique_ptr<MockPeerStorage> peerStorage_; member in aria2::UTPexExtensionMessageTest
40 peerStorage_ = make_unique<MockPeerStorage>(); in setUp()
155 msg.setPeerStorage(peerStorage_.get()); in testDoReceivedAction()
159 CPPUNIT_ASSERT_EQUAL((size_t)4, peerStorage_->getUnusedPeers().size()); in testDoReceivedAction()
161 std::shared_ptr<Peer> p = peerStorage_->getUnusedPeers()[0]; in testDoReceivedAction()
166 std::shared_ptr<Peer> p = peerStorage_->getUnusedPeers()[1]; in testDoReceivedAction()
172 std::shared_ptr<Peer> p = peerStorage_->getUnusedPeers()[2]; in testDoReceivedAction()
176 std::shared_ptr<Peer> p = peerStorage_->getUnusedPeers()[3]; in testDoReceivedAction()
|
| H A D | DefaultExtensionMessageFactoryTest.cc | 42 std::unique_ptr<MockPeerStorage> peerStorage_; member in aria2::DefaultExtensionMessageFactoryTest
54 peerStorage_ = make_unique<MockPeerStorage>(); in setUp()
69 factory_->setPeerStorage(peerStorage_.get()); in setUp()
|
| H A D | DefaultBtProgressInfoFileTest.cc | 47 std::shared_ptr<MockPeerStorage> peerStorage_; member in aria2::DefaultBtProgressInfoFileTest
84 peerStorage_.reset(new MockPeerStorage()); in initializeMembers()
122 infoFile.setPeerStorage(peerStorage_); in testLoad_compat()
174 infoFile.setPeerStorage(peerStorage_); in testLoad()
232 infoFile.setPeerStorage(peerStorage_); in testSave()
563 infoFile.setPeerStorage(peerStorage_); in testUpdateFilename()
|