Changeset View
Changeset View
Standalone View
Standalone View
src/net.cpp
Show First 20 Lines • Show All 2,461 Lines • ▼ Show 20 Lines | bool CConnman::Start(CScheduler &scheduler, const Options &connOptions) { | ||||
} | } | ||||
uiInterface.InitMessage(_("Starting network threads...")); | uiInterface.InitMessage(_("Starting network threads...")); | ||||
fAddressesInitialized = true; | fAddressesInitialized = true; | ||||
if (semOutbound == nullptr) { | if (semOutbound == nullptr) { | ||||
// initialize semaphore | // initialize semaphore | ||||
semOutbound = MakeUnique<CSemaphore>( | semOutbound = std::make_unique<CSemaphore>( | ||||
std::min((nMaxOutbound + nMaxFeeler), nMaxConnections)); | std::min((nMaxOutbound + nMaxFeeler), nMaxConnections)); | ||||
} | } | ||||
if (semAddnode == nullptr) { | if (semAddnode == nullptr) { | ||||
// initialize semaphore | // initialize semaphore | ||||
semAddnode = MakeUnique<CSemaphore>(nMaxAddnode); | semAddnode = std::make_unique<CSemaphore>(nMaxAddnode); | ||||
} | } | ||||
// | // | ||||
// Start threads | // Start threads | ||||
// | // | ||||
assert(m_msgproc); | assert(m_msgproc); | ||||
InterruptSocks5(false); | InterruptSocks5(false); | ||||
interruptNet.reset(); | interruptNet.reset(); | ||||
▲ Show 20 Lines • Show All 407 Lines • ▼ Show 20 Lines | CNode::CNode(NodeId idIn, ServiceFlags nLocalServicesIn, | ||||
filterInventoryKnown.reset(); | filterInventoryKnown.reset(); | ||||
fSendMempool = false; | fSendMempool = false; | ||||
fGetAddr = false; | fGetAddr = false; | ||||
nNextLocalAddrSend = 0; | nNextLocalAddrSend = 0; | ||||
nNextAddrSend = 0; | nNextAddrSend = 0; | ||||
nNextInvSend = 0; | nNextInvSend = 0; | ||||
fRelayTxes = false; | fRelayTxes = false; | ||||
fSentAddr = false; | fSentAddr = false; | ||||
pfilter = MakeUnique<CBloomFilter>(); | pfilter = std::make_unique<CBloomFilter>(); | ||||
timeLastMempoolReq = 0; | timeLastMempoolReq = 0; | ||||
nLastBlockTime = 0; | nLastBlockTime = 0; | ||||
nLastTXTime = 0; | nLastTXTime = 0; | ||||
nPingNonceSent = 0; | nPingNonceSent = 0; | ||||
nPingUsecStart = 0; | nPingUsecStart = 0; | ||||
nPingUsecTime = 0; | nPingUsecTime = 0; | ||||
fPingQueued = false; | fPingQueued = false; | ||||
nMinPingUsecTime = std::numeric_limits<int64_t>::max(); | nMinPingUsecTime = std::numeric_limits<int64_t>::max(); | ||||
▲ Show 20 Lines • Show All 188 Lines • Show Last 20 Lines |