summaryrefslogtreecommitdiff
path: root/src/ipcpd
diff options
context:
space:
mode:
Diffstat (limited to 'src/ipcpd')
-rw-r--r--src/ipcpd/ipcp.c5
-rw-r--r--src/ipcpd/normal/dir.c9
-rw-r--r--src/ipcpd/normal/main.c2
3 files changed, 14 insertions, 2 deletions
diff --git a/src/ipcpd/ipcp.c b/src/ipcpd/ipcp.c
index e44fafe2..2e4c3fca 100644
--- a/src/ipcpd/ipcp.c
+++ b/src/ipcpd/ipcp.c
@@ -334,6 +334,9 @@ int ipcp_init(enum ipcp_type type, struct ipcp_ops * ops)
int ipcp_boot()
{
int t;
+
+ ipcp_set_state(IPCP_INIT);
+
for (t = 0; t < IPCPD_THREADPOOL_SIZE; ++t) {
if (pthread_create(&ipcpi.threadpool[t], NULL,
ipcp_main_loop, NULL)) {
@@ -346,8 +349,6 @@ int ipcp_boot()
}
}
- ipcpi.state = IPCP_INIT;
-
return 0;
}
diff --git a/src/ipcpd/normal/dir.c b/src/ipcpd/normal/dir.c
index c5bb03dd..d9d15f72 100644
--- a/src/ipcpd/normal/dir.c
+++ b/src/ipcpd/normal/dir.c
@@ -32,6 +32,7 @@
#include <stdlib.h>
#include <string.h>
+#include <assert.h>
char * create_path(char * name)
{
@@ -94,6 +95,8 @@ int dir_name_reg(char * name)
char * path;
uint64_t * addr;
+ assert(name);
+
ro_attr_init(&attr);
attr.enrol_sync = true;
attr.recv_set = ALL_MEMBERS;
@@ -107,10 +110,12 @@ int dir_name_reg(char * name)
pathname_destroy(path);
return -ENOMEM;
}
+
*addr = ribmgr_address();
if (ro_create(path, &attr, (uint8_t *) addr, sizeof(*addr))) {
pathname_destroy(path);
+ free(addr);
LOG_ERR("Failed to create RIB object.");
return -1;
}
@@ -118,6 +123,8 @@ int dir_name_reg(char * name)
LOG_DBG("Registered %s.", name);
pathname_destroy(path);
+ free(name);
+
return 0;
}
@@ -125,6 +132,8 @@ int dir_name_unreg(char * name)
{
char * path;
+ assert(name);
+
path = create_path(name);
if (path == NULL)
return -ENOMEM;
diff --git a/src/ipcpd/normal/main.c b/src/ipcpd/normal/main.c
index 8d319894..8db754aa 100644
--- a/src/ipcpd/normal/main.c
+++ b/src/ipcpd/normal/main.c
@@ -187,6 +187,7 @@ static int normal_ipcp_enroll(char * dst_name)
LOG_WARN("Failed to finalize flow manager.");
if (ribmgr_fini())
LOG_WARN("Failed to finalize RIB manager.");
+ ipcp_set_state(IPCP_INIT);
pthread_rwlock_unlock(&ipcpi.state_lock);
LOG_ERR("Failed to create acceptor thread.");
return -1;
@@ -269,6 +270,7 @@ static int normal_ipcp_bootstrap(struct dif_config * conf)
LOG_WARN("Failed to finalize flow manager.");
if (ribmgr_fini())
LOG_WARN("Failed to finalize RIB manager.");
+ ipcp_set_state(IPCP_INIT);
pthread_rwlock_unlock(&ipcpi.state_lock);
LOG_ERR("Failed to create acceptor thread.");
return -1;