#include <net.h>

Inheritance diagram for CConnman:

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

class	PrivateBroadcast
	Group of private broadcast related members. More...

struct	ReconnectionInfo
	Struct for entries in m_reconnections. More...

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

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

const bool	use_v2transport (GetLocalServices() &NODE_P2P_V2)

	for (const std::string &added_node :connOptions.m_added_nodes)

void	SetCaptureMessages (bool cap)

	CConnman (uint64_t seed0, uint64_t seed1, AddrMan &addrman, const NetGroupManager &netgroupman, const CChainParams &params, bool network_active=true, std::shared_ptr< CThreadInterrupt > interrupt_net=std::make_shared< CThreadInterrupt >())

	~CConnman ()

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

void	StopThreads ()

void	StopNodes () EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex

void	Stop () EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex

	AssertLockNotHeld (m_reconnections_mutex)

	StopThreads ()

	StopNodes ()

void	Interrupt () EXCLUSIVE_LOCKS_REQUIRED(!mutexMsgProc)

bool	GetNetworkActive () const

bool	GetUseAddrmanOutgoing () const

void	SetNetworkActive (bool active)

bool	OpenNetworkConnection (const CAddress &addrConnect, bool fCountFailure, CountingSemaphoreGrant<> &&grant_outbound, const char *pszDest, ConnectionType conn_type, bool use_v2transport, const std::optional< Proxy > &proxy_override=std::nullopt) EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex
	Open a new P2P connection and initialize it with the PeerManager at `m_msgproc`. More...

bool	CheckIncomingNonce (uint64_t nonce) EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)

void	ASMapHealthCheck ()

Mutex &	GetNodesMutex () const LOCK_RETURNED(m_nodes_mutex)

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

void	PushMessage (CNode *pnode, CSerializedNetMsg &&msg) EXCLUSIVE_LOCKS_REQUIRED(!m_total_bytes_sent_mutex)

void	ForEachNode (const NodeFn &func) EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)

void	ForEachNode (const NodeFn &func) const EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)

std::vector< CAddress >	GetAddressesUnsafe (size_t max_addresses, size_t max_pct, std::optional< Network > network, bool filtered=true) const
	Return randomly selected addresses. More...

std::vector< CAddress >	GetAddresses (CNode &requestor, size_t max_addresses, size_t max_pct)
	Return addresses from the per-requestor cache. More...

void	SetTryNewOutboundPeer (bool flag)

bool	GetTryNewOutboundPeer () const

void	StartExtraBlockRelayPeers ()

int	GetFullOutboundConnCount () const EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)

int	GetExtraFullOutboundCount () const EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)

int	GetExtraBlockRelayCount () const EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)

bool	AddNode (const AddedNodeParams &add) EXCLUSIVE_LOCKS_REQUIRED(!m_added_nodes_mutex)

bool	RemoveAddedNode (std::string_view node) EXCLUSIVE_LOCKS_REQUIRED(!m_added_nodes_mutex)

bool	AddedNodesContain (const CAddress &addr) const EXCLUSIVE_LOCKS_REQUIRED(!m_added_nodes_mutex)

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

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

size_t	GetNodeCount (ConnectionDirection) const EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)

std::map< CNetAddr, LocalServiceInfo >	getNetLocalAddresses () const

uint32_t	GetMappedAS (const CNetAddr &addr) const

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

bool	DisconnectNode (std::string_view node) EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)

bool	DisconnectNode (const CSubNet &subnet) EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)

bool	DisconnectNode (const CNetAddr &addr) EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)

bool	DisconnectNode (NodeId id) EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)

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

void	AddLocalServices (ServiceFlags services)
	Updates the local services that this node advertises to other peers during connection handshake. More...

void	RemoveLocalServices (ServiceFlags services)

uint64_t	GetMaxOutboundTarget () const EXCLUSIVE_LOCKS_REQUIRED(!m_total_bytes_sent_mutex)

std::chrono::seconds	GetMaxOutboundTimeframe () const

bool	OutboundTargetReached (bool historicalBlockServingLimit) const EXCLUSIVE_LOCKS_REQUIRED(!m_total_bytes_sent_mutex)
	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 More...

uint64_t	GetOutboundTargetBytesLeft () const EXCLUSIVE_LOCKS_REQUIRED(!m_total_bytes_sent_mutex)
	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 EXCLUSIVE_LOCKS_REQUIRED(!m_total_bytes_sent_mutex)

uint64_t	GetTotalBytesRecv () const

uint64_t	GetTotalBytesSent () const EXCLUSIVE_LOCKS_REQUIRED(!m_total_bytes_sent_mutex)

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

void	WakeMessageHandler () EXCLUSIVE_LOCKS_REQUIRED(!mutexMsgProc)

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

bool	MultipleManualOrFullOutboundConns (Network net) const EXCLUSIVE_LOCKS_REQUIRED(m_nodes_mutex)

Public Attributes
void	!m_total_bytes_sent_mutex

	m_local_services = connOptions.m_local_services

	m_max_automatic_connections = connOptions.m_max_automatic_connections

	m_max_outbound_full_relay = std::min(MAX_OUTBOUND_FULL_RELAY_CONNECTIONS, m_max_automatic_connections)

	m_max_outbound_block_relay = std::min(MAX_BLOCK_RELAY_ONLY_CONNECTIONS, m_max_automatic_connections - m_max_outbound_full_relay)

	m_max_automatic_outbound = m_max_outbound_full_relay + m_max_outbound_block_relay + m_max_feeler

	m_max_inbound = std::max(0, m_max_automatic_connections - m_max_automatic_outbound)

	m_use_addrman_outgoing = connOptions.m_use_addrman_outgoing

	m_client_interface = connOptions.uiInterface

	m_banman = connOptions.m_banman

	m_msgproc = connOptions.m_msgproc

	nSendBufferMaxSize = connOptions.nSendBufferMaxSize

	nReceiveFloodSize = connOptions.nReceiveFloodSize

	m_peer_connect_timeout = std::chrono::seconds{connOptions.m_peer_connect_timeout}

	nMaxOutboundLimit = connOptions.nMaxOutboundLimit

	vWhitelistedRangeIncoming = connOptions.vWhitelistedRangeIncoming

	vWhitelistedRangeOutgoing = connOptions.vWhitelistedRangeOutgoing

	m_onion_binds = connOptions.onion_binds

	whitelist_forcerelay = connOptions.whitelist_forcerelay

	whitelist_relay = connOptions.whitelist_relay

	m_capture_messages = connOptions.m_capture_messages

