merge bitcoin#27766: Change LIMIT_TO_MESSAGE_TYPE from a compile-time…

… to a run-time setting

src/test/fuzz/process_message.cpp

@@ -2,15 +2,16 @@
 // Distributed under the MIT software license, see the accompanying
 // file COPYING or http://www.opensource.org/licenses/mit-license.php.
 
-#include <banman.h>
-#include <chainparams.h>
 #include <consensus/consensus.h>
 #include <net.h>
 #include <net_processing.h>
+#include <primitives/transaction.h>
 #include <protocol.h>
-#include <scheduler.h>
 #include <script/script.h>
+#include <serialize.h>
+#include <span.h>
 #include <streams.h>
+#include <sync.h>
 #include <test/fuzz/FuzzedDataProvider.h>
 #include <test/fuzz/fuzz.h>
 #include <test/fuzz/util.h>
@@ -31,38 +32,24 @@
 #include <llmq/signing_shares.h>
 
 #include <atomic>
-#include <cassert>
-#include <chrono>
-#include <cstdint>
-#include <iosfwd>
+#include <cstdlib>
 #include <iostream>
 #include <memory>
 #include <string>
+#include <string_view>
+#include <vector>
 
 namespace {
 const TestingSetup* g_setup;
+std::string_view LIMIT_TO_MESSAGE_TYPE{};
 } // namespace
 
