Bitcoin Core  0.18.99
P2P Digital Currency
Classes | Functions | Variables
net_processing.cpp File Reference
#include <net_processing.h>
#include <addrman.h>
#include <banman.h>
#include <arith_uint256.h>
#include <blockencodings.h>
#include <chainparams.h>
#include <consensus/validation.h>
#include <hash.h>
#include <validation.h>
#include <merkleblock.h>
#include <netmessagemaker.h>
#include <netbase.h>
#include <policy/fees.h>
#include <policy/policy.h>
#include <primitives/block.h>
#include <primitives/transaction.h>
#include <random.h>
#include <reverse_iterator.h>
#include <scheduler.h>
#include <tinyformat.h>
#include <txmempool.h>
#include <util/system.h>
#include <util/strencodings.h>
#include <util/validation.h>
#include <memory>
Include dependency graph for net_processing.cpp:

Go to the source code of this file.

Classes

struct  COrphanTx
 
class  CNetProcessingCleanup
 

Functions

std::map< uint256, COrphanTx > mapOrphanTransactions GUARDED_BY (g_cs_orphans)
 
void EraseOrphansFor (NodeId peer)
 
void Misbehaving (NodeId nodeid, int howmuch, const std::string &message="") EXCLUSIVE_LOCKS_REQUIRED(cs_main)
 Increase a node's misbehavior score. More...
 
void UpdateLastBlockAnnounceTime (NodeId node, int64_t time_in_seconds)
 
static bool IsOutboundDisconnectionCandidate (const CNode *node)
 
bool GetNodeStateStats (NodeId nodeid, CNodeStateStats &stats)
 Get statistics from node state. More...
 
static void AddToCompactExtraTransactions (const CTransactionRef &tx) EXCLUSIVE_LOCKS_REQUIRED(g_cs_orphans)
 
bool AddOrphanTx (const CTransactionRef &tx, NodeId peer) EXCLUSIVE_LOCKS_REQUIRED(g_cs_orphans)
 
static int EraseOrphanTx (uint256 hash) EXCLUSIVE_LOCKS_REQUIRED(g_cs_orphans)
 
unsigned int LimitOrphanTxSize (unsigned int nMaxOrphans)
 
static bool TxRelayMayResultInDisconnect (const CValidationState &state)
 Returns true if the given validation state result may result in a peer banning/disconnecting us. More...
 
static bool MaybePunishNode (NodeId nodeid, const CValidationState &state, bool via_compact_block, const std::string &message="")
 Potentially ban a node based on the contents of a CValidationState object. More...
 
static bool BlockRequestAllowed (const CBlockIndex *pindex, const Consensus::Params &consensusParams) EXCLUSIVE_LOCKS_REQUIRED(cs_main)
 
static std::shared_ptr< const CBlock > most_recent_block GUARDED_BY (cs_most_recent_block)
 
static bool AlreadyHave (const CInv &inv) EXCLUSIVE_LOCKS_REQUIRED(cs_main)
 
void RelayTransaction (const uint256 &txid, const CConnman &connman)
 Relay transaction to every node. More...
 
static void RelayAddress (const CAddress &addr, bool fReachable, CConnman *connman)
 
static void ProcessGetBlockData (CNode *pfrom, const CChainParams &chainparams, const CInv &inv, CConnman *connman)
 
static void ProcessGetData (CNode *pfrom, const CChainParams &chainparams, CConnman *connman, const std::atomic< bool > &interruptMsgProc) LOCKS_EXCLUDED(cs_main)
 
static uint32_t GetFetchFlags (CNode *pfrom) EXCLUSIVE_LOCKS_REQUIRED(cs_main)
 
static void SendBlockTransactions (const CBlock &block, const BlockTransactionsRequest &req, CNode *pfrom, CConnman *connman)
 
static bool ProcessHeadersMessage (CNode *pfrom, CConnman *connman, const std::vector< CBlockHeader > &headers, const CChainParams &chainparams, bool via_compact_block)
 