bool	!m_added_nodes_mutex

bool	!m_addr_fetches_mutex

bool	!mutexMsgProc

void	!m_reconnections_mutex

bool	!m_unused_i2p_sessions_mutex

class CConnman::PrivateBroadcast	m_private_broadcast

std::vector< AddedNodeInfo >	!m_nodes_mutex

Private Member Functions
std::chrono::seconds	GetMaxOutboundTimeLeftInCycle_ () const EXCLUSIVE_LOCKS_REQUIRED(m_total_bytes_sent_mutex)
	returns the time left in the current max outbound cycle in case of no limit, it will always return 0 More...

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::span< const std::string > seed_nodes) EXCLUSIVE_LOCKS_REQUIRED(!m_added_nodes_mutex

void	ThreadMessageHandler () EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex

void	ThreadI2PAcceptIncoming () EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)

void	ThreadPrivateBroadcast () EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex

void	AcceptConnection (const ListenSocket &hListenSocket) EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)

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

void	DisconnectNodes () EXCLUSIVE_LOCKS_REQUIRED(!m_reconnections_mutex

void	NotifyNumConnectionsChanged () EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)

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

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

void	SocketHandler () EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex
	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(!m_total_bytes_sent_mutex
	Do the read/write for connected sockets that are ready for IO. More...

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

void	ThreadSocketHandler () EXCLUSIVE_LOCKS_REQUIRED(!m_total_bytes_sent_mutex

void	ThreadDNSAddressSeed () EXCLUSIVE_LOCKS_REQUIRED(!m_addr_fetches_mutex

uint64_t	CalculateKeyedNetGroup (const CNetAddr &ad) const

bool	AlreadyConnectedToHost (std::string_view host) const EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)
	Determine whether we're already connected to a given "host:port". More...

bool	AlreadyConnectedToAddressPort (const CService &addr_port) const EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)
	Determine whether we're already connected to a given address:port. More...

bool	AlreadyConnectedToAddress (const CNetAddr &addr) const EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)
	Determine whether we're already connected to a given address. More...

bool	AttemptToEvictConnection () EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)
	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, bool use_v2transport, const std::optional< Proxy > &proxy_override) EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex
	Open a new P2P connection. More...

void	AddWhitelistPermissionFlags (NetPermissionFlags &flags, std::optional< 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) EXCLUSIVE_LOCKS_REQUIRED(!m_total_bytes_sent_mutex)

std::unordered_set< Network >	GetReachableEmptyNetworks () const
	Return reachable networks for which we have no addresses in addrman and therefore may require loading fixed seeds. More...

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

bool	MaybePickPreferredNetwork (std::optional< Network > &network) EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex)
	Search for a "preferred" network, a reachable network to which we currently don't have any OUTBOUND_FULL_RELAY or MANUAL connections. More...

uint16_t	GetDefaultPort (Network net) const

uint16_t	GetDefaultPort (const std::string &addr) const

uint64_t nTotalBytesSent	GUARDED_BY (m_total_bytes_sent_mutex)

uint64_t nMaxOutboundTotalBytesSentInCycle	GUARDED_BY (m_total_bytes_sent_mutex)

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

uint64_t nMaxOutboundLimit	GUARDED_BY (m_total_bytes_sent_mutex)

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

std::vector< AddedNodeParams > m_added_node_params	GUARDED_BY (m_added_nodes_mutex)

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

std::array< unsigned int, Network::NET_MAX > m_network_conn_counts	GUARDED_BY (m_nodes_mutex)

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

std::queue< std::unique_ptr< i2p::sam::Session > > m_unused_i2p_sessions	GUARDED_BY (m_unused_i2p_sessions_mutex)
	A pool of created I2P SAM transient sessions that should be used instead of creating new ones in order to reduce the load on the I2P network. More...

std::list< ReconnectionInfo > m_reconnections	GUARDED_BY (m_reconnections_mutex)
	List of reconnections we have to make. More...

void	PerformReconnections () EXCLUSIVE_LOCKS_REQUIRED(!m_nodes_mutex
	Attempt reconnections, if m_reconnections non-empty. More...

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

Private Attributes
void	!m_nodes_mutex

void	!m_unused_i2p_sessions_mutex

void	!m_addr_fetches_mutex

void	!mutexMsgProc

CNode	!m_unused_i2p_sessions_mutex

Mutex	m_total_bytes_sent_mutex

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}

std::reference_wrapper< AddrMan >	addrman

const NetGroupManager &	m_netgroupman

Mutex	m_addr_fetches_mutex

Mutex	m_added_nodes_mutex

std::list< CNode * >	m_nodes_disconnected

Mutex	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...

std::atomic< ServiceFlags >	m_local_services
	Services this node offers. More...

std::unique_ptr< std::counting_semaphore<> >	semOutbound

std::unique_ptr< std::counting_semaphore<> >	semAddnode

int	m_max_automatic_connections
	Maximum number of automatic connections permitted, excluding manual connections but including inbounds. More...

int	m_max_outbound_full_relay

int	m_max_outbound_block_relay

int	m_max_addnode {MAX_ADDNODE_CONNECTIONS}

int	m_max_feeler {MAX_FEELER_CONNECTIONS}

