neobytes-project/neobytes
neobytes-project/neobytes
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix relay bug (#1178)

Browse Source
This commit is contained in:
UdjinM6 2016-12-02 14:32:28 +04:00 committed by GitHub
parent d9fb724943
commit c3e5757c25
1 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/main.cpp
View File

@ -5056,16 +5056,19 @@ void static ProcessGetData(CNode* pfrom, const Consensus::Params& consensusParam
{ {
// Send stream from relay memory // Send stream from relay memory
bool pushed = false; bool pushed = false;
map<CInv, CDataStream>::iterator mi;
{ {
LOCK(cs_mapRelay); CDataStream ss(SER_NETWORK, PROTOCOL_VERSION);
mi = mapRelay.find(inv); {
if (mi != mapRelay.end()) { LOCK(cs_mapRelay);
pushed = true; map<CInv, CDataStream>::iterator mi = mapRelay.find(inv);
if (mi != mapRelay.end()) {
ss += (*mi).second;
pushed = true;
}
} }
if(pushed)
pfrom->PushMessage(inv.GetCommand(), ss);
} }
if(pushed)
pfrom->PushMessage(inv.GetCommand(), (*mi).second);
if (!pushed && inv.type == MSG_TX) { if (!pushed && inv.type == MSG_TX) {
CTransaction tx; CTransaction tx;