X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fsession.c;h=e0d0a8e64ea05431fd361e9a7b868fbf6251942a;hb=refs%2Fchanges%2F41%2F5941%2F1;hp=336dfd7005e6b17b28970787926e31d470316d1a;hpb=423d86c6032c0a27f790a3766abd0c855726eab1;p=src%2Fapp-framework-binder.git diff --git a/src/session.c b/src/session.c index 336dfd70..e0d0a8e6 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"); @@ -38,22 +38,15 @@ struct client_value void (*free_value)(void*); }; -struct afb_event_listener_list -{ - struct afb_event_listener_list *next; - struct afb_event_listener listener; - int refcount; -}; - struct AFB_clientCtx { unsigned refcount; + unsigned loa; time_t expiration; // expiration time of the token time_t access; char uuid[37]; // long term authentication of remote client char token[37]; // short term authentication of remote client struct client_value *values; - struct afb_event_listener_list *listeners; }; // Session UUID are store in a simple array [for 10 sessions this should be enough] @@ -64,10 +57,17 @@ static struct { int max; int timeout; int apicount; - const char *initok; - struct afb_event_listener_list *listeners; + char initok[37]; } 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) { @@ -84,21 +84,20 @@ static void ctxUuidFreeCB (struct AFB_clientCtx *client) // Create a new store in RAM, not that is too small it will be automatically extended void ctxStoreInit (int max_session_count, int timeout, const char *initok, int context_count) { - // let's create as store as hashtable does not have any sessions.store = calloc (1 + (unsigned)max_session_count, sizeof(struct AFB_clientCtx)); sessions.max = max_session_count; sessions.timeout = timeout; sessions.apicount = context_count; - if (!initok) { - ERROR("\"--token=\" parameter is mandatory"); - exit(1); - } - if (strlen(initok) >= sizeof(sessions.store[0]->token)) { + 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) @@ -200,7 +199,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; @@ -231,8 +229,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); } @@ -271,6 +268,7 @@ void ctxClientUnref(struct AFB_clientCtx *clientCtx) --clientCtx->refcount; if (clientCtx->refcount == 0 && clientCtx->uuid[0] == 0) { ctxStoreDel (clientCtx); + free(clientCtx); } } } @@ -279,8 +277,14 @@ 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); + if (clientCtx->refcount == 0) { + ctxStoreDel (clientCtx); + free(clientCtx); + } + } } // Sample Generic Ping Debug API @@ -302,123 +306,37 @@ 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; } -static int add_listener(struct afb_event_listener_list **head, struct afb_event_listener listener) -{ - struct afb_event_listener_list *iter, **prv; - - prv = head; - for (;;) { - iter = *prv; - if (iter == NULL) { - iter = calloc(1, sizeof *iter); - if (iter == NULL) { - errno = ENOMEM; - return -1; - } - iter->listener = listener; - iter->refcount = 1; - *prv = iter; - return 0; - } - if (iter->listener.itf == listener.itf && iter->listener.closure == listener.closure) { - iter->refcount++; - return 0; - } - prv = &iter->next; - } -} - -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 = head; - for (;;) { - iter = *prv; - if (iter == NULL) - return; - if (iter->listener.itf == listener.itf && iter->listener.closure == listener.closure) { - if (!--iter->refcount) { - *prv = iter->next; - free(iter); - } - return; - } - prv = &iter->next; - } -} - -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) +const char *ctxClientGetUuid (struct AFB_clientCtx *clientCtx) { - struct afb_event_listener_list *iter; - int result; - - result = 0; - iter = head; - while (iter != NULL) { - iter->listener.itf->send(iter->listener.closure, event, json_object_get(object)); - result++; - iter = iter->next; - } - - return result; + assert(clientCtx != NULL); + return clientCtx->uuid; } -int ctxClientEventSend(struct AFB_clientCtx *clientCtx, const char *event, struct json_object *object) +const char *ctxClientGetToken (struct AFB_clientCtx *clientCtx) { - long idx; - time_t now; - int result; - - 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 = ctxClientAddRef(sessions.store[idx]); - if (clientCtx != NULL && ctxIsActive(clientCtx, now)) { - clientCtx = ctxClientAddRef(clientCtx); - result += send(clientCtx->listeners, event, object); - } - ctxClientUnref(clientCtx); - } - } - return result; + assert(clientCtx != NULL); + return clientCtx->token; } -const char *ctxClientGetUuid (struct AFB_clientCtx *clientCtx) +unsigned ctxClientGetLOA (struct AFB_clientCtx *clientCtx) { assert(clientCtx != NULL); - return clientCtx->uuid; + return clientCtx->loa; } -const char *ctxClientGetToken (struct AFB_clientCtx *clientCtx) +void ctxClientSetLOA (struct AFB_clientCtx *clientCtx, unsigned loa) { assert(clientCtx != NULL); - return clientCtx->token; + clientCtx->loa = loa; } void *ctxClientValueGet(struct AFB_clientCtx *clientCtx, int index) @@ -437,6 +355,6 @@ void ctxClientValueSet(struct AFB_clientCtx *clientCtx, int index, void *value, assert(index < sessions.apicount); prev = clientCtx->values[index]; clientCtx->values[index] = (struct client_value){.value = value, .free_value = free_value}; - if (prev.value != NULL && prev.free_value != NULL) + if (prev.value != NULL && prev.value != value && prev.free_value != NULL) prev.free_value(prev.value); }