static void ProcessOrphanTx (CConnman *connman, std::set< uint256 > &orphan_work_set, std::list< CTransactionRef > &removed_txn) EXCLUSIVE_LOCKS_REQUIRED(cs_main
 
 AssertLockHeld (g_cs_orphans)
 
 while (!done &&!orphan_work_set.empty())
 
static bool ProcessMessage (CNode *pfrom, const std::string &strCommand, CDataStream &vRecv, int64_t nTimeReceived, const CChainParams &chainparams, CConnman *connman, const std::atomic< bool > &interruptMsgProc, bool enable_bip61)
 

Variables

static constexpr int64_t ORPHAN_TX_EXPIRE_TIME = 20 * 60
 Expiration time for orphan transactions in seconds. More...
 
static constexpr int64_t ORPHAN_TX_EXPIRE_INTERVAL = 5 * 60
 Minimum time between orphan transactions expire time checks in seconds. More...
 
static constexpr int64_t HEADERS_DOWNLOAD_TIMEOUT_BASE = 15 * 60 * 1000000
 Headers download timeout expressed in microseconds Timeout = base + per_header * (expected number of headers) More...
 
static constexpr int64_t HEADERS_DOWNLOAD_TIMEOUT_PER_HEADER = 1000
 
static constexpr int32_t MAX_OUTBOUND_PEERS_TO_PROTECT_FROM_DISCONNECT = 4
 Protect at least this many outbound peers from disconnection due to slow/ behind headers chain. More...
 
static constexpr int64_t CHAIN_SYNC_TIMEOUT = 20 * 60
 Timeout for (unprotected) outbound peers to sync to our chainwork, in seconds. More...
 
static constexpr int64_t STALE_CHECK_INTERVAL = 10 * 60
 How frequently to check for stale tips, in seconds. More...
 
static constexpr int64_t EXTRA_PEER_CHECK_INTERVAL = 45
 How frequently to check for extra outbound peers and disconnect, in seconds. More...
 
static constexpr int64_t MINIMUM_CONNECT_TIME = 30
 Minimum time an outbound-peer-eviction candidate must be connected for, in order to evict, in seconds. More...
 
static constexpr uint64_t RANDOMIZER_ID_ADDRESS_RELAY = 0x3cac0035b5866b90ULL
 SHA256("main address relay")[0:8]. More...
 
static constexpr int STALE_RELAY_AGE_LIMIT = 30 * 24 * 60 * 60
 Age after which a stale block will no longer be served if requested as protection against fingerprinting. More...
 
static constexpr int HISTORICAL_BLOCK_AGE = 7 * 24 * 60 * 60
 Age after which a block is considered historical for purposes of rate limiting block relay. More...
 
static constexpr int32_t MAX_PEER_TX_IN_FLIGHT = 100
 Maximum number of in-flight transactions from a peer. More...
 
static constexpr int32_t MAX_PEER_TX_ANNOUNCEMENTS = 2 * MAX_INV_SZ
 Maximum number of announced transactions from a peer. More...
 
static constexpr std::chrono::microseconds INBOUND_PEER_TX_DELAY {std::chrono::seconds{2}}
 How many microseconds to delay requesting transactions from inbound peers. More...
 
static constexpr std::chrono::microseconds GETDATA_TX_INTERVAL {std::chrono::seconds{60}}
 How long to wait (in microseconds) before downloading a transaction from an additional peer. More...
 
static constexpr std::chrono::microseconds MAX_GETDATA_RANDOM_DELAY {std::chrono::seconds{2}}
 Maximum delay (in microseconds) for transaction requests to avoid biasing some peers over others. More...
 
static constexpr std::chrono::microseconds TX_EXPIRY_INTERVAL {GETDATA_TX_INTERVAL * 10}
 How long to wait (in microseconds) before expiring an in-flight getdata request to a peer. More...
 
static const unsigned int MAX_GETDATA_SZ = 1000
 Limit to avoid sending big packets. More...
 
CCriticalSection g_cs_orphans
 
static constexpr unsigned int AVG_LOCAL_ADDRESS_BROADCAST_INTERVAL = 24 * 60 * 60
 Average delay between local address broadcasts in seconds. More...
 
static const unsigned int AVG_ADDRESS_BROADCAST_INTERVAL = 30
 Average delay between peer address broadcasts in seconds. More...
 
static const unsigned int INVENTORY_BROADCAST_INTERVAL = 5
 Average delay between trickled inventory transmissions in seconds. More...
 
static constexpr unsigned int INVENTORY_BROADCAST_MAX = 7 * INVENTORY_BROADCAST_INTERVAL
 Maximum number of inventory items to send per transmission. More...
 
static constexpr unsigned int AVG_FEEFILTER_BROADCAST_INTERVAL = 10 * 60
 Average delay between feefilter broadcasts in seconds. More...
 
static constexpr unsigned int MAX_FEEFILTER_CHANGE_DELAY = 5 * 60
 Maximum feefilter broadcast delay after significant change. More...
 
static CCriticalSection cs_most_recent_block
 
std::set< NodeIdsetMisbehaving
 
bool done = false
 
static CNetProcessingCleanup instance_of_cnetprocessingcleanup
 

Function Documentation

◆ AddOrphanTx()

bool AddOrphanTx ( const CTransactionRef tx,
NodeId  peer 
)

Definition at line 844 of file net_processing.cpp.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ AddToCompactExtraTransactions()

static void AddToCompactExtraTransactions ( const CTransactionRef tx)
static

Definition at line 833 of file net_processing.cpp.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ AlreadyHave()

static bool AlreadyHave ( const CInv inv)
static

Definition at line 1272 of file net_processing.cpp.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ AssertLockHeld()

AssertLockHeld ( g_cs_orphans  )

◆ BlockRequestAllowed()

static bool BlockRequestAllowed ( const CBlockIndex pindex,
const Consensus::Params consensusParams 
)
static

Definition at line 1084 of file net_processing.cpp.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ EraseOrphansFor()

void EraseOrphansFor ( NodeId  peer)

Definition at line 908 of file net_processing.cpp.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ EraseOrphanTx()

static int EraseOrphanTx ( uint256  hash)
static

Definition at line 878 of file net_processing.cpp.

Here is the caller graph for this function:

◆ GetFetchFlags()

static uint32_t GetFetchFlags ( CNode pfrom)
static

Definition at line 1585 of file net_processing.cpp.

Here is the caller graph for this function:

◆ GetNodeStateStats()

bool GetNodeStateStats ( NodeId  nodeid,
CNodeStateStats stats 
)

Get statistics from node state.

Definition at line 813 of file net_processing.cpp.

Here is the caller graph for this function:

◆ GUARDED_BY() [1/2]

std::map<uint256, COrphanTx> mapOrphanTransactions GUARDED_BY ( g_cs_orphans  )

◆ GUARDED_BY() [2/2]

static bool fWitnessesPresentInMostRecentCompactBlock GUARDED_BY ( cs_most_recent_block  )
static

◆ IsOutboundDisconnectionCandidate()

static bool IsOutboundDisconnectionCandidate ( const CNode node)
static

Definition at line 761 of file net_processing.cpp.

Here is the caller graph for this function:

◆ LimitOrphanTxSize()

unsigned int LimitOrphanTxSize ( unsigned int  nMaxOrphans)

Definition at line 925 of file net_processing.cpp.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ MaybePunishNode()

static bool MaybePunishNode ( NodeId  nodeid,
const CValidationState state,
bool  via_compact_block,
const std::string &  message = "" 
)
static

Potentially ban a node based on the contents of a CValidationState object.

Parameters
[in]via_compact_blockthis bool is passed in because net_processing should punish peers differently depending on whether the data was provided in a compact block message or not. If the compact block had a valid header, but contained invalid txs, the peer should not be punished. See BIP 152.
Returns
Returns true if the peer was punished (probably disconnected)

Changes here may need to be reflected in TxRelayMayResultInDisconnect().

Definition at line 1007 of file net_processing.cpp.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ Misbehaving()

void Misbehaving ( NodeId  nodeid,
int  howmuch,
const std::string &  message = "" 
)

Increase a node's misbehavior score.

Mark a misbehaving peer to be banned depending upon the value of -banscore.

Definition at line 964 of file net_processing.cpp.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ProcessGetBlockData()

static void ProcessGetBlockData ( CNode pfrom,
const CChainParams chainparams,
const CInv inv,
CConnman connman 
)
static

Definition at line 1354 of file net_processing.cpp.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ProcessGetData()

static void ProcessGetData ( CNode pfrom,
const CChainParams chainparams,
CConnman connman,
const std::atomic< bool > &  interruptMsgProc 
)
static

Definition at line 1509 of file net_processing.cpp.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ProcessHeadersMessage()

static bool ProcessHeadersMessage ( CNode pfrom,
CConnman connman,
const std::vector< CBlockHeader > &  headers,
const CChainParams chainparams,
bool  via_compact_block 
)
static

Definition at line 1609 of file net_processing.cpp.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ProcessMessage()

static bool ProcessMessage ( CNode pfrom,
const std::string &  strCommand,
CDataStream vRecv,
int64_t  nTimeReceived,
const CChainParams chainparams,
CConnman connman,
const std::atomic< bool > &  interruptMsgProc,
bool  enable_bip61 
)
static

Definition at line 1852 of file net_processing.cpp.

Here is the caller graph for this function:

◆ ProcessOrphanTx()

static void ProcessOrphanTx ( CConnman connman,
std::set< uint256 > &  orphan_work_set,
std::list< CTransactionRef > &  removed_txn 
)
static
Here is the caller graph for this function:

◆ RelayAddress()

static void RelayAddress ( const CAddress addr,
bool  fReachable,
CConnman connman 
)
static

Definition at line 1318 of file net_processing.cpp.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ RelayTransaction()

void RelayTransaction ( const uint256 txid,
const CConnman connman 
)

Relay transaction to every node.

Definition at line 1309 of file net_processing.cpp.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ SendBlockTransactions()

static void SendBlockTransactions ( const CBlock block,
const BlockTransactionsRequest req,
CNode pfrom,
CConnman connman 
)
inlinestatic

Definition at line 1593 of file net_processing.cpp.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ TxRelayMayResultInDisconnect()

static bool TxRelayMayResultInDisconnect ( const CValidationState state)
static

Returns true if the given validation state result may result in a peer banning/disconnecting us.

We use this to determine which unaccepted transactions from a whitelisted peer that we can safely relay.

Definition at line 989 of file net_processing.cpp.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ UpdateLastBlockAnnounceTime()

void UpdateLastBlockAnnounceTime ( NodeId  node,
int64_t  time_in_seconds 
)

Definition at line 752 of file net_processing.cpp.

◆ while()

while ( !done &&!orphan_work_set.  empty())

Definition at line 1796 of file net_processing.cpp.

Here is the call graph for this function:

Variable Documentation

◆ AVG_ADDRESS_BROADCAST_INTERVAL

const unsigned int AVG_ADDRESS_BROADCAST_INTERVAL = 30
static

Average delay between peer address broadcasts in seconds.

Definition at line 102 of file net_processing.cpp.

◆ AVG_FEEFILTER_BROADCAST_INTERVAL

constexpr unsigned int AVG_FEEFILTER_BROADCAST_INTERVAL = 10 * 60
static

Average delay between feefilter broadcasts in seconds.

Definition at line 110 of file net_processing.cpp.

◆ AVG_LOCAL_ADDRESS_BROADCAST_INTERVAL

constexpr unsigned int AVG_LOCAL_ADDRESS_BROADCAST_INTERVAL = 24 * 60 * 60
static

Average delay between local address broadcasts in seconds.

Definition at line 100 of file net_processing.cpp.

◆ CHAIN_SYNC_TIMEOUT

constexpr int64_t CHAIN_SYNC_TIMEOUT = 20 * 60
static

Timeout for (unprotected) outbound peers to sync to our chainwork, in seconds.

Definition at line 51 of file net_processing.cpp.

◆ cs_most_recent_block

CCriticalSection cs_most_recent_block
static

Definition at line 1144 of file net_processing.cpp.

◆ done

bool done = false

Definition at line 1795 of file net_processing.cpp.

◆ EXTRA_PEER_CHECK_INTERVAL

constexpr int64_t EXTRA_PEER_CHECK_INTERVAL = 45
static

How frequently to check for extra outbound peers and disconnect, in seconds.

Definition at line 55 of file net_processing.cpp.

◆ g_cs_orphans

static void g_cs_orphans
Initial value:
{
CCriticalSection cs_main
Mutex to guard access to validation specific variables, such as reading or changing the chainstate...
Definition: validation.cpp:107
AssertLockHeld(g_cs_orphans)

Definition at line 91 of file net_processing.cpp.

◆ GETDATA_TX_INTERVAL

constexpr std::chrono::microseconds GETDATA_TX_INTERVAL {std::chrono::seconds{60}}
static

How long to wait (in microseconds) before downloading a transaction from an additional peer.

Definition at line 73 of file net_processing.cpp.

◆ HEADERS_DOWNLOAD_TIMEOUT_BASE

constexpr int64_t HEADERS_DOWNLOAD_TIMEOUT_BASE = 15 * 60 * 1000000
static

Headers download timeout expressed in microseconds Timeout = base + per_header * (expected number of headers)

Definition at line 44 of file net_processing.cpp.

◆ HEADERS_DOWNLOAD_TIMEOUT_PER_HEADER

constexpr int64_t HEADERS_DOWNLOAD_TIMEOUT_PER_HEADER = 1000
static

Definition at line 45 of file net_processing.cpp.

◆ HISTORICAL_BLOCK_AGE

constexpr int HISTORICAL_BLOCK_AGE = 7 * 24 * 60 * 60
static

Age after which a block is considered historical for purposes of rate limiting block relay.

Set to one week, denominated in seconds.

Definition at line 65 of file net_processing.cpp.

◆ INBOUND_PEER_TX_DELAY

constexpr std::chrono::microseconds INBOUND_PEER_TX_DELAY {std::chrono::seconds{2}}
static

How many microseconds to delay requesting transactions from inbound peers.

Definition at line 71 of file net_processing.cpp.

◆ instance_of_cnetprocessingcleanup

CNetProcessingCleanup instance_of_cnetprocessingcleanup
static

Definition at line 4106 of file net_processing.cpp.

◆ INVENTORY_BROADCAST_INTERVAL

const unsigned int INVENTORY_BROADCAST_INTERVAL = 5
static

Average delay between trickled inventory transmissions in seconds.

Blocks and whitelisted receivers bypass this, outbound peers get half this delay.

Definition at line 105 of file net_processing.cpp.

◆ INVENTORY_BROADCAST_MAX

constexpr unsigned int INVENTORY_BROADCAST_MAX = 7 * INVENTORY_BROADCAST_INTERVAL
static

Maximum number of inventory items to send per transmission.

Limits the impact of low-fee transaction floods.

Definition at line 108 of file net_processing.cpp.

◆ MAX_FEEFILTER_CHANGE_DELAY

constexpr unsigned int MAX_FEEFILTER_CHANGE_DELAY = 5 * 60
static

Maximum feefilter broadcast delay after significant change.

Definition at line 112 of file net_processing.cpp.

◆ MAX_GETDATA_RANDOM_DELAY

constexpr std::chrono::microseconds MAX_GETDATA_RANDOM_DELAY {std::chrono::seconds{2}}
static

Maximum delay (in microseconds) for transaction requests to avoid biasing some peers over others.

Definition at line 75 of file net_processing.cpp.

◆ MAX_GETDATA_SZ

const unsigned int MAX_GETDATA_SZ = 1000
static

Limit to avoid sending big packets.

Not used in processing incoming GETDATA for compatibility

Definition at line 81 of file net_processing.cpp.

◆ MAX_OUTBOUND_PEERS_TO_PROTECT_FROM_DISCONNECT

constexpr int32_t MAX_OUTBOUND_PEERS_TO_PROTECT_FROM_DISCONNECT = 4
static

Protect at least this many outbound peers from disconnection due to slow/ behind headers chain.

Definition at line 49 of file net_processing.cpp.

◆ MAX_PEER_TX_ANNOUNCEMENTS

constexpr int32_t MAX_PEER_TX_ANNOUNCEMENTS = 2 * MAX_INV_SZ
static

Maximum number of announced transactions from a peer.

Definition at line 69 of file net_processing.cpp.

◆ MAX_PEER_TX_IN_FLIGHT

constexpr int32_t MAX_PEER_TX_IN_FLIGHT = 100
static

Maximum number of in-flight transactions from a peer.

Definition at line 67 of file net_processing.cpp.

◆ MINIMUM_CONNECT_TIME

constexpr int64_t MINIMUM_CONNECT_TIME = 30
static

Minimum time an outbound-peer-eviction candidate must be connected for, in order to evict, in seconds.

Definition at line 57 of file net_processing.cpp.

◆ ORPHAN_TX_EXPIRE_INTERVAL

constexpr int64_t ORPHAN_TX_EXPIRE_INTERVAL = 5 * 60
static

Minimum time between orphan transactions expire time checks in seconds.

Definition at line 41 of file net_processing.cpp.

◆ ORPHAN_TX_EXPIRE_TIME

constexpr int64_t ORPHAN_TX_EXPIRE_TIME = 20 * 60
static

Expiration time for orphan transactions in seconds.

Definition at line 39 of file net_processing.cpp.

◆ RANDOMIZER_ID_ADDRESS_RELAY

constexpr uint64_t RANDOMIZER_ID_ADDRESS_RELAY = 0x3cac0035b5866b90ULL
static

SHA256("main address relay")[0:8].

Definition at line 59 of file net_processing.cpp.

◆ setMisbehaving

std::set<NodeId> setMisbehaving

Definition at line 1794 of file net_processing.cpp.

◆ STALE_CHECK_INTERVAL

constexpr int64_t STALE_CHECK_INTERVAL = 10 * 60
static

How frequently to check for stale tips, in seconds.

Definition at line 53 of file net_processing.cpp.

◆ STALE_RELAY_AGE_LIMIT

constexpr int STALE_RELAY_AGE_LIMIT = 30 * 24 * 60 * 60
static

Age after which a stale block will no longer be served if requested as protection against fingerprinting.

Set to one month, denominated in seconds.

Definition at line 62 of file net_processing.cpp.

◆ TX_EXPIRY_INTERVAL

constexpr std::chrono::microseconds TX_EXPIRY_INTERVAL {GETDATA_TX_INTERVAL * 10}
static

How long to wait (in microseconds) before expiring an in-flight getdata request to a peer.

Definition at line 77 of file net_processing.cpp.