Core: new handling of termination requests

yellowman · Mar 30, 2020 · 086e954 · 086e954
1 parent d652fe3
commit 086e954
Show file tree

Hide file tree

Showing 15 changed files with 162 additions and 662 deletions.
diff --git a/include/ipfixcol2/plugins.h b/include/ipfixcol2/plugins.h
@@ -264,6 +264,8 @@ ipx_plugin_get(ipx_ctx_t *ctx, void *cfg);
  * \return #IPX_OK on success
  * \return #IPX_ERR_DENIED if a fatal memory allocation error has occurred and/or the plugin cannot
  *   continue to work properly (the collector will exit).
+ * \return #IPX_ERR_EOF if the plugin has reached expected goal (e.g. number of processed records).
+ *   This function will not be called anymore and the collector will shut down.
  */
 IPX_API int
 ipx_plugin_process(ipx_ctx_t *ctx, void *cfg, ipx_msg_t *msg);

diff --git a/src/core/CMakeLists.txt b/src/core/CMakeLists.txt
@@ -1,9 +1,11 @@
 # Core source files
 set(CORE_SOURCE
-    configurator/config_file.cpp
-    configurator/config_file.hpp
     configurator/configurator.cpp
     configurator/configurator.hpp
+    configurator/controller_file.cpp
+    configurator/controller_file.hpp
+    configurator/cpipe.c
+    configurator/cpipe.h
     configurator/extensions.cpp
     configurator/extensions.hpp
     configurator/instance.hpp