int	m_max_automatic_outbound

int	m_max_inbound

bool	m_use_addrman_outgoing

CClientUIInterface *	m_client_interface

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}

const std::shared_ptr< CThreadInterrupt >	m_interrupt_net
	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::thread	threadPrivateBroadcast

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 This takes the place of a feeler connection 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...

bool	m_capture_messages {false}
	flag for whether messages are captured More...

Mutex	m_unused_i2p_sessions_mutex
	Mutex protecting m_i2p_sam_sessions. More...

Mutex	m_reconnections_mutex
	Mutex protecting m_reconnections. More...

const CChainParams &	m_params

Static Private Attributes
static constexpr size_t	MAX_UNUSED_I2P_SESSIONS_SIZE {10}
	Cap on the size of `m_unused_i2p_sessions`, to ensure it does not unexpectedly use too much memory. More...

Friends
struct	ConnmanTestMsg

Detailed Description

Definition at line 1070 of file net.h.

Member Typedef Documentation

◆ NodeFn

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

Definition at line 1268 of file net.h.

Constructor & Destructor Documentation

◆ CConnman()

CConnman::CConnman	(	uint64_t	seed0,
		uint64_t	seed1,
		AddrMan &	addrman,
		const NetGroupManager &	netgroupman,
		const CChainParams &	params,
		bool	network_active = `true`,
		std::shared_ptr< CThreadInterrupt >	interrupt_net = `std::make_shared<CThreadInterrupt>()`
	)

Definition at line 3411 of file net.cpp.

Here is the call graph for this function:

◆ ~CConnman()

CConnman::~CConnman ( )

Definition at line 3721 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 1741 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,
		bool	use_v2transport = `false`
	)

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
[in]	use_v2transport	Set to true if node attempts to connect using BIP 324 v2 transport protocol.

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 1883 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ AddedNodesContain()

bool CConnman::AddedNodesContain ( const CAddress & addr ) const

Definition at line 3802 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ AddLocalServices()

void CConnman::AddLocalServices ( ServiceFlags services )

inline

Updates the local services that this node advertises to other peers during connection handshake.

Definition at line 1376 of file net.h.

◆ AddNode()

bool CConnman::AddNode ( const AddedNodeParams & add )

Definition at line 3776 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ AddWhitelistPermissionFlags()

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

private

Definition at line 575 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 CNetAddr & addr ) const

private

Determine whether we're already connected to a given address.

Definition at line 352 of file net.cpp.

Here is the caller graph for this function:

◆ AlreadyConnectedToAddressPort()

bool CConnman::AlreadyConnectedToAddressPort ( const CService & addr_port ) const

private

Determine whether we're already connected to a given address:port.

Note that for inbound connections, the peer is likely using a random outbound port on their side, so this will likely not match any inbound connections.

Parameters

[in] addr_port Address and port to check.

Returns: true if connected to addr_port.

Definition at line 346 of file net.cpp.

Here is the caller graph for this function:

◆ AlreadyConnectedToHost()

bool CConnman::AlreadyConnectedToHost ( std::string_view host ) const

private

Determine whether we're already connected to a given "host:port".

Note that for inbound connections, the peer is likely using a random outbound port on their side, so this will likely not match any inbound connections.

Parameters

[in] host String of the form "host[:port]", e.g. "localhost" or "localhost:8333" or "1.2.3.4:8333".

Returns: true if connected to host.

Definition at line 340 of file net.cpp.

Here is the caller graph for this function:

◆ ASMapHealthCheck()

void CConnman::ASMapHealthCheck ( )

Definition at line 4221 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ AssertLockNotHeld()

CConnman::AssertLockNotHeld ( m_reconnections_mutex )

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 1690 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 3448 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 3315 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 CNetAddr & ad ) const

private

Definition at line 4186 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 358 of file net.cpp.

◆ ConnectNode()

CNode * CConnman::ConnectNode	(	CAddress	addrConnect,
		const char *	pszDest,
		bool	fCountFailure,
		ConnectionType	conn_type,
		bool	use_v2transport,
		const std::optional< Proxy > &	proxy_override
	)

private

Open a new P2P connection.

Parameters

[in]	addrConnect	Address to connect to, if `pszDest` is `nullptr`.
[in]	pszDest	Address to resolve and connect to.
[in]	fCountFailure	Increment the number of connection attempts to this address in Addrman.
[in]	conn_type	Type of the connection to open, must not be `ConnectionType::INBOUND`.
[in]	use_v2transport	Use P2P encryption, (aka V2 transport, BIP324).
[in]	proxy_override	Optional proxy to use and override normal proxy selection.

Returns: Newly created CNode object or nullptr if the connection failed.

Definition at line 377 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 CService &	addr_bind,
		const CService &	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 1771 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 3714 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 3883 of file net.cpp.

Here is the call graph for this function:

◆ DisconnectNode() [2/4]

bool CConnman::DisconnectNode ( const CSubNet & subnet )

Definition at line 3868 of file net.cpp.

Here is the call graph for this function:

◆ DisconnectNode() [3/4]

bool CConnman::DisconnectNode ( NodeId id )

Definition at line 3889 of file net.cpp.

◆ DisconnectNode() [4/4]

bool CConnman::DisconnectNode ( std::string_view node )

Definition at line 3855 of file net.cpp.

Here is the caller graph for this function:

◆ DisconnectNodes()

void CConnman::DisconnectNodes ( )

private

Definition at line 1922 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 2413 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ for()

CConnman::for ( const std::string &added_node :connOptions. m_added_nodes )

inline

Definition at line 1131 of file net.h.

◆ ForEachNode() [1/2]

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

inline

Definition at line 1278 of file net.h.

Here is the call graph for this function:

◆ ForEachNode() [2/2]

void CConnman::ForEachNode ( const NodeFn & func )

inline

