affile: add affile_dw_unset_owner

Signed-off-by: Szilard Parrag <szilard.parrag@gmail.com>
syslog-ng · May 7, 2023 · 834fd74 · 834fd74
1 parent 34bf664
commit 834fd74
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/modules/affile/affile-dest.c b/modules/affile/affile-dest.c
@@ -316,6 +316,14 @@ affile_dw_set_owner(AFFileDestWriter *self, AFFileDestDriver *owner)
                            self->filename);
 }
 
+static void 
+affile_dw_unset_owner(AFFileDestWriter *self)
+{
+  if (self->owner)
+    log_pipe_unref(&self->owner->super.super.super);
+  self->owner = NULL;
+}
+
 static void
 affile_dw_free(LogPipe *s)
 {
@@ -496,7 +504,7 @@ affile_dd_reuse_writer(gpointer key, gpointer value, gpointer user_data)
   affile_dw_set_owner(writer, self);
   if (!log_pipe_init(&writer->super))
     {
-      affile_dw_set_owner(writer, NULL);
+      affile_dw_unset_owner(writer);
       log_pipe_unref(&writer->super);
       g_hash_table_remove(self->writer_hash, key);
     }