[HICN-369] Implement reconciliation state machine in face manager incl. reattempts in case of errors

Change-Id: Ia4ecf621fbd513d9e29313d2aaa487aa65811183
Signed-off-by: Jordan Augé <jordan.auge@cisco.com>

1 files changed, 48 insertions, 5 deletions

diff --git a/ctrl/facemgr/src/main.c b/ctrl/facemgr/src/main.c
index be5ff3c68..9eba2aa0c 100644
--- a/ctrl/facemgr/src/main.c
+++ b/ctrl/facemgr/src/main.c
@@ -24,6 +24,7 @@
 #include <stdlib.h>
 #include <stdio.h>
 #include <string.h>
+#include <unistd.h> // sleep
 
 #include <hicn/facemgr.h>
 #include <hicn/policy.h>
@@ -44,6 +45,12 @@ static struct event_base * loop;
 #endif
 static loop_t * loop = NULL;
 
+#ifdef __linux__
+#ifdef WITH_THREAD
+static bool stop = false;
+#endif /* WITH_THREAD */
+#endif /* __linux__ */
+
 static struct option long_options[] =
 {
     {"config",  required_argument, 0, 'c'},
@@ -69,6 +76,11 @@ void facemgr_signal_handler(int signal) {
     fprintf(stderr, "Received ^C... quitting !\n");
     if (loop) {
         loop_break(loop);
+#ifdef __linux__
+#ifdef WITH_THREAD
+    stop = true;
+#endif /* WITH_THREAD */
+#endif /* __linux__ */
     }
 }
 
@@ -95,6 +107,16 @@ int parse_cmdline(int argc, char ** argv, facemgr_options_t * opts)
 
 #endif /* __linux__ */
 
+int
+dump_facelet(const facemgr_t * facemgr, const facelet_t * facelet,
+        void * user_data)
+{
+    char facelet_s[MAXSZ_FACELET];
+    facelet_snprintf(facelet_s, MAXSZ_FACELET, facelet);
+    DEBUG("%s", facelet_s);
+    return 0;
+}
+
 int main(int argc, char ** argv)
 {
     facemgr_cfg_t * cfg = NULL;
@@ -176,20 +198,41 @@ MAIN_LOOP:
     if (facemgr_bootstrap(facemgr) < 0 )
         goto ERR_BOOTSTRAP;
 
-    loop_dispatch(loop);
+    if (loop_dispatch(loop) < 0) {
+        ERROR("Failed to run main loop");
+        return EXIT_FAILURE;
+    }
 
 #ifdef __linux__
 #ifdef WITH_THREAD
-    for(;;) {
-        facemgr_list_faces(facemgr, NULL, NULL);
-        sleep(5);
+    unsigned cpt = 0;
+    while(!stop) {
+        if (cpt == 10) {
+            DEBUG("<facelets>");
+#if 1
+            facemgr_list_facelets(facemgr, dump_facelet, NULL);
+#else
+            char * buffer;
+            int n = facemgr_list_facelets_json(facemgr, &buffer);
+            printf("%s\n", buffer);
+            free(buffer);
+#endif
+
+            DEBUG("</facelets>");
+            cpt = 0;
+        }
+        usleep(500000);
+        cpt++;
     }
 #endif /* WITH_THREAD */
 #endif /* __linux__ */
 
     facemgr_stop(facemgr);
 
-    loop_undispatch(loop);
+    if (loop_undispatch(loop) < 0) {
+        ERROR("Failed to terminate main loop");
+        return EXIT_FAILURE;
+    }
 
     facemgr_free(facemgr);