Definition at line 1269 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 4166 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 ( std::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 2076 of file net.cpp.

Here is the caller graph for this function:

◆ GetAddedNodeInfo()

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

Definition at line 2939 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetAddresses()

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

Return addresses from the per-requestor cache.

If no cache entry exists, it is populated with randomly selected addresses. This function can be used in untrusted contexts.

A trusted caller (e.g. from RPC or a peer with addr permission) can use GetAddressesUnsafe to avoid using the cache.

Parameters

[in]	requestor	The requesting peer. Used to key the cache to prevent privacy leaks.
[in]	max_addresses	Maximum number of addresses to return (0 = all). Ignored when cache already contains an entry for requestor.
[in]	max_pct	Maximum percentage of addresses to return (0 = all). Value must be from 0 to 100. Ignored when cache already contains an entry for requestor.

Definition at line 3738 of file net.cpp.

Here is the call graph for this function:

◆ GetAddressesUnsafe()

std::vector< CAddress > CConnman::GetAddressesUnsafe	(	size_t	max_addresses,
		size_t	max_pct,
		std::optional< Network >	network,
		bool	filtered = `true`
	)		const

Return randomly selected addresses.

This function does not use the address response cache and should only be used in trusted contexts.

An untrusted caller (e.g. from p2p) should instead use GetAddresses to use the cache.

Parameters

[in]	max_addresses	Maximum number of addresses to return (0 = all).
[in]	max_pct	Maximum percentage of addresses to return (0 = all). Value must be from 0 to 100.
[in]	network	Select only addresses of this network (nullopt = all).
[in]	filtered	Select only addresses that are considered high quality (false = all).

Definition at line 3727 of file net.cpp.

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 2925 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetDefaultPort() [1/2]

uint16_t CConnman::GetDefaultPort ( const std::string & addr ) const

private

Definition at line 3442 of file net.cpp.

Here is the call graph for this function:

◆ GetDefaultPort() [2/2]

uint16_t CConnman::GetDefaultPort ( Network net ) const

private

Definition at line 3437 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetDeterministicRandomizer()

CSipHasher CConnman::GetDeterministicRandomizer ( uint64_t id ) const

Get a unique deterministic randomizer.

Definition at line 4181 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 2499 of file net.cpp.

Here is the call graph for this function:

◆ GetExtraFullOutboundCount()

int CConnman::GetExtraFullOutboundCount ( ) const

Definition at line 2483 of file net.cpp.

Here is the call graph for this function:

◆ GetFullOutboundConnCount()

int CConnman::GetFullOutboundConnCount ( ) const

Definition at line 2463 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ 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 4002 of file net.cpp.

Here is the caller graph for this function:

◆ GetMappedAS()

uint32_t CConnman::GetMappedAS ( const CNetAddr & addr ) const

Definition at line 3836 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetMaxOutboundTarget()

uint64_t CConnman::GetMaxOutboundTarget ( ) const

Definition at line 3925 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetMaxOutboundTimeframe()

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

Definition at line 3932 of file net.cpp.

Here is the caller graph for this function:

◆ GetMaxOutboundTimeLeftInCycle()

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

Definition at line 3937 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetMaxOutboundTimeLeftInCycle_()

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

private

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

Definition at line 3944 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getNetLocalAddresses()

std::map< CNetAddr, LocalServiceInfo > CConnman::getNetLocalAddresses ( ) const

Definition at line 3830 of file net.cpp.

◆ GetNetworkActive()

bool CConnman::GetNetworkActive ( ) const

inline

Definition at line 1167 of file net.h.

Here is the caller graph for this function:

◆ GetNewNodeId()

NodeId CConnman::GetNewNodeId ( )

private

Definition at line 3432 of file net.cpp.

Here is the caller graph for this function:

◆ GetNodeCount()

size_t CConnman::GetNodeCount ( ConnectionDirection flags ) const

Definition at line 3813 of file net.cpp.

Here is the caller graph for this function:

◆ GetNodesMutex()

Mutex & CConnman::GetNodesMutex ( ) const

◆ GetNodeStats()

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

Definition at line 3841 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 3980 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetReachableEmptyNetworks()

std::unordered_set< Network > CConnman::GetReachableEmptyNetworks ( ) const

private

Return reachable networks for which we have no addresses in addrman and therefore may require loading fixed seeds.

Definition at line 2515 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetTotalBytesRecv()

uint64_t CConnman::GetTotalBytesRecv ( ) const

Definition at line 3990 of file net.cpp.

Here is the caller graph for this function:

◆ GetTotalBytesSent()

uint64_t CConnman::GetTotalBytesSent ( ) const

Definition at line 3995 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetTryNewOutboundPeer()

bool CConnman::GetTryNewOutboundPeer ( ) const

Definition at line 2445 of file net.cpp.

Here is the caller graph for this function:

◆ GetUseAddrmanOutgoing()

bool CConnman::GetUseAddrmanOutgoing ( ) const

inline

Definition at line 1168 of file net.h.

◆ GUARDED_BY() [1/11]

std::vector< AddedNodeParams > m_added_node_params CConnman::GUARDED_BY ( m_added_nodes_mutex )

private

◆ GUARDED_BY() [2/11]

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

private

◆ GUARDED_BY() [3/11]

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

private

◆ GUARDED_BY() [4/11]

std::array< unsigned int, Network::NET_MAX > m_network_conn_counts CConnman::GUARDED_BY ( m_nodes_mutex )

private

◆ GUARDED_BY() [5/11]

std::list< ReconnectionInfo > m_reconnections CConnman::GUARDED_BY ( m_reconnections_mutex )

private

List of reconnections we have to make.

◆ GUARDED_BY() [6/11]

uint64_t nTotalBytesSent CConnman::GUARDED_BY ( m_total_bytes_sent_mutex )

inlineprivate

Definition at line 1593 of file net.h.

◆ GUARDED_BY() [7/11]

uint64_t nMaxOutboundTotalBytesSentInCycle CConnman::GUARDED_BY ( m_total_bytes_sent_mutex )

inlineprivate

Definition at line 1596 of file net.h.

◆ GUARDED_BY() [8/11]

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

inlineprivate

Definition at line 1597 of file net.h.

◆ GUARDED_BY() [9/11]

uint64_t nMaxOutboundLimit CConnman::GUARDED_BY ( m_total_bytes_sent_mutex )

private

◆ GUARDED_BY() [10/11]

std::queue< std::unique_ptr< i2p::sam::Session > > m_unused_i2p_sessions CConnman::GUARDED_BY ( m_unused_i2p_sessions_mutex )

private

A pool of created I2P SAM transient sessions that should be used instead of creating new ones in order to reduce the load on the I2P network.

Creating a session in I2P is not cheap, thus if this is not empty, then pick an entry from it instead of creating a new session. If connecting to a host fails, then the created session is put to this pool for reuse.

◆ GUARDED_BY() [11/11]

bool fMsgProcWake CConnman::GUARDED_BY ( mutexMsgProc )

private

flag for waking the message processor.

◆ InactivityCheck()

bool CConnman::InactivityCheck	(	const CNode &	node,
		NodeClock::time_point	now
	)		const

private

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

Definition at line 2023 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 )

