summaryrefslogtreecommitdiff
path: root/src/lib/rib.c
diff options
context:
space:
mode:
authordimitri staessens <[email protected]>2017-01-29 16:29:51 +0100
committerdimitri staessens <[email protected]>2017-01-29 16:29:51 +0100
commitd6321a22f8c957523e7acbf6c57f5730b55ac378 (patch)
treeeaf66f732f52d84a5daf3f6736b489c3a755a620 /src/lib/rib.c
parentbbee20a43f23f4f62cb1ab1f2ab0645581cfbaac (diff)
downloadouroboros-d6321a22f8c957523e7acbf6c57f5730b55ac378.tar.gz
ouroboros-d6321a22f8c957523e7acbf6c57f5730b55ac378.zip
lib: Add function to get children of node in RIB
Returns the names of the nodes (not the full paths). The function allocates memory to the children pointer that should be freed.
Diffstat (limited to 'src/lib/rib.c')
-rw-r--r--src/lib/rib.c67
1 files changed, 67 insertions, 0 deletions
diff --git a/src/lib/rib.c b/src/lib/rib.c
index 4d1ae884..6b27ad27 100644
--- a/src/lib/rib.c
+++ b/src/lib/rib.c
@@ -95,6 +95,7 @@ struct rnode {
struct rnode * parent;
+ size_t chlen;
struct list_head children;
struct list_head subs;
@@ -248,6 +249,8 @@ static int rnode_add_child(struct rnode * node,
c->node = child;
list_add(&c->next, &node->children);
+ ++node->chlen;
+
return 0;
}
@@ -265,6 +268,7 @@ static void rnode_remove_child(struct rnode * node,
if (c->node == child) {
list_del(&c->next);
free(c);
+ --node->chlen;
return;
}
}
@@ -321,6 +325,8 @@ static struct rnode * rnode_create(struct rnode * parent,
node->parent = parent;
+ node->chlen = 0;
+
branch_hash(node);
rnode_throw_event(node, RO_CREATE);
@@ -606,6 +612,13 @@ ssize_t rib_read(const char * path,
return -EFBIG;
}
+ if (node->data == NULL) {
+ pthread_rwlock_unlock(&rib.lock);
+ return 0;
+ }
+
+ assert(node->len > 0);
+
memcpy(data, node->data, node->len);
rlen = node->len;
@@ -681,6 +694,60 @@ bool rib_has(const char * path)
return node != NULL;
}
+ssize_t rib_children(const char * path,
+ char *** children)
+{
+ struct list_head * p;
+
+ struct rnode * node;
+
+ ssize_t i = 0;
+
+ assert(path);
+ assert(children);
+
+ pthread_rwlock_rdlock(&rib.lock);
+
+ node = find_rnode_by_path(path);
+ if (node == NULL) {
+ pthread_rwlock_unlock(&rib.lock);
+ return -EPERM;
+ }
+
+ if (node->chlen == 0) {
+ pthread_rwlock_unlock(&rib.lock);
+ *children = NULL;
+ return 0;
+ }
+
+ *children = malloc(sizeof(**children) * node->chlen);
+ if (*children == NULL) {
+ pthread_rwlock_unlock(&rib.lock);
+ return -ENOMEM;
+ }
+
+ list_for_each(p, &node->children) {
+ struct child * c = list_entry(p, struct child, next);
+ (*children)[i] = strdup(c->node->name);
+ if ((*children)[i] == NULL) {
+ ssize_t j;
+ pthread_rwlock_unlock(&rib.lock);
+ for (j = 0; j < i; ++j)
+ free((*children)[j]);
+ free(*children);
+ return -ENOMEM;
+ }
+ ++i;
+ }
+
+ assert(i > 0);
+ assert((size_t) i == node->chlen);
+
+ pthread_rwlock_unlock(&rib.lock);
+
+ return i;
+}
+
static struct rib_sub * rib_get_sub(uint32_t sid)
{
struct list_head * p;