#include <net.h>

Collaboration diagram for CConnman:

Classes
struct	ListenSocket

struct	Options

Public Types
enum	NumConnections { CONNECTIONS_NONE = 0, CONNECTIONS_IN = (1U << 0), CONNECTIONS_OUT = (1U << 1), CONNECTIONS_ALL = (CONNECTIONS_IN \| CONNECTIONS_OUT) }

Public Member Functions
void	Init (const Options &connOptions)

	CConnman (uint64_t seed0, uint64_t seed1)

	~CConnman ()

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

void	StopThreads ()

void	StopNodes ()

void	Stop ()

void	Interrupt ()

bool	GetNetworkActive () const

bool	GetUseAddrmanOutgoing () const

void	SetNetworkActive (bool active)

void	OpenNetworkConnection (const CAddress &addrConnect, bool fCountFailure, CSemaphoreGrant grantOutbound=nullptr, const char strDest=nullptr, bool fOneShot=false, bool fFeeler=false, bool manual_connection=false, bool block_relay_only=false)

bool	CheckIncomingNonce (uint64_t nonce)

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

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

template<typename Callable >
void	ForEachNode (Callable &&func)

template<typename Callable >
void	ForEachNode (Callable &&func) const

template<typename Callable , typename CallableAfter >
void	ForEachNodeThen (Callable &&pre, CallableAfter &&post)

template<typename Callable , typename CallableAfter >
void	ForEachNodeThen (Callable &&pre, CallableAfter &&post) const

size_t	GetAddressCount () const

void	SetServices (const CService &addr, ServiceFlags nServices)

void	MarkAddressGood (const CAddress &addr)

void	AddNewAddresses (const std::vector< CAddress > &vAddr, const CAddress &addrFrom, int64_t nTimePenalty=0)

std::vector< CAddress >	GetAddresses ()

void	SetTryNewOutboundPeer (bool flag)

bool	GetTryNewOutboundPeer ()

int	GetExtraOutboundCount ()

bool	AddNode (const std::string &node)

bool	RemoveAddedNode (const std::string &node)

std::vector< AddedNodeInfo >	GetAddedNodeInfo ()

size_t	GetNodeCount (NumConnections num)

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

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

void	SetMaxOutboundTarget (uint64_t limit)
	set the max outbound target in bytes More...

uint64_t	GetMaxOutboundTarget ()

void	SetMaxOutboundTimeframe (uint64_t timeframe)
	set the timeframe for the max outbound target More...

uint64_t	GetMaxOutboundTimeframe ()

bool	OutboundTargetReached (bool historicalBlockServingLimit)
	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 ()
	response the bytes left in the current max outbound cycle in case of no limit, it will always response 0 More...

uint64_t	GetMaxOutboundTimeLeftInCycle ()
	response the time in second left in the current max outbound cycle in case of no limit, it will always response 0 More...

uint64_t	GetTotalBytesRecv ()

uint64_t	GetTotalBytesSent ()

void	SetBestHeight (int height)

int	GetBestHeight () const

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

unsigned int	GetReceiveFloodSize () const

void	WakeMessageHandler ()

int64_t	PoissonNextSendInbound (int64_t now, int average_interval_seconds)
	Attempts to obfuscate tx time through exponentially distributed emitting. More...

void	SetAsmap (std::vector< bool > asmap)

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 std::vector< CService > &binds, const std::vector< NetWhitebindPermissions > &whiteBinds)

void	ThreadOpenAddedConnections ()

void	AddOneShot (const std::string &strDest)

void	ProcessOneShot ()

void	ThreadOpenConnections (std::vector< std::string > connect)

void	ThreadMessageHandler ()

void	AcceptConnection (const ListenSocket &hListenSocket)

void	DisconnectNodes ()

void	NotifyNumConnectionsChanged ()

void	InactivityCheck (CNode *pnode)

bool	GenerateSelectSet (std::set< SOCKET > &recv_set, std::set< SOCKET > &send_set, std::set< SOCKET > &error_set)

void	SocketEvents (std::set< SOCKET > &recv_set, std::set< SOCKET > &send_set, std::set< SOCKET > &error_set)

void	SocketHandler ()

void	ThreadSocketHandler ()

void	ThreadDNSAddressSeed ()

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	AttemptToEvictConnection ()
	Try to find a connection to evict when the node is full. More...

CNode *	ConnectNode (CAddress addrConnect, const char *pszDest, bool fCountFailure, bool manual_connection, bool block_relay_only)

