diff options
Diffstat (limited to 'include/ouroboros/cdap.h')
| -rw-r--r-- | include/ouroboros/cdap.h | 182 |
1 files changed, 55 insertions, 127 deletions
diff --git a/include/ouroboros/cdap.h b/include/ouroboros/cdap.h index 72788ad6..da669feb 100644 --- a/include/ouroboros/cdap.h +++ b/include/ouroboros/cdap.h @@ -4,6 +4,7 @@ * The Common Distributed Application Protocol * * Sander Vrijders <sander.vrijders@intec.ugent.be> + * Dimitri Staessens <dimitri.staessens@intec.ugent.be> * * 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 @@ -23,148 +24,75 @@ #ifndef OUROBOROS_CDAP_H #define OUROBOROS_CDAP_H +#include <ouroboros/common.h> + #include <stdbool.h> +#include <stdint.h> +#include <unistd.h> + +#define F_SYNC 0x0001 struct cdap; +/* Callback functions that work on the application's RIB */ struct cdap_ops { - /* Sender related callbacks */ - int (* handle_connect_r)(int fd, - int invoke_id, - int result); - int (* handle_release_r)(int fd, - int invoke_id, - int result); - int (* handle_read_r)(int fd, - int invoke_id, - int result, - char * reason, - char * obj_val, - bool complete); - int (* handle_cancelread_r)(int fd, - int invoke_id, - int result); - int (* handle_write_r)(int fd, - int invoke_id, - int result, - char * reason, - char * obj_val); - int (* handle_create_r)(int fd, - int invoke_id, - int result); - int (* handle_delete_r)(int fd, - int invoke_id, - int result); - int (* handle_start_r)(int fd, - int invoke_id, - int result); - int (* handle_stop_r)(int fd, - int invoke_id, - int result); + int (* cdap_reply)(struct cdap * instance, + int invoke_id, + int result, + buffer_t * val, + size_t len); + + int (* cdap_read)(struct cdap * instance, + char * name); + int (* cdap_write)(struct cdap * instance, + char * name, + buffer_t * val, + size_t len, + uint32_t flags); - /* Receiver related callbacks */ - int (* handle_connect)(int fd, - int invoke_id, - rina_name_t src, - rina_name_t dst, - char * auth_mech, - char * auth_val); - int (* handle_release)(int fd, - int invoke_id); - int (* handle_cancelread)(int fd, - int invoke_id); - int (* handle_write)(int fd, - int invoke_id, - char * obj_name, - char * obj_val); - int (* handle_create)(int fd, - int invoke_id, - char * obj_class, - char * obj_name, - char * obj_val); - int (* handle_delete)(int fd, - int invoke_id, - char * obj_name); - int (* handle_start)(int fd, - int invoke_id, - char * obj_name, - char * obj_val); - int (* handle_stop)(int fd, - int invoke_id, - char * obj_name, - char * obj_val); + int (* cdap_create)(struct cdap * instance, + char * name, + buffer_t val); + int (* cdap_delete)(struct cdap * instance, + char * name, + buffer_t val); + + int (* cdap_start)(struct cdap * instance, + char * name); + int (* cdap_stop)(struct cdap * instance, + char * name); }; -struct cdap * cdap_create(struct cdap_ops ops, - int fd); +/* Assumes flow is blocking */ +struct cdap * cdap_create(struct cdap_ops * ops, + int fd); int cdap_destroy(struct cdap * instance); -/* Sender related functions */ -int cdap_send_connect(struct cdap * instance, - int invoke_id, - rina_name_t src, - rina_name_t dst, - char * auth_mech, - char * auth_val); -int cdap_send_release(struct cdap * instance, - int invoke_id); +/* Returns a positive invoke-id on success to be used in the callback */ int cdap_send_read(struct cdap * instance, - int invoke_id, - char * obj_name); -int cdap_send_cancelread(struct cdap * instance, - int invoke_id, - char * obj_name); + char * name); int cdap_send_write(struct cdap * instance, - int invoke_id, - char * obj_name, - char * obj_val); + char * name, + buffer_t * val, + size_t len, + uint32_t flags); + int cdap_send_create(struct cdap * instance, - int invoke_id, - char * obj_name, - char * obj_val); + char * name, + buffer_t val); int cdap_send_delete(struct cdap * instance, - int invoke_id, - char * obj_name); + char * name, + buffer_t val); + int cdap_send_start(struct cdap * instance, - int invoke_id, - char * obj_name, - char * obj_val); + char * name); int cdap_send_stop(struct cdap * instance, - int invoke_id, - char * obj_name, - char * obj_val); + char * name); -/* Receiver related functions */ -int cdap_send_connect_r(struct cdap * instance, - int invoke_id, - int result); -int cdap_send_release_r(struct cdap * instance, - int invoke_id, - int result); -int cdap_send_read_r(struct cdap * instance, - int invoke_id, - int result, - char * reason, - char * obj_val, - bool complete); -int cdap_send_cancelread_r(struct cdap * instance, - int invoke_id, - int result); -int cdap_send_write_r(struct cdap * instance, - int invoke_id, - int result, - char * obj_name, - char * obj_val); -int cdap_send_create_r(struct cdap * instance, - int invoke_id, - int result); -int cdap_send_delete_r(struct cdap * instance, - int invoke_id, - int result); -int cdap_send_start_r(struct cdap * instance, - int invoke_id, - int result); -int cdap_send_stop_r(struct cdap * instance, - int invoke_id, - int result); +/* Can only be called following a callback function */ +int cdap_send_reply(struct cdap * instance, + int invoke_id, + int result, + buffer_t * val, + size_t len); #endif |