35 std::list<const CZMQAbstractNotifier*> result;
37 result.push_back(n.get());
44 std::map<std::string, CZMQNotifierFactory> factories;
45 factories[
"pubhashblock"] = CZMQAbstractNotifier::Create<CZMQPublishHashBlockNotifier>;
46 factories[
"pubhashtx"] = CZMQAbstractNotifier::Create<CZMQPublishHashTransactionNotifier>;
47 factories[
"pubrawblock"] = CZMQAbstractNotifier::Create<CZMQPublishRawBlockNotifier>;
48 factories[
"pubrawtx"] = CZMQAbstractNotifier::Create<CZMQPublishRawTransactionNotifier>;
49 factories[
"pubsequence"] = CZMQAbstractNotifier::Create<CZMQPublishSequenceNotifier>;
51 std::list<std::unique_ptr<CZMQAbstractNotifier>>
notifiers;
52 for (
const auto& entry : factories)
54 std::string arg(
"-zmq" + entry.first);
55 const auto& factory = entry.second;
57 std::unique_ptr<CZMQAbstractNotifier> notifier = factory();
58 notifier->SetType(entry.first);
59 notifier->SetAddress(address);
68 notificationInterface->notifiers = std::move(
notifiers);
70 if (notificationInterface->Initialize()) {
71 return notificationInterface.release();
81 int major = 0, minor = 0, patch = 0;
82 zmq_version(&major, &minor, &patch);
92 zmqError(
"Unable to initialize context");
97 if (notifier->Initialize(
pcontext)) {
98 LogPrint(
BCLog::ZMQ,
"Notifier %s ready (address = %s)\n", notifier->GetType(), notifier->GetAddress());
100 LogPrint(
BCLog::ZMQ,
"Notifier %s failed (address = %s)\n", notifier->GetType(), notifier->GetAddress());
115 LogPrint(
BCLog::ZMQ,
"Shutdown notifier %s at %s\n", notifier->GetType(), notifier->GetAddress());
116 notifier->Shutdown();
126 template <
typename Function>
127 void TryForEachAndRemoveFailed(std::list<std::unique_ptr<CZMQAbstractNotifier>>& notifiers,
const Function& func)
129 for (
auto i = notifiers.begin(); i != notifiers.end(); ) {
131 if (func(notifier)) {
135 i = notifiers.erase(i);
144 if (fInitialDownload || pindexNew == pindexFork)
std::vector< std::string > GetArgs(const std::string &strArg) const
Return a vector of strings of the given argument.
int64_t GetIntArg(const std::string &strArg, int64_t nDefault) const
Return integer argument or default value.
The block chain is a tree shaped structure starting with the genesis block at the root,...
The basic transaction that is broadcasted on the network and contained in blocks.
virtual void Shutdown()=0
virtual bool NotifyBlockConnect(const CBlockIndex *pindex)
static const int DEFAULT_ZMQ_SNDHWM
virtual bool NotifyTransactionRemoval(const CTransaction &transaction, uint64_t mempool_sequence)
virtual bool NotifyBlock(const CBlockIndex *pindex)
virtual bool NotifyTransaction(const CTransaction &transaction)
virtual bool NotifyBlockDisconnect(const CBlockIndex *pindex)
virtual bool NotifyTransactionAcceptance(const CTransaction &transaction, uint64_t mempool_sequence)
virtual ~CZMQNotificationInterface()
void BlockConnected(const std::shared_ptr< const CBlock > &pblock, const CBlockIndex *pindexConnected) override
Notifies listeners of a block being connected.
static CZMQNotificationInterface * Create()
void TransactionAddedToMempool(const CTransactionRef &tx, uint64_t mempool_sequence) override
Notifies listeners of a transaction having been added to mempool.
void UpdatedBlockTip(const CBlockIndex *pindexNew, const CBlockIndex *pindexFork, bool fInitialDownload) override
Notifies listeners when the block chain tip advances.
std::list< std::unique_ptr< CZMQAbstractNotifier > > notifiers
void BlockDisconnected(const std::shared_ptr< const CBlock > &pblock, const CBlockIndex *pindexDisconnected) override
Notifies listeners of a block being disconnected.
CZMQNotificationInterface()
void TransactionRemovedFromMempool(const CTransactionRef &tx, MemPoolRemovalReason reason, uint64_t mempool_sequence) override
Notifies listeners of a transaction leaving mempool.
std::list< const CZMQAbstractNotifier * > GetActiveNotifiers() const
#define LogPrint(category,...)
std::shared_ptr< const CTransaction > CTransactionRef
MemPoolRemovalReason
Reason why a transaction was removed from the mempool, this is passed to the notification signal.
CZMQNotificationInterface * g_zmq_notification_interface
void zmqError(const std::string &str)