Here is the caller graph for this function:

◆ InitBinds()

bool CConnman::InitBinds ( const Options & options )

private

Definition at line 3467 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 3629 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ MaybePickPreferredNetwork()

bool CConnman::MaybePickPreferredNetwork ( std::optional< Network > & network )

private

Search for a "preferred" network, a reachable network to which we currently don't have any OUTBOUND_FULL_RELAY or MANUAL connections.

There needs to be at least one address in AddrMan for a preferred network to be picked.

Parameters

[out] network Preferred network, if found.

Returns: bool Whether a preferred network was found.

Definition at line 2534 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ MultipleManualOrFullOutboundConns()

bool CConnman::MultipleManualOrFullOutboundConns ( Network net ) const

Definition at line 2528 of file net.cpp.

Here is the call graph for this function:

◆ NodeFullyConnected()

bool CConnman::NodeFullyConnected ( const CNode * pnode )

staticprivate

Definition at line 4090 of file net.cpp.

Here is the caller graph for this function:

◆ NotifyNumConnectionsChanged()

void CConnman::NotifyNumConnectionsChanged ( )

private

Definition at line 2001 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ OpenNetworkConnection()

bool CConnman::OpenNetworkConnection	(	const CAddress &	addrConnect,
		bool	fCountFailure,
		CountingSemaphoreGrant<> &&	grant_outbound,
		const char *	pszDest,
		ConnectionType	conn_type,
		bool	use_v2transport,
		const std::optional< Proxy > &	proxy_override = `std::nullopt`
	)

Open a new P2P connection and initialize it with the PeerManager at m_msgproc.

Parameters

[in]	addrConnect	Address to connect to, if `pszDest` is `nullptr`.
[in]	fCountFailure	Increment the number of connection attempts to this address in Addrman.
[in]	grant_outbound	Take ownership of this grant, to be released later when the connection is closed.
[in]	pszDest	Address to resolve and connect to.
[in]	conn_type	Type of the connection to open, must not be `ConnectionType::INBOUND`.
[in]	use_v2transport	Use P2P encryption, (aka V2 transport, BIP324).
[in]	proxy_override	Optional proxy to use and override normal proxy selection.

Return values

true	The connection was opened successfully.
false	The connection attempt failed.

Definition at line 3034 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 3959 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ PerformReconnections()

void CConnman::PerformReconnections ( )

private

Attempt reconnections, if m_reconnections non-empty.

Definition at line 4193 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 2423 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 4106 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 3902 of file net.cpp.

Here is the caller graph for this function:

◆ RecordBytesSent()

void CConnman::RecordBytesSent ( uint64_t bytes )

private

Definition at line 3907 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ RemoveAddedNode()

bool CConnman::RemoveAddedNode ( std::string_view node )

Definition at line 3790 of file net.cpp.

◆ RemoveLocalServices()

void CConnman::RemoveLocalServices ( ServiceFlags services )

inline

Definition at line 1377 of file net.h.

◆ SetCaptureMessages()

void CConnman::SetCaptureMessages ( bool cap )

inline

Definition at line 1142 of file net.h.

◆ SetNetworkActive()

void CConnman::SetNetworkActive ( bool active )

Definition at line 3396 of file net.cpp.

Here is the caller graph for this function:

◆ SetTryNewOutboundPeer()

void CConnman::SetTryNewOutboundPeer ( bool flag )

Definition at line 2450 of file net.cpp.

Here is the caller graph for this function:

◆ ShouldRunInactivityChecks()

bool CConnman::ShouldRunInactivityChecks	(	const CNode &	node,
		NodeClock::time_point	now
	)		const

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

Definition at line 2018 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 2107 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 2136 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 2238 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).

< second return value (whether unsent data remains)

Definition at line 1603 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 3501 of file net.cpp.

Here is the call graph for this function:

◆ StartExtraBlockRelayPeers()

void CConnman::StartExtraBlockRelayPeers ( )

Definition at line 2456 of file net.cpp.

◆ Stop()

void CConnman::Stop ( )

Here is the caller graph for this function:

◆ StopNodes() [1/2]

CConnman::StopNodes ( )

◆ StopNodes() [2/2]

void CConnman::StopNodes ( )

Definition at line 3676 of file net.cpp.

Here is the call graph for this function:

◆ StopThreads() [1/2]

void CConnman::StopThreads ( )

Definition at line 3656 of file net.cpp.

◆ StopThreads() [2/2]

CConnman::StopThreads ( )

◆ ThreadDNSAddressSeed()

void CConnman::ThreadDNSAddressSeed ( )

private

