81 static constexpr unsigned int NUM_TXNS_CREATED = 100;
82 static constexpr int64_t TX_SIZE{469};
83 static constexpr int64_t TOTAL_SIZE = NUM_TXNS_CREATED * TX_SIZE;
85 std::vector<CTransactionRef> txns;
86 txns.reserve(NUM_TXNS_CREATED);
88 for (
unsigned int i{0}; i < NUM_TXNS_CREATED; ++i) {
90 txns.emplace_back(ptx);
102 orphanage_low_ann->AddTx(txns.at(0), peer);
103 orphanage_low_mem->AddTx(txns.at(0), peer);
106 orphanage_low_ann->AddTx(txns.at(1), peer);
107 orphanage_low_mem->AddTx(txns.at(1), peer);
110 BOOST_CHECK(!orphanage_low_ann->HaveTx(txns.at(0)->GetWitnessHash()));
111 BOOST_CHECK(!orphanage_low_mem->HaveTx(txns.at(0)->GetWitnessHash()));
112 BOOST_CHECK(orphanage_low_ann->HaveTx(txns.at(1)->GetWitnessHash()));
113 BOOST_CHECK(orphanage_low_mem->HaveTx(txns.at(1)->GetWitnessHash()));
115 orphanage_low_ann->SanityCheck();
116 orphanage_low_mem->SanityCheck();
126 orphanage_low_ann->AddTx(txns.at(0), peer);
129 std::vector<COutPoint> outpoints_45;
130 for (
unsigned int j{0}; j < 45; ++j) {
134 orphanage_low_ann->AddTx(ptx, peer);
137 BOOST_CHECK(!orphanage_low_ann->HaveTx(txns.at(0)->GetWitnessHash()));
138 BOOST_CHECK(orphanage_low_ann->HaveTx(ptx->GetWitnessHash()));
140 orphanage_low_ann->SanityCheck();
146 std::vector<CTransactionRef> parents;
147 std::vector<CTransactionRef> children;
148 for (
unsigned int i{0}; i < 10; ++i) {
151 parents.emplace_back(parent);
152 children.emplace_back(child);
160 orphanage->AddTx(children.at(0), peer);
163 orphanage->AddTx(children.at(1), peer);
164 orphanage->AddTx(children.at(2), peer);
167 const std::vector<std::pair<Wtxid, NodeId>> expected_set_c0{std::make_pair(children.at(0)->GetWitnessHash(), peer)};
168 BOOST_CHECK(orphanage->AddChildrenToWorkSet(*parents.at(0), det_rand) == expected_set_c0);
172 orphanage->AddTx(children.at(3), peer);
173 BOOST_CHECK(orphanage->HaveTx(children.at(0)->GetWitnessHash()));
174 BOOST_CHECK(!orphanage->HaveTx(children.at(1)->GetWitnessHash()));
175 BOOST_CHECK(orphanage->HaveTx(children.at(2)->GetWitnessHash()));
176 BOOST_CHECK(orphanage->HaveTx(children.at(3)->GetWitnessHash()));
177 orphanage->SanityCheck();
180 orphanage->AddTx(children.at(4), peer);
181 BOOST_CHECK(orphanage->HaveTx(children.at(0)->GetWitnessHash()));
182 BOOST_CHECK(!orphanage->HaveTx(children.at(2)->GetWitnessHash()));
183 BOOST_CHECK(orphanage->HaveTx(children.at(3)->GetWitnessHash()));
184 BOOST_CHECK(orphanage->HaveTx(children.at(4)->GetWitnessHash()));
187 const std::vector<std::pair<Wtxid, NodeId>> expected_set_c4{std::make_pair(children.at(4)->GetWitnessHash(), peer)};
188 BOOST_CHECK(orphanage->AddChildrenToWorkSet(*parents.at(4), det_rand) == expected_set_c4);
189 const std::vector<std::pair<Wtxid, NodeId>> expected_set_c3{std::make_pair(children.at(3)->GetWitnessHash(), peer)};
190 BOOST_CHECK(orphanage->AddChildrenToWorkSet(*parents.at(3), det_rand) == expected_set_c3);
193 orphanage->AddTx(children.at(5), peer);
194 BOOST_CHECK(orphanage->HaveTx(children.at(0)->GetWitnessHash()));
195 BOOST_CHECK(orphanage->HaveTx(children.at(3)->GetWitnessHash()));
196 BOOST_CHECK(orphanage->HaveTx(children.at(4)->GetWitnessHash()));
197 BOOST_CHECK(!orphanage->HaveTx(children.at(5)->GetWitnessHash()));
201 orphanage->AddTx(children.at(6), peer);
202 BOOST_CHECK(!orphanage->HaveTx(children.at(0)->GetWitnessHash()));
203 BOOST_CHECK(orphanage->HaveTx(children.at(3)->GetWitnessHash()));
204 BOOST_CHECK(orphanage->HaveTx(children.at(4)->GetWitnessHash()));
205 BOOST_CHECK(orphanage->HaveTx(children.at(6)->GetWitnessHash()));
212 orphanage->SanityCheck();
221 unsigned int max_announcements = 60;
226 for (
unsigned int i{0}; i < max_announcements; ++i) {
227 orphanage->AddTx(txns.at(i), peer_dosy);
229 orphanage->SanityCheck();
230 BOOST_CHECK_EQUAL(orphanage->AnnouncementsFromPeer(peer_dosy), max_announcements);
236 unsigned int num_from_peer1 = 10;
237 for (
unsigned int i{0}; i < num_from_peer1; ++i) {
238 orphanage->AddTx(txns.at(max_announcements + i), peer1);
241 BOOST_CHECK(orphanage->AnnouncementsFromPeer(peer_dosy) > orphanage->MaxPeerLatencyScore());
244 BOOST_CHECK_EQUAL(orphanage->AnnouncementsFromPeer(peer_dosy), max_announcements - i - 1);
247 BOOST_CHECK(!orphanage->HaveTx(txns.at(i)->GetWitnessHash()));
251 for (
unsigned int i{num_from_peer1}; i < num_from_peer1 + 10; ++i) {
253 BOOST_CHECK(orphanage->HaveTxFromPeer(txns.at(i)->GetWitnessHash(), peer_dosy));
254 orphanage->AddTx(txns.at(i), peer2);
257 BOOST_CHECK_EQUAL(orphanage->AnnouncementsFromPeer(peer_dosy), max_announcements - i - 1);
259 BOOST_CHECK_EQUAL(orphanage->AnnouncementsFromPeer(peer2), i + 1 - num_from_peer1);
262 BOOST_CHECK(!orphanage->HaveTxFromPeer(txns.at(i)->GetWitnessHash(), peer_dosy));
263 BOOST_CHECK(orphanage->HaveTx(txns.at(i)->GetWitnessHash()));
267 const unsigned int max_per_peer{max_announcements / 6};
268 const unsigned int num_announcements{orphanage->CountAnnouncements()};
269 for (
NodeId peer{3}; peer < 6; ++peer) {
270 for (
unsigned int i{0}; i < max_per_peer; ++i) {
272 orphanage->AddTx(txns.at(peer * max_per_peer + i), peer);
276 for (
NodeId peer{0}; peer < 6; ++peer) {
279 orphanage->SanityCheck();
294 orphanage->AddTx(txns.at(0), 0);
301 orphanage->AddTx(txns.at(1), 1);
308 orphanage->AddTx(txns.at(2), 2);
315 orphanage->AddTx(txns.at(3), 2);
323 orphanage->EraseForPeer(2);
330 orphanage->EraseTx(txns.at(0)->GetWitnessHash());
336 orphanage->SanityCheck();
343 tx_large.
vin.resize(1);
355 for (
unsigned int i = 0; i < 20; i++) {
356 orphanage->AddTx(txns.at(i), i < 10 ? peer_normal : peer_large);
358 BOOST_CHECK(orphanage->TotalLatencyScore() <= orphanage->MaxGlobalLatencyScore());
359 BOOST_CHECK(orphanage->TotalOrphanUsage() <= orphanage->MaxGlobalUsage());
362 orphanage->AddTx(ptx_large, peer_large);
367 BOOST_CHECK(orphanage->HaveTxFromPeer(ptx_large->GetWitnessHash(), peer_large));
370 orphanage->SanityCheck();
378 std::vector<COutPoint> outpoints_9;
379 for (
unsigned int j{0}; j < 9; ++j) {
382 for (
unsigned int i{0}; i < 10; ++i) {
384 orphanage->AddTx(ptx, 0);
390 std::vector<COutPoint> outpoints_50;
391 for (
unsigned int j{0}; j < 50; ++j) {
395 for (
unsigned int i{0}; i < 10; ++i) {
397 std::shuffle(outpoints_50.begin(), outpoints_50.end(), m_rng);
415 orphanage->SanityCheck();
566 std::vector<COutPoint> empty_outpoints;
572 while (parent1->GetHash() == parent2->GetHash()) {
594 BOOST_CHECK(orphanage->AddTx(child_p1n0_p1n1, node1));
595 BOOST_CHECK(orphanage->AddTx(child_p1n0_p2n0, node1));
598 BOOST_CHECK(!orphanage->AddTx(child_p1n0_p1n1, node0));
603 std::vector<CTransactionRef> expected_parent1_children{child_p1n0_p2n0, child_p1n0_p1n1, child_p1n0};
604 std::vector<CTransactionRef> expected_parent2_children{child_p1n0_p2n0, child_p2n1};
606 BOOST_CHECK(expected_parent1_children == orphanage->GetChildrenFromSamePeer(parent1, node1));
607 BOOST_CHECK(expected_parent2_children == orphanage->GetChildrenFromSamePeer(parent2, node1));
610 BOOST_CHECK(orphanage->GetChildrenFromSamePeer(parent1, node2).empty());
611 BOOST_CHECK(orphanage->GetChildrenFromSamePeer(parent2, node2).empty());
614 BOOST_CHECK(orphanage->GetChildrenFromSamePeer(child_p1n0_p2n0, node1).empty());
615 BOOST_CHECK(orphanage->GetChildrenFromSamePeer(child_p1n0_p2n0, node2).empty());
623 BOOST_CHECK(orphanage->AddTx(child_p1n0_p1n1, node2));
624 BOOST_CHECK(orphanage->AddTx(child_p1n0_p2n0, node2));
635 std::set<CTransactionRef> expected_parent1_node1{child_p1n0};
638 BOOST_CHECK(orphanage->HaveTxFromPeer(child_p1n0->GetWitnessHash(), node1));
639 BOOST_CHECK(
EqualTxns(expected_parent1_node1, orphanage->GetChildrenFromSamePeer(parent1, node1)));
644 std::set<CTransactionRef> expected_parent2_node1{child_p2n1};
646 BOOST_CHECK(
EqualTxns(expected_parent2_node1, orphanage->GetChildrenFromSamePeer(parent2, node1)));
651 std::vector<CTransactionRef> expected_parent1_node2{child_p1n0_p2n0, child_p1n0_p1n1};
652 BOOST_CHECK(orphanage->HaveTxFromPeer(child_p1n0_p1n1->GetWitnessHash(), node2));
653 BOOST_CHECK(orphanage->HaveTxFromPeer(child_p1n0_p2n0->GetWitnessHash(), node2));
654 BOOST_CHECK(expected_parent1_node2 == orphanage->GetChildrenFromSamePeer(parent1, node2));
659 std::set<CTransactionRef> expected_parent2_node2{child_p1n0_p2n0};
662 BOOST_CHECK(orphanage->HaveTxFromPeer(child_p1n0_p2n0->GetWitnessHash(), node2));
663 BOOST_CHECK(
EqualTxns(expected_parent2_node2, orphanage->GetChildrenFromSamePeer(parent2, node2)));
691 std::vector<COutPoint> outpoints;
692 const uint32_t num_outpoints{6};
693 outpoints.reserve(num_outpoints);
694 for (uint32_t i{0}; i < num_outpoints; ++i) {
707 block.
vtx.emplace_back(bo_tx_same_txid);
711 block.
vtx.emplace_back(b_tx_same_txid_diff_witness);
713 auto o_tx_same_txid_diff_witness =
MakeMutation(b_tx_same_txid_diff_witness);
718 block.
vtx.emplace_back(b_tx_conflict);
725 block.
vtx.emplace_back(b_tx_conflict_partial);
730 orphanage->EraseForBlock(block);
731 for (
const auto& expected_removed : {bo_tx_same_txid, o_tx_same_txid_diff_witness, o_tx_conflict, o_tx_conflict_partial_2}) {
732 const auto& expected_removed_wtxid = expected_removed->GetWitnessHash();
733 BOOST_CHECK(!orphanage->HaveTx(expected_removed_wtxid));
737 BOOST_CHECK(orphanage->HaveTx(control_tx->GetWitnessHash()));
745 size_t expected_total_count{0};
753 const auto& wtxid = ptx->GetWitnessHash();
756 expected_total_count += 1;
766 BOOST_CHECK(orphanage->HaveTx(ptx_mutated->GetWitnessHash()));
767 expected_total_count += 1;
772 BOOST_CHECK(orphanage->AddAnnouncer(ptx->GetWitnessHash(), node2));
776 BOOST_CHECK(orphanage->HaveTxFromPeer(ptx->GetWitnessHash(), node2));
777 BOOST_CHECK(!orphanage->AddAnnouncer(ptx->GetWitnessHash(), node2));
785 orphanage->EraseForPeer(node0);
786 BOOST_CHECK(orphanage->HaveTx(ptx->GetWitnessHash()));
787 BOOST_CHECK(!orphanage->HaveTxFromPeer(ptx->GetWitnessHash(), node0));
789 BOOST_CHECK(!orphanage->HaveTx(ptx_mutated->GetWitnessHash()));
790 expected_total_count -= 1;
794 orphanage->EraseForPeer(node1);
796 BOOST_CHECK(orphanage->HaveTx(ptx->GetWitnessHash()));
797 orphanage->EraseForPeer(node2);
798 expected_total_count -= 1;
800 BOOST_CHECK(!orphanage->HaveTx(ptx->GetWitnessHash()));
807 block.
vtx.emplace_back(tx_block);
811 expected_total_count += 1;
815 orphanage->EraseForBlock(block);
817 expected_total_count -= 1;