ctdb-common: Do not initialize run_proc inside run_event
authorAmitay Isaacs <amitay@gmail.com>
Wed, 9 May 2018 06:42:40 +0000 (16:42 +1000)
committerMartin Schwenke <martins@samba.org>
Tue, 5 Jun 2018 20:34:18 +0000 (22:34 +0200)
Allowing run_event_init() to take run_proc_context as an argument allows
to create multiple run_event instances with a single run_proc_context.

Signed-off-by: Amitay Isaacs <amitay@gmail.com>
Reviewed-by: Martin Schwenke <martin@meltin.net>
ctdb/common/run_event.c
ctdb/common/run_event.h
ctdb/server/ctdb_eventd.c
ctdb/tests/src/run_event_test.c

index b1b50ec..c78d956 100644 (file)
@@ -272,7 +272,7 @@ struct run_event_context {
 };
 
 
-int run_event_init(TALLOC_CTX *mem_ctx, struct tevent_context *ev,
+int run_event_init(TALLOC_CTX *mem_ctx, struct run_proc_context *run_proc_ctx,
                   const char *script_dir, const char *debug_prog,
                   struct run_event_context **out)
 {
@@ -285,11 +285,7 @@ int run_event_init(TALLOC_CTX *mem_ctx, struct tevent_context *ev,
                return ENOMEM;
        }
 
-       ret = run_proc_init(run_ctx, ev, &run_ctx->run_proc_ctx);
-       if (ret != 0) {
-               talloc_free(run_ctx);
-               return ret;
-       }
+       run_ctx->run_proc_ctx = run_proc_ctx;
 
        ret = stat(script_dir, &st);
        if (ret != 0) {
index bd0f3e6..72878e1 100644 (file)
@@ -75,7 +75,7 @@ struct run_event_script_list {
  * @param[out] result New run_event context
  * @return 0 on success, errno on error
  */
-int run_event_init(TALLOC_CTX *mem_ctx, struct tevent_context *ev,
+int run_event_init(TALLOC_CTX *mem_ctx, struct run_proc_context *run_proc_ctx,
                   const char *script_dir, const char *debug_prog,
                   struct run_event_context **result);
 
index feeac07..f1c8a8c 100644 (file)
@@ -50,6 +50,7 @@ struct eventd_client {
 };
 
 struct eventd_context {
+       struct run_proc_context *run_proc_ctx;
        struct run_event_context *run_ctx;
 
        /* result of last execution */
@@ -78,7 +79,16 @@ static int eventd_context_init(TALLOC_CTX *mem_ctx,
                return ENOMEM;
        }
 
-       ret = run_event_init(ectx, ev, script_dir, debug_script,
+       ret = run_proc_init(ectx, ev, &ectx->run_proc_ctx);
+       if (ret != 0) {
+               talloc_free(ectx);
+               return ret;
+       }
+
+       ret = run_event_init(ectx,
+                            ectx->run_proc_ctx,
+                            script_dir,
+                            debug_script,
                             &ectx->run_ctx);
        if (ret != 0) {
                talloc_free(ectx);
index 5539ceb..ddee92e 100644 (file)
@@ -160,6 +160,7 @@ int main(int argc, const char **argv)
 {
        TALLOC_CTX *mem_ctx;
        struct tevent_context *ev;
+       struct run_proc_context *run_proc_ctx;
        struct run_event_context *run_ctx;
        int ret;
 
@@ -180,7 +181,13 @@ int main(int argc, const char **argv)
                exit(1);
        }
 
-       ret = run_event_init(mem_ctx, ev, argv[1], NULL, &run_ctx);
+       ret = run_proc_init(mem_ctx, ev, &run_proc_ctx);
+       if (ret != 0) {
+               fprintf(stderr, "run_proc_init() failed, ret=%d\n", ret);
+               exit(1);
+       }
+
+       ret = run_event_init(mem_ctx, run_proc_ctx, argv[1], NULL, &run_ctx);
        if (ret != 0) {
                fprintf(stderr, "run_event_init() failed, ret=%d\n", ret);
                exit(1);