summaryrefslogtreecommitdiff
path: root/src/ipcpd
diff options
context:
space:
mode:
authorDimitri Staessens <dimitri.staessens@ugent.be>2017-11-07 07:41:26 +0100
committerSander Vrijders <sander.vrijders@ugent.be>2017-11-07 11:34:18 +0100
commitc59053040ce927f2926e5a569b19bdd129c354a7 (patch)
tree43636bdb49626cfb2e4281ff02fcdcabc43eeef0 /src/ipcpd
parentec67efa3059f1fb879e4b6def0b947b9288144a7 (diff)
downloadouroboros-c59053040ce927f2926e5a569b19bdd129c354a7.tar.gz
ouroboros-c59053040ce927f2926e5a569b19bdd129c354a7.zip
ipcpd: List adjacencies in link-state database
The lsdb will now list management and data transfer adjacencies. Signed-off-by: Dimitri Staessens <dimitri.staessens@ugent.be> Signed-off-by: Sander Vrijders <sander.vrijders@ugent.be>
Diffstat (limited to 'src/ipcpd')
-rw-r--r--src/ipcpd/normal/pol/link_state.c31
1 files changed, 27 insertions, 4 deletions
diff --git a/src/ipcpd/normal/pol/link_state.c b/src/ipcpd/normal/pol/link_state.c
index 9c41dba3..3979328c 100644
--- a/src/ipcpd/normal/pol/link_state.c
+++ b/src/ipcpd/normal/pol/link_state.c
@@ -97,6 +97,7 @@ typedef int (* rtable_fn_t)(struct graph * graph,
struct {
struct list_head nbs;
+ size_t nbs_len;
fset_t * mgmt_set;
struct list_head db;
@@ -156,7 +157,7 @@ static int lsdb_read(const char * path,
pthread_rwlock_rdlock(&ls.db_lock);
- if (ls.db_len == 0) {
+ if (ls.db_len + ls.nbs_len == 0) {
pthread_rwlock_unlock(&ls.db_lock);
return -EPERM;
}
@@ -184,17 +185,35 @@ static int lsdb_readdir(char *** buf)
pthread_rwlock_rdlock(&ls.db_lock);
- if (ls.db_len == 0) {
+ if (ls.db_len + ls.nbs_len == 0) {
pthread_rwlock_unlock(&ls.db_lock);
return 0;
}
- *buf = malloc(sizeof(**buf) * ls.db_len);
+ *buf = malloc(sizeof(**buf) * (ls.db_len + ls.nbs_len));
if (*buf == NULL) {
pthread_rwlock_unlock(&ls.db_lock);
return -ENOMEM;
}
+ list_for_each(p, &ls.nbs) {
+ struct nb * nb = list_entry(p, struct nb, next);
+ char * str = (nb->type == NB_DT ? "dt." : "mgmt.");
+ sprintf(entry, "%s%" PRIu64, str, nb->addr);
+ (*buf)[idx] = malloc(strlen(entry) + 1);
+ if ((*buf)[idx] == NULL) {
+ while (--idx >= 0)
+ free(*buf[idx]);
+ free(buf);
+ pthread_rwlock_unlock(&ls.db_lock);
+ return -ENOMEM;
+ }
+
+ strcpy((*buf)[idx], entry);
+
+ idx++;
+ }
+
list_for_each(p, &ls.db) {
struct adjacency * a = list_entry(p, struct adjacency, next);
sprintf(entry, "%" PRIu64 ".%" PRIu64, a->src, a->dst);
@@ -261,6 +280,8 @@ static int lsdb_add_nb(uint64_t addr,
list_add_tail(&nb->next, p);
+ ++ls.nbs_len;
+
log_dbg("Type %s neighbor %" PRIu64 " added.",
nb->type == NB_DT ? "dt" : "mgmt", addr);
@@ -281,6 +302,7 @@ static int lsdb_del_nb(uint64_t addr,
struct nb * nb = list_entry(p, struct nb, next);
if (nb->addr == addr && nb->fd == fd) {
list_del(&nb->next);
+ --ls.nbs_len;
pthread_rwlock_unlock(&ls.db_lock);
log_dbg("Type %s neighbor %" PRIu64 " deleted.",
nb->type == NB_DT ? "dt" : "mgmt", addr);
@@ -772,7 +794,8 @@ int link_state_init(enum pol_routing pr)
if (pthread_create(&ls.listener, NULL, ls_conn_handle, NULL))
goto fail_pthread_create_listener;
- ls.db_len = 0;
+ ls.db_len = 0;
+ ls.nbs_len = 0;
rib_reg(LSDB, &r_ops);