#include <net.h>

Inheritance diagram for ConnmanTestMsg:

Collaboration diagram for ConnmanTestMsg:

Public Member Functions
void	SetMsgProc (NetEventsInterface *msgproc)

void	SetPeerConnectTimeout (std::chrono::seconds timeout)

void	ResetAddrCache ()

void	ResetMaxOutboundCycle ()

std::vector< CNode * >	TestNodes ()

void	AddTestNode (CNode &node)

void	ClearTestNodes ()

void	CreateNodeFromAcceptedSocketPublic (std::unique_ptr< Sock > sock, NetPermissionFlags permissions, const CAddress &addr_bind, const CAddress &addr_peer)

bool	InitBindsPublic (const CConnman::Options &options)

void	SocketHandlerPublic ()

void	NodeReceiveMsgBytes (CNode &node, std::span< const uint8_t > msg_bytes, bool &complete) const

bool	ReceiveMsgFrom (CNode &node, CSerializedNetMsg &&ser_msg) const

void	FlushSendBuffer (CNode &node) const

bool	AlreadyConnectedToAddressPublic (const CNetAddr &addr)

CNode *	ConnectNodePublic (PeerManager &peerman, const char *pszDest, ConnectionType conn_type) EXCLUSIVE_LOCKS_REQUIRED(!m_unused_i2p_sessions_mutex)

	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 >())

Public Member Functions inherited from CConnman
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)

	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 ()

void	Stop ()

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_unused_i2p_sessions_mutex)
	Open a new P2P connection and initialize it with the PeerManager at `m_msgproc`. More...

bool	CheckIncomingNonce (uint64_t nonce)

void	ASMapHealthCheck ()

RecursiveMutex &	GetNodesMutex () const LOCK_RETURNED(m_nodes_mutex)

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

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

void	ForEachNode (const NodeFn &func)

void	ForEachNode (const NodeFn &func) const

std::vector< CAddress >	GetAddressesUnsafe (size_t max_addresses, size_t max_pct, std::optional< Network > network, const 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

int	GetExtraFullOutboundCount () const

int	GetExtraBlockRelayCount () const

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_unused_i2p_sessions_mutex)
	Attempts to open a connection. More...

size_t	GetNodeCount (ConnectionDirection) const

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

uint32_t	GetMappedAS (const CNetAddr &addr) const

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

bool	DisconnectNode (std::string_view 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	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, std::chrono::seconds 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 Handshake(CNode &node, bool successfully_connected, ServiceFlags remote_services, ServiceFlags local_services, int32_t version, bool relay_txs) EXCLUSIVE_LOCKS_REQUIRED(NetEventsInterface bool	ProcessMessagesOnce (CNode &node) EXCLUSIVE_LOCKS_REQUIRED(NetEventsInterface

Public Attributes inherited from CConnman
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

bool	!m_added_nodes_mutex

bool	!m_addr_fetches_mutex

bool	!mutexMsgProc

Additional Inherited Members
Public Types inherited from CConnman
using	NodeFn = std::function< void(CNode *)>

Detailed Description

Definition at line 35 of file net.h.

Member Function Documentation

◆ AddTestNode()

void ConnmanTestMsg::AddTestNode ( CNode & node )

inline

Definition at line 57 of file net.h.

Here is the caller graph for this function:

◆ AlreadyConnectedToAddressPublic()

bool ConnmanTestMsg::AlreadyConnectedToAddressPublic ( const CNetAddr & addr )

inline

Definition at line 110 of file net.h.

Here is the call graph for this function:

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

Here is the call graph for this function:

◆ ClearTestNodes()

void ConnmanTestMsg::ClearTestNodes ( )

inline

Definition at line 65 of file net.h.

◆ ConnectNodePublic()

CNode * ConnmanTestMsg::ConnectNodePublic	(	PeerManager &	peerman,
		const char *	pszDest,
		ConnectionType	conn_type
	)

Definition at line 117 of file net.cpp.

Here is the call graph for this function:

◆ CreateNodeFromAcceptedSocketPublic()

void ConnmanTestMsg::CreateNodeFromAcceptedSocketPublic	(	std::unique_ptr< Sock >	sock,
		NetPermissionFlags	permissions,
		const CAddress &	addr_bind,
		const CAddress &	addr_peer
	)

inline

Definition at line 74 of file net.h.

Here is the call graph for this function:

◆ FlushSendBuffer()

void ConnmanTestMsg::FlushSendBuffer ( CNode & node ) const

Definition at line 91 of file net.cpp.

Here is the caller graph for this function:

◆ InitBindsPublic()

bool ConnmanTestMsg::InitBindsPublic ( const CConnman::Options & options )

inline

Definition at line 82 of file net.h.

Here is the call graph for this function:

◆ NodeReceiveMsgBytes()

void ConnmanTestMsg::NodeReceiveMsgBytes	(	CNode &	node,
		std::span< const uint8_t >	msg_bytes,
		bool &	complete
	)		const

Definition at line 83 of file net.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ReceiveMsgFrom()

bool ConnmanTestMsg::ReceiveMsgFrom	(	CNode &	node,
		CSerializedNetMsg &&	ser_msg
	)		const

Definition at line 103 of file net.cpp.

Here is the call graph for this function:

◆ ResetAddrCache()

void ConnmanTestMsg::ResetAddrCache ( )

Definition at line 74 of file net.cpp.

Here is the caller graph for this function:

◆ ResetMaxOutboundCycle()

void ConnmanTestMsg::ResetMaxOutboundCycle ( )

Definition at line 76 of file net.cpp.

◆ SetMsgProc()

void ConnmanTestMsg::SetMsgProc ( NetEventsInterface * msgproc )

inline

Definition at line 38 of file net.h.

◆ SetPeerConnectTimeout()

void ConnmanTestMsg::SetPeerConnectTimeout ( std::chrono::seconds timeout )

inline

Definition at line 43 of file net.h.

Here is the caller graph for this function:

◆ SocketHandlerPublic()

void ConnmanTestMsg::SocketHandlerPublic ( )

inline

Definition at line 87 of file net.h.

Here is the call graph for this function:

◆ TestNodes()

std::vector< CNode * > ConnmanTestMsg::TestNodes ( )

inline

Definition at line 51 of file net.h.

Member Data Documentation

◆ ProcessMessagesOnce

void Handshake(CNode &node, bool successfully_connected, ServiceFlags remote_services, ServiceFlags local_services, int32_t version, bool relay_txs) EXCLUSIVE_LOCKS_REQUIRED(NetEventsInterface bool ConnmanTestMsg::ProcessMessagesOnce(CNode &node) EXCLUSIVE_LOCKS_REQUIRED(NetEventsInterface

inline

Definition at line 100 of file net.h.

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

src/test/util/net.h
src/test/util/net.cpp

Public Member Functions

Public Attributes

Additional Inherited Members

Detailed Description

Member Function Documentation

◆ AddTestNode()

◆ AlreadyConnectedToAddressPublic()

◆ CConnman()

◆ ClearTestNodes()

◆ ConnectNodePublic()

◆ CreateNodeFromAcceptedSocketPublic()

◆ FlushSendBuffer()

◆ InitBindsPublic()

◆ NodeReceiveMsgBytes()

◆ ReceiveMsgFrom()

◆ ResetAddrCache()

◆ ResetMaxOutboundCycle()

◆ SetMsgProc()

◆ SetPeerConnectTimeout()

◆ SocketHandlerPublic()

◆ TestNodes()

Member Data Documentation

◆ ProcessMessagesOnce