diff --git a/src/test/fuzz/process_message.cpp b/src/test/fuzz/process_message.cpp index 86ab187a25..afb3b3432d 100644 --- a/src/test/fuzz/process_message.cpp +++ b/src/test/fuzz/process_message.cpp @@ -73,6 +73,10 @@ void fuzz_target(const std::vector& buffer, const std::string& LIMIT_TO g_setup->m_node.peer_logic->ProcessMessage(p2p_node, random_message_type, random_bytes_data_stream, GetTimeMillis(), Params(), std::atomic{false}); } catch (const std::ios_base::failure& e) { } + { + LOCK(p2p_node.cs_sendProcessing); + g_setup->m_node.peer_logic->SendMessages(&p2p_node); + } SyncWithValidationInterfaceQueue(); } diff --git a/src/test/fuzz/process_messages.cpp b/src/test/fuzz/process_messages.cpp index 5d506e01cb..d2bb561d17 100644 --- a/src/test/fuzz/process_messages.cpp +++ b/src/test/fuzz/process_messages.cpp @@ -72,6 +72,10 @@ FUZZ_TARGET_INIT(process_messages, initialize_process_messages) connman.ProcessMessagesOnce(random_node); } catch (const std::ios_base::failure&) { } + { + LOCK(random_node.cs_sendProcessing); + g_setup->m_node.peer_logic->SendMessages(&random_node); + } } connman.ClearTestNodes(); SyncWithValidationInterfaceQueue();