void	AddWhitelistPermissionFlags (NetPermissionFlags &flags, const CNetAddr &addr) const

void	DeleteNode (CNode *pnode)

NodeId	GetNewNodeId ()

size_t	SocketSendData (CNode *pnode) const

void	DumpAddresses ()

void	RecordBytesRecv (uint64_t bytes)

void	RecordBytesSent (uint64_t bytes)

uint64_t nTotalBytesRecv	GUARDED_BY (cs_totalBytesRecv)

uint64_t nTotalBytesSent	GUARDED_BY (cs_totalBytesSent)

uint64_t nMaxOutboundTotalBytesSentInCycle	GUARDED_BY (cs_totalBytesSent)

uint64_t nMaxOutboundCycleStartTime	GUARDED_BY (cs_totalBytesSent)

uint64_t nMaxOutboundLimit	GUARDED_BY (cs_totalBytesSent)

uint64_t nMaxOutboundTimeframe	GUARDED_BY (cs_totalBytesSent)

std::deque< std::string > vOneShots	GUARDED_BY (cs_vOneShots)

std::vector< std::string > vAddedNodes	GUARDED_BY (cs_vAddedNodes)

std::vector< CNode * > vNodes	GUARDED_BY (cs_vNodes)

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

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

Private Attributes
RecursiveMutex	cs_totalBytesRecv

RecursiveMutex	cs_totalBytesSent

int64_t	m_peer_connect_timeout

std::vector< NetWhitelistPermissions >	vWhitelistedRange

unsigned int	nSendBufferMaxSize {0}

unsigned int	nReceiveFloodSize {0}

std::vector< ListenSocket >	vhListenSocket

std::atomic< bool >	fNetworkActive {true}

bool	fAddressesInitialized {false}

CAddrMan	addrman

RecursiveMutex	cs_vOneShots

RecursiveMutex	cs_vAddedNodes

std::list< CNode * >	vNodesDisconnected

RecursiveMutex	cs_vNodes

std::atomic< NodeId >	nLastNodeId {0}

unsigned int	nPrevNodeCount {0}

ServiceFlags	nLocalServices
	Services this instance 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	nMaxAddnode

int	nMaxFeeler

int	m_max_outbound

bool	m_use_addrman_outgoing

std::atomic< int >	nBestHeight

CClientUIInterface *	clientInterface

NetEventsInterface *	m_msgproc

BanMan *	m_banman

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

std::thread	threadDNSAddressSeed

std::thread	threadSocketHandler

std::thread	threadOpenAddedConnections

std::thread	threadOpenConnections

std::thread	threadMessageHandler

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< int64_t >	m_next_send_inv_to_incoming {0}

Friends
struct	CConnmanTest

struct	ConnmanTestMsg

Detailed Description

Definition at line 118 of file net.h.

Member Enumeration Documentation

◆ NumConnections

enum CConnman::NumConnections

Enumerator
CONNECTIONS_NONE
CONNECTIONS_IN
CONNECTIONS_OUT
CONNECTIONS_ALL

Definition at line 122 of file net.h.

Constructor & Destructor Documentation

◆ CConnman()

CConnman::CConnman	(	uint64_t	seed0,
		uint64_t	seed1
	)

Definition at line 2261 of file net.cpp.

Here is the call graph for this function:

◆ ~CConnman()

CConnman::~CConnman ( )

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

Here is the call graph for this function:

Here is the caller graph for this function:

◆ AddNewAddresses()

void CConnman::AddNewAddresses	(	const std::vector< CAddress > &	vAddr,
		const CAddress &	addrFrom,
		int64_t	nTimePenalty = `0`
	)

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

◆ AddOneShot()

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

private

Definition at line 107 of file net.cpp.

Here is the caller graph for this function:

◆ AddWhitelistPermissionFlags()

void CConnman::AddWhitelistPermissionFlags	(	NetPermissionFlags &	flags,
		const CNetAddr &	addr
	)		const

private

Definition at line 481 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 864 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 2275 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 2129 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 2861 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 344 of file net.cpp.

Here is the caller graph for this function:

◆ ConnectNode()

CNode * CConnman::ConnectNode	(	CAddress	addrConnect,
		const char *	pszDest,
		bool	fCountFailure,
		bool	manual_connection,
		bool	block_relay_only
	)

private

debug print

Definition at line 370 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 2491 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 std::string & node )

Definition at line 2583 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ DisconnectNode() [2/4]

bool CConnman::DisconnectNode ( const CSubNet & subnet )

Definition at line 2593 of file net.cpp.

