kernel-netlink,pfroute: Properly update address flag within ROAM_DELAY

77d4a02 and 55da01f only updated the address flag when a job was created,
which obviously had the same limitation as the old code.

Fixes #374.

diff --git a/src/libhydra/plugins/kernel_netlink/kernel_netlink_net.c b/src/libhydra/plugins/kernel_netlink/kernel_netlink_net.c
index 89fb076adcb7f3f54784c4d9808d59e535c41c14..43bcb677ba3ec4b1305fc929056f0d0b96217374 100644 (file)
--- a/src/libhydra/plugins/kernel_netlink/kernel_netlink_net.c
+++ b/src/libhydra/plugins/kernel_netlink/kernel_netlink_net.c
@@ -729,6 +729,7 @@ static void fire_roam_event(private_kernel_netlink_net_t *this, bool address)
 
        time_monotonic(&now);
        this->roam_lock->lock(this->roam_lock);
+       this->roam_address |= address;
        if (!timercmp(&now, &this->next_roam, >))
        {
                this->roam_lock->unlock(this->roam_lock);
@@ -736,7 +737,6 @@ static void fire_roam_event(private_kernel_netlink_net_t *this, bool address)
        }
        timeval_add_ms(&now, ROAM_DELAY);
        this->next_roam = now;
-       this->roam_address |= address;
        this->roam_lock->unlock(this->roam_lock);
 
        job = (job_t*)callback_job_create((callback_job_cb_t)roam_event,

diff --git a/src/libhydra/plugins/kernel_pfroute/kernel_pfroute_net.c b/src/libhydra/plugins/kernel_pfroute/kernel_pfroute_net.c
index 05aeb903b5ea7462b23cca2bc33313a992ef16f1..f432ecdb7cfb1607d2e9ddd0c8208f09b9b96f92 100644 (file)
--- a/src/libhydra/plugins/kernel_pfroute/kernel_pfroute_net.c
+++ b/src/libhydra/plugins/kernel_pfroute/kernel_pfroute_net.c
@@ -565,6 +565,7 @@ static void fire_roam_event(private_kernel_pfroute_net_t *this, bool address)
 
        time_monotonic(&now);
        this->roam_lock->lock(this->roam_lock);
+       this->roam_address |= address;
        if (!timercmp(&now, &this->next_roam, >))
        {
                this->roam_lock->unlock(this->roam_lock);
@@ -572,7 +573,6 @@ static void fire_roam_event(private_kernel_pfroute_net_t *this, bool address)
        }
        timeval_add_ms(&now, ROAM_DELAY);
        this->next_roam = now;
-       this->roam_address |= address;
        this->roam_lock->unlock(this->roam_lock);
 
        job = (job_t*)callback_job_create((callback_job_cb_t)roam_event,