Use a separate mutex for cached routes in kernel-netlink plugin

diff --git a/src/libhydra/plugins/kernel_netlink/kernel_netlink_net.c b/src/libhydra/plugins/kernel_netlink/kernel_netlink_net.c
index dc6f8ccd5a6264fed6e36901cc200df6e605fe7c..4b64a8d26c43d9538859caba7bc6fb8cce15d841 100644 (file)
--- a/src/libhydra/plugins/kernel_netlink/kernel_netlink_net.c
+++ b/src/libhydra/plugins/kernel_netlink/kernel_netlink_net.c
@@ -398,6 +398,11 @@ struct private_kernel_netlink_net_t {
         */
        hashtable_t *routes;
 
+       /**
+        * mutex for routes
+        */
+       mutex_t *routes_lock;
+
        /**
         * interface changes which may trigger route reinstallation
         */
@@ -473,7 +478,7 @@ static job_requeue_t reinstall_routes(private_kernel_netlink_net_t *this)
        route_entry_t *route;
 
        this->net_changes_lock->lock(this->net_changes_lock);
-       this->mutex->lock(this->mutex);
+       this->routes_lock->lock(this->routes_lock);
 
        enumerator = this->routes->create_enumerator(this->routes);
        while (enumerator->enumerate(enumerator, NULL, (void**)&route))
@@ -503,7 +508,7 @@ static job_requeue_t reinstall_routes(private_kernel_netlink_net_t *this)
                }
        }
        enumerator->destroy(enumerator);
-       this->mutex->unlock(this->mutex);
+       this->routes_lock->unlock(this->routes_lock);
 
        net_changes_clear(this);
        this->net_changes_lock->unlock(this->net_changes_lock);
@@ -1899,18 +1904,18 @@ METHOD(kernel_net_t, add_route, status_t,
                .if_name = if_name,
        };
 
-       this->mutex->lock(this->mutex);
+       this->routes_lock->lock(this->routes_lock);
        found = this->routes->get(this->routes, &route);
        if (found)
        {
-               this->mutex->unlock(this->mutex);
+               this->routes_lock->unlock(this->routes_lock);
                return ALREADY_DONE;
        }
        found = route_entry_clone(&route);
        this->routes->put(this->routes, found, found);
        status = manage_srcroute(this, RTM_NEWROUTE, NLM_F_CREATE | NLM_F_EXCL,
                                                         dst_net, prefixlen, gateway, src_ip, if_name);
-       this->mutex->unlock(this->mutex);
+       this->routes_lock->unlock(this->routes_lock);
        return status;
 }
 
@@ -1927,18 +1932,18 @@ METHOD(kernel_net_t, del_route, status_t,
                .if_name = if_name,
        };
 
-       this->mutex->lock(this->mutex);
+       this->routes_lock->lock(this->routes_lock);
        found = this->routes->get(this->routes, &route);
        if (!found)
        {
-               this->mutex->unlock(this->mutex);
+               this->routes_lock->unlock(this->routes_lock);
                return NOT_FOUND;
        }
        this->routes->remove(this->routes, found);
        route_entry_destroy(found);
        status = manage_srcroute(this, RTM_DELROUTE, 0, dst_net, prefixlen,
                                                         gateway, src_ip, if_name);
-       this->mutex->unlock(this->mutex);
+       this->routes_lock->unlock(this->routes_lock);
        return status;
 }
 
@@ -2140,6 +2145,7 @@ METHOD(kernel_net_t, destroy, void,
        }
        enumerator->destroy(enumerator);
        this->routes->destroy(this->routes);
+       this->routes_lock->destroy(this->routes_lock);
        DESTROY_IF(this->socket);
 
        net_changes_clear(this);
@@ -2193,6 +2199,7 @@ kernel_netlink_net_t *kernel_netlink_net_create()
                                                                (hashtable_equals_t)addr_map_entry_equals, 16),
                .vips = hashtable_create((hashtable_hash_t)addr_map_entry_hash,
                                                                 (hashtable_equals_t)addr_map_entry_equals, 16),
+               .routes_lock = mutex_create(MUTEX_TYPE_DEFAULT),
                .net_changes_lock = mutex_create(MUTEX_TYPE_DEFAULT),
                .ifaces = linked_list_create(),
                .mutex = mutex_create(MUTEX_TYPE_RECURSIVE),