diff options
| author | instagibbs <gsanders87@gmail.com> | 2016-11-22 15:47:07 -0500 |
|---|---|---|
| committer | Gregory Sanders <gsanders87@gmail.com> | 2016-12-05 07:43:22 -0500 |
| commit | 412bab22b23036962509d2655b68cccd726b6ba4 (patch) | |
| tree | 62eadd8c5279b73c053b0704d5eae5ce7f2436f4 /src/zmq | |
| parent | bc7ff8db99dbc28f8b2d7a22f4650fa5349cb23b (diff) | |
| download | bitcoin-412bab22b23036962509d2655b68cccd726b6ba4.tar.xz | |
Adapt ZMQ/rest serialization to take rpcserialversion arg
Diffstat (limited to 'src/zmq')
| -rw-r--r-- | src/zmq/zmqpublishnotifier.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/zmq/zmqpublishnotifier.cpp b/src/zmq/zmqpublishnotifier.cpp index 99d42ab526..a11256dfd5 100644 --- a/src/zmq/zmqpublishnotifier.cpp +++ b/src/zmq/zmqpublishnotifier.cpp @@ -7,6 +7,7 @@ #include "zmqpublishnotifier.h" #include "validation.h" #include "util.h" +#include "rpc/server.h" 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()); const Consensus::Params& consensusParams = Params().GetConsensus(); - CDataStream ss(SER_NETWORK, PROTOCOL_VERSION); + CDataStream ss(SER_NETWORK, PROTOCOL_VERSION | RPCSerializationFlags()); { LOCK(cs_main); CBlock block; @@ -186,7 +187,7 @@ bool CZMQPublishRawTransactionNotifier::NotifyTransaction(const CTransaction &tr { uint256 hash = transaction.GetHash(); LogPrint("zmq", "zmq: Publish rawtx %s\n", hash.GetHex()); - CDataStream ss(SER_NETWORK, PROTOCOL_VERSION); + CDataStream ss(SER_NETWORK, PROTOCOL_VERSION | RPCSerializationFlags()); ss << transaction; return SendMessage(MSG_RAWTX, &(*ss.begin()), ss.size()); } |