async external reducer, external reducer for start state

1 files changed, 62 insertions, 0 deletions

diff --git a/src/reducer/anastasis_api_recovery_redux.c b/src/reducer/anastasis_api_recovery_redux.c
index 59f5ae3..94e5e10 100644
--- a/src/reducer/anastasis_api_recovery_redux.c
+++ b/src/reducer/anastasis_api_recovery_redux.c
@@ -83,6 +83,68 @@ json_t *
 ANASTASIS_recovery_start (const struct GNUNET_CONFIGURATION_Handle *cfg)
 {
   json_t *initial_state;
+  const char *external_reducer = ANASTASIS_REDUX_probe_external_reducer ();
+
+  if (NULL != external_reducer)
+  {
+    int pipefd_stdout[2];
+    pid_t pid = 0;
+    int status;
+    FILE *reducer_stdout;
+
+    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+                "Using external reducer '%s' for recovery start status\n",
+                external_reducer);
+
+    GNUNET_assert (0 == pipe (pipefd_stdout));
+    pid = fork ();
+    if (pid == 0)
+    {
+      close (pipefd_stdout[0]);
+      dup2 (pipefd_stdout[1], STDOUT_FILENO);
+      execlp (external_reducer,
+              external_reducer,
+              "-r",
+              NULL);
+      GNUNET_assert (0);
+    }
+
+    close (pipefd_stdout[1]);
+    reducer_stdout = fdopen (pipefd_stdout[0],
+                             "r");
+    {
+      json_error_t err;
+
+      initial_state = json_loadf (reducer_stdout,
+                                  0,
+                                  &err);
+
+      if (NULL == initial_state)
+      {
+        GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+                    "External reducer did not output valid JSON: %s:%d:%d %s\n",
+                    err.source,
+                    err.line,
+                    err.column,
+                    err.text);
+        GNUNET_assert (0 == fclose (reducer_stdout));
+        waitpid (pid, &status, 0);
+        return NULL;
+      }
+    }
+
+    GNUNET_assert (NULL != initial_state);
+    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+                "Waiting for external reducer to terminate.\n");
+    GNUNET_assert (0 == fclose (reducer_stdout));
+    reducer_stdout = NULL;
+    waitpid (pid, &status, 0);
+
+    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+                "External reducer finished with exit status '%d'\n",
+                status);
+    return initial_state;
+  }
 
   (void) cfg;
   initial_state = ANASTASIS_REDUX_load_continents_ ();