Here is the call graph for this function:

◆ DisconnectNode() [3/4]

bool CConnman::DisconnectNode ( const CNetAddr & addr )

Definition at line 2606 of file net.cpp.

Here is the call graph for this function:

◆ DisconnectNode() [4/4]

bool CConnman::DisconnectNode ( NodeId id )

Definition at line 2611 of file net.cpp.

◆ DisconnectNodes()

void CConnman::DisconnectNodes ( )

private

Definition at line 1061 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 1713 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 300 of file net.cpp.

Here is the caller graph for this function:

◆ FindNode() [2/4]

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

private

Definition at line 311 of file net.cpp.

Here is the call graph for this function:

◆ FindNode() [3/4]

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

private

Definition at line 322 of file net.cpp.

◆ FindNode() [4/4]

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

private

Definition at line 333 of file net.cpp.

◆ ForEachNode() [1/2]

template<typename Callable >

void CConnman::ForEachNode ( Callable && func )

inline

Definition at line 208 of file net.h.

Here is the caller graph for this function:

◆ ForEachNode() [2/2]

template<typename Callable >

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

inline

Definition at line 218 of file net.h.

◆ ForEachNodeThen() [1/2]

template<typename Callable , typename CallableAfter >

void CConnman::ForEachNodeThen	(	Callable &&	pre,
		CallableAfter &&	post
	)

inline

Definition at line 228 of file net.h.

Here is the caller graph for this function:

◆ ForEachNodeThen() [2/2]

template<typename Callable , typename CallableAfter >

void CConnman::ForEachNodeThen	(	Callable &&	pre,
		CallableAfter &&	post
	)		const

inline

Definition at line 239 of file net.h.

◆ ForNode()

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

Definition at line 2827 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GenerateSelectSet()

bool CConnman::GenerateSelectSet	(	std::set< SOCKET > &	recv_set,
		std::set< SOCKET > &	send_set,
		std::set< SOCKET > &	error_set
	)

private

Definition at line 1170 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetAddedNodeInfo()

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

Definition at line 1954 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetAddressCount()

size_t CConnman::GetAddressCount ( ) const

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

Definition at line 2528 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetBestHeight()

int CConnman::GetBestHeight ( ) const

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

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetExtraOutboundCount()

int CConnman::GetExtraOutboundCount ( )

Definition at line 1758 of file net.cpp.

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

◆ GetMaxOutboundTarget()

uint64_t CConnman::GetMaxOutboundTarget ( )

Definition at line 2652 of file net.cpp.

◆ GetMaxOutboundTimeframe()

uint64_t CConnman::GetMaxOutboundTimeframe ( )

Definition at line 2658 of file net.cpp.

◆ GetMaxOutboundTimeLeftInCycle()

uint64_t CConnman::GetMaxOutboundTimeLeftInCycle ( )

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

Definition at line 2664 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetNetworkActive()

bool CConnman::GetNetworkActive ( ) const

inline

Definition at line 197 of file net.h.

Here is the caller graph for this function:

◆ GetNewNodeId()

NodeId CConnman::GetNewNodeId ( )

private

Definition at line 2269 of file net.cpp.

Here is the caller graph for this function:

◆ GetNodeCount()

size_t CConnman::GetNodeCount ( NumConnections num )

Definition at line 2556 of file net.cpp.

◆ GetNodeStats()

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

Definition at line 2572 of file net.cpp.

◆ GetOutboundTargetBytesLeft()

uint64_t CConnman::GetOutboundTargetBytesLeft ( )

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

Definition at line 2710 of file net.cpp.

◆ GetReceiveFloodSize()

unsigned int CConnman::GetReceiveFloodSize ( ) const

Definition at line 2746 of file net.cpp.

Here is the caller graph for this function:

◆ GetTotalBytesRecv()

uint64_t CConnman::GetTotalBytesRecv ( )

Definition at line 2719 of file net.cpp.

◆ GetTotalBytesSent()

uint64_t CConnman::GetTotalBytesSent ( )

Definition at line 2725 of file net.cpp.

◆ GetTryNewOutboundPeer()

bool CConnman::GetTryNewOutboundPeer ( )

Definition at line 1741 of file net.cpp.

Here is the caller graph for this function:

◆ GetUseAddrmanOutgoing()

bool CConnman::GetUseAddrmanOutgoing ( ) const

inline

Definition at line 198 of file net.h.

Here is the caller graph for this function:

◆ GUARDED_BY() [1/10]

