Bitcoin Core  0.20.99
P2P Digital Currency
zmqabstractnotifier.h
Go to the documentation of this file.
1 // Copyright (c) 2015-2018 The Bitcoin Core developers
2 // Distributed under the MIT software license, see the accompanying
3 // file COPYING or http://www.opensource.org/licenses/mit-license.php.
4 
5 #ifndef BITCOIN_ZMQ_ZMQABSTRACTNOTIFIER_H
6 #define BITCOIN_ZMQ_ZMQABSTRACTNOTIFIER_H
7 
8 #include <util/memory.h>
9 
10 #include <memory>
11 #include <string>
12 
13 class CBlockIndex;
14 class CTransaction;
16 
17 using CZMQNotifierFactory = std::unique_ptr<CZMQAbstractNotifier> (*)();
18 
20 {
21 public:
22  static const int DEFAULT_ZMQ_SNDHWM {1000};
23 
25  virtual ~CZMQAbstractNotifier();
26 
27  template <typename T>
28  static std::unique_ptr<CZMQAbstractNotifier> Create()
29  {
30  return MakeUnique<T>();
31  }
32 
33  std::string GetType() const { return type; }
34  void SetType(const std::string &t) { type = t; }
35  std::string GetAddress() const { return address; }
36  void SetAddress(const std::string &a) { address = a; }
38  void SetOutboundMessageHighWaterMark(const int sndhwm) {
39  if (sndhwm >= 0) {
41  }
42  }
43 
44  virtual bool Initialize(void *pcontext) = 0;
45  virtual void Shutdown() = 0;
46 
47  // Notifies of ConnectTip result, i.e., new active tip only
48  virtual bool NotifyBlock(const CBlockIndex *pindex);
49  // Notifies of every block connection
50  virtual bool NotifyBlockConnect(const CBlockIndex *pindex);
51  // Notifies of every block disconnection
52  virtual bool NotifyBlockDisconnect(const CBlockIndex *pindex);
53  // Notifies of every mempool acceptance
54  virtual bool NotifyTransactionAcceptance(const CTransaction &transaction, uint64_t mempool_sequence);
55  // Notifies of every mempool removal, except inclusion in blocks
56  virtual bool NotifyTransactionRemoval(const CTransaction &transaction, uint64_t mempool_sequence);
57  // Notifies of transactions added to mempool or appearing in blocks
58  virtual bool NotifyTransaction(const CTransaction &transaction);
59 
60 protected:
61  void *psocket;
62  std::string type;
63  std::string address;
65 };
66 
67 #endif // BITCOIN_ZMQ_ZMQABSTRACTNOTIFIER_H
static std::unique_ptr< CZMQAbstractNotifier > Create()
virtual bool NotifyBlockDisconnect(const CBlockIndex *pindex)
virtual bool NotifyBlock(const CBlockIndex *pindex)
std::string GetAddress() const
virtual bool NotifyTransactionRemoval(const CTransaction &transaction, uint64_t mempool_sequence)
virtual bool NotifyBlockConnect(const CBlockIndex *pindex)
virtual bool NotifyTransaction(const CTransaction &transaction)
void SetOutboundMessageHighWaterMark(const int sndhwm)
int GetOutboundMessageHighWaterMark() const
std::unique_ptr< CZMQAbstractNotifier >(*)() CZMQNotifierFactory
void SetAddress(const std::string &a)
static const int DEFAULT_ZMQ_SNDHWM
virtual void Shutdown()=0
The block chain is a tree shaped structure starting with the genesis block at the root...
Definition: chain.h:137
virtual bool NotifyTransactionAcceptance(const CTransaction &transaction, uint64_t mempool_sequence)
virtual bool Initialize(void *pcontext)=0
The basic transaction that is broadcasted on the network and contained in blocks. ...
Definition: transaction.h:259
void SetType(const std::string &t)
std::string GetType() const