diff options
Diffstat (limited to 'src/ipcpd/normal/ro.h')
-rw-r--r-- | src/ipcpd/normal/ro.h | 77 |
1 files changed, 77 insertions, 0 deletions
diff --git a/src/ipcpd/normal/ro.h b/src/ipcpd/normal/ro.h new file mode 100644 index 00000000..0dfa7e8a --- /dev/null +++ b/src/ipcpd/normal/ro.h @@ -0,0 +1,77 @@ +/* + * Ouroboros - Copyright (C) 2016 + * + * RIB objects + * + * Sander Vrijders <[email protected]> + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version. + * + * This program 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 General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + */ + +#ifndef OUROBOROS_IPCP_RO_H +#define OUROBOROS_IPCP_RO_H + +enum ro_recv_set { + ALL_MEMBERS = 0, + NEIGHBORS +}; + +struct ro_props { + bool enrol_sync; + enum ro_recv_set recv_set; + struct timespec * expiry; +}; + +/* All RIB-objects have a pathname, separated by a slash. */ +/* Takes ownership of the data */ +int ro_create(const char * name, + uint8_t * data, + size_t len); + +int ro_delete(const char * name); + +/* Reader takes ownership of data */ +ssize_t ro_read(const char * name, + uint8_t ** data); + +int ro_write(const char * name, + uint8_t * data, + size_t len); + +/* Takes ownership of the props */ +int ro_props(const char * name, + struct ro_props * props); + +/* Sync changes with other members in the DIF */ +int ro_sync(const char * name); + +/* Callback passes ownership of the data */ +struct ro_sub_ops { + int (* ro_created)(const char * name, + uint8_t * data, + size_t len); + int (* ro_updated)(const char * name, + uint8_t * data, + size_t len); + int (* ro_deleted)(const char * name); +}; + +/* Returns subscriber-id */ +int ro_subscribe(const char * name, + struct ro_sub_ops * ops); + +int ro_unsubscribe(int sid); + +#endif |