Update copyright dates

[src/app-framework-binder.git] / bindings / samples / hello3.c

diff --git a/bindings/samples/hello3.c b/bindings/samples/hello3.c
index b50ea46..3a6c9ad 100644 (file)
--- a/bindings/samples/hello3.c
+++ b/bindings/samples/hello3.c
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2015-2018 "IoT.bzh"
+ * Copyright (C) 2015-2020 "IoT.bzh"
  * Author "Fulup Ar Foll"
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
@@ -19,6 +19,8 @@
 #include <string.h>
 #include <pthread.h>
 #include <fcntl.h>
+#include <math.h>
+#include <errno.h>
 #include <sys/stat.h>
 #include <sys/types.h>
 #include <unistd.h>
@@ -29,7 +31,7 @@
 #include <afb/afb-binding.h>
 
 #if !defined(APINAME)
-#define APINAME "hello3"
+#define APINAME "hello"
 #endif
 
 static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
@@ -422,7 +424,7 @@ static void broadcast(afb_req_t request)
                        afb_req_success(request, NULL, NULL);
                pthread_mutex_unlock(&mutex);
        } else if (name != NULL) {
-               if (0 > afb_daemon_broadcast_event(name, object))
+               if (0 > afb_daemon_broadcast_event(name, json_object_get(object)))
                        afb_req_fail(request, "failed", "broadcast error");
                else
                        afb_req_success(request, NULL, NULL);
@@ -618,6 +620,78 @@ static void locale (afb_req_t request)
        }
 }
 
+static void in_after (afb_req_t request)
+{
+       int rc;
+       const char *ts, *ty;
+       char *te;
+       double td;
+       struct timespec t;
+
+       /* get the type */
+       ty = afb_req_value(request, "type") ?: "call";
+       if (strcmp(ty, "call") && strcmp(ty, "callsync")
+        && strcmp(ty, "subcall") && strcmp(ty, "subcallsync"))
+               return afb_req_reply(request, NULL, "invalid", "bad type");
+
+       /* get the delay */
+       ts = afb_req_value(request, "delay");
+       if (!ts)
+               return afb_req_reply(request, NULL, "invalid", "no delay");
+       td = strtod(ts, &te);
+       if (*te || td < 0 || td > 3e6) /* a month is the biggest accepted */
+               return afb_req_reply(request, NULL, "invalid", "bad delay");
+
+       /* wait for that time */
+       if (td > 0) {
+               t.tv_nsec = (long)(1e6 * modf(td, &td));
+               t.tv_sec = (time_t)td;
+               do {
+                       rc = nanosleep(&t, &t);
+               } while (rc != 0 && errno == EINTR);
+
+               if (rc)
+                       return afb_req_reply(request, NULL, "error", "sleep failed");
+       }
+
+       /* do the call */
+       if (!strcmp(ty, "subcallsync"))
+               subcall(request);
+       else if (!strcmp(ty, "subcall"))
+               subcallsync(request);
+       else if (!strcmp(ty, "callsync"))
+               callsync(request);
+       else
+               call(request);
+}
+
+static void *thread_after (void *closure)
+{
+       afb_req_t request = closure;
+       in_after (request);
+       afb_req_unref(request);
+       return NULL;
+}
+
+static void after (afb_req_t request)
+{
+       int rc;
+       pthread_t tid;
+       pthread_attr_t attr;
+
+       afb_req_addref(request);
+
+       pthread_attr_init(&attr);
+       pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
+       rc =pthread_create(&tid, &attr, thread_after, request);
+       pthread_attr_destroy(&attr);
+
+       if (rc != 0) {
+               afb_req_unref(request);
+               afb_req_reply(request, NULL, "cant-start", NULL);
+       }
+}
+
 static void api (afb_req_t request);
 
 /**
@@ -735,6 +809,7 @@ static const struct afb_verb_v3 verbs[]= {
   { .verb="setctx",      .callback=setctx, .vcbdata = (void*)(intptr_t)1 },
   { .verb="setctxif",    .callback=setctx, .vcbdata = (void*)(intptr_t)0 },
   { .verb="getctx",      .callback=getctx },
+  { .verb="checktok",    .callback=ok, .session=AFB_SESSION_CHECK },
   { .verb="reftok",      .callback=ok, .session=AFB_SESSION_CHECK | AFB_SESSION_REFRESH },
   { .verb="info",        .callback=info },
   { .verb="eventloop",   .callback=eventloop },
@@ -749,6 +824,7 @@ static const struct afb_verb_v3 verbs[]= {
   { .verb="mutebug",     .callback=mutebug},
   { .verb="queue",       .callback=queue},
   { .verb="settings",    .callback=settings},
+  { .verb="after",       .callback=after},
   { .verb=NULL}
 };
 
@@ -837,6 +913,7 @@ static void api (afb_req_t request)
                }
                sapi->api = afb_api_new_api(api, apiname, NULL, 1, apipreinit, NULL);
                if (!sapi->api) {
+                       free(sapi);
                        afb_req_reply_f(request, NULL, "cant-create", "%m");
                        goto end;
                }