Changeset View
Changeset View
Standalone View
Standalone View
src/net.cpp
Show First 20 Lines • Show All 2,616 Lines • ▼ Show 20 Lines | void CConnman::Interrupt() { | ||||
if (semAddnode) { | if (semAddnode) { | ||||
for (int i = 0; i < nMaxAddnode; i++) { | for (int i = 0; i < nMaxAddnode; i++) { | ||||
semAddnode->post(); | semAddnode->post(); | ||||
} | } | ||||
} | } | ||||
} | } | ||||
void CConnman::Stop() { | void CConnman::StopThreads() { | ||||
if (threadMessageHandler.joinable()) { | if (threadMessageHandler.joinable()) { | ||||
threadMessageHandler.join(); | threadMessageHandler.join(); | ||||
} | } | ||||
if (threadOpenConnections.joinable()) { | if (threadOpenConnections.joinable()) { | ||||
threadOpenConnections.join(); | threadOpenConnections.join(); | ||||
} | } | ||||
if (threadOpenAddedConnections.joinable()) { | if (threadOpenAddedConnections.joinable()) { | ||||
threadOpenAddedConnections.join(); | threadOpenAddedConnections.join(); | ||||
} | } | ||||
if (threadDNSAddressSeed.joinable()) { | if (threadDNSAddressSeed.joinable()) { | ||||
threadDNSAddressSeed.join(); | threadDNSAddressSeed.join(); | ||||
} | } | ||||
if (threadSocketHandler.joinable()) { | if (threadSocketHandler.joinable()) { | ||||
threadSocketHandler.join(); | threadSocketHandler.join(); | ||||
} | } | ||||
} | |||||
void CConnman::StopNodes() { | |||||
if (fAddressesInitialized) { | if (fAddressesInitialized) { | ||||
DumpAddresses(); | DumpAddresses(); | ||||
fAddressesInitialized = false; | fAddressesInitialized = false; | ||||
} | } | ||||
// Close sockets | // Close sockets | ||||
LOCK(cs_vNodes); | |||||
for (CNode *pnode : vNodes) { | for (CNode *pnode : vNodes) { | ||||
pnode->CloseSocketDisconnect(); | pnode->CloseSocketDisconnect(); | ||||
} | } | ||||
for (ListenSocket &hListenSocket : vhListenSocket) { | for (ListenSocket &hListenSocket : vhListenSocket) { | ||||
if (hListenSocket.socket != INVALID_SOCKET) { | if (hListenSocket.socket != INVALID_SOCKET) { | ||||
if (!CloseSocket(hListenSocket.socket)) { | if (!CloseSocket(hListenSocket.socket)) { | ||||
LogPrintf("CloseSocket(hListenSocket) failed with error %s\n", | LogPrintf("CloseSocket(hListenSocket) failed with error %s\n", | ||||
NetworkErrorString(WSAGetLastError())); | NetworkErrorString(WSAGetLastError())); | ||||
▲ Show 20 Lines • Show All 434 Lines • Show Last 20 Lines |