logmpx: move log_msg_write_protect() back to multiplexer

Making the message write protected is independent of filterx and is required by all pipeline elements. Signed-off-by: László Várady <[email protected]>
axoflow · Sep 27, 2024 · 6d73b8e · 6d73b8e
1 parent dfb8760
commit 6d73b8e
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 1 deletion.
diff --git a/lib/filterx/filterx-eval.h b/lib/filterx/filterx-eval.h
@@ -94,7 +94,6 @@ filterx_eval_prepare_for_fork(FilterXEvalContext *context, LogMessage **pmsg, co
   filterx_eval_sync_message(context, pmsg, path_options);
   if (context)
     filterx_scope_write_protect(context->scope);
-  log_msg_write_protect(*pmsg);
 }
 
 #endif
diff --git a/lib/logmpx.c b/lib/logmpx.c
@@ -94,6 +94,7 @@ log_multiplexer_queue(LogPipe *s, LogMessage *msg, const LogPathOptions *path_op
        * data we still need */
 
       filterx_eval_prepare_for_fork(path_options->filterx_context, &msg, path_options);
+      log_msg_write_protect(msg);
     }
   for (fallback = 0; (fallback == 0) || (fallback == 1 && self->fallback_exists && !delivered); fallback++)
     {