|
|
|
@ -209,9 +209,10 @@ bool CZMQPublishHashBlockNotifier::NotifyBlock(const CBlockIndex *pindex)
|
|
|
|
|
{
|
|
|
|
|
uint256 hash = pindex->GetBlockHash();
|
|
|
|
|
LogPrint(BCLog::ZMQ, "zmq: Publish hashblock %s to %s\n", hash.GetHex(), this->address);
|
|
|
|
|
char data[32];
|
|
|
|
|
for (unsigned int i = 0; i < 32; i++)
|
|
|
|
|
uint8_t data[32];
|
|
|
|
|
for (unsigned int i = 0; i < 32; i++) {
|
|
|
|
|
data[31 - i] = hash.begin()[i];
|
|
|
|
|
}
|
|
|
|
|
return SendZmqMessage(MSG_HASHBLOCK, data, 32);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@ -219,9 +220,10 @@ bool CZMQPublishHashTransactionNotifier::NotifyTransaction(const CTransaction &t
|
|
|
|
|
{
|
|
|
|
|
uint256 hash = transaction.GetHash();
|
|
|
|
|
LogPrint(BCLog::ZMQ, "zmq: Publish hashtx %s to %s\n", hash.GetHex(), this->address);
|
|
|
|
|
char data[32];
|
|
|
|
|
for (unsigned int i = 0; i < 32; i++)
|
|
|
|
|
uint8_t data[32];
|
|
|
|
|
for (unsigned int i = 0; i < 32; i++) {
|
|
|
|
|
data[31 - i] = hash.begin()[i];
|
|
|
|
|
}
|
|
|
|
|
return SendZmqMessage(MSG_HASHTX, data, 32);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|