Bitcoin Core  22.99.0
P2P Digital Currency
net_processing.h
Go to the documentation of this file.
1 // Copyright (c) 2009-2010 Satoshi Nakamoto
2 // Copyright (c) 2009-2020 The Bitcoin Core developers
3 // Distributed under the MIT software license, see the accompanying
4 // file COPYING or http://www.opensource.org/licenses/mit-license.php.
5 
6 #ifndef BITCOIN_NET_PROCESSING_H
7 #define BITCOIN_NET_PROCESSING_H
8 
9 #include <net.h>
10 #include <validationinterface.h>
11 
12 class AddrMan;
13 class CChainParams;
14 class CTxMemPool;
15 class ChainstateManager;
16 
18 static const unsigned int DEFAULT_MAX_ORPHAN_TRANSACTIONS = 100;
20 static const unsigned int DEFAULT_BLOCK_RECONSTRUCTION_EXTRA_TXN = 100;
21 static const bool DEFAULT_PEERBLOOMFILTERS = false;
22 static const bool DEFAULT_PEERBLOCKFILTERS = false;
24 static const int DISCOURAGEMENT_THRESHOLD{100};
25 
27  int nSyncHeight = -1;
28  int nCommonHeight = -1;
30  std::chrono::microseconds m_ping_wait;
31  std::vector<int> vHeightInFlight;
32  uint64_t m_addr_processed = 0;
33  uint64_t m_addr_rate_limited = 0;
34  bool m_addr_relay_enabled{false};
35 };
36 
38 {
39 public:
40  static std::unique_ptr<PeerManager> make(const CChainParams& chainparams, CConnman& connman, AddrMan& addrman,
41  BanMan* banman, ChainstateManager& chainman,
42  CTxMemPool& pool, bool ignore_incoming_txs);
43  virtual ~PeerManager() { }
44 
46  virtual void StartScheduledTasks(CScheduler& scheduler) = 0;
47 
49  virtual bool GetNodeStateStats(NodeId nodeid, CNodeStateStats& stats) const = 0;
50 
52  virtual bool IgnoresIncomingTxs() = 0;
53 
55  virtual void RelayTransaction(const uint256& txid, const uint256& wtxid) = 0;
56 
58  virtual void SendPings() = 0;
59 
61  virtual void SetBestHeight(int height) = 0;
62 
68  virtual void Misbehaving(const NodeId pnode, const int howmuch, const std::string& message) = 0;
69 
74  virtual void CheckForStaleTipAndEvictPeers() = 0;
75 
77  virtual void ProcessMessage(CNode& pfrom, const std::string& msg_type, CDataStream& vRecv,
78  const std::chrono::microseconds time_received, const std::atomic<bool>& interruptMsgProc) = 0;
79 };
80 
81 #endif // BITCOIN_NET_PROCESSING_H
CValidationInterface
Implement this to subscribe to events generated in validation.
Definition: validationinterface.h:78
NodeId
int64_t NodeId
Definition: net.h:87
PeerManager::GetNodeStateStats
virtual bool GetNodeStateStats(NodeId nodeid, CNodeStateStats &stats) const =0
Get statistics from node state.
PeerManager::SendPings
virtual void SendPings()=0
Send ping message to all peers.
CNodeStateStats::vHeightInFlight
std::vector< int > vHeightInFlight
Definition: net_processing.h:31
CScheduler
Simple class for background tasks that should be run periodically or once "after a while".
Definition: scheduler.h:33
CNodeStateStats::nCommonHeight
int nCommonHeight
Definition: net_processing.h:28
PeerManager::IgnoresIncomingTxs
virtual bool IgnoresIncomingTxs()=0
Whether this node ignores txs received over p2p.
NetEventsInterface
Interface for message handling.
Definition: net.h:705
PeerManager::Misbehaving
virtual void Misbehaving(const NodeId pnode, const int howmuch, const std::string &message)=0
Increment peer's misbehavior score.
CNodeStateStats::m_addr_rate_limited
uint64_t m_addr_rate_limited
Definition: net_processing.h:33
CTxMemPool
CTxMemPool stores valid-according-to-the-current-best-chain transactions that may be included in the ...
Definition: txmempool.h:475
CNode
Information about a peer.
Definition: net.h:393
validationinterface.h
AddrMan
Stochastic address manager.
Definition: addrman.h:54
CChainParams
CChainParams defines various tweakable parameters of a given instance of the Bitcoin system.
Definition: chainparams.h:69
CNodeStateStats::nSyncHeight
int nSyncHeight
Definition: net_processing.h:27
PeerManager::make
static std::unique_ptr< PeerManager > make(const CChainParams &chainparams, CConnman &connman, AddrMan &addrman, BanMan *banman, ChainstateManager &chainman, CTxMemPool &pool, bool ignore_incoming_txs)
Definition: net_processing.cpp:1429
CNodeStateStats::m_addr_relay_enabled
bool m_addr_relay_enabled
Definition: net_processing.h:34
PeerManager::SetBestHeight
virtual void SetBestHeight(int height)=0
Set the best height.
DEFAULT_MAX_ORPHAN_TRANSACTIONS
static const unsigned int DEFAULT_MAX_ORPHAN_TRANSACTIONS
Default for -maxorphantx, maximum number of orphan transactions kept in memory.
Definition: net_processing.h:18
DEFAULT_PEERBLOCKFILTERS
static const bool DEFAULT_PEERBLOCKFILTERS
Definition: net_processing.h:22
PeerManager::StartScheduledTasks
virtual void StartScheduledTasks(CScheduler &scheduler)=0
Begin running background tasks, should only be called once.
DEFAULT_PEERBLOOMFILTERS
static const bool DEFAULT_PEERBLOOMFILTERS
Definition: net_processing.h:21
PeerManager::ProcessMessage
virtual void ProcessMessage(CNode &pfrom, const std::string &msg_type, CDataStream &vRecv, const std::chrono::microseconds time_received, const std::atomic< bool > &interruptMsgProc)=0
Process a single message from a peer.
DEFAULT_BLOCK_RECONSTRUCTION_EXTRA_TXN
static const unsigned int DEFAULT_BLOCK_RECONSTRUCTION_EXTRA_TXN
Default number of orphan+recently-replaced txn to keep around for block reconstruction.
Definition: net_processing.h:20
PeerManager
Definition: net_processing.h:37
uint256
256-bit opaque blob.
Definition: uint256.h:124
PeerManager::CheckForStaleTipAndEvictPeers
virtual void CheckForStaleTipAndEvictPeers()=0
Evict extra outbound peers.
CNodeStateStats::m_addr_processed
uint64_t m_addr_processed
Definition: net_processing.h:32
CNodeStateStats::m_starting_height
int m_starting_height
Definition: net_processing.h:29
BanMan
Definition: banman.h:58
ChainstateManager
Provides an interface for creating and interacting with one or two chainstates: an IBD chainstate gen...
Definition: validation.h:849
CConnman
Definition: net.h:740
PeerManager::~PeerManager
virtual ~PeerManager()
Definition: net_processing.h:43
DISCOURAGEMENT_THRESHOLD
static const int DISCOURAGEMENT_THRESHOLD
Threshold for marking a node to be discouraged, e.g.
Definition: net_processing.h:24
CDataStream
Double ended buffer combining vector and stream-like interfaces.
Definition: streams.h:204
CNodeStateStats::m_ping_wait
std::chrono::microseconds m_ping_wait
Definition: net_processing.h:30
PeerManager::RelayTransaction
virtual void RelayTransaction(const uint256 &txid, const uint256 &wtxid)=0
Relay transaction to all peers.
CNodeStateStats
Definition: net_processing.h:26
net.h