|
void | Init (const Options &connOptions) |
|
| CConnman (const Config &configIn, 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, ConnectionType conn_type=ConnectionType::OUTBOUND) |
|
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 |
|
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. 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) |
|
|
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 | AddAddrFetch (const std::string &strDest) |
|
void | ProcessAddrFetch () |
|
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, ConnectionType conn_type) |
|
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 > m_addr_fetches | GUARDED_BY (m_addr_fetches_mutex) |
|
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...
|
|
Definition at line 167 of file net.h.