X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=include%2Fafb-req-itf.h;h=a975503dbb61f32bc7ea8d021e0044889fcb73cf;hb=b5cf93aed93e7f331eb645c8afe5317fb67ee50e;hp=357ffd7b3a72db6de0ecd2f5d5547c1e836d2262;hpb=68a8eaafe5f43480f29308bfd2ec12ad54da43f1;p=src%2Fapp-framework-binder.git diff --git a/include/afb-req-itf.h b/include/afb-req-itf.h index 357ffd7b..a975503d 100644 --- a/include/afb-req-itf.h +++ b/include/afb-req-itf.h @@ -26,26 +26,30 @@ struct afb_arg { }; struct afb_req_itf { - struct json_object *(*json)(void *data); - struct afb_arg (*get)(void *data, const char *name); - void (*success)(void *data, struct json_object *obj, const char *info); - void (*fail)(void *data, const char *status, const char *info); - const char *(*raw)(void *data, size_t *size); - void (*send)(void *data, char *buffer, size_t size); - int (*session_create)(void *data); - int (*session_check)(void *data, int refresh); - void (*session_close)(void *data); + struct json_object *(*json)(void *closure); + struct afb_arg (*get)(void *closure, const char *name); + + void (*success)(void *closure, struct json_object *obj, const char *info); + void (*fail)(void *closure, const char *status, const char *info); + + const char *(*raw)(void *closure, size_t *size); + void (*send)(void *closure, const char *buffer, size_t size); + + void *(*context_get)(void *closure); + void (*context_set)(void *closure, void *value, void (*free_value)(void*)); + + void (*addref)(void *closure); + void (*unref)(void *closure); }; struct afb_req { const struct afb_req_itf *itf; - void *data; - void **context; + void *closure; }; static inline struct afb_arg afb_req_get(struct afb_req req, const char *name) { - return req.itf->get(req.data, name); + return req.itf->get(req.closure, name); } static inline const char *afb_req_value(struct afb_req req, const char *name) @@ -60,48 +64,72 @@ static inline const char *afb_req_path(struct afb_req req, const char *name) static inline struct json_object *afb_req_json(struct afb_req req) { - return req.itf->json(req.data); + return req.itf->json(req.closure); } static inline void afb_req_success(struct afb_req req, struct json_object *obj, const char *info) { - req.itf->success(req.data, obj, info); + req.itf->success(req.closure, obj, info); } static inline void afb_req_fail(struct afb_req req, const char *status, const char *info) { - req.itf->fail(req.data, status, info); + req.itf->fail(req.closure, status, info); } static inline const char *afb_req_raw(struct afb_req req, size_t *size) { - return req.itf->raw(req.data, size); + return req.itf->raw(req.closure, size); } -static inline void afb_req_send(struct afb_req req, char *buffer, size_t size) +static inline void afb_req_send(struct afb_req req, const char *buffer, size_t size) { - req.itf->send(req.data, buffer, size); + req.itf->send(req.closure, buffer, size); } -static inline int afb_req_session_create(struct afb_req req) +static inline void *afb_req_context_get(struct afb_req req) { - int result = req.itf->session_create(req.data); - if (!result) - afb_req_fail(req, "fail", "Can't create the session"); - return result; + return req.itf->context_get(req.closure); +} + +static inline void afb_req_context_set(struct afb_req req, void *value, void (*free_value)(void*)) +{ + return req.itf->context_set(req.closure, value, free_value); +} + +static inline void afb_req_context_clear(struct afb_req req) +{ + afb_req_context_set(req, NULL, NULL); } -static inline int afb_req_session_check(struct afb_req req, int refresh) +static inline void afb_req_addref(struct afb_req req) { - int result = req.itf->session_check(req.data, refresh); - if (!result) - afb_req_fail(req, "fail", "Token chek failed for the session"); + return req.itf->addref(req.closure); +} + +static inline void afb_req_unref(struct afb_req req) +{ + return req.itf->unref(req.closure); +} + +#include + +static inline struct afb_req *afb_req_store(struct afb_req req) +{ + struct afb_req *result = malloc(sizeof *result); + if (result != NULL) { + *result = req; + afb_req_addref(req); + } return result; } -static inline void afb_req_session_close(struct afb_req req) +static inline struct afb_req afb_req_unstore(struct afb_req *req) { - req.itf->session_close(req.data); + struct afb_req result = *req; + free(req); + afb_req_unref(result); + return result; } #if !defined(_GNU_SOURCE) @@ -109,7 +137,6 @@ static inline void afb_req_session_close(struct afb_req req) #endif #include -#include #include static inline void afb_req_fail_v(struct afb_req req, const char *status, const char *info, va_list args)