diff options
| author | practicalswift <[email protected]> | 2017-08-09 16:07:22 +0200 |
|---|---|---|
| committer | practicalswift <[email protected]> | 2017-11-09 16:52:44 +0100 |
| commit | 8ccf1bb0c31108762e47f28d9d592e8d4c788564 (patch) | |
| tree | df1f221b3c3e7d28b743b99b259eb964cde4dff7 /src | |
| parent | Use unique_ptr for upnp_thread (boost::thread) (diff) | |
| download | discoin-8ccf1bb0c31108762e47f28d9d592e8d4c788564.tar.xz discoin-8ccf1bb0c31108762e47f28d9d592e8d4c788564.zip | |
Use unique_ptr for sem{Addnode,Outbound} (CSemaphore)
Diffstat (limited to 'src')
| -rw-r--r-- | src/net.cpp | 12 | ||||
| -rw-r--r-- | src/net.h | 4 |
2 files changed, 6 insertions, 10 deletions
diff --git a/src/net.cpp b/src/net.cpp index 2db1f2a04..5f0a7a477 100644 --- a/src/net.cpp +++ b/src/net.cpp @@ -2222,8 +2222,6 @@ CConnman::CConnman(uint64_t nSeed0In, uint64_t nSeed1In) : nSeed0(nSeed0In), nSe nLastNodeId = 0; nSendBufferMaxSize = 0; nReceiveFloodSize = 0; - semOutbound = nullptr; - semAddnode = nullptr; flagInterruptMsgProc = false; SetTryNewOutboundPeer(false); @@ -2329,11 +2327,11 @@ bool CConnman::Start(CScheduler& scheduler, const Options& connOptions) if (semOutbound == nullptr) { // initialize semaphore - semOutbound = new CSemaphore(std::min((nMaxOutbound + nMaxFeeler), nMaxConnections)); + semOutbound = std::unique_ptr<CSemaphore>(new CSemaphore(std::min((nMaxOutbound + nMaxFeeler), nMaxConnections))); } if (semAddnode == nullptr) { // initialize semaphore - semAddnode = new CSemaphore(nMaxAddnode); + semAddnode = std::unique_ptr<CSemaphore>(new CSemaphore(nMaxAddnode)); } // @@ -2456,10 +2454,8 @@ void CConnman::Stop() vNodes.clear(); vNodesDisconnected.clear(); vhListenSocket.clear(); - delete semOutbound; - semOutbound = nullptr; - delete semAddnode; - semAddnode = nullptr; + semOutbound.reset(); + semAddnode.reset(); } void CConnman::DeleteNode(CNode* pnode) @@ -399,8 +399,8 @@ private: /** Services this instance offers */ ServiceFlags nLocalServices; - CSemaphore *semOutbound; - CSemaphore *semAddnode; + std::unique_ptr<CSemaphore> semOutbound; + std::unique_ptr<CSemaphore> semAddnode; int nMaxConnections; int nMaxOutbound; int nMaxAddnode; |