Handle event in core binding

Prefers to handle the events reception by the binding, in C, rather than using
the LUA interpreter to avoid race condition on the LUA context. Because we are
waiting events in LUA context using binder call sync, when the event is received
then 2 threads operate simultaneously on LUA context, the waiting event thread and
the receiving event thread.

Bug-AGL: SPEC-2135

Change-Id: Ied0a78a61263b8fd41305969c636a491c6bb0295
Signed-off-by: Romain Forlot <romain.forlot@iot.bzh>

1 files changed, 52 insertions, 33 deletions

diff --git a/src/aft.c b/src/aft.c
index 19510af..7d8af8a 100644
--- a/src/aft.c
+++ b/src/aft.c
@@ -17,8 +17,6 @@
 */
 
 #define _GNU_SOURCE
-#include <stdio.h>
-#include <time.h>
 #include <pthread.h>
 #include <string.h>
 #include <systemd/sd-event.h>
@@ -35,6 +33,18 @@ static pthread_mutex_t memo_lock;
 static afb_req_t memo_sync = NULL;
 static struct sd_event_source *timersrc = NULL;
 
+static void onTraceEvent(void *closure, const char *event, json_object *data, afb_api_t api) {
+	/* If LUA evt Handler return 0 then stop the waiting sync request else
+	 * do nothing and continue to wait for every requested event to arrive.
+	 */
+	pthread_mutex_lock(&memo_lock);
+	if(memo_sync) {
+		afb_req_reply(memo_sync, json_object_get(data), NULL, event);afb_req_unref(memo_sync);
+		memo_sync = NULL;
+	}
+	pthread_mutex_unlock(&memo_lock);
+}
+
 // Config Section definition
 static CtlSectionT ctrlSections[] = {
 	{.key = "resources", .loadCB = PluginConfig},
@@ -91,13 +101,23 @@ static void ctrlapi_exit(afb_req_t request) {
 
 static int timeoutCB(struct sd_event_source *s, uint64_t us, void *ud)
 {
-	if (memo_sync)
-		afb_req_reply(memo_sync, NULL, "timeout", NULL);
+	afb_req_t req;
+
+	pthread_mutex_lock(&memo_lock);
+	req = memo_sync;
 	memo_sync = NULL;
+	sd_event_source_unref(timersrc);
 	timersrc = NULL;
+	pthread_mutex_unlock(&memo_lock);
+
+	if(req) {
+		afb_req_reply(req, NULL, "timeout", NULL);
+		afb_req_unref(req);
+	}
 
 	return 0;
 }
+
 /**
  * @brief A verb to call synchronously that will end when a timeout expires or
  * when a call with a 'stop' order given in the arguments.
@@ -106,36 +126,39 @@ static int timeoutCB(struct sd_event_source *s, uint64_t us, void *ud)
  */
 static void ctrlapi_sync(afb_req_t request) {
 	struct json_object *obj, *val;
-	uint64_t to, usec;
+	uint64_t timeout, usec;
 
-	AFB_REQ_NOTICE(request, "Syncing...");
+	AFB_REQ_DEBUG(request, "Syncing...");
+	obj = afb_req_json(request);
 
 	pthread_mutex_lock(&memo_lock);
-	obj = afb_req_json(request);
-	if (json_object_object_get_ex(obj, "start", &val)) {
-		to = json_object_get_int(val);
-		if (memo_sync)
-			afb_req_reply(request, NULL, "Bad-State", "There is an already ongoing waiting request.");
-		else {
-			sd_event_now(afb_api_get_event_loop(afb_req_get_api(request)), CLOCK_MONOTONIC, &usec);
-			usec = to + usec;
-			sd_event_add_time(afb_api_get_event_loop(afb_req_get_api(request)), &timersrc, CLOCK_MONOTONIC, usec, 0, timeoutCB, NULL);
-			memo_sync = afb_req_addref(request);
+	if(json_object_object_get_ex(obj, "start", &val) &&
+	    (timeout = json_object_get_int(val)) &&
+	    ! memo_sync) {
+		sd_event_now(afb_api_get_event_loop(afb_req_get_api(request)), CLOCK_MONOTONIC, &usec);
+		usec = timeout + usec;
+		sd_event_add_time(afb_api_get_event_loop(afb_req_get_api(request)), &timersrc, CLOCK_MONOTONIC, usec, 0, timeoutCB, NULL);
+		memo_sync = afb_req_addref(request);
+	} else if(json_object_object_get_ex(obj, "continue", &val) && ! memo_sync) {
+		memo_sync = afb_req_addref(request);
+	} else if(json_object_object_get_ex(obj, "stop", &val) && timersrc) {
+		if(memo_sync) {
+			afb_req_reply(request, NULL, NULL, "Unfinished start request ended");
+			afb_req_unref(memo_sync);
+			memo_sync = NULL;
 		}
-	} else if (json_object_object_get_ex(obj, "stop", &val)) {
-		if (!memo_sync)
-			afb_req_reply(request, NULL, "Bad-State", "There isn't any ongoing waiting request.");
-		else {
-			afb_req_reply(memo_sync, json_object_get(val), NULL, NULL);
+		sd_event_source_set_enabled(timersrc, SD_EVENT_OFF);
+		sd_event_source_unref(timersrc);
+		afb_req_reply(request, NULL, NULL, "stopped");
+		timersrc = NULL;
+	} else {
+		if(memo_sync) {
+			afb_req_reply(request, NULL, "Bad State", "Unfinished start request ended");
 			afb_req_unref(memo_sync);
-			sd_event_source_unref(timersrc);
 			memo_sync = NULL;
-			timersrc = NULL;
-			afb_req_reply(request, NULL, NULL, NULL);
 		}
-	} else
-		afb_req_reply(request, NULL, "Invalid", "No 'start' nor 'stop' order provided.");
-
+		afb_req_reply(request, NULL, "Bad state", NULL);
+	}
 	pthread_mutex_unlock(&memo_lock);
 }
 
@@ -188,7 +211,7 @@ static int CtrlLoadOneApi(void *cbdata, afb_api_t apiHandle) {
 	err = CtlLoadSections(apiHandle, ctrlConfig, ctrlSections);
 
 	// declare an event event manager for this API;
-	afb_api_on_event(apiHandle, CtrlDispatchApiEvent);
+	afb_api_event_handler_add(apiHandle, "monitor/trace", onTraceEvent, NULL);
 
 	// init API function (does not receive user closure ???
 	afb_api_on_init(apiHandle, CtrlInitOneApi);
@@ -207,7 +230,7 @@ static CtlConfigT *CtrlLoadConfigFile(afb_api_t apiHandle, const char *configPat
 
 static int CtrlCreateApi(afb_api_t apiHandle, CtlConfigT *ctrlConfig) {
 	int err = 0;
-	json_object *resourcesJ = NULL, *eventsJ = NULL;
+	json_object *resourcesJ = NULL;
 
 	if(!ctrlConfig) {
 		AFB_API_ERROR(apiHandle,
@@ -229,16 +252,12 @@ static int CtrlCreateApi(afb_api_t apiHandle, CtlConfigT *ctrlConfig) {
 		"uid", "AFT",
 		"info", "LUA Binder test framework",
 		"libs", "aft.lua" );
-	err += wrap_json_pack(&eventsJ, "{s[{ss, ss}]}", "events",
-		"uid", "monitor/trace",
-		"action", "lua://AFT#_evt_catcher_" );
 
 	if(err) {
 		AFB_API_ERROR(apiHandle, "Error at Controller configuration editing.");
 		return err;
 	}
 	wrap_json_object_add(ctrlConfig->configJ, resourcesJ);
-	wrap_json_object_add(ctrlConfig->configJ, eventsJ);
 
 	if(! afb_api_new_api(apiHandle, ctrlConfig->api, ctrlConfig->info, 0, CtrlLoadOneApi, ctrlConfig))
 		return ERROR;