From 5d0fb985db60c0807efc76f05edc8d4d3e5ffa95 Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Thu, 5 Jan 2017 01:55:27 -0800 Subject: SUB protocol implemented (uses sorted linked list for topics). --- src/core/list.c | 32 ++++++++++++++++++++++++++++++++ 1 file changed, 32 insertions(+) (limited to 'src/core/list.c') diff --git a/src/core/list.c b/src/core/list.c index ca200415..b1adf2cd 100644 --- a/src/core/list.c +++ b/src/core/list.c @@ -83,6 +83,38 @@ nni_list_prepend(nni_list *list, void *item) } +void +nni_list_insert_before(nni_list *list, void *item, void *before) +{ + nni_list_node *node = NODE(list, item); + nni_list_node *where = NODE(list, before); + + if ((node->ln_next != NULL) || (node->ln_prev != NULL)) { + nni_panic("prepending node already on a list or not inited"); + } + node->ln_next = where; + node->ln_prev = where->ln_prev; + node->ln_next->ln_prev = node; + node->ln_prev->ln_next = node; +} + + +void +nni_list_insert_after(nni_list *list, void *item, void *after) +{ + nni_list_node *node = NODE(list, item); + nni_list_node *where = NODE(list, after); + + if ((node->ln_next != NULL) || (node->ln_prev != NULL)) { + nni_panic("prepending node already on a list or not inited"); + } + node->ln_prev = where; + node->ln_next = where->ln_next; + node->ln_next->ln_prev = node; + node->ln_prev->ln_next = node; +} + + void * nni_list_next(const nni_list *list, void *item) { -- cgit v1.2.3-70-g09d2