|
|
@ -7,6 +7,7 @@ |
|
|
|
#include "zmqpublishnotifier.h" |
|
|
|
#include "zmqpublishnotifier.h" |
|
|
|
#include "validation.h" |
|
|
|
#include "validation.h" |
|
|
|
#include "util.h" |
|
|
|
#include "util.h" |
|
|
|
|
|
|
|
#include "rpc/server.h" |
|
|
|
|
|
|
|
|
|
|
|
static std::multimap<std::string, CZMQAbstractPublishNotifier*> mapPublishNotifiers; |
|
|
|
static std::multimap<std::string, CZMQAbstractPublishNotifier*> mapPublishNotifiers; |
|
|
|
|
|
|
|
|
|
|
@ -166,7 +167,7 @@ bool CZMQPublishRawBlockNotifier::NotifyBlock(const CBlockIndex *pindex) |
|
|
|
LogPrint("zmq", "zmq: Publish rawblock %s\n", pindex->GetBlockHash().GetHex()); |
|
|
|
LogPrint("zmq", "zmq: Publish rawblock %s\n", pindex->GetBlockHash().GetHex()); |
|
|
|
|
|
|
|
|
|
|
|
const Consensus::Params& consensusParams = Params().GetConsensus(); |
|
|
|
const Consensus::Params& consensusParams = Params().GetConsensus(); |
|
|
|
CDataStream ss(SER_NETWORK, PROTOCOL_VERSION); |
|
|
|
CDataStream ss(SER_NETWORK, PROTOCOL_VERSION | RPCSerializationFlags()); |
|
|
|
{ |
|
|
|
{ |
|
|
|
LOCK(cs_main); |
|
|
|
LOCK(cs_main); |
|
|
|
CBlock block; |
|
|
|
CBlock block; |
|
|
@ -186,7 +187,7 @@ bool CZMQPublishRawTransactionNotifier::NotifyTransaction(const CTransaction &tr |
|
|
|
{ |
|
|
|
{ |
|
|
|
uint256 hash = transaction.GetHash(); |
|
|
|
uint256 hash = transaction.GetHash(); |
|
|
|
LogPrint("zmq", "zmq: Publish rawtx %s\n", hash.GetHex()); |
|
|
|
LogPrint("zmq", "zmq: Publish rawtx %s\n", hash.GetHex()); |
|
|
|
CDataStream ss(SER_NETWORK, PROTOCOL_VERSION); |
|
|
|
CDataStream ss(SER_NETWORK, PROTOCOL_VERSION | RPCSerializationFlags()); |
|
|
|
ss << transaction; |
|
|
|
ss << transaction; |
|
|
|
return SendMessage(MSG_RAWTX, &(*ss.begin()), ss.size()); |
|
|
|
return SendMessage(MSG_RAWTX, &(*ss.begin()), ss.size()); |
|
|
|
} |
|
|
|
} |
|
|
|