]> git.ipfire.org Git - thirdparty/kea.git/commitdiff
use thread_local
authorRazvan Becheriu <razvan@isc.org>
Tue, 15 Oct 2019 09:52:52 +0000 (12:52 +0300)
committerRazvan Becheriu <razvan@isc.org>
Wed, 6 Nov 2019 17:32:51 +0000 (19:32 +0200)
src/lib/dhcp/libdhcp++.cc
src/lib/dhcpsrv/alloc_engine.cc
src/lib/dhcpsrv/alloc_engine.h
src/lib/dhcpsrv/thread_pool.h
src/lib/dhcpsrv/thread_resource_mgr.h

index 51de725607dbf1afe447077828f60da8d4697376..56c0fa6d3e86d062264d6a23b8a83427b3d536c7 100644 (file)
@@ -89,7 +89,7 @@ void initOptionSpace(OptionDefContainerPtr& defs,
 const OptionDefContainerPtr&
 LibDHCP::getOptionDefs(const std::string& space) {
     static mutex local_mutex;
-    std::lock_guard<std::mutex> lock(&local_mutex);
+    std::lock_guard<std::mutex> lock(local_mutex);
     // If any of the containers is not initialized, it means that we haven't
     // initialized option definitions at all.
     if (option_defs_.end() == option_defs_.find(space)) {
index ad138d7460a56b663f4be00d83d255fa805bc980..2e8297b6dad6454584f19070d09d4cbefae0c6af 100644 (file)
@@ -46,7 +46,7 @@ using namespace isc::dhcp;
 using namespace isc::dhcp_ddns;
 using namespace isc::hooks;
 using namespace isc::stats;
-using namespace isc::util::thread;
+using namespace isc::util;
 
 namespace {
 /// Structure that holds registered hook indexes
index 32c6be7fcba67fff9b21added7e7b676b303dca5..1f829422fbf5731ea61aca1bb713e7e825236b51 100644 (file)
@@ -95,7 +95,7 @@ protected:
                     const ClientClasses& client_classes,
                     const DuidPtr& duid,
                     const isc::asiolink::IOAddress& hint) {
-            std::lock_guard<std::mutex> lock(&mutex_);
+            std::lock_guard<std::mutex> lock(mutex_);
             return pickAddressInternal(subnet, client_classes, duid, hint);
         }
 
index 8a2ab702b4914ff205e8702e40914e3d95b005bd..bcf98f8b9e42e4d84f60019227f67a4e7caeb71b 100644 (file)
@@ -42,7 +42,7 @@ struct ThreadPoolQueue {
     }
 
     void add(WorkItem item) {
-        std::lock_guard<std::mutex> lock(&mutex_);
+        std::lock_guard<std::mutex> lock(mutex_);
         if (exit_) {
             return;
         }
@@ -70,22 +70,22 @@ struct ThreadPoolQueue {
     }
 
     size_t count() {
-        std::lock_guard<std::mutex> lock(&mutex_);
+        std::lock_guard<std::mutex> lock(mutex_);
         return queue_.size();
     }
 
     void removeAll() {
-        std::lock_guard<std::mutex> lock(&mutex_);
+        std::lock_guard<std::mutex> lock(mutex_);
         removeAllUnsafe();
     }
 
     void create() {
-        std::lock_guard<std::mutex> lock(&mutex_);
+        std::lock_guard<std::mutex> lock(mutex_);
         exit_ = false;
     }
 
     void destroy() {
-        std::lock_guard<std::mutex> lock(&mutex_);
+        std::lock_guard<std::mutex> lock(mutex_);
         exit_ = true;
         // Notify get() so that it can exit.
         cv_.notify_all();
index baa2b1fea50f2f4792d03c7776c3bbea7c73b4ee..52685d5010277376a459a3903f2443131baa85ee 100644 (file)
@@ -20,7 +20,7 @@ class ThreadResourceMgr {
     typedef boost::shared_ptr<Resource> ResourcePtr;
 public:
     ResourcePtr resource() {
-        std::lock_guard<std::mutex> lock(&mutex_);
+        std::lock_guard<std::mutex> lock(mutex_);
         auto id = std::this_thread::get_id();
         if (map_.find(id) != map_.end()) {
             return map_[id];