#include <net.h>

Collaboration diagram for CConnman:

Classes
struct	CachedAddrResponse
	Cache responses to addr requests to minimize privacy leak. More...

struct	ListenSocket

class	NodesSnapshot
	RAII helper to atomically create a copy of `m_nodes` and add a reference to each of the nodes. More...

struct	Options

Public Types
using	NodeFn = std::function< void(CNode *)>

Public Member Functions
void	Init (const Options &connOptions) EXCLUSIVE_LOCKS_REQUIRED(!m_added_nodes_mutex)

	CConnman (const Config &configIn, uint64_t seed0, uint64_t seed1, AddrMan &addrmanIn, bool network_active=true)

	~CConnman ()

bool	Start (CScheduler &scheduler, const Options &options) EXCLUSIVE_LOCKS_REQUIRED(!m_added_nodes_mutex

void	StopThreads ()

void	StopNodes ()

void	Stop ()

void	Interrupt () EXCLUSIVE_LOCKS_REQUIRED(!mutexMsgProc)

bool	GetNetworkActive () const

bool	GetUseAddrmanOutgoing () const

void	SetNetworkActive (bool active)

void	OpenNetworkConnection (const CAddress &addrConnect, bool fCountFailure, CSemaphoreGrant grantOutbound, const char strDest, ConnectionType conn_type)

bool	CheckIncomingNonce (uint64_t nonce)

bool	ForNode (NodeId id, std::function< bool(CNode *pnode)> func)

void	PushMessage (CNode *pnode, CSerializedNetMsg &&msg)

void	ForEachNode (const NodeFn &func)

void	ForEachNode (const NodeFn &func) const

std::vector< CAddress >	GetAddresses (size_t max_addresses, size_t max_pct, std::optional< Network > network) const
	Return all or many randomly selected addresses, optionally by network. More...

std::vector< CAddress >	GetAddresses (CNode &requestor, size_t max_addresses, size_t max_pct)
	Cache is used to minimize topology leaks, so it should be used for all non-trusted calls, for example, p2p. More...

void	SetTryNewOutboundPeer (bool flag)

bool	GetTryNewOutboundPeer () const

void	StartExtraBlockRelayPeers ()

int	GetExtraFullOutboundCount () const

int	GetExtraBlockRelayCount () const

bool	AddNode (const std::string &node) EXCLUSIVE_LOCKS_REQUIRED(!m_added_nodes_mutex)

bool	RemoveAddedNode (const std::string &node) EXCLUSIVE_LOCKS_REQUIRED(!m_added_nodes_mutex)

std::vector< AddedNodeInfo >	GetAddedNodeInfo () const EXCLUSIVE_LOCKS_REQUIRED(!m_added_nodes_mutex)

bool	AddConnection (const std::string &address, ConnectionType conn_type)
	Attempts to open a connection. More...

size_t	GetNodeCount (ConnectionDirection) const

void	GetNodeStats (std::vector< CNodeStats > &vstats) const

bool	DisconnectNode (const std::string &node)

bool	DisconnectNode (const CSubNet &subnet)

bool	DisconnectNode (const CNetAddr &addr)

bool	DisconnectNode (NodeId id)

ServiceFlags	GetLocalServices () const
	Used to convey which local services we are offering peers during node connection. More...

uint64_t	GetMaxOutboundTarget () const

std::chrono::seconds	GetMaxOutboundTimeframe () const

bool	OutboundTargetReached (bool historicalBlockServingLimit) const
	check if the outbound target is reached. More...

uint64_t	GetOutboundTargetBytesLeft () const
	response the bytes left in the current max outbound cycle in case of no limit, it will always response 0 More...

std::chrono::seconds	GetMaxOutboundTimeLeftInCycle () const
	returns the time in second left in the current max outbound cycle in case of no limit, it will always return 0 More...

uint64_t	GetTotalBytesRecv () const

uint64_t	GetTotalBytesSent () const

CSipHasher	GetDeterministicRandomizer (uint64_t id) const
	Get a unique deterministic randomizer. More...

unsigned int	GetReceiveFloodSize () const

void	WakeMessageHandler () EXCLUSIVE_LOCKS_REQUIRED(!mutexMsgProc)

bool	ShouldRunInactivityChecks (const CNode &node, std::chrono::seconds now) const
	Return true if we should disconnect the peer for failing an inactivity check. More...

Public Attributes
bool	!m_addr_fetches_mutex

bool	!mutexMsgProc

Private Member Functions
bool	BindListenPort (const CService &bindAddr, bilingual_str &strError, NetPermissionFlags permissions)

bool	Bind (const CService &addr, unsigned int flags, NetPermissionFlags permissions)

bool	InitBinds (const Options &options)

void	ThreadOpenAddedConnections () EXCLUSIVE_LOCKS_REQUIRED(!m_added_nodes_mutex)

void	AddAddrFetch (const std::string &strDest) EXCLUSIVE_LOCKS_REQUIRED(!m_addr_fetches_mutex)

void	ProcessAddrFetch () EXCLUSIVE_LOCKS_REQUIRED(!m_addr_fetches_mutex)

void	ThreadOpenConnections (std::vector< std::string > connect, std::function< void(const CAddress &, ConnectionType)> mockOpenConnection) EXCLUSIVE_LOCKS_REQUIRED(!m_addr_fetches_mutex

void	ThreadMessageHandler () EXCLUSIVE_LOCKS_REQUIRED(!mutexMsgProc)

void	ThreadI2PAcceptIncoming ()

void	AcceptConnection (const ListenSocket &hListenSocket)

void	CreateNodeFromAcceptedSocket (std::unique_ptr< Sock > &&sock, NetPermissionFlags permission_flags, const CAddress &addr_bind, const CAddress &addr)
	Create a `CNode` object from a socket that has just been accepted and add the node to the `m_nodes` member. More...

void	DisconnectNodes ()

void	NotifyNumConnectionsChanged ()

bool	InactivityCheck (const CNode &node) const
	Return true if the peer is inactive and should be disconnected. More...

Sock::EventsPerSock	GenerateWaitSockets (Span< CNode *const > nodes)
	Generate a collection of sockets to check for IO readiness. More...

void	SocketHandler () EXCLUSIVE_LOCKS_REQUIRED(!mutexMsgProc)
	Check connected and listening sockets for IO readiness and process them accordingly. More...

void	SocketHandlerConnected (const std::vector< CNode * > &nodes, const Sock::EventsPerSock &events_per_sock) EXCLUSIVE_LOCKS_REQUIRED(!mutexMsgProc)
	Do the read/write for connected sockets that are ready for IO. More...

void	SocketHandlerListening (const Sock::EventsPerSock &events_per_sock)
	Accept incoming connections, one from each read-ready listening socket. More...

void	ThreadSocketHandler () EXCLUSIVE_LOCKS_REQUIRED(!mutexMsgProc)

void	ThreadDNSAddressSeed () EXCLUSIVE_LOCKS_REQUIRED(!m_addr_fetches_mutex

uint64_t	CalculateKeyedNetGroup (const CAddress &ad) const

CNode *	FindNode (const CNetAddr &ip)

CNode *	FindNode (const CSubNet &subNet)

CNode *	FindNode (const std::string &addrName)

CNode *	FindNode (const CService &addr)

bool	AlreadyConnectedToAddress (const CAddress &addr)
	Determine whether we're already connected to a given address, in order to avoid initiating duplicate connections. More...

bool	AttemptToEvictConnection ()
	Try to find a connection to evict when the node is full. More...

CNode *	ConnectNode (CAddress addrConnect, const char *pszDest, bool fCountFailure, ConnectionType conn_type)

void	AddWhitelistPermissionFlags (NetPermissionFlags &flags, const CNetAddr &addr, const std::vector< NetWhitelistPermissions > &ranges) const

void	DeleteNode (CNode *pnode)

NodeId	GetNewNodeId ()

std::pair< size_t, bool >	SocketSendData (CNode &node) const EXCLUSIVE_LOCKS_REQUIRED(node.cs_vSend)
	(Try to) send data from node's vSendMsg. More...

void	DumpAddresses ()

void	RecordBytesRecv (uint64_t bytes)

void	RecordBytesSent (uint64_t bytes)

std::vector< CAddress >	GetCurrentBlockRelayOnlyConns () const
	Return vector of current BLOCK_RELAY peers. More...

uint64_t nTotalBytesSent	GUARDED_BY (cs_totalBytesSent)

uint64_t nMaxOutboundTotalBytesSentInCycle	GUARDED_BY (cs_totalBytesSent)

std::chrono::seconds nMaxOutboundCycleStartTime	GUARDED_BY (cs_totalBytesSent)

uint64_t nMaxOutboundLimit	GUARDED_BY (cs_totalBytesSent)

std::deque< std::string > m_addr_fetches	GUARDED_BY (m_addr_fetches_mutex)

std::vector< std::string > m_added_nodes	GUARDED_BY (m_added_nodes_mutex)

std::vector< CNode * > m_nodes	GUARDED_BY (m_nodes_mutex)

bool fMsgProcWake	GUARDED_BY (mutexMsgProc)
	flag for waking the message processor. More...

Static Private Member Functions
static bool	NodeFullyConnected (const CNode *pnode)

Private Attributes
void	!m_added_nodes_mutex

void	!m_nodes_mutex

const Config *	config

RecursiveMutex	cs_totalBytesSent

std::atomic< uint64_t >	nTotalBytesRecv {0}

std::chrono::seconds	m_peer_connect_timeout

std::vector< NetWhitelistPermissions >	vWhitelistedRangeIncoming

std::vector< NetWhitelistPermissions >	vWhitelistedRangeOutgoing

unsigned int	nSendBufferMaxSize {0}

unsigned int	nReceiveFloodSize {0}

std::vector< ListenSocket >	vhListenSocket

std::atomic< bool >	fNetworkActive {true}

bool	fAddressesInitialized {false}

AddrMan &	addrman

Mutex	m_addr_fetches_mutex

Mutex	m_added_nodes_mutex

std::list< CNode * >	m_nodes_disconnected

RecursiveMutex	m_nodes_mutex

std::atomic< NodeId >	nLastNodeId {0}

unsigned int	nPrevNodeCount {0}

std::map< uint64_t, CachedAddrResponse >	m_addr_response_caches
	Addr responses stored in different caches per (network, local socket) prevent cross-network node identification. More...

ServiceFlags	nLocalServices
	Services this node offers. More...

std::unique_ptr< CSemaphore >	semOutbound

std::unique_ptr< CSemaphore >	semAddnode

int	nMaxConnections

int	m_max_outbound_full_relay

int	m_max_outbound_block_relay

int	m_max_avalanche_outbound

int	nMaxAddnode

int	nMaxFeeler

int	m_max_outbound

bool	m_use_addrman_outgoing

CClientUIInterface *	m_client_interface

std::vector< NetEventsInterface * >	m_msgproc

BanMan *	m_banman
	Pointer to this node's banman. More...

std::vector< CAddress >	m_anchors
	Addresses that were saved during the previous clean shutdown. More...

const uint64_t	nSeed0
	SipHasher seeds for deterministic randomness. More...

const uint64_t	nSeed1

std::condition_variable	condMsgProc

Mutex	mutexMsgProc

std::atomic< bool >	flagInterruptMsgProc {false}

CThreadInterrupt	interruptNet
	This is signaled when network activity should cease. More...

std::unique_ptr< i2p::sam::Session >	m_i2p_sam_session
	I2P SAM session. More...

std::thread	threadDNSAddressSeed

std::thread	threadSocketHandler

std::thread	threadOpenAddedConnections

std::thread	threadOpenConnections

std::thread	threadMessageHandler

std::thread	threadI2PAcceptIncoming

std::atomic_bool	m_try_another_outbound_peer
	flag for deciding to connect to an extra outbound peer, in excess of m_max_outbound_full_relay. More...

std::atomic_bool	m_start_extra_block_relay_peers {false}
	flag for initiating extra block-relay-only peer connections. More...

std::vector< CService >	m_onion_binds
	A vector of -bind=<address>:<port>=onion arguments each of which is an address and port that are designated for incoming Tor connections. More...

bool	whitelist_forcerelay
	flag for adding 'forcerelay' permission to whitelisted inbound and manual peers with default permissions. More...

bool	whitelist_relay
	flag for adding 'relay' permission to whitelisted inbound and manual peers with default permissions. More...

Friends
struct	::CConnmanTest

struct	ConnmanTestMsg

Detailed Description

Definition at line 856 of file net.h.

Member Typedef Documentation

◆ NodeFn

using CConnman::NodeFn = std::function<void(CNode *)>

Definition at line 960 of file net.h.

Constructor & Destructor Documentation

◆ CConnman()

CConnman::CConnman	(	const Config &	configIn,
		uint64_t	seed0,
		uint64_t	seed1,
		AddrMan &	addrmanIn,
		bool	network_active = `true`
	)

Definition at line 2701 of file net.cpp.

Here is the call graph for this function:

◆ ~CConnman()

CConnman::~CConnman ( )

Definition at line 2988 of file net.cpp.

Here is the call graph for this function:

Member Function Documentation

◆ AcceptConnection()

void CConnman::AcceptConnection ( const ListenSocket & hListenSocket )

private

Definition at line 1284 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ AddAddrFetch()

void CConnman::AddAddrFetch ( const std::string & strDest )

private

Definition at line 132 of file net.cpp.

Here is the caller graph for this function:

◆ AddConnection()

bool CConnman::AddConnection	(	const std::string &	address,
		ConnectionType	conn_type
	)

Attempts to open a connection.

Currently only used from tests.

Parameters

[in]	address	Address of node to try connecting to
[in]	conn_type	ConnectionType::OUTBOUND, ConnectionType::BLOCK_RELAY, ConnectionType::ADDR_FETCH, or ConnectionType::FEELER

Returns

bool Returns false if there are no available slots for this connection:

conn_type not a supported ConnectionType
Max total outbound connection capacity filled
Max connection capacity for type is filled

Definition at line 1412 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ AddNode()

bool CConnman::AddNode ( const std::string & node )

Definition at line 3060 of file net.cpp.

Here is the caller graph for this function:

◆ AddWhitelistPermissionFlags()

void CConnman::AddWhitelistPermissionFlags	(	NetPermissionFlags &	flags,
		const CNetAddr &	addr,
		const std::vector< NetWhitelistPermissions > &	ranges
	)		const

private

Definition at line 576 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ AlreadyConnectedToAddress()

bool CConnman::AlreadyConnectedToAddress ( const CAddress & addr )

private

Determine whether we're already connected to a given address, in order to avoid initiating duplicate connections.

Definition at line 391 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ AttemptToEvictConnection()

bool CConnman::AttemptToEvictConnection ( )

private

Try to find a connection to evict when the node is full.

Extreme care must be taken to avoid opening the node to attacker triggered network partitioning. The strategy used here is to protect a small number of peers for each of several distinct characteristics which are difficult to forge. In order to partition a node the attacker must be simultaneously better at all of them than honest peers.

Definition at line 1230 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Bind()

bool CConnman::Bind	(	const CService &	addr,
		unsigned int	flags,
		NetPermissionFlags	permissions
	)

private

Definition at line 2716 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ BindListenPort()

bool CConnman::BindListenPort	(	const CService &	bindAddr,
		bilingual_str &	strError,
		NetPermissionFlags	permissions
	)

private

Definition at line 2559 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CalculateKeyedNetGroup()

uint64_t CConnman::CalculateKeyedNetGroup ( const CAddress & ad ) const

private

Definition at line 3387 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CheckIncomingNonce()

bool CConnman::CheckIncomingNonce ( uint64_t nonce )

Definition at line 396 of file net.cpp.

◆ ConnectNode()

CNode * CConnman::ConnectNode	(	CAddress	addrConnect,
		const char *	pszDest,
		bool	fCountFailure,
		ConnectionType	conn_type
	)

private

Definition at line 423 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CreateNodeFromAcceptedSocket()

void CConnman::CreateNodeFromAcceptedSocket	(	std::unique_ptr< Sock > &&	sock,
		NetPermissionFlags	permission_flags,
		const CAddress &	addr_bind,
		const CAddress &	addr
	)

private

Create a CNode object from a socket that has just been accepted and add the node to the m_nodes member.

Parameters

[in]	sock	Connected socket to communicate with the peer.
[in]	permission_flags	The peer's permissions.
[in]	addr_bind	The address and port at our side of the connection.
[in]	addr	The address and port at the peer's side of the connection

Definition at line 1312 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ DeleteNode()

void CConnman::DeleteNode ( CNode * pnode )

private

Definition at line 2980 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ DisconnectNode() [1/4]

bool CConnman::DisconnectNode ( const CNetAddr & addr )

Definition at line 3141 of file net.cpp.

Here is the call graph for this function:

◆ DisconnectNode() [2/4]

bool CConnman::DisconnectNode ( const CSubNet & subnet )

Definition at line 3125 of file net.cpp.

Here is the call graph for this function:

◆ DisconnectNode() [3/4]

bool CConnman::DisconnectNode ( const std::string & node )

Definition at line 3113 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ DisconnectNode() [4/4]

bool CConnman::DisconnectNode ( NodeId id )

Definition at line 3145 of file net.cpp.

◆ DisconnectNodes()

void CConnman::DisconnectNodes ( )

private

Definition at line 1461 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ DumpAddresses()

void CConnman::DumpAddresses ( )

private

Definition at line 1903 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ FindNode() [1/4]

CNode * CConnman::FindNode ( const CNetAddr & ip )

private

Definition at line 351 of file net.cpp.

Here is the caller graph for this function:

◆ FindNode() [2/4]

CNode * CConnman::FindNode ( const CService & addr )

private

Definition at line 381 of file net.cpp.

◆ FindNode() [3/4]

CNode * CConnman::FindNode ( const CSubNet & subNet )

private

Definition at line 361 of file net.cpp.

Here is the call graph for this function:

◆ FindNode() [4/4]

CNode * CConnman::FindNode ( const std::string & addrName )

private

Definition at line 371 of file net.cpp.

◆ ForEachNode() [1/2]

void CConnman::ForEachNode ( const NodeFn & func )

inline

Definition at line 961 of file net.h.

Here is the call graph for this function:

◆ ForEachNode() [2/2]

void CConnman::ForEachNode ( const NodeFn & func ) const

inline

Definition at line 970 of file net.h.

Here is the call graph for this function:

◆ ForNode()

bool CConnman::ForNode	(	NodeId	id,
		std::function< bool(CNode *pnode)>	func
	)

Definition at line 3371 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GenerateWaitSockets()

Sock::EventsPerSock CConnman::GenerateWaitSockets ( Span< CNode *const > nodes )

private

Generate a collection of sockets to check for IO readiness.

Parameters

[in] nodes Select from these nodes' sockets.

Returns: sockets to check for readiness

Definition at line 1570 of file net.cpp.

Here is the caller graph for this function:

◆ GetAddedNodeInfo()

std::vector< AddedNodeInfo > CConnman::GetAddedNodeInfo ( ) const

Definition at line 2332 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetAddresses() [1/2]

std::vector< CAddress > CConnman::GetAddresses	(	CNode &	requestor,
		size_t	max_addresses,
		size_t	max_pct
	)

Cache is used to minimize topology leaks, so it should be used for all non-trusted calls, for example, p2p.

A non-malicious call (from RPC or a peer with addr permission) should call the function without a parameter to avoid using the cache.

Definition at line 3011 of file net.cpp.

Here is the call graph for this function:

◆ GetAddresses() [2/2]

std::vector< CAddress > CConnman::GetAddresses	(	size_t	max_addresses,
		size_t	max_pct,
		std::optional< Network >	network
	)		const

Return all or many randomly selected addresses, optionally by network.

Parameters

[in]	max_addresses	Maximum number of addresses to return (0 = all).
[in]	max_pct	Maximum percentage of addresses to return (0 = all).
[in]	network	Select only addresses of this network (nullopt = all).

Definition at line 2994 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetCurrentBlockRelayOnlyConns()

std::vector< CAddress > CConnman::GetCurrentBlockRelayOnlyConns ( ) const

private

Return vector of current BLOCK_RELAY peers.

Definition at line 2320 of file net.cpp.

Here is the caller graph for this function:

◆ GetDeterministicRandomizer()

CSipHasher CConnman::GetDeterministicRandomizer ( uint64_t id ) const

Get a unique deterministic randomizer.

Definition at line 3383 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetExtraBlockRelayCount()

int CConnman::GetExtraBlockRelayCount ( ) const

Definition at line 1962 of file net.cpp.

◆ GetExtraFullOutboundCount()

int CConnman::GetExtraFullOutboundCount ( ) const

Definition at line 1946 of file net.cpp.

◆ GetLocalServices()

ServiceFlags CConnman::GetLocalServices ( ) const

Used to convey which local services we are offering peers during node connection.

The data returned by this is used in CNode construction, which is used to advertise which services we are offering that peer during net_processing.cpp:PushNodeVersion().

Definition at line 3245 of file net.cpp.

◆ GetMaxOutboundTarget()

uint64_t CConnman::GetMaxOutboundTarget ( ) const

Definition at line 3177 of file net.cpp.

Here is the caller graph for this function:

◆ GetMaxOutboundTimeframe()

std::chrono::seconds CConnman::GetMaxOutboundTimeframe ( ) const

Definition at line 3182 of file net.cpp.

Here is the caller graph for this function:

◆ GetMaxOutboundTimeLeftInCycle()

std::chrono::seconds CConnman::GetMaxOutboundTimeLeftInCycle ( ) const

returns the time in second left in the current max outbound cycle in case of no limit, it will always return 0

Definition at line 3186 of file net.cpp.

Here is the caller graph for this function:

◆ GetNetworkActive()

bool CConnman::GetNetworkActive ( ) const

inline

Definition at line 948 of file net.h.

Here is the caller graph for this function:

◆ GetNewNodeId()

NodeId CConnman::GetNewNodeId ( )

private

Definition at line 2712 of file net.cpp.

Here is the caller graph for this function:

◆ GetNodeCount()

size_t CConnman::GetNodeCount ( ConnectionDirection flags ) const

Definition at line 3084 of file net.cpp.

Here is the caller graph for this function:

◆ GetNodeStats()

void CConnman::GetNodeStats ( std::vector< CNodeStats > & vstats ) const

Definition at line 3102 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetOutboundTargetBytesLeft()

uint64_t CConnman::GetOutboundTargetBytesLeft ( ) const

response the bytes left in the current max outbound cycle in case of no limit, it will always response 0

Definition at line 3225 of file net.cpp.

Here is the caller graph for this function:

◆ GetReceiveFloodSize()

unsigned int CConnman::GetReceiveFloodSize ( ) const

Definition at line 3249 of file net.cpp.

◆ GetTotalBytesRecv()

uint64_t CConnman::GetTotalBytesRecv ( ) const

Definition at line 3236 of file net.cpp.

Here is the caller graph for this function:

◆ GetTotalBytesSent()

uint64_t CConnman::GetTotalBytesSent ( ) const

Definition at line 3240 of file net.cpp.

Here is the caller graph for this function:

◆ GetTryNewOutboundPeer()

bool CConnman::GetTryNewOutboundPeer ( ) const

Definition at line 1930 of file net.cpp.

Here is the caller graph for this function:

◆ GetUseAddrmanOutgoing()

bool CConnman::GetUseAddrmanOutgoing ( ) const

inline

Definition at line 949 of file net.h.

◆ GUARDED_BY() [1/8]

uint64_t nTotalBytesSent CConnman::GUARDED_BY ( cs_totalBytesSent )

inlineprivate

Definition at line 1229 of file net.h.

◆ GUARDED_BY() [2/8]

uint64_t nMaxOutboundTotalBytesSentInCycle CConnman::GUARDED_BY ( cs_totalBytesSent )

inlineprivate

Definition at line 1232 of file net.h.

◆ GUARDED_BY() [3/8]

std::chrono::seconds nMaxOutboundCycleStartTime CConnman::GUARDED_BY ( cs_totalBytesSent )

inlineprivate

Definition at line 1234 of file net.h.

◆ GUARDED_BY() [4/8]

uint64_t nMaxOutboundLimit CConnman::GUARDED_BY ( cs_totalBytesSent )

private

◆ GUARDED_BY() [5/8]

std::vector< std::string > m_added_nodes CConnman::GUARDED_BY ( m_added_nodes_mutex )

private

◆ GUARDED_BY() [6/8]

std::deque< std::string > m_addr_fetches CConnman::GUARDED_BY ( m_addr_fetches_mutex )

private

◆ GUARDED_BY() [7/8]

std::vector< CNode * > m_nodes CConnman::GUARDED_BY ( m_nodes_mutex )

private

◆ GUARDED_BY() [8/8]

bool fMsgProcWake CConnman::GUARDED_BY ( mutexMsgProc )

private

flag for waking the message processor.

◆ InactivityCheck()

bool CConnman::InactivityCheck ( const CNode & node ) const

private

Return true if the peer is inactive and should be disconnected.

Definition at line 1530 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Init()

void CConnman::Init ( const Options & connOptions )

inline

Definition at line 890 of file net.h.

Here is the caller graph for this function:

◆ InitBinds()

bool CConnman::InitBinds ( const Options & options )

private

Definition at line 2738 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Interrupt()

void CConnman::Interrupt ( )

Definition at line 2901 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ NodeFullyConnected()

bool CConnman::NodeFullyConnected ( const CNode * pnode )

staticprivate

Definition at line 3321 of file net.cpp.

Here is the caller graph for this function:

◆ NotifyNumConnectionsChanged()

void CConnman::NotifyNumConnectionsChanged ( )

private

Definition at line 1511 of file net.cpp.

Here is the caller graph for this function:

◆ OpenNetworkConnection()

void CConnman::OpenNetworkConnection	(	const CAddress &	addrConnect,
		bool	fCountFailure,
		CSemaphoreGrant *	grantOutbound,
		const char *	strDest,
		ConnectionType	conn_type
	)

Definition at line 2421 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ OutboundTargetReached()

bool CConnman::OutboundTargetReached ( bool historicalBlockServingLimit ) const

check if the outbound target is reached.

If param historicalBlockServingLimit is set true, the function will response true if the limit for serving historical blocks has been reached.

Definition at line 3202 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ProcessAddrFetch()

void CConnman::ProcessAddrFetch ( )

private

Definition at line 1912 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ PushMessage()

void CConnman::PushMessage	(	CNode *	pnode,
		CSerializedNetMsg &&	msg
	)

Definition at line 3325 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ RecordBytesRecv()

void CConnman::RecordBytesRecv ( uint64_t bytes )

private

Definition at line 3158 of file net.cpp.

Here is the caller graph for this function:

◆ RecordBytesSent()

void CConnman::RecordBytesSent ( uint64_t bytes )

private

Definition at line 3162 of file net.cpp.

Here is the caller graph for this function:

◆ RemoveAddedNode()

bool CConnman::RemoveAddedNode ( const std::string & node )

Definition at line 3072 of file net.cpp.

Here is the caller graph for this function:

◆ SetNetworkActive()

void CConnman::SetNetworkActive ( bool active )

Definition at line 2687 of file net.cpp.

Here is the caller graph for this function:

◆ SetTryNewOutboundPeer()

void CConnman::SetTryNewOutboundPeer ( bool flag )

Definition at line 1934 of file net.cpp.

Here is the caller graph for this function:

◆ ShouldRunInactivityChecks()

bool CConnman::ShouldRunInactivityChecks	(	const CNode &	node,
		std::chrono::seconds	now
	)		const

Return true if we should disconnect the peer for failing an inactivity check.

Definition at line 1525 of file net.cpp.

Here is the caller graph for this function:

◆ SocketHandler()

void CConnman::SocketHandler ( )

private

Check connected and listening sockets for IO readiness and process them accordingly.

Definition at line 1596 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ SocketHandlerConnected()

void CConnman::SocketHandlerConnected	(	const std::vector< CNode * > &	nodes,
		const Sock::EventsPerSock &	events_per_sock
	)

private

Do the read/write for connected sockets that are ready for IO.

Parameters

[in]	nodes	Nodes to process. The socket of each node is checked against `what`.
[in]	events_per_sock	Sockets that are ready for IO.

Definition at line 1624 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ SocketHandlerListening()

void CConnman::SocketHandlerListening ( const Sock::EventsPerSock & events_per_sock )

private

Accept incoming connections, one from each read-ready listening socket.

Parameters

[in] events_per_sock Sockets that are ready for IO.

Definition at line 1739 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ SocketSendData()

std::pair< size_t, bool > CConnman::SocketSendData ( CNode & node ) const

private

(Try to) send data from node's vSendMsg.

Returns (bytes_sent, data_left).

Definition at line 844 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Start()

bool CConnman::Start	(	CScheduler &	scheduler,
		const Options &	options
	)

Definition at line 2765 of file net.cpp.

Here is the call graph for this function:

◆ StartExtraBlockRelayPeers()

void CConnman::StartExtraBlockRelayPeers ( )

inline

Definition at line 1006 of file net.h.

◆ Stop()

void CConnman::Stop ( )

inline

Definition at line 942 of file net.h.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ StopNodes()

void CConnman::StopNodes ( )

Definition at line 2945 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ StopThreads()

void CConnman::StopThreads ( )

Definition at line 2924 of file net.cpp.

Here is the caller graph for this function:

◆ ThreadDNSAddressSeed()

void CConnman::ThreadDNSAddressSeed ( )

private

Definition at line 1768 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ThreadI2PAcceptIncoming()

void CConnman::ThreadI2PAcceptIncoming ( )

private

Definition at line 2521 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ThreadMessageHandler()

void CConnman::ThreadMessageHandler ( )

private

Definition at line 2470 of file net.cpp.

Here is the caller graph for this function:

◆ ThreadOpenAddedConnections()

void CConnman::ThreadOpenAddedConnections ( )

private

Definition at line 2389 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ThreadOpenConnections()

void CConnman::ThreadOpenConnections	(	std::vector< std::string >	connect,
		std::function< void(const CAddress &, ConnectionType)>	mockOpenConnection
	)

private

Definition at line 1976 of file net.cpp.

Here is the call graph for this function:

◆ ThreadSocketHandler()

void CConnman::ThreadSocketHandler ( )

private

Definition at line 1752 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ WakeMessageHandler()

void CConnman::WakeMessageHandler ( )

Definition at line 1760 of file net.cpp.

Here is the caller graph for this function:

Friends And Related Function Documentation

◆ ::CConnmanTest

friend struct ::CConnmanTest

friend

Definition at line 1430 of file net.h.

◆ ConnmanTestMsg

friend struct ConnmanTestMsg

friend

Definition at line 1431 of file net.h.

Member Data Documentation

◆ !m_added_nodes_mutex

void CConnman::!m_added_nodes_mutex

private

Definition at line 1122 of file net.h.

◆ !m_addr_fetches_mutex

bool CConnman::!m_addr_fetches_mutex

Definition at line 937 of file net.h.

◆ !m_nodes_mutex

void CConnman::!m_nodes_mutex

private

Definition at line 1123 of file net.h.

◆ !mutexMsgProc

bool CConnman::!mutexMsgProc

Definition at line 938 of file net.h.

◆ addrman

AddrMan& CConnman::addrman

private

Definition at line 1252 of file net.h.

◆ condMsgProc

std::condition_variable CConnman::condMsgProc

private

Definition at line 1341 of file net.h.

◆ config

const Config* CConnman::config

private

Definition at line 1224 of file net.h.

◆ cs_totalBytesSent

RecursiveMutex CConnman::cs_totalBytesSent

mutableprivate

Definition at line 1227 of file net.h.

◆ fAddressesInitialized

bool CConnman::fAddressesInitialized {false}

private

Definition at line 1251 of file net.h.

◆ flagInterruptMsgProc

std::atomic<bool> CConnman::flagInterruptMsgProc {false}

private

Definition at line 1343 of file net.h.

◆ fNetworkActive

std::atomic<bool> CConnman::fNetworkActive {true}

private

Definition at line 1250 of file net.h.

◆ interruptNet

CThreadInterrupt CConnman::interruptNet

private

This is signaled when network activity should cease.

A pointer to it is saved in m_i2p_sam_session, so make sure that the lifetime of interruptNet is not shorter than the lifetime of m_i2p_sam_session.

Definition at line 1351 of file net.h.

◆ m_added_nodes_mutex

Mutex CConnman::m_added_nodes_mutex

mutableprivate

Definition at line 1256 of file net.h.

◆ m_addr_fetches_mutex

Mutex CConnman::m_addr_fetches_mutex

private

Definition at line 1254 of file net.h.

◆ m_addr_response_caches

std::map<uint64_t, CachedAddrResponse> CConnman::m_addr_response_caches

private

Addr responses stored in different caches per (network, local socket) prevent cross-network node identification.

If a node for example is multi-homed under Tor and IPv6, a single cache (or no cache at all) would let an attacker to easily detect that it is the same node by comparing responses. Indexing by local socket prevents leakage when a node has multiple listening addresses on the same network.

The used memory equals to 1000 CAddress records (or around 40 bytes) per distinct Network (up to 5) we have/had an inbound peer from, resulting in at most ~196 KB. Every separate local socket may add up to ~196 KB extra.

Definition at line 1288 of file net.h.

◆ m_anchors

std::vector<CAddress> CConnman::m_anchors

private

Addresses that were saved during the previous clean shutdown.

We'll attempt to make block-relay-only connections to them.

Definition at line 1333 of file net.h.

◆ m_banman

BanMan* CConnman::m_banman

private

Pointer to this node's banman.

May be nullptr - check existence before dereferencing.

Definition at line 1327 of file net.h.

◆ m_client_interface

CClientUIInterface* CConnman::m_client_interface

private

Definition at line 1320 of file net.h.

◆ m_i2p_sam_session

std::unique_ptr<i2p::sam::Session> CConnman::m_i2p_sam_session

private

I2P SAM session.

Used to accept incoming and make outgoing I2P connections.

Definition at line 1357 of file net.h.

◆ m_max_avalanche_outbound

int CConnman::m_max_avalanche_outbound

private

Definition at line 1314 of file net.h.

◆ m_max_outbound

int CConnman::m_max_outbound

private

Definition at line 1318 of file net.h.

◆ m_max_outbound_block_relay

int CConnman::m_max_outbound_block_relay

private

Definition at line 1311 of file net.h.

◆ m_max_outbound_full_relay

int CConnman::m_max_outbound_full_relay

private

Definition at line 1307 of file net.h.

◆ m_msgproc

std::vector<NetEventsInterface *> CConnman::m_msgproc

private

Definition at line 1322 of file net.h.

◆ m_nodes_disconnected

std::list<CNode *> CConnman::m_nodes_disconnected

private

Definition at line 1258 of file net.h.

◆ m_nodes_mutex

RecursiveMutex CConnman::m_nodes_mutex

mutableprivate

Definition at line 1259 of file net.h.

◆ m_onion_binds

std::vector<CService> CConnman::m_onion_binds

private

A vector of -bind=<address>:<port>=onion arguments each of which is an address and port that are designated for incoming Tor connections.

Definition at line 1383 of file net.h.

◆ m_peer_connect_timeout

std::chrono::seconds CConnman::m_peer_connect_timeout

private

Definition at line 1238 of file net.h.

◆ m_start_extra_block_relay_peers

std::atomic_bool CConnman::m_start_extra_block_relay_peers {false}

private

flag for initiating extra block-relay-only peer connections.

this should only be enabled after initial chain sync has occurred, as these connections are intended to be short-lived and low-bandwidth.

Definition at line 1377 of file net.h.

◆ m_try_another_outbound_peer

std::atomic_bool CConnman::m_try_another_outbound_peer

private

flag for deciding to connect to an extra outbound peer, in excess of m_max_outbound_full_relay.

This takes the place of a feeler connection.

Definition at line 1370 of file net.h.

◆ m_use_addrman_outgoing

bool CConnman::m_use_addrman_outgoing

private

Definition at line 1319 of file net.h.

◆ mutexMsgProc

Mutex CConnman::mutexMsgProc

private

Definition at line 1342 of file net.h.

◆ nLastNodeId

std::atomic<NodeId> CConnman::nLastNodeId {0}

private

Definition at line 1260 of file net.h.

◆ nLocalServices

ServiceFlags CConnman::nLocalServices

private

Services this node offers.

This data is replicated in each Peer instance we create.

This data is not marked const, but after being set it should not change.

See also: Peer::m_our_services

Definition at line 1300 of file net.h.

◆ nMaxAddnode

int CConnman::nMaxAddnode

private

Definition at line 1316 of file net.h.

◆ nMaxConnections

int CConnman::nMaxConnections

private

Definition at line 1304 of file net.h.

◆ nMaxFeeler

int CConnman::nMaxFeeler

private

Definition at line 1317 of file net.h.

◆ nPrevNodeCount

unsigned int CConnman::nPrevNodeCount {0}

private

Definition at line 1261 of file net.h.

◆ nReceiveFloodSize

unsigned int CConnman::nReceiveFloodSize {0}

private

Definition at line 1247 of file net.h.

◆ nSeed0

const uint64_t CConnman::nSeed0

private

SipHasher seeds for deterministic randomness.

Definition at line 1336 of file net.h.

◆ nSeed1

const uint64_t CConnman::nSeed1

private

Definition at line 1336 of file net.h.

◆ nSendBufferMaxSize

unsigned int CConnman::nSendBufferMaxSize {0}

private

Definition at line 1246 of file net.h.

◆ nTotalBytesRecv

std::atomic<uint64_t> CConnman::nTotalBytesRecv {0}

private

Definition at line 1228 of file net.h.

◆ semAddnode

std::unique_ptr<CSemaphore> CConnman::semAddnode

private

Definition at line 1303 of file net.h.

◆ semOutbound

std::unique_ptr<CSemaphore> CConnman::semOutbound

private

Definition at line 1302 of file net.h.

◆ threadDNSAddressSeed

std::thread CConnman::threadDNSAddressSeed

private

Definition at line 1359 of file net.h.

◆ threadI2PAcceptIncoming

std::thread CConnman::threadI2PAcceptIncoming

private

Definition at line 1364 of file net.h.

◆ threadMessageHandler

std::thread CConnman::threadMessageHandler

private

Definition at line 1363 of file net.h.

◆ threadOpenAddedConnections

std::thread CConnman::threadOpenAddedConnections

private

Definition at line 1361 of file net.h.

◆ threadOpenConnections

std::thread CConnman::threadOpenConnections

private

Definition at line 1362 of file net.h.

◆ threadSocketHandler

std::thread CConnman::threadSocketHandler

private

Definition at line 1360 of file net.h.

◆ vhListenSocket

std::vector<ListenSocket> CConnman::vhListenSocket

private

Definition at line 1249 of file net.h.

◆ vWhitelistedRangeIncoming

std::vector<NetWhitelistPermissions> CConnman::vWhitelistedRangeIncoming

private

Definition at line 1242 of file net.h.

◆ vWhitelistedRangeOutgoing

std::vector<NetWhitelistPermissions> CConnman::vWhitelistedRangeOutgoing

private

Definition at line 1244 of file net.h.

◆ whitelist_forcerelay

bool CConnman::whitelist_forcerelay

private

flag for adding 'forcerelay' permission to whitelisted inbound and manual peers with default permissions.

Definition at line 1389 of file net.h.

◆ whitelist_relay

bool CConnman::whitelist_relay

private

flag for adding 'relay' permission to whitelisted inbound and manual peers with default permissions.

Definition at line 1395 of file net.h.

The documentation for this class was generated from the following files:

/work/src/net.h
/work/src/net.cpp

Classes

Public Types

Public Member Functions

Public Attributes

Private Member Functions

Static Private Member Functions

Private Attributes

Friends

Detailed Description

Member Typedef Documentation

◆ NodeFn

Constructor & Destructor Documentation

◆ CConnman()

◆ ~CConnman()

Member Function Documentation

◆ AcceptConnection()

◆ AddAddrFetch()

◆ AddConnection()

◆ AddNode()

◆ AddWhitelistPermissionFlags()

◆ AlreadyConnectedToAddress()

◆ AttemptToEvictConnection()

◆ Bind()

◆ BindListenPort()

◆ CalculateKeyedNetGroup()

◆ CheckIncomingNonce()

◆ ConnectNode()

◆ CreateNodeFromAcceptedSocket()

◆ DeleteNode()

◆ DisconnectNode() [1/4]

◆ DisconnectNode() [2/4]

◆ DisconnectNode() [3/4]

◆ DisconnectNode() [4/4]

◆ DisconnectNodes()

◆ DumpAddresses()

◆ FindNode() [1/4]

◆ FindNode() [2/4]

◆ FindNode() [3/4]

◆ FindNode() [4/4]

◆ ForEachNode() [1/2]

◆ ForEachNode() [2/2]

◆ ForNode()

◆ GenerateWaitSockets()

◆ GetAddedNodeInfo()

◆ GetAddresses() [1/2]

◆ GetAddresses() [2/2]

◆ GetCurrentBlockRelayOnlyConns()

◆ GetDeterministicRandomizer()

◆ GetExtraBlockRelayCount()

◆ GetExtraFullOutboundCount()

◆ GetLocalServices()

◆ GetMaxOutboundTarget()

◆ GetMaxOutboundTimeframe()

◆ GetMaxOutboundTimeLeftInCycle()

◆ GetNetworkActive()

◆ GetNewNodeId()

◆ GetNodeCount()

◆ GetNodeStats()

◆ GetOutboundTargetBytesLeft()

◆ GetReceiveFloodSize()

◆ GetTotalBytesRecv()

◆ GetTotalBytesSent()

◆ GetTryNewOutboundPeer()

◆ GetUseAddrmanOutgoing()

◆ GUARDED_BY() [1/8]

◆ GUARDED_BY() [2/8]

◆ GUARDED_BY() [3/8]

◆ GUARDED_BY() [4/8]

◆ GUARDED_BY() [5/8]

◆ GUARDED_BY() [6/8]

◆ GUARDED_BY() [7/8]

◆ GUARDED_BY() [8/8]

◆ InactivityCheck()

◆ Init()

◆ InitBinds()

◆ Interrupt()

◆ NodeFullyConnected()

◆ NotifyNumConnectionsChanged()

◆ OpenNetworkConnection()

◆ OutboundTargetReached()