diff options
Diffstat (limited to 'src/ipcpd/unicast')
| -rw-r--r-- | src/ipcpd/unicast/connmgr.c | 4 | ||||
| -rw-r--r-- | src/ipcpd/unicast/dir/dht.c | 4 |
2 files changed, 3 insertions, 5 deletions
diff --git a/src/ipcpd/unicast/connmgr.c b/src/ipcpd/unicast/connmgr.c index 11c5d5b6..07568fb5 100644 --- a/src/ipcpd/unicast/connmgr.c +++ b/src/ipcpd/unicast/connmgr.c @@ -32,8 +32,4 @@ #define BUILD_IPCP_UNICAST -#ifdef IPCP_CONN_WAIT_DIR - #include "dir.h" -#endif - #include "common/connmgr.c" diff --git a/src/ipcpd/unicast/dir/dht.c b/src/ipcpd/unicast/dir/dht.c index 4a243059..a56c8af2 100644 --- a/src/ipcpd/unicast/dir/dht.c +++ b/src/ipcpd/unicast/dir/dht.c @@ -3693,6 +3693,8 @@ static void dht_kv_replicate(void) list_head_init(&repl); list_head_init(&rebl); + pthread_cleanup_push(free, key); + while (dht_kv_next_values(key, &repl, &rebl) == 0) { dht_kv_replicate_values(key, &repl, &rebl); if (!list_is_empty(&repl)) { @@ -3708,7 +3710,7 @@ static void dht_kv_replicate(void) } } - free(key); + pthread_cleanup_pop(true); } static void dht_kv_refresh_contacts(void) |