diff options
author | dimitri staessens <dimitri.staessens@intec.ugent.be> | 2017-01-20 12:59:17 +0100 |
---|---|---|
committer | dimitri staessens <dimitri.staessens@intec.ugent.be> | 2017-01-21 09:55:10 +0100 |
commit | 9c92dd66d5e7fab3a3e243abbad9a20b29891fee (patch) | |
tree | 819ed39b4cb7b1dd2fb82f62f516bb9fd24e8432 /include/ouroboros/rqueue.h | |
parent | 82d947a8321737108f545a25f91d7d50d10e831d (diff) | |
download | ouroboros-9c92dd66d5e7fab3a3e243abbad9a20b29891fee.tar.gz ouroboros-9c92dd66d5e7fab3a3e243abbad9a20b29891fee.zip |
lib: Add new version of Resource Information Base
The new RIB is implemented as a tree with doubly linked nodes (parents
keep a link to each child, each child keeps a link to its parent). An
index is kept in a btree using CRC32 hashes of the path name in the
RIB. Nodes keep an SHA3-256 hash value that is unique for the entire
subtree. This allows quick checks to see if two RIB subtrees are in
sync. The event system for the RIB is based on the event system for
flows (fqueue), but implemented completely in dynamic memory using
linked lists. An initial test is performed for the RIB. This PR does
not modify existing code to use the new RIB.
Diffstat (limited to 'include/ouroboros/rqueue.h')
-rw-r--r-- | include/ouroboros/rqueue.h | 72 |
1 files changed, 72 insertions, 0 deletions
diff --git a/include/ouroboros/rqueue.h b/include/ouroboros/rqueue.h new file mode 100644 index 00000000..7bfbfa8f --- /dev/null +++ b/include/ouroboros/rqueue.h @@ -0,0 +1,72 @@ +/* + * Ouroboros - Copyright (C) 2016 - 2017 + * + * RIB event queues + * + * Dimitri Staessens <dimitri.staessens@intec.ugent.be> + * Sander Vrijders <sander.vrijders@intec.ugent.be> + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public License + * version 2.1 as published by the Free Software Foundation. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA + */ + +#ifndef OUROBOROS_RQUEUE_H +#define OUROBOROS_RQUEUE_H + +#include <stdbool.h> +#include <stdint.h> +#include <time.h> + +#define RO_READ 0x00000001 +#define RO_MODIFY 0x00000002 +#define RO_CREATE 0x00000004 +#define RO_DELETE 0x00000008 +#define RO_START 0x00000010 +#define RO_STOP 0x00000020 + +#define RO_NO_OPS 0x00000000 +#define RO_ALL_OPS 0xFFFFFFFF + +struct ro_set; + +struct rqueue; + +typedef struct ro_set ro_set_t; +typedef struct rqueue rqueue_t; + +ro_set_t * ro_set_create(void); + +void ro_set_destroy(ro_set_t * set); + +rqueue_t * rqueue_create(void); + +int rqueue_destroy(struct rqueue * rq); + +int ro_set_zero(ro_set_t * set); + +int ro_set_add(ro_set_t * set, + const char * path, + int32_t flags); + +int ro_set_del(ro_set_t * set, + const char * path); + +int32_t rqueue_next(rqueue_t * rq, + char * path); + +int rib_event_wait(ro_set_t * set, + rqueue_t * rq, + const struct timespec * timeout); + +#endif /* OUROBOROS_RQUEUE_H */ |