@@ -896,6 +896,8 @@ void CSigSharesManager::SendMessages()
896
896
CollectSigSharesToAnnounce (sigSharesToAnnounce);
897
897
}
898
898
899
+ bool didSend = false ;
900
+
899
901
g_connman->ForEachNode ([&](CNode* pnode) {
900
902
CNetMsgMaker msgMaker (pnode->GetSendVersion ());
901
903
@@ -905,7 +907,8 @@ void CSigSharesManager::SendMessages()
905
907
assert (p.second .CountSet () != 0 );
906
908
LogPrint (" llmq" , " CSigSharesManager::SendMessages -- QGETSIGSHARES inv={%s}, node=%d\n " ,
907
909
p.second .ToString (), pnode->id );
908
- g_connman->PushMessage (pnode, msgMaker.Make (NetMsgType::QGETSIGSHARES, p.second ));
910
+ g_connman->PushMessage (pnode, msgMaker.Make (NetMsgType::QGETSIGSHARES, p.second ), false );
911
+ didSend = true ;
909
912
}
910
913
}
911
914
@@ -915,7 +918,8 @@ void CSigSharesManager::SendMessages()
915
918
assert (!p.second .sigShares .empty ());
916
919
LogPrint (" llmq" , " CSigSharesManager::SendMessages -- QBSIGSHARES inv={%s}, node=%d\n " ,
917
920
p.second .ToInv ().ToString (), pnode->id );
918
- g_connman->PushMessage (pnode, msgMaker.Make (NetMsgType::QBSIGSHARES, p.second ));
921
+ g_connman->PushMessage (pnode, msgMaker.Make (NetMsgType::QBSIGSHARES, p.second ), false );
922
+ didSend = true ;
919
923
}
920
924
}
921
925
@@ -925,12 +929,17 @@ void CSigSharesManager::SendMessages()
925
929
assert (p.second .CountSet () != 0 );
926
930
LogPrint (" llmq" , " CSigSharesManager::SendMessages -- QSIGSHARESINV inv={%s}, node=%d\n " ,
927
931
p.second .ToString (), pnode->id );
928
- g_connman->PushMessage (pnode, msgMaker.Make (NetMsgType::QSIGSHARESINV, p.second ));
932
+ g_connman->PushMessage (pnode, msgMaker.Make (NetMsgType::QSIGSHARESINV, p.second ), false );
933
+ didSend = true ;
929
934
}
930
935
}
931
936
932
937
return true ;
933
938
});
939
+
940
+ if (didSend) {
941
+ g_connman->WakeSelect ();
942
+ }
934
943
}
935
944
936
945
void CSigSharesManager::Cleanup ()
0 commit comments