Definition at line 2273 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 3201 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 3160 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ThreadOpenAddedConnections()

void CConnman::ThreadOpenAddedConnections ( )

private

Definition at line 3001 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::span< const std::string >	seed_nodes
	)

private

Definition at line 2552 of file net.cpp.

Here is the call graph for this function:

◆ ThreadPrivateBroadcast()

void CConnman::ThreadPrivateBroadcast ( )

private

Definition at line 3246 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ThreadSocketHandler()

void CConnman::ThreadSocketHandler ( )

private

Definition at line 2253 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ use_v2transport()

const bool CConnman::use_v2transport ( GetLocalServices() & NODE_P2P_V2 )

Here is the caller graph for this function:

◆ WakeMessageHandler()

void CConnman::WakeMessageHandler ( )

Definition at line 2264 of file net.cpp.

Here is the caller graph for this function:

Friends And Related Function Documentation

◆ ConnmanTestMsg

friend struct ConnmanTestMsg

friend

Definition at line 1861 of file net.h.

Member Data Documentation

◆ !m_added_nodes_mutex

bool CConnman::!m_added_nodes_mutex

Definition at line 1154 of file net.h.

◆ !m_addr_fetches_mutex [1/2]

bool CConnman::!m_addr_fetches_mutex

Definition at line 1154 of file net.h.

◆ !m_addr_fetches_mutex [2/2]

void CConnman::!m_addr_fetches_mutex

private

Definition at line 1441 of file net.h.

◆ !m_nodes_mutex [1/2]

void CConnman::!m_nodes_mutex

Definition at line 1339 of file net.h.

◆ !m_nodes_mutex [2/2]

void CConnman::!m_nodes_mutex

private

Definition at line 1429 of file net.h.

◆ !m_reconnections_mutex

void CConnman::!m_reconnections_mutex

Initial value:

