affile: remove internal queue "filter"

Signed-off-by: László Várady <[email protected]>
axoflow · May 22, 2024 · 5158985 · 5158985
1 parent 4c6a532
commit 5158985
Show file tree

Hide file tree

Showing 4 changed files with 1 addition and 45 deletions.
diff --git a/modules/affile/CMakeLists.txt b/modules/affile/CMakeLists.txt
@@ -1,6 +1,5 @@
 set(AFFILE_SOURCES
     "affile-dest.h"
-    "affile-dest-internal-queue-filter.h"
     "affile-parser.h"
     "affile-source.h"
     "collection-comparator.h"

diff --git a/modules/affile/Makefile.am b/modules/affile/Makefile.am
@@ -44,8 +44,7 @@ modules_affile_libaffile_la_SOURCES	=			\
 	modules/affile/affile-parser.h				\
 	modules/affile/affile-plugin.c \
 	modules/affile/file-list.h				\
-	modules/affile/file-list.c				\
-  modules/affile/affile-dest-internal-queue-filter.h
+	modules/affile/file-list.c
 
 if HAVE_INOTIFY
   modules_affile_libaffile_la_SOURCES +=      \

diff --git a/modules/affile/affile-dest-internal-queue-filter.h b/modules/affile/affile-dest-internal-queue-filter.h
diff --git a/modules/affile/affile-dest.c b/modules/affile/affile-dest.c
@@ -33,7 +33,6 @@
 #include "transport/transport-file.h"
 #include "transport/transport-pipe.h"
 #include "logwriter.h"
-#include "affile-dest-internal-queue-filter.h"
 #include "file-specializations.h"
 #include "apphook.h"
 #include "timeutils/cache.h"
@@ -282,12 +281,6 @@ affile_dw_deinit(LogPipe *s)
 static void
 affile_dw_queue(LogPipe *s, LogMessage *lm, const LogPathOptions *path_options)
 {
-  if (!affile_dw_queue_enabled_for_msg(lm))
-    {
-      log_msg_drop(lm, path_options, AT_PROCESSED);
-      return;
-    }
-
   AFFileDestWriter *self = (AFFileDestWriter *) s;
 
   g_mutex_lock(&self->lock);