X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fsession.c;h=320eab9b8e2fde3b9ce08fd04bfed3eab4c6ab07;hb=779f425daa66d2b0cd431fdc6f7f4ed976cbae15;hp=d586e51791b00ddc1df5ef903a2a3ab7d82be274;hpb=f1b901ed676b2d45ec8e6ae3d6ef2f94d79f9ee6;p=src%2Fapp-framework-binder.git diff --git a/src/session.c b/src/session.c index d586e517..320eab9b 100644 --- a/src/session.c +++ b/src/session.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2015 "IoT.bzh" + * Copyright (C) 2015, 2016 "IoT.bzh" * Author "Fulup Ar Foll" * * Licensed under the Apache License, Version 2.0 (the "License"); @@ -25,9 +25,10 @@ #include #include -#include +#include #include "session.h" +#include "verbose.h" #define NOW (time(NULL)) @@ -63,9 +64,18 @@ static struct { int max; int timeout; int apicount; - const char *initok; + char initok[37]; + struct afb_event_listener_list *listeners; } sessions; +/* generate a uuid */ +static void new_uuid(char uuid[37]) +{ + uuid_t newuuid; + uuid_generate(newuuid); + uuid_unparse_lower(newuuid, uuid); +} + // Free context [XXXX Should be protected again memory abort XXXX] static void ctxUuidFreeCB (struct AFB_clientCtx *client) { @@ -87,11 +97,15 @@ void ctxStoreInit (int max_session_count, int timeout, const char *initok, int c sessions.max = max_session_count; sessions.timeout = timeout; sessions.apicount = context_count; - if (strlen(initok) >= sizeof(sessions.store[0]->token)) { - fprintf(stderr, "Error: initial token '%s' too long (max length 36)", initok); + if (initok == NULL) + /* without token, a secret is made to forbid creation of sessions */ + new_uuid(sessions.initok); + else if (strlen(initok) < sizeof(sessions.store[0]->token)) + strcpy(sessions.initok, initok); + else { + ERROR("initial token '%s' too long (max length 36)", initok); exit(1); } - sessions.initok = initok; } static struct AFB_clientCtx *ctxStoreSearch (const char* uuid) @@ -145,8 +159,6 @@ static int ctxStoreAdd (struct AFB_clientCtx *client) assert (client != NULL); - //fprintf (stderr, "ctxStoreAdd request uuid=%s count=%d\n", client->uuid, sessions.count); - pthread_mutex_lock(&sessions.mutex); for (idx=0; idx < sessions.max; idx++) { @@ -166,7 +178,15 @@ added: // Check if context timeout or not static int ctxStoreTooOld (struct AFB_clientCtx *ctx, time_t now) { - return ctx->expiration <= now; + assert (ctx != NULL); + return ctx->expiration < now; +} + +// Check if context is active or not +static int ctxIsActive (struct AFB_clientCtx *ctx, time_t now) +{ + assert (ctx != NULL); + return ctx->uuid[0] != 0 && ctx->expiration >= now; } // Loop on every entry and remove old context sessions.hash @@ -187,7 +207,6 @@ static void ctxStoreCleanUp (time_t now) // This function will return exiting client context or newly created client context struct AFB_clientCtx *ctxClientGetSession (const char *uuid, int *created) { - uuid_t newuuid; struct AFB_clientCtx *clientCtx; time_t now; @@ -218,8 +237,7 @@ struct AFB_clientCtx *ctxClientGetSession (const char *uuid, int *created) /* generate the uuid */ if (uuid == NULL) { - uuid_generate(newuuid); - uuid_unparse_lower(newuuid, clientCtx->uuid); + new_uuid(clientCtx->uuid); } else { strcpy(clientCtx->uuid, uuid); } @@ -258,6 +276,7 @@ void ctxClientUnref(struct AFB_clientCtx *clientCtx) --clientCtx->refcount; if (clientCtx->refcount == 0 && clientCtx->uuid[0] == 0) { ctxStoreDel (clientCtx); + free(clientCtx); } } } @@ -266,8 +285,16 @@ void ctxClientUnref(struct AFB_clientCtx *clientCtx) void ctxClientClose (struct AFB_clientCtx *clientCtx) { assert(clientCtx != NULL); - ctxUuidFreeCB (clientCtx); - clientCtx->uuid[0] = 0; + if (clientCtx->uuid[0] != 0) { + clientCtx->uuid[0] = 0; + ctxUuidFreeCB (clientCtx); + while(clientCtx->listeners != NULL) + ctxClientEventListenerRemove(clientCtx, clientCtx->listeners->listener); + if (clientCtx->refcount == 0) { + ctxStoreDel (clientCtx); + free(clientCtx); + } + } } // Sample Generic Ping Debug API @@ -277,7 +304,7 @@ int ctxTokenCheck (struct AFB_clientCtx *clientCtx, const char *token) assert(token != NULL); // compare current token with previous one - if (ctxStoreTooOld (clientCtx, NOW)) + if (!ctxIsActive (clientCtx, NOW)) return 0; if (clientCtx->token[0] && strcmp (token, clientCtx->token) != 0) @@ -289,23 +316,20 @@ int ctxTokenCheck (struct AFB_clientCtx *clientCtx, const char *token) // generate a new token and update client context void ctxTokenNew (struct AFB_clientCtx *clientCtx) { - uuid_t newuuid; - assert(clientCtx != NULL); // Old token was valid let's regenerate a new one - uuid_generate(newuuid); // create a new UUID - uuid_unparse_lower(newuuid, clientCtx->token); + new_uuid(clientCtx->token); // keep track of time for session timeout and further clean up clientCtx->expiration = NOW + sessions.timeout; } -int ctxClientEventListenerAdd(struct AFB_clientCtx *clientCtx, struct afb_event_listener listener) +static int add_listener(struct afb_event_listener_list **head, struct afb_event_listener listener) { struct afb_event_listener_list *iter, **prv; - prv = &clientCtx->listeners; + prv = head; for (;;) { iter = *prv; if (iter == NULL) { @@ -327,11 +351,16 @@ int ctxClientEventListenerAdd(struct AFB_clientCtx *clientCtx, struct afb_event_ } } -void ctxClientEventListenerRemove(struct AFB_clientCtx *clientCtx, struct afb_event_listener listener) +int ctxClientEventListenerAdd(struct AFB_clientCtx *clientCtx, struct afb_event_listener listener) +{ + return add_listener(clientCtx != NULL ? &clientCtx->listeners : &sessions.listeners, listener); +} + +static void remove_listener(struct afb_event_listener_list **head, struct afb_event_listener listener) { struct afb_event_listener_list *iter, **prv; - prv = &clientCtx->listeners; + prv = head; for (;;) { iter = *prv; if (iter == NULL) @@ -347,16 +376,23 @@ void ctxClientEventListenerRemove(struct AFB_clientCtx *clientCtx, struct afb_ev } } -static int send(struct AFB_clientCtx *clientCtx, const char *event, struct json_object *object) +void ctxClientEventListenerRemove(struct AFB_clientCtx *clientCtx, struct afb_event_listener listener) +{ + remove_listener(clientCtx != NULL ? &clientCtx->listeners : &sessions.listeners, listener); +} + +static int send(struct afb_event_listener_list *head, const char *event, struct json_object *object) { struct afb_event_listener_list *iter; int result; result = 0; - iter = clientCtx->listeners; + iter = head; while (iter != NULL) { - iter->listener.itf->send(iter->listener.closure, event, json_object_get(object)); - result++; + if (iter->listener.itf->expects == NULL || iter->listener.itf->expects(iter->listener.closure, event)) { + iter->listener.itf->send(iter->listener.closure, event, json_object_get(object)); + result++; + } iter = iter->next; } @@ -369,18 +405,18 @@ int ctxClientEventSend(struct AFB_clientCtx *clientCtx, const char *event, struc time_t now; int result; - if (clientCtx != NULL) - result = send(clientCtx, event, object); - else { - result = 0; - now = NOW; + now = NOW; + if (clientCtx != NULL) { + result = ctxIsActive(clientCtx, now) ? send(clientCtx->listeners, event, object) : 0; + } else { + result = send(sessions.listeners, event, object); for (idx=0; idx < sessions.max; idx++) { - clientCtx = sessions.store[idx]; - if (clientCtx != NULL && !ctxStoreTooOld(clientCtx, now)) { + clientCtx = ctxClientAddRef(sessions.store[idx]); + if (clientCtx != NULL && ctxIsActive(clientCtx, now)) { clientCtx = ctxClientAddRef(clientCtx); - result += send(clientCtx, event, object); - ctxClientUnref(clientCtx); + result += send(clientCtx->listeners, event, object); } + ctxClientUnref(clientCtx); } } return result;