{

AssertLockNotHeld(m_nodes_mutex)

CConnman::AssertLockNotHeld

AssertLockNotHeld(m_reconnections_mutex)

CConnman::m_nodes_mutex

Mutex m_nodes_mutex

Definition: net.h:1626

Definition at line 1157 of file net.h.

◆ !m_total_bytes_sent_mutex

void CConnman::!m_total_bytes_sent_mutex

Initial value:

{

AssertLockNotHeld(m_total_bytes_sent_mutex)

CConnman::m_total_bytes_sent_mutex

Mutex m_total_bytes_sent_mutex

Definition: net.h:1591

Definition at line 1103 of file net.h.

◆ !m_unused_i2p_sessions_mutex [1/3]

void CConnman::!m_unused_i2p_sessions_mutex

Definition at line 1190 of file net.h.

◆ !m_unused_i2p_sessions_mutex [2/3]

void CConnman::!m_unused_i2p_sessions_mutex

private

Definition at line 1431 of file net.h.

◆ !m_unused_i2p_sessions_mutex [3/3]

CNode CConnman::!m_unused_i2p_sessions_mutex

private

Definition at line 1544 of file net.h.

◆ !mutexMsgProc [1/2]

void CConnman::!mutexMsgProc

Definition at line 1154 of file net.h.

◆ !mutexMsgProc [2/2]

void CConnman::!mutexMsgProc

private

Definition at line 1446 of file net.h.

◆ addrman

std::reference_wrapper<AddrMan> CConnman::addrman

private

Definition at line 1615 of file net.h.

◆ condMsgProc

std::condition_variable CConnman::condMsgProc

private

Definition at line 1718 of file net.h.

◆ fAddressesInitialized

bool CConnman::fAddressesInitialized {false}

private

Definition at line 1614 of file net.h.

◆ flagInterruptMsgProc

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

private

Definition at line 1720 of file net.h.

◆ fNetworkActive

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

private

Definition at line 1613 of file net.h.

◆ m_added_nodes_mutex

Mutex CConnman::m_added_nodes_mutex

mutableprivate

Definition at line 1623 of file net.h.

◆ m_addr_fetches_mutex

Mutex CConnman::m_addr_fetches_mutex

private

Definition at line 1618 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 1658 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 1710 of file net.h.

◆ m_banman [1/2]

CConnman::m_banman = connOptions.m_banman

Definition at line 1115 of file net.h.

◆ m_banman [2/2]

BanMan* CConnman::m_banman

private

Pointer to this node's banman.

May be nullptr - check existence before dereferencing.

Definition at line 1704 of file net.h.

◆ m_capture_messages [1/2]

CConnman::m_capture_messages = connOptions.m_capture_messages

Definition at line 1138 of file net.h.

◆ m_capture_messages [2/2]

bool CConnman::m_capture_messages {false}

private

flag for whether messages are captured

Definition at line 1775 of file net.h.

◆ m_client_interface [1/2]

CConnman::m_client_interface = connOptions.uiInterface

Definition at line 1114 of file net.h.

◆ m_client_interface [2/2]

CClientUIInterface* CConnman::m_client_interface

private

Definition at line 1701 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 from a persistent address.

Definition at line 1733 of file net.h.

◆ m_interrupt_net

const std::shared_ptr<CThreadInterrupt> CConnman::m_interrupt_net

private

This is signaled when network activity should cease.

A copy of this is saved in m_i2p_sam_session.

Definition at line 1726 of file net.h.

◆ m_local_services [1/2]

CConnman::m_local_services = connOptions.m_local_services

Definition at line 1107 of file net.h.

◆ m_local_services [2/2]

std::atomic<ServiceFlags> CConnman::m_local_services

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. Unless AssumeUTXO is started, in which case, the peer will be limited until the background chain sync finishes.

See also: Peer::our_services

Definition at line 1671 of file net.h.

◆ m_max_addnode

int CConnman::m_max_addnode {MAX_ADDNODE_CONNECTIONS}

private

Definition at line 1695 of file net.h.

◆ m_max_automatic_connections [1/2]

CConnman::m_max_automatic_connections = connOptions.m_max_automatic_connections

Definition at line 1108 of file net.h.

◆ m_max_automatic_connections [2/2]

int CConnman::m_max_automatic_connections

private

Maximum number of automatic connections permitted, excluding manual connections but including inbounds.

May be changed by the user and is potentially limited by the operating system (number of file descriptors).

Definition at line 1681 of file net.h.

◆ m_max_automatic_outbound [1/2]

CConnman::m_max_automatic_outbound = m_max_outbound_full_relay + m_max_outbound_block_relay + m_max_feeler

Definition at line 1111 of file net.h.

◆ m_max_automatic_outbound [2/2]

int CConnman::m_max_automatic_outbound

private

Definition at line 1697 of file net.h.

◆ m_max_feeler

int CConnman::m_max_feeler {MAX_FEELER_CONNECTIONS}

private

Definition at line 1696 of file net.h.

◆ m_max_inbound [1/2]

CConnman::m_max_inbound = std::max(0, m_max_automatic_connections - m_max_automatic_outbound)

Definition at line 1112 of file net.h.

◆ m_max_inbound [2/2]

int CConnman::m_max_inbound

private

Definition at line 1698 of file net.h.

◆ m_max_outbound_block_relay [1/2]

CConnman::m_max_outbound_block_relay = std::min(MAX_BLOCK_RELAY_ONLY_CONNECTIONS, m_max_automatic_connections - m_max_outbound_full_relay)

Definition at line 1110 of file net.h.

◆ m_max_outbound_block_relay [2/2]

int CConnman::m_max_outbound_block_relay

private

Definition at line 1693 of file net.h.

◆ m_max_outbound_full_relay [1/2]

CConnman::m_max_outbound_full_relay = std::min(MAX_OUTBOUND_FULL_RELAY_CONNECTIONS, m_max_automatic_connections)

Definition at line 1109 of file net.h.

◆ m_max_outbound_full_relay [2/2]

int CConnman::m_max_outbound_full_relay

private

Definition at line 1689 of file net.h.

◆ m_msgproc [1/2]

CConnman::m_msgproc = connOptions.m_msgproc

Definition at line 1116 of file net.h.

◆ m_msgproc [2/2]

NetEventsInterface* CConnman::m_msgproc

private

Definition at line 1702 of file net.h.

◆ m_netgroupman

const NetGroupManager& CConnman::m_netgroupman

private

Definition at line 1616 of file net.h.

◆ m_nodes_disconnected

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

private

Definition at line 1625 of file net.h.

◆ m_nodes_mutex

Mutex CConnman::m_nodes_mutex

mutableprivate

Definition at line 1626 of file net.h.

◆ m_onion_binds [1/2]

CConnman::m_onion_binds = connOptions.onion_binds

Definition at line 1135 of file net.h.

◆ m_onion_binds [2/2]

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 1758 of file net.h.

◆ m_params

const CChainParams& CConnman::m_params

private

Definition at line 1859 of file net.h.

◆ m_peer_connect_timeout [1/2]

CConnman::m_peer_connect_timeout = std::chrono::seconds{connOptions.m_peer_connect_timeout}

Definition at line 1119 of file net.h.

◆ m_peer_connect_timeout [2/2]

std::chrono::seconds CConnman::m_peer_connect_timeout

private

Definition at line 1601 of file net.h.

◆ m_private_broadcast

class CConnman::PrivateBroadcast CConnman::m_private_broadcast

◆ m_reconnections_mutex

Mutex CConnman::m_reconnections_mutex

private

Mutex protecting m_reconnections.

Definition at line 1794 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 1752 of file net.h.

◆ m_total_bytes_sent_mutex

Mutex CConnman::m_total_bytes_sent_mutex

mutableprivate

Definition at line 1591 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 1746 of file net.h.

◆ m_unused_i2p_sessions_mutex

Mutex CConnman::m_unused_i2p_sessions_mutex

private

Mutex protecting m_i2p_sam_sessions.

Definition at line 1780 of file net.h.

◆ m_use_addrman_outgoing [1/2]

CConnman::m_use_addrman_outgoing = connOptions.m_use_addrman_outgoing

Definition at line 1113 of file net.h.

◆ m_use_addrman_outgoing [2/2]

bool CConnman::m_use_addrman_outgoing

private

Definition at line 1700 of file net.h.

◆ MAX_UNUSED_I2P_SESSIONS_SIZE

constexpr size_t CConnman::MAX_UNUSED_I2P_SESSIONS_SIZE {10}

staticconstexprprivate

Cap on the size of m_unused_i2p_sessions, to ensure it does not unexpectedly use too much memory.

Definition at line 1819 of file net.h.

◆ mutexMsgProc

Mutex CConnman::mutexMsgProc

private

Definition at line 1719 of file net.h.

◆ nLastNodeId

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

private

Definition at line 1627 of file net.h.

◆ nMaxOutboundLimit

CConnman::nMaxOutboundLimit = connOptions.nMaxOutboundLimit

Definition at line 1122 of file net.h.

◆ nPrevNodeCount

unsigned int CConnman::nPrevNodeCount {0}

private

Definition at line 1628 of file net.h.

◆ nReceiveFloodSize [1/2]

CConnman::nReceiveFloodSize = connOptions.nReceiveFloodSize

Definition at line 1118 of file net.h.

◆ nReceiveFloodSize [2/2]

unsigned int CConnman::nReceiveFloodSize {0}

private

Definition at line 1610 of file net.h.

◆ nSeed0

const uint64_t CConnman::nSeed0

private

SipHasher seeds for deterministic randomness.

Definition at line 1713 of file net.h.

◆ nSeed1

const uint64_t CConnman::nSeed1

private

Definition at line 1713 of file net.h.

◆ nSendBufferMaxSize [1/2]

CConnman::nSendBufferMaxSize = connOptions.nSendBufferMaxSize

Definition at line 1117 of file net.h.

◆ nSendBufferMaxSize [2/2]

unsigned int CConnman::nSendBufferMaxSize {0}

private

Definition at line 1609 of file net.h.

◆ nTotalBytesRecv

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

private

Definition at line 1592 of file net.h.

◆ semAddnode

std::unique_ptr<std::counting_semaphore<> > CConnman::semAddnode

private

Definition at line 1674 of file net.h.

◆ semOutbound

std::unique_ptr<std::counting_semaphore<> > CConnman::semOutbound

private

Definition at line 1673 of file net.h.

◆ threadDNSAddressSeed

std::thread CConnman::threadDNSAddressSeed

private

Definition at line 1735 of file net.h.

◆ threadI2PAcceptIncoming

std::thread CConnman::threadI2PAcceptIncoming

private

Definition at line 1740 of file net.h.

◆ threadMessageHandler

std::thread CConnman::threadMessageHandler

private

Definition at line 1739 of file net.h.

◆ threadOpenAddedConnections

std::thread CConnman::threadOpenAddedConnections

private

Definition at line 1737 of file net.h.

◆ threadOpenConnections

std::thread CConnman::threadOpenConnections

private

Definition at line 1738 of file net.h.

◆ threadPrivateBroadcast

std::thread CConnman::threadPrivateBroadcast

private

Definition at line 1741 of file net.h.

◆ threadSocketHandler

std::thread CConnman::threadSocketHandler

private

Definition at line 1736 of file net.h.

◆ vhListenSocket

std::vector<ListenSocket> CConnman::vhListenSocket

private

Definition at line 1612 of file net.h.

◆ vWhitelistedRangeIncoming [1/2]

CConnman::vWhitelistedRangeIncoming = connOptions.vWhitelistedRangeIncoming

Definition at line 1124 of file net.h.

◆ vWhitelistedRangeIncoming [2/2]

std::vector<NetWhitelistPermissions> CConnman::vWhitelistedRangeIncoming

private

Definition at line 1605 of file net.h.

◆ vWhitelistedRangeOutgoing [1/2]

CConnman::vWhitelistedRangeOutgoing = connOptions.vWhitelistedRangeOutgoing

Definition at line 1125 of file net.h.

◆ vWhitelistedRangeOutgoing [2/2]

std::vector<NetWhitelistPermissions> CConnman::vWhitelistedRangeOutgoing

private

Definition at line 1607 of file net.h.

◆ whitelist_forcerelay [1/2]

CConnman::whitelist_forcerelay = connOptions.whitelist_forcerelay

Definition at line 1136 of file net.h.

◆ whitelist_forcerelay [2/2]

bool CConnman::whitelist_forcerelay

private

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

Definition at line 1764 of file net.h.

◆ whitelist_relay [1/2]

CConnman::whitelist_relay = connOptions.whitelist_relay

Definition at line 1137 of file net.h.

◆ whitelist_relay [2/2]

bool CConnman::whitelist_relay

private

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

Definition at line 1770 of file net.h.

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

src/net.h
src/net.cpp

Classes

Public Types

Public Member Functions

Public Attributes

Private Member Functions

Static Private Member Functions

Private Attributes

Static Private Attributes

Friends

Detailed Description

Member Typedef Documentation

◆ NodeFn

Constructor & Destructor Documentation

◆ CConnman()

◆ ~CConnman()

Member Function Documentation

◆ AcceptConnection()

◆ AddAddrFetch()

◆ AddConnection()

◆ AddedNodesContain()

◆ AddLocalServices()

◆ AddNode()

◆ AddWhitelistPermissionFlags()

◆ AlreadyConnectedToAddress()

◆ AlreadyConnectedToAddressPort()

◆ AlreadyConnectedToHost()

◆ ASMapHealthCheck()

◆ AssertLockNotHeld()

◆ AttemptToEvictConnection()

◆ Bind()

◆ BindListenPort()

◆ CalculateKeyedNetGroup()

◆ CheckIncomingNonce()

◆ ConnectNode()

◆ CreateNodeFromAcceptedSocket()

◆ DeleteNode()

◆ DisconnectNode() [1/4]

◆ DisconnectNode() [2/4]

◆ DisconnectNode() [3/4]

◆ DisconnectNode() [4/4]

◆ DisconnectNodes()

◆ DumpAddresses()

◆ for()

◆ ForEachNode() [1/2]

◆ ForEachNode() [2/2]

◆ ForNode()

◆ GenerateWaitSockets()

◆ GetAddedNodeInfo()

◆ GetAddresses()

◆ GetAddressesUnsafe()

◆ GetCurrentBlockRelayOnlyConns()

◆ GetDefaultPort() [1/2]

◆ GetDefaultPort() [2/2]

◆ GetDeterministicRandomizer()

◆ GetExtraBlockRelayCount()

◆ GetExtraFullOutboundCount()

◆ GetFullOutboundConnCount()

◆ GetLocalServices()

◆ GetMappedAS()

◆ GetMaxOutboundTarget()

◆ GetMaxOutboundTimeframe()

◆ GetMaxOutboundTimeLeftInCycle()

◆ GetMaxOutboundTimeLeftInCycle_()

◆ getNetLocalAddresses()

◆ GetNetworkActive()

◆ GetNewNodeId()

◆ GetNodeCount()

◆ GetNodesMutex()

◆ GetNodeStats()

◆ GetOutboundTargetBytesLeft()

◆ GetReachableEmptyNetworks()

◆ GetTotalBytesRecv()

◆ GetTotalBytesSent()

◆ GetTryNewOutboundPeer()

◆ GetUseAddrmanOutgoing()

◆ GUARDED_BY() [1/11]

◆ GUARDED_BY() [2/11]

◆ GUARDED_BY() [3/11]

◆ GUARDED_BY() [4/11]

◆ GUARDED_BY() [5/11]