uint64_t nTotalBytesRecv CConnman::GUARDED_BY ( cs_totalBytesRecv )

inlineprivate

Definition at line 386 of file net.h.

◆ GUARDED_BY() [2/10]

uint64_t nTotalBytesSent CConnman::GUARDED_BY ( cs_totalBytesSent )

inlineprivate

Definition at line 387 of file net.h.

Here is the call graph for this function:

◆ GUARDED_BY() [3/10]

uint64_t nMaxOutboundTotalBytesSentInCycle CConnman::GUARDED_BY ( cs_totalBytesSent )

private

◆ GUARDED_BY() [4/10]

uint64_t nMaxOutboundCycleStartTime CConnman::GUARDED_BY ( cs_totalBytesSent )

private

◆ GUARDED_BY() [5/10]

uint64_t nMaxOutboundLimit CConnman::GUARDED_BY ( cs_totalBytesSent )

private

◆ GUARDED_BY() [6/10]

uint64_t nMaxOutboundTimeframe CConnman::GUARDED_BY ( cs_totalBytesSent )

private

◆ GUARDED_BY() [7/10]

std::deque<std::string> vOneShots CConnman::GUARDED_BY ( cs_vOneShots )

private

◆ GUARDED_BY() [8/10]

std::vector<std::string> vAddedNodes CConnman::GUARDED_BY ( cs_vAddedNodes )

private

◆ GUARDED_BY() [9/10]

std::vector<CNode*> vNodes CConnman::GUARDED_BY ( cs_vNodes )

private

◆ GUARDED_BY() [10/10]

bool fMsgProcWake CConnman::GUARDED_BY ( mutexMsgProc )

private

flag for waking the message processor.

◆ InactivityCheck()

void CConnman::InactivityCheck ( CNode * pnode )

private

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

Here is the caller graph for this function:

◆ InitBinds()

bool CConnman::InitBinds	(	const std::vector< CService > &	binds,
		const std::vector< NetWhitebindPermissions > &	whiteBinds
	)

private

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

Here is the call graph for this function:

Here is the caller graph for this function:

◆ MarkAddressGood()

void CConnman::MarkAddressGood ( const CAddress & addr )

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

◆ NotifyNumConnectionsChanged()

void CConnman::NotifyNumConnectionsChanged ( )

private

Definition at line 1123 of file net.cpp.

Here is the caller graph for this function:

◆ OpenNetworkConnection()

void CConnman::OpenNetworkConnection	(	const CAddress &	addrConnect,
		bool	fCountFailure,
		CSemaphoreGrant *	grantOutbound = `nullptr`,
		const char *	strDest = `nullptr`,
		bool	fOneShot = `false`,
		bool	fFeeler = `false`,
		bool	manual_connection = `false`,
		bool	block_relay_only = `false`
	)

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

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

Here is the call graph for this function:

Here is the caller graph for this function:

◆ PoissonNextSendInbound()

int64_t CConnman::PoissonNextSendInbound	(	int64_t	now,
		int	average_interval_seconds
	)

Attempts to obfuscate tx time through exponentially distributed emitting.

Works assuming that a single interval is used. Variable intervals will result in privacy decrease.

Definition at line 2840 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ProcessOneShot()

void CConnman::ProcessOneShot ( )

private

Definition at line 1724 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 2794 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 2623 of file net.cpp.

Here is the caller graph for this function:

◆ RecordBytesSent()

void CConnman::RecordBytesSent ( uint64_t bytes )

private

Definition at line 2629 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ RemoveAddedNode()

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

Definition at line 2544 of file net.cpp.

◆ SetAsmap()

void CConnman::SetAsmap ( std::vector< bool > asmap )

inline

Definition at line 328 of file net.h.

◆ SetBestHeight()

void CConnman::SetBestHeight ( int height )

Definition at line 2736 of file net.cpp.

Here is the caller graph for this function:

◆ SetMaxOutboundTarget()

void CConnman::SetMaxOutboundTarget ( uint64_t limit )

set the max outbound target in bytes

Definition at line 2646 of file net.cpp.

◆ SetMaxOutboundTimeframe()

void CConnman::SetMaxOutboundTimeframe ( uint64_t timeframe )

set the timeframe for the max outbound target

Definition at line 2678 of file net.cpp.

Here is the call graph for this function:

◆ SetNetworkActive()

void CConnman::SetNetworkActive ( bool active )

Definition at line 2248 of file net.cpp.

◆ SetServices()

void CConnman::SetServices	(	const CService &	addr,
		ServiceFlags	nServices
	)

