|
|
@ -1897,6 +1897,7 @@ void RelayTransaction(const CTransaction& tx) |
|
|
|
|
|
|
|
void RelayTransaction(const CTransaction& tx, const CDataStream& ss) |
|
|
|
{ |
|
|
|
fprintf(stderr,"RelayTransaction\n"); |
|
|
|
CInv inv(MSG_TX, tx.GetHash()); |
|
|
|
{ |
|
|
|
LOCK(cs_mapRelay); |
|
|
@ -1914,15 +1915,16 @@ void RelayTransaction(const CTransaction& tx, const CDataStream& ss) |
|
|
|
LOCK(cs_vNodes); |
|
|
|
BOOST_FOREACH(CNode* pnode, vNodes) |
|
|
|
{ |
|
|
|
fprintf(stderr,"pnode relay tx.%d\n",(int32_t)pnode->fRelayTxes); |
|
|
|
if(!pnode->fRelayTxes) |
|
|
|
continue; |
|
|
|
fprintf(stderr,"found pnode\n"); |
|
|
|
LOCK(pnode->cs_filter); |
|
|
|
if (pnode->pfilter) |
|
|
|
{ |
|
|
|
if (pnode->pfilter->IsRelevantAndUpdate(tx)) |
|
|
|
pnode->PushInventory(inv); |
|
|
|
} else |
|
|
|
pnode->PushInventory(inv); |
|
|
|
} else pnode->PushInventory(inv); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|