-size_t& GetNumMsgTypes()
-{
-    static size_t g_num_msg_types{0};
-    return g_num_msg_types;
-}
-#define FUZZ_TARGET_MSG(msg_type)                                            \
-    struct msg_type##_Count_Before_Main {                                    \
-        msg_type##_Count_Before_Main()                                       \
-        {                                                                    \
-            ++GetNumMsgTypes();                                              \
-        }                                                                    \
-    } const static g_##msg_type##_count_before_main;                         \
-    FUZZ_TARGET_INIT(process_message_##msg_type, initialize_process_message) \
-    {                                                                        \
-        fuzz_target(buffer, #msg_type);                                      \
-    }
-
 void initialize_process_message()
 {
-    Assert(GetNumMsgTypes() == getAllNetMessageTypes().size()); // If this fails, add or remove the message type below
+    if (const auto val{std::getenv("LIMIT_TO_MESSAGE_TYPE")}) {
+        LIMIT_TO_MESSAGE_TYPE = val;
+        Assert(std::count(getAllNetMessageTypes().begin(), getAllNetMessageTypes().end(), LIMIT_TO_MESSAGE_TYPE)); // Unknown message type passed
+    }
 
     static const auto testing_setup = MakeNoLogFileContext<const TestingSetup>(
             /*chain_name=*/CBaseChainParams::REGTEST,
@@ -74,7 +61,7 @@ void initialize_process_message()
     SyncWithValidationInterfaceQueue();
 }
 
-void fuzz_target(FuzzBufferType buffer, const std::string& LIMIT_TO_MESSAGE_TYPE)
+FUZZ_TARGET_INIT(process_message, initialize_process_message)
 {
     FuzzedDataProvider fuzzed_data_provider(buffer.data(), buffer.size());
 
@@ -107,78 +94,3 @@ void fuzz_target(FuzzBufferType buffer, const std::string& LIMIT_TO_MESSAGE_TYPE
     SyncWithValidationInterfaceQueue();
     g_setup->m_node.connman->StopNodes();
 }
-
-FUZZ_TARGET_INIT(process_message, initialize_process_message) { fuzz_target(buffer, ""); }
-FUZZ_TARGET_MSG(addr);
-FUZZ_TARGET_MSG(addrv2);
-FUZZ_TARGET_MSG(block);
-FUZZ_TARGET_MSG(blocktxn);
-FUZZ_TARGET_MSG(cfcheckpt);
-FUZZ_TARGET_MSG(cfheaders);
-FUZZ_TARGET_MSG(cfilter);
-FUZZ_TARGET_MSG(clsig);
-FUZZ_TARGET_MSG(cmpctblock);
-FUZZ_TARGET_MSG(dsa);
-FUZZ_TARGET_MSG(dsc);
-FUZZ_TARGET_MSG(dsf);
-FUZZ_TARGET_MSG(dsi);
-FUZZ_TARGET_MSG(dsq);
-FUZZ_TARGET_MSG(dss);
-FUZZ_TARGET_MSG(dssu);
-FUZZ_TARGET_MSG(dstx);
-FUZZ_TARGET_MSG(filteradd);
-FUZZ_TARGET_MSG(filterclear);
-FUZZ_TARGET_MSG(filterload);
-FUZZ_TARGET_MSG(getaddr);
-FUZZ_TARGET_MSG(getblocks);
-FUZZ_TARGET_MSG(getblocktxn);
-FUZZ_TARGET_MSG(getcfcheckpt);
-FUZZ_TARGET_MSG(getcfheaders);
-FUZZ_TARGET_MSG(getcfilters);
-FUZZ_TARGET_MSG(getdata);
-FUZZ_TARGET_MSG(getheaders);
-FUZZ_TARGET_MSG(getheaders2);
-FUZZ_TARGET_MSG(getmnlistd);
-FUZZ_TARGET_MSG(getqrinfo);
-FUZZ_TARGET_MSG(getsporks);
-FUZZ_TARGET_MSG(govobj);
-FUZZ_TARGET_MSG(govobjvote);
-FUZZ_TARGET_MSG(govsync);
-FUZZ_TARGET_MSG(headers);
-FUZZ_TARGET_MSG(headers2);
-FUZZ_TARGET_MSG(inv);
-FUZZ_TARGET_MSG(isdlock);
-FUZZ_TARGET_MSG(mempool);
-FUZZ_TARGET_MSG(merkleblock);
-FUZZ_TARGET_MSG(mnauth);
-FUZZ_TARGET_MSG(mnlistdiff);
-FUZZ_TARGET_MSG(notfound);
-FUZZ_TARGET_MSG(ping);
-FUZZ_TARGET_MSG(pong);
-FUZZ_TARGET_MSG(qbsigs);
-FUZZ_TARGET_MSG(qcomplaint);
-FUZZ_TARGET_MSG(qcontrib);
-FUZZ_TARGET_MSG(qdata);
-FUZZ_TARGET_MSG(qfcommit);
-FUZZ_TARGET_MSG(qgetdata);
-FUZZ_TARGET_MSG(qgetsigs);
-FUZZ_TARGET_MSG(qjustify);
-FUZZ_TARGET_MSG(qpcommit);
-FUZZ_TARGET_MSG(qrinfo);
-FUZZ_TARGET_MSG(qsendrecsigs);
-FUZZ_TARGET_MSG(qsigrec);
-FUZZ_TARGET_MSG(qsigsesann);
-FUZZ_TARGET_MSG(qsigshare);
-FUZZ_TARGET_MSG(qsigsinv);
-FUZZ_TARGET_MSG(qwatch);
-FUZZ_TARGET_MSG(sendaddrv2);
-FUZZ_TARGET_MSG(sendcmpct);
-FUZZ_TARGET_MSG(senddsq);
-FUZZ_TARGET_MSG(sendheaders);
-FUZZ_TARGET_MSG(sendheaders2);
-FUZZ_TARGET_MSG(sendtxrcncl);
-FUZZ_TARGET_MSG(spork);
-FUZZ_TARGET_MSG(ssc);
-FUZZ_TARGET_MSG(tx);
-FUZZ_TARGET_MSG(verack);
-FUZZ_TARGET_MSG(version);

src/test/util/setup_common.h

@@ -11,7 +11,7 @@
 #include <key.h>
 #include <util/system.h>
 #include <node/caches.h>
-#include <node/context.h>
+#include <node/context.h> // IWYU pragma: export
 #include <pubkey.h>
 #include <random.h>
 #include <txmempool.h>