Definition at line 2513 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ SetTryNewOutboundPeer()

void CConnman::SetTryNewOutboundPeer ( bool flag )

Definition at line 1746 of file net.cpp.

Here is the caller graph for this function:

◆ SocketEvents()

void CConnman::SocketEvents	(	std::set< SOCKET > &	recv_set,
		std::set< SOCKET > &	send_set,
		std::set< SOCKET > &	error_set
	)

private

Definition at line 1259 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ SocketHandler()

void CConnman::SocketHandler ( )

private

Definition at line 1334 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ SocketSendData()

size_t CConnman::SocketSendData ( CNode * pnode ) const

private

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

Here is the call graph for this function:

◆ Stop()

void CConnman::Stop ( )

inline

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

Here is the call graph for this function:

◆ StopThreads()

void CConnman::StopThreads ( )

Definition at line 2447 of file net.cpp.

◆ ThreadDNSAddressSeed()

void CConnman::ThreadDNSAddressSeed ( )

private

Definition at line 1592 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 2075 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 2008 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 )

private

Definition at line 1772 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 1458 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 1468 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

Friends And Related Function Documentation

◆ CConnmanTest

friend struct CConnmanTest

friend

Definition at line 478 of file net.h.

◆ ConnmanTestMsg

friend struct ConnmanTestMsg

friend

Definition at line 479 of file net.h.

Member Data Documentation

◆ addrman

CAddrMan CConnman::addrman

private

Definition at line 408 of file net.h.

◆ clientInterface

CClientUIInterface* CConnman::clientInterface

private

Definition at line 449 of file net.h.

◆ condMsgProc

std::condition_variable CConnman::condMsgProc

private

Definition at line 459 of file net.h.

◆ cs_totalBytesRecv

RecursiveMutex CConnman::cs_totalBytesRecv

private

Definition at line 384 of file net.h.

◆ cs_totalBytesSent

RecursiveMutex CConnman::cs_totalBytesSent

private

Definition at line 385 of file net.h.

◆ cs_vAddedNodes

RecursiveMutex CConnman::cs_vAddedNodes

private

Definition at line 412 of file net.h.

◆ cs_vNodes

RecursiveMutex CConnman::cs_vNodes

mutableprivate

Definition at line 415 of file net.h.

◆ cs_vOneShots

RecursiveMutex CConnman::cs_vOneShots

private

Definition at line 410 of file net.h.

◆ fAddressesInitialized

bool CConnman::fAddressesInitialized {false}

private

Definition at line 407 of file net.h.

◆ flagInterruptMsgProc

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

private

Definition at line 461 of file net.h.

◆ fNetworkActive

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

private

Definition at line 406 of file net.h.

◆ interruptNet

CThreadInterrupt CConnman::interruptNet

private

Definition at line 463 of file net.h.

◆ m_banman

BanMan* CConnman::m_banman

private

Definition at line 451 of file net.h.

◆ m_max_outbound

int CConnman::m_max_outbound

private

Definition at line 446 of file net.h.

◆ m_max_outbound_block_relay

int CConnman::m_max_outbound_block_relay

private

Definition at line 442 of file net.h.

◆ m_max_outbound_full_relay

int CConnman::m_max_outbound_full_relay

private

Definition at line 438 of file net.h.

◆ m_msgproc

NetEventsInterface* CConnman::m_msgproc

private

Definition at line 450 of file net.h.

◆ m_next_send_inv_to_incoming

std::atomic<int64_t> CConnman::m_next_send_inv_to_incoming {0}

private

Definition at line 476 of file net.h.

◆ m_peer_connect_timeout

int64_t CConnman::m_peer_connect_timeout

private

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

◆ m_use_addrman_outgoing

bool CConnman::m_use_addrman_outgoing

private

Definition at line 447 of file net.h.

◆ mutexMsgProc

Mutex CConnman::mutexMsgProc

private

Definition at line 460 of file net.h.

◆ nBestHeight

std::atomic<int> CConnman::nBestHeight

private

Definition at line 448 of file net.h.

◆ nLastNodeId

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

private

Definition at line 416 of file net.h.

◆ nLocalServices

ServiceFlags CConnman::nLocalServices

private

Services this instance offers.

This data is replicated in each CNode instance we create during peer connection (in ConnectNode()) under a member also called nLocalServices.

This data is not marked const, but after being set it should not change. See the note in CNode::nLocalServices documentation.

See also: CNode::nLocalServices

Definition at line 431 of file net.h.

