Sync with devel

phaag · Apr 14, 2024 · 9bc3553 · 9bc3553
1 parent 686f749
commit 9bc3553
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/src/libnfdump/filter/filter.c b/src/libnfdump/filter/filter.c
@@ -598,6 +598,18 @@ void FilterSetParam(void *engine, const char *ident, const int hasGeoDB) {
     filterEngine->ident = ident;
 }  // End of FilterSetParam
 
+void *FilterCloneEngine(void *engine) {
+    FilterEngine_t *filterEngine = malloc(sizeof(FilterEngine_t));
+    if (!filterEngine) {
+        LogError("malloc() error in %s line %d: %s", __FILE__, __LINE__, strerror(errno));
+        exit(EXIT_FAILURE);
+    }
+    memcpy((void *)filterEngine, engine, sizeof(FilterEngine_t));
+    if (filterEngine->ident) filterEngine->ident = strdup(filterEngine->ident);
+
+    return (void *)filterEngine;
+}  // End of FilterCloneEngine
+
 int FilterRecord(const void *engine, recordHandle_t *handle) {
     FilterEngine_t *filterEngine = (FilterEngine_t *)engine;
     return filterEngine->filterFunction(filterEngine, handle);

diff --git a/src/libnfdump/filter/filter.h b/src/libnfdump/filter/filter.h
@@ -156,6 +156,8 @@ void *CompileFilter(char *FilterSyntax);
 
 void DisposeFilter(void *engine);
 
+void *FilterCloneEngine(void *engine);
+
 void FilterSetParam(void *engine, const char *ident, const int hasGeoDB);
 
 int FilterRecord(const void *engine, recordHandle_t *handle);