Merged in dstaesse/ouroboros/be-irmd (pull request #177)

irmd: Revised flow allocation

1 files changed, 393 insertions, 419 deletions

diff --git a/src/irmd/main.c b/src/irmd/main.c
index 625c28c8..6cf16505 100644
--- a/src/irmd/main.c
+++ b/src/irmd/main.c
@@ -76,7 +76,7 @@ struct spawned_api {
 };
 
 /* keeps track of port_id's between N and N - 1 */
-struct port_map_entry {
+struct irm_flow {
         struct list_head next;
 
         int              port_id;
@@ -84,12 +84,11 @@ struct port_map_entry {
         pid_t            n_api;
         pid_t            n_1_api;
 
-        pthread_cond_t   res_signal;
-        pthread_mutex_t  res_lock;
+        struct timespec  t0;
 
         enum flow_state  state;
-
-        struct timespec  t0;
+        pthread_cond_t   state_cond;
+        pthread_mutex_t  state_lock;
 };
 
 struct irm {
@@ -104,23 +103,24 @@ struct irm {
         /* keep track of all flows in this processing system */
         struct bmp *        port_ids;
         /* maps port_ids to api pair */
-        struct list_head    port_map;
+        struct list_head    irm_flows;
         pthread_rwlock_t    flows_lock;
 
-        enum irm_state      state;
         struct lockfile *   lf;
         struct shm_du_map * dum;
         pthread_t *         threadpool;
         int                 sockfd;
+
+        enum irm_state      state;
         pthread_rwlock_t    state_lock;
 
         pthread_t           cleanup_flows;
         pthread_t           shm_sanitize;
-} * instance = NULL;
+} * irmd = NULL;
 
-static struct port_map_entry * port_map_entry_create()
+static struct irm_flow * irm_flow_create()
 {
-        struct port_map_entry * e = malloc(sizeof(*e));
+        struct irm_flow * e = malloc(sizeof(*e));
         if (e == NULL)
                 return NULL;
 
@@ -129,12 +129,12 @@ static struct port_map_entry * port_map_entry_create()
         e->port_id = -1;
         e->state   = FLOW_NULL;
 
-        if (pthread_cond_init(&e->res_signal, NULL)) {
+        if (pthread_cond_init(&e->state_cond, NULL)) {
                 free(e);
                 return NULL;
         }
 
-        if (pthread_mutex_init(&e->res_lock, NULL)) {
+        if (pthread_mutex_init(&e->state_lock, NULL)) {
                 free(e);
                 return NULL;
         }
@@ -145,36 +145,36 @@ static struct port_map_entry * port_map_entry_create()
         return e;
 }
 
-static void port_map_entry_destroy(struct port_map_entry * e)
+static void irm_flow_destroy(struct irm_flow * e)
 {
-        bool wait = true;
-        pthread_mutex_lock(&e->res_lock);
-        e->state = FLOW_NULL;
+        pthread_mutex_lock(&e->state_lock);
 
-        pthread_cond_broadcast(&e->res_signal);
-        pthread_mutex_unlock(&e->res_lock);
+        if (e->state == FLOW_PENDING)
+                e->state = FLOW_DESTROY;
 
-        while (wait) {
-                pthread_mutex_lock(&e->res_lock);
-                if (pthread_cond_destroy(&e->res_signal))
-                        pthread_cond_broadcast(&e->res_signal);
-                else
-                        wait = false;
-                pthread_mutex_unlock(&e->res_lock);
-        }
+        pthread_cond_signal(&e->state_cond);
+        pthread_mutex_unlock(&e->state_lock);
+
+        pthread_cleanup_push((void(*)(void *)) pthread_mutex_unlock,
+                             (void *) &e->state_lock);
+
+        while (e->state != FLOW_NULL)
+                pthread_cond_wait(&e->state_cond, &e->state_lock);
 
-        pthread_mutex_destroy(&e->res_lock);
+        pthread_cleanup_pop(true);
+
+        pthread_cond_destroy(&e->state_cond);
+        pthread_mutex_destroy(&e->state_lock);
 
         free(e);
 }
 
-static struct port_map_entry * get_port_map_entry(int port_id)
+static struct irm_flow * get_irm_flow(int port_id)
 {
         struct list_head * pos = NULL;
 
-        list_for_each(pos, &instance->port_map) {
-                struct port_map_entry * e =
-                        list_entry(pos, struct port_map_entry, next);
+        list_for_each(pos, &irmd->irm_flows) {
+                struct irm_flow * e = list_entry(pos, struct irm_flow, next);
 
                 if (e->port_id == port_id)
                         return e;
@@ -183,13 +183,12 @@ static struct port_map_entry * get_port_map_entry(int port_id)
         return NULL;
 }
 
-static struct port_map_entry * get_port_map_entry_n(pid_t n_api)
+static struct irm_flow * get_irm_flow_n(pid_t n_api)
 {
         struct list_head * pos = NULL;
 
-        list_for_each(pos, &instance->port_map) {
-                struct port_map_entry * e =
-                        list_entry(pos, struct port_map_entry, next);
+        list_for_each(pos, &irmd->irm_flows) {
+                struct irm_flow * e = list_entry(pos, struct irm_flow, next);
 
                 if (e->n_api == n_api)
                         return e;
@@ -230,7 +229,7 @@ static struct ipcp_entry * get_ipcp_entry_by_api(pid_t api)
 {
         struct list_head * pos = NULL;
 
-        list_for_each(pos, &instance->ipcps) {
+        list_for_each(pos, &irmd->ipcps) {
                 struct ipcp_entry * tmp =
                         list_entry(pos, struct ipcp_entry, next);
                 if (api == tmp->api)
@@ -246,9 +245,9 @@ static pid_t get_ipcp_by_dst_name(char * dst_name)
 {
         struct list_head * pos = NULL;
         char * dif_name =
-                registry_get_dif_for_dst(&instance->registry, dst_name);
+                registry_get_dif_for_dst(&irmd->registry, dst_name);
         if (dif_name == NULL) {
-                list_for_each(pos, &instance->ipcps) {
+                list_for_each(pos, &irmd->ipcps) {
                         struct ipcp_entry * e =
                                 list_entry(pos, struct ipcp_entry, next);
                         if (e->type == IPCP_NORMAL) {
@@ -257,7 +256,7 @@ static pid_t get_ipcp_by_dst_name(char * dst_name)
                         }
                 }
 
-                list_for_each(pos, &instance->ipcps) {
+                list_for_each(pos, &irmd->ipcps) {
                         struct ipcp_entry * e =
                                 list_entry(pos, struct ipcp_entry, next);
                         if (e->type == IPCP_SHIM_ETH_LLC) {
@@ -267,7 +266,7 @@ static pid_t get_ipcp_by_dst_name(char * dst_name)
                 }
 
 
-                list_for_each(pos, &instance->ipcps) {
+                list_for_each(pos, &irmd->ipcps) {
                         struct ipcp_entry * e =
                                 list_entry(pos, struct ipcp_entry, next);
                         if (e->type == IPCP_SHIM_UDP) {
@@ -280,7 +279,7 @@ static pid_t get_ipcp_by_dst_name(char * dst_name)
         if (dif_name == NULL)
                 return -1;
 
-        list_for_each(pos, &instance->ipcps) {
+        list_for_each(pos, &irmd->ipcps) {
                 struct ipcp_entry * e =
                         list_entry(pos, struct ipcp_entry, next);
                 if (strcmp(e->dif_name, dif_name) == 0)
@@ -302,23 +301,23 @@ static pid_t create_ipcp(char *         name,
         if (api == NULL)
                 return -ENOMEM;
 
-        pthread_rwlock_rdlock(&instance->state_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
 
-        if (instance->state != IRMD_RUNNING) {
-                pthread_rwlock_unlock(&instance->state_lock);
+        if (irmd->state != IRMD_RUNNING) {
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
 
         api->api = ipcp_create(ipcp_type);
         if (api->api == -1) {
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_ERR("Failed to create IPCP.");
                 return -1;
         }
 
         tmp = ipcp_entry_create();
         if (tmp == NULL) {
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
 
@@ -328,28 +327,28 @@ static pid_t create_ipcp(char *         name,
         tmp->name = strdup(name);
         if (tmp->name  == NULL) {
                 ipcp_entry_destroy(tmp);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
 
         tmp->dif_name = NULL;
         tmp->type = ipcp_type;
 
-        pthread_rwlock_wrlock(&instance->reg_lock);
+        pthread_rwlock_wrlock(&irmd->reg_lock);
 
-        list_for_each(pos, &instance->ipcps) {
+        list_for_each(pos, &irmd->ipcps) {
                 struct ipcp_entry * e =
                         list_entry(pos, struct ipcp_entry, next);
                 if (e->type < ipcp_type)
                         break;
         }
 
-        list_add(&tmp->next, &instance->ipcps);
+        list_add(&tmp->next, &irmd->ipcps);
 
-        list_add(&api->next, &instance->spawned_apis);
+        list_add(&api->next, &irmd->spawned_apis);
 
-        pthread_rwlock_unlock(&instance->reg_lock);
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_unlock(&irmd->reg_lock);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
         LOG_INFO("Created IPCP %d.", api->api);
 
@@ -361,7 +360,7 @@ static void clear_spawned_api(pid_t api)
         struct list_head * pos = NULL;
         struct list_head * n   = NULL;
 
-        list_for_each_safe(pos, n, &(instance->spawned_apis)) {
+        list_for_each_safe(pos, n, &(irmd->spawned_apis)) {
                 struct spawned_api * a =
                         list_entry(pos, struct spawned_api, next);
 
@@ -377,10 +376,10 @@ static int destroy_ipcp(pid_t api)
         struct list_head * pos = NULL;
         struct list_head * n   = NULL;
 
-        pthread_rwlock_rdlock(&instance->state_lock);
-        pthread_rwlock_wrlock(&instance->reg_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
+        pthread_rwlock_wrlock(&irmd->reg_lock);
 
-        list_for_each_safe(pos, n, &(instance->ipcps)) {
+        list_for_each_safe(pos, n, &(irmd->ipcps)) {
                 struct ipcp_entry * tmp =
                         list_entry(pos, struct ipcp_entry, next);
 
@@ -395,8 +394,8 @@ static int destroy_ipcp(pid_t api)
                 }
         }
 
-        pthread_rwlock_unlock(&instance->reg_lock);
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_unlock(&irmd->reg_lock);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
         return 0;
 }
@@ -406,42 +405,42 @@ static int bootstrap_ipcp(pid_t              api,
 {
         struct ipcp_entry * entry = NULL;
 
-        pthread_rwlock_rdlock(&instance->state_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
 
-        if (instance->state != IRMD_RUNNING) {
-                pthread_rwlock_unlock(&instance->state_lock);
+        if (irmd->state != IRMD_RUNNING) {
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
 
-        pthread_rwlock_wrlock(&instance->reg_lock);
+        pthread_rwlock_wrlock(&irmd->reg_lock);
 
         entry = get_ipcp_entry_by_api(api);
         if (entry == NULL) {
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_ERR("No such IPCP.");
                 return -1;
         }
 
         entry->dif_name = strdup(conf->dif_name);
         if (entry->dif_name == NULL) {
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_ERR("Failed to strdup.");
                 return -1;
         }
 
         if (ipcp_bootstrap(entry->api, conf)) {
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_ERR("Could not bootstrap IPCP.");
                 free(entry->dif_name);
                 entry->dif_name = NULL;
                 return -1;
         }
 
-        pthread_rwlock_unlock(&instance->reg_lock);
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_unlock(&irmd->reg_lock);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
         LOG_INFO("Bootstrapped IPCP %d in DIF %s.",
                  entry->api, conf->dif_name);
@@ -454,27 +453,27 @@ static int enroll_ipcp(pid_t  api,
 {
         struct ipcp_entry * entry = NULL;
 
-        pthread_rwlock_rdlock(&instance->state_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
 
-        if (instance->state != IRMD_RUNNING) {
-                pthread_rwlock_unlock(&instance->state_lock);
+        if (irmd->state != IRMD_RUNNING) {
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
 
-        pthread_rwlock_rdlock(&instance->reg_lock);
+        pthread_rwlock_rdlock(&irmd->reg_lock);
 
         entry = get_ipcp_entry_by_api(api);
         if (entry == NULL) {
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_ERR("No such IPCP.");
                 return -1;
         }
 
         entry->dif_name = strdup(dif_name);
         if (entry->dif_name == NULL) {
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_ERR("Failed to strdup.");
                 return -1;
         }
@@ -482,14 +481,14 @@ static int enroll_ipcp(pid_t  api,
         if (ipcp_enroll(api, dif_name)) {
                 free(entry->dif_name);
                 entry->dif_name = NULL;
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_ERR("Could not enroll IPCP.");
                 return -1;
         }
 
-        pthread_rwlock_unlock(&instance->reg_lock);
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_unlock(&irmd->reg_lock);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
         LOG_INFO("Enrolled IPCP %d in DIF %s.",
                  entry->api, dif_name);
@@ -510,14 +509,14 @@ static int bind_name(char *   name,
         if (name == NULL || ap_name == NULL)
                 return -EINVAL;
 
-        pthread_rwlock_rdlock(&instance->state_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
 
-        if (instance->state != IRMD_RUNNING) {
-                pthread_rwlock_unlock(&instance->state_lock);
+        if (irmd->state != IRMD_RUNNING) {
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
 
-        pthread_rwlock_wrlock(&instance->reg_lock);
+        pthread_rwlock_wrlock(&irmd->reg_lock);
 
         if (opts & BIND_AP_AUTO) {
                 /* we need to duplicate argv */
@@ -530,17 +529,17 @@ static int bind_name(char *   name,
                 }
         }
 
-        if (registry_add_binding(&instance->registry,
+        if (registry_add_binding(&irmd->registry,
                                  strdup(name), strdup(apn),
                                  opts, argv_dup) < 0) {
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_ERR("Failed to register %s.", name);
                 return -1;
         }
 
-        pthread_rwlock_unlock(&instance->reg_lock);
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_unlock(&irmd->reg_lock);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
         LOG_INFO("Bound %s to registered name %s.", ap_name, name);
 
@@ -558,24 +557,24 @@ static int unbind_name(char *   name,
         if (!(opts & UNBIND_AP_HARD) && apn == NULL)
                 return -EINVAL;
 
-        pthread_rwlock_rdlock(&instance->state_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
 
-        if (instance->state != IRMD_RUNNING) {
-                pthread_rwlock_unlock(&instance->state_lock);
+        if (irmd->state != IRMD_RUNNING) {
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
 
-        pthread_rwlock_wrlock(&instance->reg_lock);
+        pthread_rwlock_wrlock(&irmd->reg_lock);
 
         if ((opts & UNBIND_AP_HARD) && apn == NULL) {
-                registry_deassign(&instance->registry, name);
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                registry_deassign(&irmd->registry, name);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_INFO("Removed all bindings of %s.", name);
         } else {
-                registry_del_binding(&instance->registry, name, apn);
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                registry_del_binding(&irmd->registry, name, apn);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_INFO("Removed binding from %s to %s.", apn, name);
         }
 
@@ -589,7 +588,7 @@ static ssize_t list_ipcps(char * name,
         ssize_t count = 0;
         int i = 0;
 
-        list_for_each(pos, &instance->ipcps) {
+        list_for_each(pos, &irmd->ipcps) {
                 struct ipcp_entry * tmp =
                         list_entry(pos, struct ipcp_entry, next);
 
@@ -603,7 +602,7 @@ static ssize_t list_ipcps(char * name,
                 return -1;
         }
 
-        list_for_each(pos, &instance->ipcps) {
+        list_for_each(pos, &irmd->ipcps) {
                 struct ipcp_entry * tmp =
                         list_entry(pos, struct ipcp_entry, next);
 
@@ -626,22 +625,22 @@ static int ap_reg(char *  name,
         if (name == NULL || difs == NULL || len == 0 || difs[0] == NULL)
                 return -EINVAL;
 
-        pthread_rwlock_rdlock(&instance->state_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
 
-        if (instance->state != IRMD_RUNNING) {
-                pthread_rwlock_unlock(&instance->state_lock);
+        if (irmd->state != IRMD_RUNNING) {
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
 
-        pthread_rwlock_wrlock(&instance->reg_lock);
+        pthread_rwlock_wrlock(&irmd->reg_lock);
 
-        if (list_empty(&instance->ipcps)) {
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+        if (list_empty(&irmd->ipcps)) {
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
 
-        list_for_each(pos, &instance->ipcps) {
+        list_for_each(pos, &irmd->ipcps) {
                 struct ipcp_entry * e =
                         list_entry(pos, struct ipcp_entry, next);
 
@@ -656,7 +655,7 @@ static int ap_reg(char *  name,
                                 LOG_ERR("Could not register %s in DIF %s.",
                                         name, e->dif_name);
                         } else {
-                                if(registry_add_name_to_dif(&instance->registry,
+                                if(registry_add_name_to_dif(&irmd->registry,
                                                             name,
                                                             e->dif_name,
                                                             e->type) < 0)
@@ -671,13 +670,13 @@ static int ap_reg(char *  name,
         }
 
         if (ret == 0) {
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
 
-        pthread_rwlock_unlock(&instance->reg_lock);
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_unlock(&irmd->reg_lock);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
         return ret;
 }
@@ -693,16 +692,16 @@ static int ap_unreg(char *  name,
         if (name == NULL || len == 0 || difs == NULL || difs[0] == NULL)
                 return -1;
 
-        pthread_rwlock_rdlock(&instance->state_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
 
-        if (instance->state != IRMD_RUNNING) {
-                pthread_rwlock_unlock(&instance->state_lock);
+        if (irmd->state != IRMD_RUNNING) {
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
 
-        pthread_rwlock_wrlock(&instance->reg_lock);
+        pthread_rwlock_wrlock(&irmd->reg_lock);
 
-        list_for_each(pos, &instance->ipcps) {
+        list_for_each(pos, &irmd->ipcps) {
                 struct ipcp_entry * e =
                         list_entry(pos, struct ipcp_entry, next);
 
@@ -718,7 +717,7 @@ static int ap_unreg(char *  name,
                                         name, e->dif_name);
                                 --ret;
                         } else {
-                                registry_del_name_from_dif(&instance->registry,
+                                registry_del_name_from_dif(&irmd->registry,
                                                            name,
                                                            e->dif_name);
                                 LOG_INFO("Unregistered %s from %s.",
@@ -727,44 +726,44 @@ static int ap_unreg(char *  name,
                 }
         }
 
-        pthread_rwlock_unlock(&instance->reg_lock);
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_unlock(&irmd->reg_lock);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
         return ret;
 }
 
-static struct port_map_entry * flow_accept(pid_t   api,
-                                           char *  srv_ap_name,
-                                           char ** dst_ae_name)
+static struct irm_flow * flow_accept(pid_t   api,
+                                     char *  srv_ap_name,
+                                     char ** dst_ae_name)
 {
-        struct port_map_entry * pme = NULL;
+        struct irm_flow * pme = NULL;
         struct reg_entry *      rne = NULL;
         struct reg_api *        rgi = NULL;
 
-        pthread_rwlock_rdlock(&instance->state_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
 
-        if (instance->state != IRMD_RUNNING) {
-                pthread_rwlock_unlock(&instance->state_lock);
+        if (irmd->state != IRMD_RUNNING) {
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return NULL;
         }
 
-        pthread_rwlock_wrlock(&instance->reg_lock);
+        pthread_rwlock_wrlock(&irmd->reg_lock);
 
-        rne = registry_get_entry_by_apn(&instance->registry, srv_ap_name);
+        rne = registry_get_entry_by_apn(&irmd->registry, srv_ap_name);
         if (rne == NULL) {
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_ERR("AP %s is unknown.", srv_ap_name);
                 return NULL;
         }
 
         if (!reg_entry_get_reg_api(rne, api)) {
-                rgi = registry_add_api_name(&instance->registry,
+                rgi = registry_add_api_name(&irmd->registry,
                                             api,
                                             rne->name);
                 if (rgi == NULL) {
-                        pthread_rwlock_unlock(&instance->reg_lock);
-                        pthread_rwlock_unlock(&instance->state_lock);
+                        pthread_rwlock_unlock(&irmd->reg_lock);
+                        pthread_rwlock_unlock(&irmd->state_lock);
                         LOG_ERR("Failed to register instance %d with %s.",
                                 api,srv_ap_name);
                         return NULL;
@@ -772,31 +771,31 @@ static struct port_map_entry * flow_accept(pid_t   api,
                 LOG_INFO("New instance (%d) of %s added.", api, srv_ap_name);
         }
 
-        pthread_rwlock_unlock(&instance->reg_lock);
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_unlock(&irmd->reg_lock);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
         reg_api_sleep(rgi);
 
-        pthread_rwlock_rdlock(&instance->state_lock);
-        pthread_rwlock_rdlock(&instance->reg_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
+        pthread_rwlock_rdlock(&irmd->reg_lock);
         pthread_mutex_lock(&rne->state_lock);
 
         if (rne->state != REG_NAME_FLOW_ARRIVED) {
                 pthread_mutex_unlock(&rne->state_lock);
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return NULL;
         }
 
         pthread_mutex_unlock(&rne->state_lock);
-        pthread_rwlock_unlock(&instance->reg_lock);
+        pthread_rwlock_unlock(&irmd->reg_lock);
 
-        pthread_rwlock_rdlock(&instance->flows_lock);
+        pthread_rwlock_rdlock(&irmd->flows_lock);
 
-        pme = get_port_map_entry_n(api);
+        pme = get_irm_flow_n(api);
         if (pme == NULL) {
-                pthread_rwlock_unlock(&instance->flows_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->flows_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_ERR("Port_id was not created yet.");
                 return NULL;
         }
@@ -804,8 +803,8 @@ static struct port_map_entry * flow_accept(pid_t   api,
         if (dst_ae_name != NULL)
                 *dst_ae_name = rne->req_ae_name;
 
-        pthread_rwlock_unlock(&instance->flows_lock);
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_unlock(&irmd->flows_lock);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
         return pme;
 }
@@ -814,53 +813,54 @@ static int flow_alloc_resp(pid_t n_api,
                            int   port_id,
                            int   response)
 {
-        struct port_map_entry * pme = NULL;
+        struct irm_flow * pme = NULL;
         struct reg_entry * rne      = NULL;
         int ret = -1;
 
-        pthread_rwlock_rdlock(&instance->state_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
 
-        if (instance->state != IRMD_RUNNING) {
-                pthread_rwlock_unlock(&instance->state_lock);
+        if (irmd->state != IRMD_RUNNING) {
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
 
-        pthread_rwlock_wrlock(&instance->reg_lock);
+        pthread_rwlock_wrlock(&irmd->reg_lock);
 
-        rne = registry_get_entry_by_api(&instance->registry, n_api);
+        rne = registry_get_entry_by_api(&irmd->registry, n_api);
         if (rne == NULL) {
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
 
         if (rne->state != REG_NAME_FLOW_ARRIVED) {
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_ERR("Process not listening for this name.");
                 return -1;
         }
 
         pthread_mutex_lock(&rne->state_lock);
 
-        registry_del_api(&instance->registry, n_api);
+        registry_del_api(&irmd->registry, n_api);
 
         pthread_mutex_unlock(&rne->state_lock);
 
-        pthread_rwlock_unlock(&instance->reg_lock);
+        pthread_rwlock_unlock(&irmd->reg_lock);
 
         if (!response) {
-                pthread_rwlock_wrlock(&instance->flows_lock);
+                pthread_rwlock_wrlock(&irmd->flows_lock);
 
-                pme = get_port_map_entry(port_id);
+                pme = get_irm_flow(port_id);
                 if (pme == NULL) {
-                        pthread_rwlock_unlock(&instance->flows_lock);
-                        pthread_rwlock_unlock(&instance->state_lock);
+                        pthread_rwlock_unlock(&irmd->flows_lock);
+                        pthread_rwlock_unlock(&irmd->state_lock);
                         return -1;
                 }
 
                 pme->state = FLOW_ALLOCATED;
-                pthread_rwlock_unlock(&instance->flows_lock);
+                pthread_cond_signal(&pme->state_cond);
+                pthread_rwlock_unlock(&irmd->flows_lock);
 
                 ret = ipcp_flow_alloc_resp(pme->n_1_api,
                                            port_id,
@@ -868,32 +868,32 @@ static int flow_alloc_resp(pid_t n_api,
                                            response);
         }
 
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
         return ret;
 }
 
-static struct port_map_entry * flow_alloc(pid_t  api,
-                                          char * dst_name,
-                                          char * src_ae_name,
-                                          struct qos_spec * qos)
+static struct irm_flow * flow_alloc(pid_t  api,
+                                    char * dst_name,
+                                    char * src_ae_name,
+                                    struct qos_spec * qos)
 {
-        struct port_map_entry * pme;
+        struct irm_flow * pme;
         pid_t ipcp;
 
         /* FIXME: Map qos_spec to qos_cube */
 
-        pthread_rwlock_rdlock(&instance->state_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
 
-        if (instance->state != IRMD_RUNNING) {
-                pthread_rwlock_unlock(&instance->state_lock);
+        if (irmd->state != IRMD_RUNNING) {
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return NULL;
         }
 
-        pme = port_map_entry_create();
+        pme = irm_flow_create();
         if (pme == NULL) {
-                pthread_rwlock_unlock(&instance->state_lock);
-                LOG_ERR("Failed to create port_map_entry.");
+                pthread_rwlock_unlock(&irmd->state_lock);
+                LOG_ERR("Failed to create irm_flow.");
                 return NULL;
         }
 
@@ -902,26 +902,26 @@ static struct port_map_entry * flow_alloc(pid_t  api,
         if (clock_gettime(CLOCK_MONOTONIC, &pme->t0) < 0)
                 LOG_WARN("Failed to set timestamp.");
 
-        pthread_rwlock_rdlock(&instance->reg_lock);
+        pthread_rwlock_rdlock(&irmd->reg_lock);
 
         ipcp = get_ipcp_by_dst_name(dst_name);
         if (ipcp == -1) {
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_INFO("Destination unreachable.");
                 return NULL;
         }
 
-        pthread_rwlock_unlock(&instance->reg_lock);
-        pthread_rwlock_wrlock(&instance->flows_lock);
+        pthread_rwlock_unlock(&irmd->reg_lock);
+        pthread_rwlock_wrlock(&irmd->flows_lock);
 
-        pme->port_id = bmp_allocate(instance->port_ids);
+        pme->port_id = bmp_allocate(irmd->port_ids);
         pme->n_1_api = ipcp;
 
-        list_add(&pme->next, &instance->port_map);
+        list_add(&pme->next, &irmd->irm_flows);
 
-        pthread_rwlock_unlock(&instance->flows_lock);
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_unlock(&irmd->flows_lock);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
         if (ipcp_flow_alloc(ipcp,
                             pme->port_id,
@@ -929,12 +929,12 @@ static struct port_map_entry * flow_alloc(pid_t  api,
                             dst_name,
                             src_ae_name,
                             QOS_CUBE_BE) < 0) {
-                pthread_rwlock_rdlock(&instance->state_lock);
-                pthread_rwlock_wrlock(&instance->flows_lock);
+                pthread_rwlock_rdlock(&irmd->state_lock);
+                pthread_rwlock_wrlock(&irmd->flows_lock);
                 list_del(&pme->next);
-                bmp_release(instance->port_ids, pme->port_id);
-                pthread_rwlock_unlock(&instance->flows_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                bmp_release(irmd->port_ids, pme->port_id);
+                pthread_rwlock_unlock(&irmd->flows_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 free(pme);
                 return NULL;
         }
@@ -944,75 +944,68 @@ static struct port_map_entry * flow_alloc(pid_t  api,
 
 static int flow_alloc_res(int port_id)
 {
-        struct port_map_entry * e;
+        struct irm_flow * e;
 
-        pthread_rwlock_rdlock(&instance->state_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
 
-        if (instance->state != IRMD_RUNNING) {
-                pthread_rwlock_unlock(&instance->state_lock);
+        if (irmd->state != IRMD_RUNNING) {
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
-        pthread_rwlock_rdlock(&instance->flows_lock);
+        pthread_rwlock_rdlock(&irmd->flows_lock);
 
-        e = get_port_map_entry(port_id);
+        e = get_irm_flow(port_id);
         if (e == NULL) {
                 LOG_ERR("Could not find port %d.", port_id);
-                pthread_rwlock_unlock(&instance->flows_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->flows_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
 
         if (e->state == FLOW_NULL) {
                 LOG_INFO("Port %d is deprecated.", port_id);
-                pthread_rwlock_unlock(&instance->flows_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->flows_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
 
         if (e->state == FLOW_ALLOCATED) {
-                pthread_rwlock_unlock(&instance->flows_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->flows_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return 0;
         }
 
-        pthread_rwlock_unlock(&instance->flows_lock);
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_unlock(&irmd->flows_lock);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
-        while (true) {
-                pthread_mutex_lock(&e->res_lock);
-                pthread_cleanup_push((void(*)(void *))pthread_mutex_unlock,
-                                     (void*) &e->res_lock);
+        pthread_mutex_lock(&e->state_lock);
+        pthread_cleanup_push((void(*)(void *))pthread_mutex_unlock,
+                             (void*) &e->state_lock);
 
-                pthread_cond_wait(&e->res_signal, &e->res_lock);
+        while (e->state == FLOW_PENDING)
+                pthread_cond_wait(&e->state_cond, &e->state_lock);
 
-                pthread_cleanup_pop(true);
+        pthread_cleanup_pop(true);
 
-                pthread_rwlock_rdlock(&instance->state_lock);
-                pthread_rwlock_wrlock(&instance->flows_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
+        pthread_rwlock_wrlock(&irmd->flows_lock);
+        pthread_mutex_lock(&e->state_lock);
 
-                e = get_port_map_entry(port_id);
-                if (e == NULL) {
-                        pthread_rwlock_unlock(&instance->flows_lock);
-                        pthread_rwlock_unlock(&instance->state_lock);
-                        return -1;
-                }
-                if (e->state == FLOW_ALLOCATED) {
-                        pthread_rwlock_unlock(&instance->flows_lock);
-                        pthread_rwlock_unlock(&instance->state_lock);
-                        return 0;
-                }
-                if (e->state == FLOW_NULL) {
-                        /* don't release the port_id, AP has to call dealloc */
-                        list_del(&e->next);
-                        pthread_rwlock_unlock(&instance->flows_lock);
-                        pthread_rwlock_unlock(&instance->state_lock);
-                        free(e);
-                        return -1;
+        if (e->state == FLOW_ALLOCATED) {
+                pthread_mutex_unlock(&e->state_lock);
+                pthread_rwlock_unlock(&irmd->flows_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
+                return 0;
+        }
 
-                }
-                /* still pending, spurious wake */
-                pthread_rwlock_unlock(&instance->flows_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+        if (e->state == FLOW_DESTROY) {
+                /* don't release the port_id, AP has to call dealloc */
+                e->state = FLOW_NULL;
+                pthread_cond_signal(&e->state_cond);
+                pthread_mutex_unlock(&e->state_lock);
+                pthread_rwlock_unlock(&irmd->flows_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
+                return -1;
         }
 
         return 0;
@@ -1023,16 +1016,16 @@ static int flow_dealloc(int port_id)
         pid_t n_1_api;
         int   ret = 0;
 
-        struct port_map_entry * e = NULL;
+        struct irm_flow * e = NULL;
 
-        pthread_rwlock_rdlock(&instance->state_lock);
-        pthread_rwlock_wrlock(&instance->flows_lock);
-        bmp_release(instance->port_ids, port_id);
+        pthread_rwlock_rdlock(&irmd->state_lock);
+        pthread_rwlock_wrlock(&irmd->flows_lock);
+        bmp_release(irmd->port_ids, port_id);
 
-        e = get_port_map_entry(port_id);
+        e = get_irm_flow(port_id);
         if (e == NULL) {
-                pthread_rwlock_unlock(&instance->flows_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->flows_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return 0;
         }
 
@@ -1040,11 +1033,11 @@ static int flow_dealloc(int port_id)
 
         list_del(&e->next);
 
-        pthread_rwlock_unlock(&instance->flows_lock);
+        pthread_rwlock_unlock(&irmd->flows_lock);
 
         ret = ipcp_flow_dealloc(n_1_api, port_id);
 
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
         free(e);
 
@@ -1083,21 +1076,21 @@ static pid_t auto_execute(char ** argv)
         exit(EXIT_FAILURE);
 }
 
-static struct port_map_entry * flow_req_arr(pid_t  api,
-                                            char * dst_name,
-                                            char * ae_name)
+static struct irm_flow * flow_req_arr(pid_t  api,
+                                      char * dst_name,
+                                      char * ae_name)
 {
         struct reg_entry *      rne = NULL;
-        struct port_map_entry * pme = NULL;
+        struct irm_flow * pme = NULL;
 
         bool acc_wait = true;
         enum reg_name_state state;
 
         struct spawned_api * c_api;
 
-        pme = port_map_entry_create();
+        pme = irm_flow_create();
         if (pme == NULL) {
-                LOG_ERR("Failed to create port_map_entry.");
+                LOG_ERR("Failed to create irm_flow.");
                 return NULL;
         }
 
@@ -1106,13 +1099,13 @@ static struct port_map_entry * flow_req_arr(pid_t  api,
         if (clock_gettime(CLOCK_MONOTONIC, &pme->t0) < 0)
                 LOG_WARN("Failed to set timestamp.");
 
-        pthread_rwlock_rdlock(&instance->state_lock);
-        pthread_rwlock_rdlock(&instance->reg_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
+        pthread_rwlock_rdlock(&irmd->reg_lock);
 
-        rne = registry_get_entry_by_name(&instance->registry, dst_name);
+        rne = registry_get_entry_by_name(&irmd->registry, dst_name);
         if (rne == NULL) {
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_ERR("Unknown name: %s.", dst_name);
                 free(pme);
                 return NULL;
@@ -1124,16 +1117,16 @@ static struct port_map_entry * flow_req_arr(pid_t  api,
 
         switch (state) {
         case REG_NAME_IDLE:
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_ERR("No AP's for %s.", dst_name);
                 free(pme);
                 return NULL;
         case REG_NAME_AUTO_ACCEPT:
                 c_api = malloc(sizeof(*c_api));
                 if (c_api == NULL) {
-                        pthread_rwlock_unlock(&instance->reg_lock);
-                        pthread_rwlock_unlock(&instance->state_lock);
+                        pthread_rwlock_unlock(&irmd->reg_lock);
+                        pthread_rwlock_unlock(&irmd->state_lock);
                         free(pme);
                         return NULL;
                 }
@@ -1147,55 +1140,60 @@ static struct port_map_entry * flow_req_arr(pid_t  api,
                         pthread_mutex_lock(&rne->state_lock);
                         rne->state = REG_NAME_AUTO_ACCEPT;
                         pthread_mutex_unlock(&rne->state_lock);
-                        pthread_rwlock_unlock(&instance->reg_lock);
-                        pthread_rwlock_unlock(&instance->state_lock);
+                        pthread_rwlock_unlock(&irmd->reg_lock);
+                        pthread_rwlock_unlock(&irmd->state_lock);
                         free(pme);
                         free(c_api);
                         return NULL;
                 }
 
-                list_add(&c_api->next, &instance->spawned_apis);
+                list_add(&c_api->next, &irmd->spawned_apis);
 
-                pthread_rwlock_unlock(&instance->reg_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
 
                 pthread_mutex_lock(&rne->state_lock);
                 pthread_cleanup_push((void(*)(void *)) pthread_mutex_unlock,
                                      (void *) &rne->state_lock);
 
                 while (rne->state == REG_NAME_AUTO_EXEC)
-                        pthread_cond_wait(&rne->acc_signal,
-                                          &rne->state_lock);
+                        pthread_cond_wait(&rne->state_cond, &rne->state_lock);
 
                 pthread_cleanup_pop(true);
 
-                pthread_rwlock_rdlock(&instance->reg_lock);
-
+                pthread_rwlock_rdlock(&irmd->reg_lock);
+                pthread_mutex_lock(&rne->state_lock);
+                if (rne->state == REG_NAME_DESTROY) {
+                        pthread_mutex_unlock(&rne->state_lock);
+                        pthread_rwlock_unlock(&irmd->reg_lock);
+                        return NULL;
+                }
+                pthread_mutex_unlock(&rne->state_lock);
         case REG_NAME_FLOW_ACCEPT:
                 pme->n_api = reg_entry_resolve_api(rne);
                 if (pme->n_api == -1) {
-                        pthread_rwlock_unlock(&instance->reg_lock);
-                        pthread_rwlock_unlock(&instance->state_lock);
+                        pthread_rwlock_unlock(&irmd->reg_lock);
+                        pthread_rwlock_unlock(&irmd->state_lock);
                         LOG_ERR("Invalid api returned.");
                         return NULL;
                 }
 
                 break;
         default:
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 LOG_ERR("IRMd in wrong state.");
                 free(pme);
                 return NULL;
         }
 
-        pthread_rwlock_unlock(&instance->reg_lock);
+        pthread_rwlock_unlock(&irmd->reg_lock);
 
-        pthread_rwlock_wrlock(&instance->flows_lock);
-        pme->port_id = bmp_allocate(instance->port_ids);
+        pthread_rwlock_wrlock(&irmd->flows_lock);
+        pme->port_id = bmp_allocate(irmd->port_ids);
 
-        list_add(&pme->next, &instance->port_map);
+        list_add(&pme->next, &irmd->irm_flows);
 
-        pthread_rwlock_unlock(&instance->flows_lock);
+        pthread_rwlock_unlock(&irmd->flows_lock);
 
         pthread_mutex_lock(&rne->state_lock);
 
@@ -1207,15 +1205,15 @@ static struct port_map_entry * flow_req_arr(pid_t  api,
 
         pthread_mutex_unlock(&rne->state_lock);
 
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
         while (acc_wait) {
-                pthread_rwlock_rdlock(&instance->state_lock);
+                pthread_rwlock_rdlock(&irmd->state_lock);
                 pthread_mutex_lock(&rne->state_lock);
                 acc_wait = (rne->state == REG_NAME_FLOW_ARRIVED &&
-                            instance->state == IRMD_RUNNING);
+                            irmd->state == IRMD_RUNNING);
                 pthread_mutex_unlock(&rne->state_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
         }
 
         return pme;
@@ -1224,19 +1222,19 @@ static struct port_map_entry * flow_req_arr(pid_t  api,
 static int flow_alloc_reply(int port_id,
                             int response)
 {
-        struct port_map_entry * e;
+        struct irm_flow * e;
 
-        pthread_rwlock_rdlock(&instance->state_lock);
-        pthread_rwlock_rdlock(&instance->flows_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
+        pthread_rwlock_rdlock(&irmd->flows_lock);
 
-        e = get_port_map_entry(port_id);
+        e = get_irm_flow(port_id);
         if (e == NULL) {
-                pthread_rwlock_unlock(&instance->flows_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->flows_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return -1;
         }
 
-        pthread_mutex_lock(&e->res_lock);
+        pthread_mutex_lock(&e->state_lock);
 
         if (!response)
                 e->state = FLOW_ALLOCATED;
@@ -1244,35 +1242,35 @@ static int flow_alloc_reply(int port_id,
         else
                 e->state = FLOW_NULL;
 
-        if (pthread_cond_signal(&e->res_signal))
+        if (pthread_cond_signal(&e->state_cond))
                 LOG_ERR("Failed to send signal.");
 
-        pthread_mutex_unlock(&e->res_lock);
+        pthread_mutex_unlock(&e->state_lock);
 
-        pthread_rwlock_unlock(&instance->flows_lock);
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_unlock(&irmd->flows_lock);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
         return 0;
 }
 
 static int flow_dealloc_ipcp(int port_id)
 {
-        struct port_map_entry * e = NULL;
+        struct irm_flow * e = NULL;
 
-        pthread_rwlock_rdlock(&instance->state_lock);
-        pthread_rwlock_wrlock(&instance->flows_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
+        pthread_rwlock_wrlock(&irmd->flows_lock);
 
-        e = get_port_map_entry(port_id);
+        e = get_irm_flow(port_id);
         if (e == NULL) {
-                pthread_rwlock_unlock(&instance->flows_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->flows_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
                 return 0;
         }
 
         list_del(&e->next);
 
-        pthread_rwlock_unlock(&instance->flows_lock);
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_unlock(&irmd->flows_lock);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
         free(e);
 
@@ -1284,17 +1282,17 @@ static void irm_destroy()
         struct list_head * h;
         struct list_head * t;
 
-        pthread_rwlock_rdlock(&instance->state_lock);
+        pthread_rwlock_rdlock(&irmd->state_lock);
 
-        if (instance->state != IRMD_NULL)
+        if (irmd->state != IRMD_NULL)
                 LOG_WARN("Unsafe destroy.");
 
-        if (instance->threadpool != NULL)
-                free(instance->threadpool);
+        if (irmd->threadpool != NULL)
+                free(irmd->threadpool);
 
-        pthread_rwlock_wrlock(&instance->reg_lock);
+        pthread_rwlock_wrlock(&irmd->reg_lock);
         /* clear the lists */
-        list_for_each_safe(h, t, &instance->ipcps) {
+        list_for_each_safe(h, t, &irmd->ipcps) {
                 struct ipcp_entry * e = list_entry(h, struct ipcp_entry, next);
                 list_del(&e->next);
                 ipcp_destroy(e->api);
@@ -1302,52 +1300,49 @@ static void irm_destroy()
                 ipcp_entry_destroy(e);
         }
 
-        list_for_each_safe(h, t, &instance->registry) {
-                struct reg_entry * e = list_entry(h, struct reg_entry, next);
-                list_del(&e->next);
-                reg_entry_destroy(e);
-        }
+        registry_destroy(&irmd->registry);
 
-        list_for_each_safe(h, t, &instance->spawned_apis) {
+        list_for_each_safe(h, t, &irmd->spawned_apis) {
                 struct spawned_api * api =
                         list_entry(h, struct spawned_api, next);
                 int status;
                 if (kill(api->api, SIGTERM))
-                        LOG_DBGF("Could not send kill signal to %d.", api->api);
+                        LOG_DBG("Could not send kill signal to %d.", api->api);
                 else if (waitpid(api->api, &status, 0) < 0)
-                        LOG_DBGF("Error waiting for %d to exit.", api->api);
+                        LOG_DBG("Error waiting for %d to exit.", api->api);
                 list_del(&api->next);
                 free(api);
         }
 
-        pthread_rwlock_unlock(&instance->reg_lock);
+        pthread_rwlock_unlock(&irmd->reg_lock);
 
-        pthread_rwlock_wrlock(&instance->flows_lock);
+        pthread_rwlock_wrlock(&irmd->flows_lock);
 
-        list_for_each_safe(h, t, &instance->port_map) {
-                struct port_map_entry * e = list_entry(h,
-                                                       struct port_map_entry,
-                                                       next);
+        list_for_each_safe(h, t, &irmd->irm_flows) {
+                struct irm_flow * e = list_entry(h, struct irm_flow, next);
                 list_del(&e->next);
-                port_map_entry_destroy(e);
+                irm_flow_destroy(e);
         }
 
-        if (instance->port_ids != NULL)
-                bmp_destroy(instance->port_ids);
+        if (irmd->port_ids != NULL)
+                bmp_destroy(irmd->port_ids);
+
+        pthread_rwlock_unlock(&irmd->flows_lock);
 
-        pthread_rwlock_unlock(&instance->flows_lock);
+        if (irmd->dum != NULL)
+                shm_du_map_destroy(irmd->dum);
 
-        if (instance->dum != NULL)
-                shm_du_map_destroy(instance->dum);
+        if (irmd->lf != NULL)
+                lockfile_destroy(irmd->lf);
 
-        if (instance->lf != NULL)
-                lockfile_destroy(instance->lf);
+        close(irmd->sockfd);
 
-        close(instance->sockfd);
+        pthread_rwlock_unlock(&irmd->state_lock);
 
-        pthread_rwlock_unlock(&instance->state_lock);
+        pthread_rwlock_destroy(&irmd->reg_lock);
+        pthread_rwlock_destroy(&irmd->state_lock);
 
-        free(instance);
+        free(irmd);
 }
 
 void irmd_sig_handler(int sig, siginfo_t * info, void * c)
@@ -1358,20 +1353,20 @@ void irmd_sig_handler(int sig, siginfo_t * info, void * c)
         case SIGINT:
         case SIGTERM:
         case SIGHUP:
-                pthread_rwlock_wrlock(&instance->state_lock);
+                pthread_rwlock_wrlock(&irmd->state_lock);
 
-                instance->state = IRMD_NULL;
+                irmd->state = IRMD_NULL;
 
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
 
-                if (instance->threadpool != NULL) {
+                if (irmd->threadpool != NULL) {
                         for (i = 0; i < IRMD_THREADPOOL_SIZE; i++)
-                                pthread_cancel(instance->threadpool[i]);
+                                pthread_cancel(irmd->threadpool[i]);
 
                 }
 
-                pthread_cancel(instance->shm_sanitize);
-                pthread_cancel(instance->cleanup_flows);
+                pthread_cancel(irmd->shm_sanitize);
+                pthread_cancel(irmd->cleanup_flows);
                 break;
         case SIGPIPE:
                 LOG_DBG("Ignored SIGPIPE.");
@@ -1386,9 +1381,6 @@ void * irm_flow_cleaner()
         struct list_head * pos = NULL;
         struct list_head * n   = NULL;
 
-        struct list_head * pos2 = NULL;
-        struct list_head * n2   = NULL;
-
         struct timespec timeout = {IRMD_CLEANUP_TIMER / BILLION,
                                    IRMD_CLEANUP_TIMER % BILLION};
         int status;
@@ -1398,37 +1390,37 @@ void * irm_flow_cleaner()
                         LOG_WARN("Failed to get time.");
                 /* cleanup stale PENDING flows */
 
-                pthread_rwlock_rdlock(&instance->state_lock);
+                pthread_rwlock_rdlock(&irmd->state_lock);
 
-                if (instance->state == IRMD_NULL) {
-                        pthread_rwlock_unlock(&instance->state_lock);
+                if (irmd->state == IRMD_NULL) {
+                        pthread_rwlock_unlock(&irmd->state_lock);
                         return (void *) 0;
                 }
 
-                pthread_rwlock_wrlock(&instance->flows_lock);
+                pthread_rwlock_wrlock(&irmd->flows_lock);
 
-                list_for_each_safe(pos, n, &(instance->port_map)) {
-                        struct port_map_entry * e =
-                                list_entry(pos, struct port_map_entry, next);
+                list_for_each_safe(pos, n, &(irmd->irm_flows)) {
+                        struct irm_flow * e =
+                                list_entry(pos, struct irm_flow, next);
 
-                        pthread_mutex_lock(&e->res_lock);
+                        pthread_mutex_lock(&e->state_lock);
 
                         if (e->state == FLOW_PENDING &&
                             ts_diff_ms(&e->t0, &now) > IRMD_FLOW_TIMEOUT) {
                                 LOG_INFO("Pending port_id %d timed out.",
                                          e->port_id);
                                 e->state = FLOW_NULL;
-                                pthread_cond_signal(&e->res_signal);
-                                pthread_mutex_unlock(&e->res_lock);
+                                pthread_cond_signal(&e->state_cond);
+                                pthread_mutex_unlock(&e->state_lock);
                                 continue;
                         }
 
-                        pthread_mutex_unlock(&e->res_lock);
+                        pthread_mutex_unlock(&e->state_lock);
 
                         if (kill(e->n_api, 0) < 0) {
                                 struct shm_ap_rbuff * n_rb =
                                         shm_ap_rbuff_open(e->n_api);
-                                bmp_release(instance->port_ids, e->port_id);
+                                bmp_release(irmd->port_ids, e->port_id);
 
                                 list_del(&e->next);
                                 LOG_INFO("Process %d gone, %d deallocated.",
@@ -1436,7 +1428,7 @@ void * irm_flow_cleaner()
                                 ipcp_flow_dealloc(e->n_1_api, e->port_id);
                                 if (n_rb != NULL)
                                         shm_ap_rbuff_destroy(n_rb);
-                                port_map_entry_destroy(e);
+                                irm_flow_destroy(e);
                         }
                         if (kill(e->n_1_api, 0) < 0) {
                                 struct shm_ap_rbuff * n_1_rb =
@@ -1446,34 +1438,16 @@ void * irm_flow_cleaner()
                                         e->n_1_api, e->port_id);
                                 if (n_1_rb != NULL)
                                         shm_ap_rbuff_destroy(n_1_rb);
-                                port_map_entry_destroy(e);
+                                irm_flow_destroy(e);
                         }
                 }
 
-                pthread_rwlock_unlock(&instance->flows_lock);
-                pthread_rwlock_wrlock(&instance->reg_lock);
-
-                list_for_each_safe(pos, n, &instance->registry) {
-                        struct reg_entry * e =
-                                list_entry(pos, struct reg_entry, next);
-
-                        list_for_each_safe(pos2, n2, &e->reg_apis) {
-                                struct reg_api * r =
-                                        list_entry(pos2,
-                                                   struct reg_api,
-                                                   next);
-                                if (kill(r->api, 0) < 0) {
-                                        LOG_INFO("Process %d gone, "
-                                                 "registry binding removed.",
-                                                 r->api);
-                                        registry_del_api(
-                                                &instance->registry,
-                                                r->api);
-                                }
-                        }
-                }
+                pthread_rwlock_unlock(&irmd->flows_lock);
+                pthread_rwlock_wrlock(&irmd->reg_lock);
+
+                registry_sanitize_apis(&irmd->registry);
 
-                list_for_each_safe(pos, n, &instance->spawned_apis) {
+                list_for_each_safe(pos, n, &irmd->spawned_apis) {
                         struct spawned_api * api =
                                 list_entry(pos, struct spawned_api, next);
                         waitpid(api->api, &status, WNOHANG);
@@ -1487,8 +1461,8 @@ void * irm_flow_cleaner()
                         }
                 }
 
-                pthread_rwlock_unlock(&instance->reg_lock);
-                pthread_rwlock_unlock(&instance->state_lock);
+                pthread_rwlock_unlock(&irmd->reg_lock);
+                pthread_rwlock_unlock(&irmd->state_lock);
 
                 nanosleep(&timeout, NULL);
         }
@@ -1509,12 +1483,12 @@ void * mainloop()
                 ssize_t count;
                 buffer_t buffer;
                 irm_msg_t ret_msg = IRM_MSG__INIT;
-                struct port_map_entry * e = NULL;
+                struct irm_flow * e = NULL;
                 pid_t * apis = NULL;
 
                 ret_msg.code = IRM_MSG_CODE__IRM_REPLY;
 
-                cli_sockfd = accept(instance->sockfd, 0, 0);
+                cli_sockfd = accept(irmd->sockfd, 0, 0);
                 if (cli_sockfd < 0) {
                         LOG_ERR("Cannot accept new connection.");
                         continue;
@@ -1703,17 +1677,17 @@ static struct irm * irm_create()
 {
         struct stat st = {0};
 
-        instance = malloc(sizeof(*instance));
-        if (instance == NULL)
+        irmd = malloc(sizeof(*irmd));
+        if (irmd == NULL)
                 return NULL;
 
-        instance->state = IRMD_NULL;
+        irmd->state = IRMD_NULL;
 
         if (access("/dev/shm/" LOCKFILE_NAME, F_OK) != -1) {
                 struct lockfile * lf = lockfile_open();
                 if (lf == NULL) {
                         LOG_ERR("Failed to open existing lockfile.");
-                        free(instance);
+                        free(irmd);
                         return NULL;
                 }
 
@@ -1726,42 +1700,42 @@ static struct irm * irm_create()
                         LOG_INFO("IRMd already running (%d), exiting.",
                                  lockfile_owner(lf));
                         lockfile_close(lf);
-                        free(instance);
+                        free(irmd);
                         return NULL;
                 }
         }
 
-        if (pthread_rwlock_init(&instance->state_lock, NULL)) {
+        if (pthread_rwlock_init(&irmd->state_lock, NULL)) {
                 LOG_ERR("Failed to initialize rwlock.");
-                free(instance);
+                free(irmd);
                 return NULL;
         }
 
-        if (pthread_rwlock_init(&instance->reg_lock, NULL)) {
+        if (pthread_rwlock_init(&irmd->reg_lock, NULL)) {
                 LOG_ERR("Failed to initialize rwlock.");
-                free(instance);
+                free(irmd);
                 return NULL;
         }
 
-        if (pthread_rwlock_init(&instance->flows_lock, NULL)) {
+        if (pthread_rwlock_init(&irmd->flows_lock, NULL)) {
                 LOG_ERR("Failed to initialize rwlock.");
-                free(instance);
+                free(irmd);
                 return NULL;
         }
 
-        INIT_LIST_HEAD(&instance->ipcps);
-        INIT_LIST_HEAD(&instance->spawned_apis);
-        INIT_LIST_HEAD(&instance->registry);
-        INIT_LIST_HEAD(&instance->port_map);
+        INIT_LIST_HEAD(&irmd->ipcps);
+        INIT_LIST_HEAD(&irmd->spawned_apis);
+        INIT_LIST_HEAD(&irmd->registry);
+        INIT_LIST_HEAD(&irmd->irm_flows);
 
-        instance->port_ids = bmp_create(IRMD_MAX_FLOWS, 0);
-        if (instance->port_ids == NULL) {
+        irmd->port_ids = bmp_create(IRMD_MAX_FLOWS, 0);
+        if (irmd->port_ids == NULL) {
                 irm_destroy();
                 return NULL;
         }
 
-        instance->threadpool = malloc(sizeof(pthread_t) * IRMD_THREADPOOL_SIZE);
-        if (instance->threadpool == NULL) {
+        irmd->threadpool = malloc(sizeof(pthread_t) * IRMD_THREADPOOL_SIZE);
+        if (irmd->threadpool == NULL) {
                 irm_destroy();
                 return NULL;
         }
@@ -1774,8 +1748,8 @@ static struct irm * irm_create()
                 }
         }
 
-        instance->sockfd = server_socket_open(IRM_SOCK_PATH);
-        if (instance->sockfd < 0) {
+        irmd->sockfd = server_socket_open(IRM_SOCK_PATH);
+        if (irmd->sockfd < 0) {
                 irm_destroy();
                 return NULL;
         }
@@ -1786,19 +1760,19 @@ static struct irm * irm_create()
                 return NULL;
         }
 
-        if ((instance->lf = lockfile_create()) == NULL) {
+        if ((irmd->lf = lockfile_create()) == NULL) {
                 irm_destroy();
                 return NULL;
         }
 
-        if ((instance->dum = shm_du_map_create()) == NULL) {
+        if ((irmd->dum = shm_du_map_create()) == NULL) {
                 irm_destroy();
                 return NULL;
         }
 
-        instance->state = IRMD_RUNNING;
+        irmd->state = IRMD_RUNNING;
 
-        return instance;
+        return irmd;
 }
 
 static void usage()
@@ -1892,25 +1866,25 @@ int main(int argc, char ** argv)
         if (sigaction(SIGPIPE, &sig_act, NULL) < 0)
                 exit(EXIT_FAILURE);
 
-        instance = irm_create();
-        if (instance == NULL) {
+        irmd = irm_create();
+        if (irmd == NULL) {
                 close_logfile();
                 exit(EXIT_FAILURE);
         }
 
         for (t = 0; t < IRMD_THREADPOOL_SIZE; ++t)
-                pthread_create(&instance->threadpool[t], NULL, mainloop, NULL);
+                pthread_create(&irmd->threadpool[t], NULL, mainloop, NULL);
 
-        pthread_create(&instance->cleanup_flows, NULL, irm_flow_cleaner, NULL);
-        pthread_create(&instance->shm_sanitize, NULL,
-                       shm_du_map_sanitize, instance->dum);
+        pthread_create(&irmd->cleanup_flows, NULL, irm_flow_cleaner, NULL);
+        pthread_create(&irmd->shm_sanitize, NULL,
+                       shm_du_map_sanitize, irmd->dum);
 
         /* wait for (all of them) to return */
         for (t = 0; t < IRMD_THREADPOOL_SIZE; ++t)
-                pthread_join(instance->threadpool[t], NULL);
+                pthread_join(irmd->threadpool[t], NULL);
 
-        pthread_join(instance->shm_sanitize, NULL);
-        pthread_join(instance->cleanup_flows, NULL);
+        pthread_join(irmd->shm_sanitize, NULL);
+        pthread_join(irmd->cleanup_flows, NULL);
 
         irm_destroy();