X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fafb-hook.c;h=6afcd2fb68c53616913631ba73b46e1281a3dc47;hb=524ce4c40da3b25630dffdd80c5aca99364a3569;hp=efd2e6525892a5283c17e4291eccd3ab8818c837;hpb=3580f1a46e5d1a4d4baab7db790418d6bc35b679;p=src%2Fapp-framework-binder.git diff --git a/src/afb-hook.c b/src/afb-hook.c index efd2e652..6afcd2fb 100644 --- a/src/afb-hook.c +++ b/src/afb-hook.c @@ -35,6 +35,7 @@ #include "afb-cred.h" #include "afb-xreq.h" #include "afb-ditf.h" +#include "afb-svc.h" #include "verbose.h" /** @@ -63,6 +64,18 @@ struct afb_hook_ditf { void *closure; /**< closure for callbacks */ }; +/** + * Definition of a hook for svc + */ +struct afb_hook_svc { + struct afb_hook_svc *next; /**< next hook */ + unsigned refcount; /**< reference count */ + char *api; /**< api hooked or NULL for any */ + unsigned flags; /**< hook flags */ + struct afb_hook_svc_itf *itf; /**< interface of hook */ + void *closure; /**< closure for callbacks */ +}; + /* synchronisation across threads */ static pthread_rwlock_t rwlock = PTHREAD_RWLOCK_INITIALIZER; @@ -72,6 +85,9 @@ static struct afb_hook_xreq *list_of_xreq_hooks = NULL; /* list of hooks for ditf */ static struct afb_hook_ditf *list_of_ditf_hooks = NULL; +/* list of hooks for svc */ +static struct afb_hook_svc *list_of_svc_hooks = NULL; + /****************************************************************************** * section: default callbacks for tracing requests *****************************************************************************/ @@ -99,8 +115,9 @@ static void hook_xreq_begin_default_cb(void * closure, const struct afb_xreq *xr if (!xreq->cred) _hook_xreq_(xreq, "BEGIN"); else - _hook_xreq_(xreq, "BEGIN uid=%d gid=%d pid=%d label=%s id=%s", + _hook_xreq_(xreq, "BEGIN uid=%d=%s gid=%d pid=%d label=%s id=%s", (int)xreq->cred->uid, + xreq->cred->user, (int)xreq->cred->gid, (int)xreq->cred->pid, xreq->cred->label?:"(null)", @@ -133,16 +150,6 @@ static void hook_xreq_fail_default_cb(void * closure, const struct afb_xreq *xre _hook_xreq_(xreq, "fail(%s, %s)", status, info); } -static void hook_xreq_raw_default_cb(void * closure, const struct afb_xreq *xreq, const char *buffer, size_t size) -{ - _hook_xreq_(xreq, "raw() -> %.*s", (int)size, buffer); -} - -static void hook_xreq_send_default_cb(void * closure, const struct afb_xreq *xreq, const char *buffer, size_t size) -{ - _hook_xreq_(xreq, "send(%.*s)", (int)size, buffer); -} - static void hook_xreq_context_get_default_cb(void * closure, const struct afb_xreq *xreq, void *value) { _hook_xreq_(xreq, "context_get() -> %p", value); @@ -203,6 +210,24 @@ static void hook_xreq_subcallsync_result_default_cb(void * closure, const struct _hook_xreq_(xreq, " ...subcallsync... -> %d: %s", status, json_object_to_json_string(result)); } +static void hook_xreq_vverbose_default_cb(void * closure, const struct afb_xreq *xreq, int level, const char *file, int line, const char *func, const char *fmt, va_list args) +{ + int len; + char *msg; + va_list ap; + + va_copy(ap, args); + len = vasprintf(&msg, fmt, ap); + va_end(ap); + + if (len < 0) + _hook_xreq_(xreq, "vverbose(%d, %s, %d, %s) -> %s ? ? ?", level, file, line, func, fmt); + else { + _hook_xreq_(xreq, "vverbose(%d, %s, %d, %s) -> %s", level, file, line, func, msg); + free(msg); + } +} + static struct afb_hook_xreq_itf hook_xreq_default_itf = { .hook_xreq_begin = hook_xreq_begin_default_cb, .hook_xreq_end = hook_xreq_end_default_cb, @@ -210,8 +235,6 @@ static struct afb_hook_xreq_itf hook_xreq_default_itf = { .hook_xreq_get = hook_xreq_get_default_cb, .hook_xreq_success = hook_xreq_success_default_cb, .hook_xreq_fail = hook_xreq_fail_default_cb, - .hook_xreq_raw = hook_xreq_raw_default_cb, - .hook_xreq_send = hook_xreq_send_default_cb, .hook_xreq_context_get = hook_xreq_context_get_default_cb, .hook_xreq_context_set = hook_xreq_context_set_default_cb, .hook_xreq_addref = hook_xreq_addref_default_cb, @@ -224,6 +247,7 @@ static struct afb_hook_xreq_itf hook_xreq_default_itf = { .hook_xreq_subcall_result = hook_xreq_subcall_result_default_cb, .hook_xreq_subcallsync = hook_xreq_subcallsync_default_cb, .hook_xreq_subcallsync_result = hook_xreq_subcallsync_result_default_cb, + .hook_xreq_vverbose = hook_xreq_vverbose_default_cb }; /****************************************************************************** @@ -279,17 +303,6 @@ void afb_hook_xreq_fail(const struct afb_xreq *xreq, const char *status, const c _HOOK_XREQ_(fail, xreq, status, info); } -const char *afb_hook_xreq_raw(const struct afb_xreq *xreq, const char *buffer, size_t size) -{ - _HOOK_XREQ_(raw, xreq, buffer, size); - return buffer; -} - -void afb_hook_xreq_send(const struct afb_xreq *xreq, const char *buffer, size_t size) -{ - _HOOK_XREQ_(send, xreq, buffer, size); -} - void *afb_hook_xreq_context_get(const struct afb_xreq *xreq, void *value) { _HOOK_XREQ_(context_get, xreq, value); @@ -355,8 +368,13 @@ int afb_hook_xreq_subcallsync_result(const struct afb_xreq *xreq, int status, st return status; } +void afb_hook_xreq_vverbose(const struct afb_xreq *xreq, int level, const char *file, int line, const char *func, const char *fmt, va_list args) +{ + _HOOK_XREQ_(vverbose, xreq, level, file ?: "?", line, func ?: "?", fmt, args); +} + /****************************************************************************** - * section: + * section: hooking xreqs *****************************************************************************/ void afb_hook_init_xreq(struct afb_xreq *xreq) @@ -583,7 +601,7 @@ static struct afb_hook_ditf_itf hook_ditf_default_itf = { }; /****************************************************************************** - * section: hooks for tracing requests + * section: hooks for tracing daemon interface (ditf) *****************************************************************************/ #define _HOOK_DITF_(what,...) \ @@ -659,7 +677,7 @@ int afb_hook_ditf_queue_job(const struct afb_ditf *ditf, void (*callback)(int si } /****************************************************************************** - * section: + * section: hooking ditf *****************************************************************************/ int afb_hook_flags_ditf(const char *api) @@ -744,3 +762,222 @@ void afb_hook_unref_ditf(struct afb_hook_ditf *hook) } } +/****************************************************************************** + * section: default callbacks for tracing service interface (svc) + *****************************************************************************/ + +static void _hook_svc_(const struct afb_svc *svc, const char *format, ...) +{ + int len; + char *buffer; + va_list ap; + + va_start(ap, format); + len = vasprintf(&buffer, format, ap); + va_end(ap); + + if (len < 0) + NOTICE("hook svc-%s allocation error for %s", svc->api, format); + else { + NOTICE("hook svc-%s %s", svc->api, buffer); + free(buffer); + } +} + +static void hook_svc_start_before_default_cb(void *closure, const struct afb_svc *svc) +{ + _hook_svc_(svc, "start.before"); +} + +static void hook_svc_start_after_default_cb(void *closure, const struct afb_svc *svc, int status) +{ + _hook_svc_(svc, "start.after -> %d", status); +} + +static void hook_svc_on_event_before_default_cb(void *closure, const struct afb_svc *svc, const char *event, int eventid, struct json_object *object) +{ + _hook_svc_(svc, "on_event.before(%s, %d, %s)", event, eventid, json_object_to_json_string(object)); +} + +static void hook_svc_on_event_after_default_cb(void *closure, const struct afb_svc *svc, const char *event, int eventid, struct json_object *object) +{ + _hook_svc_(svc, "on_event.after(%s, %d, %s)", event, eventid, json_object_to_json_string(object)); +} + +static void hook_svc_call_default_cb(void *closure, const struct afb_svc *svc, const char *api, const char *verb, struct json_object *args) +{ + _hook_svc_(svc, "call(%s/%s, %s) ...", api, verb, json_object_to_json_string(args)); +} + +static void hook_svc_call_result_default_cb(void *closure, const struct afb_svc *svc, int status, struct json_object *result) +{ + _hook_svc_(svc, " ...call... -> %d: %s", status, json_object_to_json_string(result)); +} + +static void hook_svc_callsync_default_cb(void *closure, const struct afb_svc *svc, const char *api, const char *verb, struct json_object *args) +{ + _hook_svc_(svc, "callsync(%s/%s, %s) ...", api, verb, json_object_to_json_string(args)); +} + +static void hook_svc_callsync_result_default_cb(void *closure, const struct afb_svc *svc, int status, struct json_object *result) +{ + _hook_svc_(svc, " ...callsync... -> %d: %s", status, json_object_to_json_string(result)); +} + +static struct afb_hook_svc_itf hook_svc_default_itf = { + .hook_svc_start_before = hook_svc_start_before_default_cb, + .hook_svc_start_after = hook_svc_start_after_default_cb, + .hook_svc_on_event_before = hook_svc_on_event_before_default_cb, + .hook_svc_on_event_after = hook_svc_on_event_after_default_cb, + .hook_svc_call = hook_svc_call_default_cb, + .hook_svc_call_result = hook_svc_call_result_default_cb, + .hook_svc_callsync = hook_svc_callsync_default_cb, + .hook_svc_callsync_result = hook_svc_callsync_result_default_cb +}; + +/****************************************************************************** + * section: hooks for tracing service interface (svc) + *****************************************************************************/ + +#define _HOOK_SVC_(what,...) \ + struct afb_hook_svc *hook; \ + pthread_rwlock_rdlock(&rwlock); \ + hook = list_of_svc_hooks; \ + while (hook) { \ + if (hook->itf->hook_svc_##what \ + && (hook->flags & afb_hook_flag_svc_##what) != 0 \ + && (!hook->api || !strcasecmp(hook->api, svc->api))) { \ + hook->itf->hook_svc_##what(hook->closure, __VA_ARGS__); \ + } \ + hook = hook->next; \ + } \ + pthread_rwlock_unlock(&rwlock); + +void afb_hook_svc_start_before(const struct afb_svc *svc) +{ + _HOOK_SVC_(start_before, svc); +} + +int afb_hook_svc_start_after(const struct afb_svc *svc, int status) +{ + _HOOK_SVC_(start_after, svc, status); + return status; +} + +void afb_hook_svc_on_event_before(const struct afb_svc *svc, const char *event, int eventid, struct json_object *object) +{ + _HOOK_SVC_(on_event_before, svc, event, eventid, object); +} + +void afb_hook_svc_on_event_after(const struct afb_svc *svc, const char *event, int eventid, struct json_object *object) +{ + _HOOK_SVC_(on_event_after, svc, event, eventid, object); +} + +void afb_hook_svc_call(const struct afb_svc *svc, const char *api, const char *verb, struct json_object *args) +{ + _HOOK_SVC_(call, svc, api, verb, args); +} + +void afb_hook_svc_call_result(const struct afb_svc *svc, int status, struct json_object *result) +{ + _HOOK_SVC_(call_result, svc, status, result); +} + +void afb_hook_svc_callsync(const struct afb_svc *svc, const char *api, const char *verb, struct json_object *args) +{ + _HOOK_SVC_(callsync, svc, api, verb, args); +} + +int afb_hook_svc_callsync_result(const struct afb_svc *svc, int status, struct json_object *result) +{ + _HOOK_SVC_(callsync_result, svc, status, result); + return status; +} + +/****************************************************************************** + * section: hooking services (svc) + *****************************************************************************/ + +int afb_hook_flags_svc(const char *api) +{ + int flags; + struct afb_hook_svc *hook; + + pthread_rwlock_rdlock(&rwlock); + flags = 0; + hook = list_of_svc_hooks; + while (hook) { + if (!api || !hook->api || !strcasecmp(hook->api, api)) + flags |= hook->flags; + hook = hook->next; + } + pthread_rwlock_unlock(&rwlock); + return flags; +} + +struct afb_hook_svc *afb_hook_create_svc(const char *api, int flags, struct afb_hook_svc_itf *itf, void *closure) +{ + struct afb_hook_svc *hook; + + /* alloc the result */ + hook = calloc(1, sizeof *hook); + if (hook == NULL) + return NULL; + + /* get a copy of the names */ + hook->api = api ? strdup(api) : NULL; + if (api && !hook->api) { + free(hook); + return NULL; + } + + /* initialise the rest */ + hook->refcount = 1; + hook->flags = flags; + hook->itf = itf ? itf : &hook_svc_default_itf; + hook->closure = closure; + + /* record the hook */ + pthread_rwlock_wrlock(&rwlock); + hook->next = list_of_svc_hooks; + list_of_svc_hooks = hook; + pthread_rwlock_unlock(&rwlock); + + /* returns it */ + return hook; +} + +struct afb_hook_svc *afb_hook_addref_svc(struct afb_hook_svc *hook) +{ + pthread_rwlock_wrlock(&rwlock); + hook->refcount++; + pthread_rwlock_unlock(&rwlock); + return hook; +} + +void afb_hook_unref_svc(struct afb_hook_svc *hook) +{ + struct afb_hook_svc **prv; + + if (hook) { + pthread_rwlock_wrlock(&rwlock); + if (--hook->refcount) + hook = NULL; + else { + /* unlink */ + prv = &list_of_svc_hooks; + while (*prv && *prv != hook) + prv = &(*prv)->next; + if(*prv) + *prv = hook->next; + } + pthread_rwlock_unlock(&rwlock); + if (hook) { + /* free */ + free(hook->api); + free(hook); + } + } +} +