X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fafb-api-so.c;h=4bb6087f717066356575b1a8aa334fac9dec3faf;hb=98a5bca16007a7c4740c4326ef83768d034aed3e;hp=39a6e9b196784d1ee0c573319ab60f046032a262;hpb=7059e59cddc1c81321639875636e88895bc14309;p=src%2Fapp-framework-binder.git diff --git a/src/afb-api-so.c b/src/afb-api-so.c index 39a6e9b1..4bb6087f 100644 --- a/src/afb-api-so.c +++ b/src/afb-api-so.c @@ -38,6 +38,7 @@ #include "afb-apis.h" #include "afb-api-so.h" #include "afb-sig-handler.h" +#include "afb-thread.h" #include "afb-evt.h" #include "afb-svc.h" #include "verbose.h" @@ -64,23 +65,28 @@ static const char binding_service_event_function_v1[] = "afbBindingV1ServiceEven static int api_timeout = 15; -static struct afb_event afb_api_so_event_make(struct api_so_desc *desc, const char *name); -static int afb_api_so_event_broadcast(struct api_so_desc *desc, const char *name, struct json_object *object); -static void afb_api_so_vverbose(struct api_so_desc *desc, int level, const char *file, int line, const char *fmt, va_list args); +static struct afb_event afb_api_so_event_make_cb(void *closure, const char *name); +static int afb_api_so_event_broadcast_cb(void *closure, const char *name, struct json_object *object); +static void afb_api_so_vverbose_cb(void *closure, int level, const char *file, int line, const char *fmt, va_list args); +static int afb_api_so_rootdir_get_fd(void *closure); +static int afb_api_so_rootdir_open_locale(void *closure, const char *filename, int flags, const char *locale); static const struct afb_daemon_itf daemon_itf = { - .event_broadcast = (void*)afb_api_so_event_broadcast, - .get_event_loop = (void*)afb_common_get_event_loop, - .get_user_bus = (void*)afb_common_get_user_bus, - .get_system_bus = (void*)afb_common_get_system_bus, - .vverbose = (void*)afb_api_so_vverbose, - .event_make = (void*)afb_api_so_event_make + .event_broadcast = afb_api_so_event_broadcast_cb, + .get_event_loop = afb_common_get_event_loop, + .get_user_bus = afb_common_get_user_bus, + .get_system_bus = afb_common_get_system_bus, + .vverbose = afb_api_so_vverbose_cb, + .event_make = afb_api_so_event_make_cb, + .rootdir_get_fd = afb_api_so_rootdir_get_fd, + .rootdir_open_locale = afb_api_so_rootdir_open_locale }; -static struct afb_event afb_api_so_event_make(struct api_so_desc *desc, const char *name) +static struct afb_event afb_api_so_event_make_cb(void *closure, const char *name) { size_t length; char *event; + struct api_so_desc *desc = closure; /* makes the event name */ assert(desc->binding != NULL); @@ -94,10 +100,11 @@ static struct afb_event afb_api_so_event_make(struct api_so_desc *desc, const ch return afb_evt_create_event(event); } -static int afb_api_so_event_broadcast(struct api_so_desc *desc, const char *name, struct json_object *object) +static int afb_api_so_event_broadcast_cb(void *closure, const char *name, struct json_object *object) { size_t length; char *event; + struct api_so_desc *desc = closure; /* makes the event name */ assert(desc->binding != NULL); @@ -110,9 +117,10 @@ static int afb_api_so_event_broadcast(struct api_so_desc *desc, const char *name return afb_evt_broadcast(event, object); } -static void afb_api_so_vverbose(struct api_so_desc *desc, int level, const char *file, int line, const char *fmt, va_list args) +static void afb_api_so_vverbose_cb(void *closure, int level, const char *file, int line, const char *fmt, va_list args) { char *p; + struct api_so_desc *desc = closure; if (vasprintf(&p, fmt, args) < 0) vverbose(level, file, line, fmt, args); @@ -122,37 +130,37 @@ static void afb_api_so_vverbose(struct api_so_desc *desc, int level, const char } } -static void monitored_call(int signum, struct monitoring *data) +static int afb_api_so_rootdir_get_fd(void *closure) { - if (signum != 0) - afb_req_fail_f(data->req, "aborted", "signal %s(%d) caught", strsignal(signum), signum); - else - data->action(data->req); + return afb_common_rootdir_get_fd(); } -static void call_check(struct afb_req req, struct afb_context *context, const struct afb_verb_desc_v1 *verb) +static int afb_api_so_rootdir_open_locale(void *closure, const char *filename, int flags, const char *locale) { - struct monitoring data; + return afb_common_rootdir_open_locale(filename, flags, locale); +} +static int call_check(struct afb_req req, struct afb_context *context, const struct afb_verb_desc_v1 *verb) +{ int stag = (int)verb->session; if ((stag & (AFB_SESSION_CREATE|AFB_SESSION_CLOSE|AFB_SESSION_RENEW|AFB_SESSION_CHECK|AFB_SESSION_LOA_EQ)) != 0) { if (!afb_context_check(context)) { afb_context_close(context); afb_req_fail(req, "failed", "invalid token's identity"); - return; - } + return 0; + } } if ((stag & AFB_SESSION_CREATE) != 0) { if (afb_context_check_loa(context, 1)) { afb_req_fail(req, "failed", "invalid creation state"); - return; + return 0; } afb_context_change_loa(context, 1); afb_context_refresh(context); } - + if ((stag & (AFB_SESSION_CREATE | AFB_SESSION_RENEW)) != 0) afb_context_refresh(context); @@ -165,7 +173,7 @@ static void call_check(struct afb_req req, struct afb_context *context, const st int loa = (stag >> AFB_SESSION_LOA_SHIFT) & AFB_SESSION_LOA_MASK; if (!afb_context_check_loa(context, loa)) { afb_req_fail(req, "failed", "invalid LOA"); - return; + return 0; } } @@ -173,33 +181,39 @@ static void call_check(struct afb_req req, struct afb_context *context, const st int loa = (stag >> AFB_SESSION_LOA_SHIFT) & AFB_SESSION_LOA_MASK; if (afb_context_check_loa(context, loa + 1)) { afb_req_fail(req, "failed", "invalid LOA"); - return; + return 0; } } - - data.req = req; - data.action = verb->callback; - afb_sig_monitor((void*)monitored_call, &data, api_timeout); + return 1; } -static void call(struct api_so_desc *desc, struct afb_req req, struct afb_context *context, const char *verb, size_t lenverb) +static void call_cb(void *closure, struct afb_req req, struct afb_context *context, const char *strverb, size_t lenverb) { - const struct afb_verb_desc_v1 *v; - - v = desc->binding->v1.verbs; - while (v->name && (strncasecmp(v->name, verb, lenverb) || v->name[lenverb])) - v++; - if (v->name) - call_check(req, context, v); - else - afb_req_fail_f(req, "unknown-verb", "verb %.*s unknown within api %s", (int)lenverb, verb, desc->binding->v1.prefix); + const struct afb_verb_desc_v1 *verb; + struct api_so_desc *desc = closure; + + verb = desc->binding->v1.verbs; + while (verb->name && (strncasecmp(verb->name, strverb, lenverb) || verb->name[lenverb])) + verb++; + if (!verb->name) + afb_req_fail_f(req, "unknown-verb", "verb %.*s unknown within api %s", (int)lenverb, strverb, desc->binding->v1.prefix); + else if (call_check(req, context, verb)) { + if (0) + /* not threaded */ + afb_sig_req_timeout(req, verb->callback, api_timeout); + else + /* threaded */ + afb_thread_call(req, verb->callback, api_timeout, desc); + } } -static int service_start(struct api_so_desc *desc, int share_session, int onneed) +static int service_start_cb(void *closure, int share_session, int onneed) { int (*init)(struct afb_service service); void (*onevent)(const char *event, struct json_object *object); + struct api_so_desc *desc = closure; + /* check state */ if (desc->service != NULL) { /* not an error when onneed */ @@ -246,6 +260,8 @@ int afb_api_so_add_binding(const char *path) void *handle; struct api_so_desc *desc; struct afb_binding *(*register_function) (const struct afb_binding_interface *interface); + struct afb_verb_desc_v1 fake_verb; + struct afb_binding fake_binding; // This is a loadable library let's check if it's a binding rc = 0; @@ -278,6 +294,14 @@ int afb_api_so_add_binding(const char *path) desc->interface.daemon.itf = &daemon_itf; desc->interface.daemon.closure = desc; + /* for log purpose, a fake binding is needed here */ + desc->binding = &fake_binding; + fake_binding.type = AFB_BINDING_VERSION_1; + fake_binding.v1.info = path; + fake_binding.v1.prefix = path; + fake_binding.v1.verbs = &fake_verb; + fake_verb.name = NULL; + /* init the binding */ NOTICE("binding [%s] calling registering function %s", path, binding_register_function_v1); desc->binding = register_function(&desc->interface); @@ -312,8 +336,8 @@ int afb_api_so_add_binding(const char *path) desc->apilength = strlen(desc->binding->v1.prefix); if (afb_apis_add(desc->binding->v1.prefix, (struct afb_api){ .closure = desc, - .call = (void*)call, - .service_start = (void*)service_start }) < 0) { + .call = call_cb, + .service_start = service_start_cb }) < 0) { ERROR("binding [%s] can't be registered...", path); goto error3; }