◆ nMaxAddnode

int CConnman::nMaxAddnode

private

Definition at line 444 of file net.h.

◆ nMaxConnections

int CConnman::nMaxConnections

private

Definition at line 435 of file net.h.

◆ nMaxFeeler

int CConnman::nMaxFeeler

private

Definition at line 445 of file net.h.

◆ nPrevNodeCount

unsigned int CConnman::nPrevNodeCount {0}

private

Definition at line 417 of file net.h.

◆ nReceiveFloodSize

unsigned int CConnman::nReceiveFloodSize {0}

private

Definition at line 403 of file net.h.

◆ nSeed0

const uint64_t CConnman::nSeed0

private

SipHasher seeds for deterministic randomness.

Definition at line 454 of file net.h.

◆ nSeed1

const uint64_t CConnman::nSeed1

private

Definition at line 454 of file net.h.

◆ nSendBufferMaxSize

unsigned int CConnman::nSendBufferMaxSize {0}

private

Definition at line 402 of file net.h.

◆ semAddnode

std::unique_ptr<CSemaphore> CConnman::semAddnode

private

Definition at line 434 of file net.h.

◆ semOutbound

std::unique_ptr<CSemaphore> CConnman::semOutbound

private

Definition at line 433 of file net.h.

◆ threadDNSAddressSeed

std::thread CConnman::threadDNSAddressSeed

private

Definition at line 465 of file net.h.

◆ threadMessageHandler

std::thread CConnman::threadMessageHandler

private

Definition at line 469 of file net.h.

◆ threadOpenAddedConnections

std::thread CConnman::threadOpenAddedConnections

private

Definition at line 467 of file net.h.

◆ threadOpenConnections

std::thread CConnman::threadOpenConnections

private

Definition at line 468 of file net.h.

◆ threadSocketHandler

std::thread CConnman::threadSocketHandler

private

Definition at line 466 of file net.h.

◆ vhListenSocket

std::vector<ListenSocket> CConnman::vhListenSocket

private

Definition at line 405 of file net.h.

◆ vNodesDisconnected

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

private

Definition at line 414 of file net.h.

◆ vWhitelistedRange

std::vector<NetWhitelistPermissions> CConnman::vWhitelistedRange

private

Definition at line 400 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

Private Member Functions

Static Private Member Functions

Private Attributes

Friends

Detailed Description

Member Enumeration Documentation

◆ NumConnections

Constructor & Destructor Documentation

◆ CConnman()

◆ ~CConnman()

Member Function Documentation

◆ AcceptConnection()

◆ AddNewAddresses()

◆ AddNode()

◆ AddOneShot()

◆ AddWhitelistPermissionFlags()

◆ AttemptToEvictConnection()

◆ Bind()

◆ BindListenPort()

◆ CalculateKeyedNetGroup()

◆ CheckIncomingNonce()

◆ ConnectNode()

◆ 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]

◆ ForEachNodeThen() [1/2]

◆ ForEachNodeThen() [2/2]

◆ ForNode()

◆ GenerateSelectSet()

◆ GetAddedNodeInfo()

◆ GetAddressCount()

◆ GetAddresses()

◆ GetBestHeight()

◆ GetDeterministicRandomizer()

◆ GetExtraOutboundCount()

◆ GetLocalServices()

◆ GetMaxOutboundTarget()

◆ GetMaxOutboundTimeframe()

◆ GetMaxOutboundTimeLeftInCycle()

◆ GetNetworkActive()

◆ GetNewNodeId()

◆ GetNodeCount()

◆ GetNodeStats()

◆ GetOutboundTargetBytesLeft()

◆ GetReceiveFloodSize()

◆ GetTotalBytesRecv()

◆ GetTotalBytesSent()

◆ GetTryNewOutboundPeer()

◆ GetUseAddrmanOutgoing()

◆ GUARDED_BY() [1/10]

◆ GUARDED_BY() [2/10]

◆ GUARDED_BY() [3/10]

◆ GUARDED_BY() [4/10]

◆ GUARDED_BY() [5/10]

◆ GUARDED_BY() [6/10]

◆ GUARDED_BY() [7/10]

◆ GUARDED_BY() [8/10]

◆ GUARDED_BY() [9/10]

◆ GUARDED_BY() [10/10]

◆ InactivityCheck()

◆ Init()

◆ InitBinds()

◆ Interrupt()

◆ MarkAddressGood()

◆ NodeFullyConnected()

◆ NotifyNumConnectionsChanged()

◆ OpenNetworkConnection()