engine: send backlog chunks on shutdown

PettitWesley · singholt · commit 76c983bf0e72 · 2025-02-17T13:39:40.000-08:00
Signed-off-by: Wesley Pettit &lt;wppttt@amazon.com&gt;
diff --git a/src/flb_engine.c b/src/flb_engine.c
@@ -946,7 +946,8 @@ int flb_engine_start(struct flb_config *config)
 
     ret = sb_segregate_chunks(config);
 
-    if (ret) {
+    if (ret < 0)
+    {
         flb_error("[engine] could not segregate backlog chunks");
         return -2;
     }
@@ -1023,6 +1024,11 @@ int flb_engine_start(struct flb_config *config)
                     if (ret > 0 && (config->grace_count < config->grace || config->grace == -1)) {
                         if (config->grace_count == 1) {
                             flb_task_running_print(config);
+                            ret = sb_segregate_chunks(config);
+                            if (ret < 0) {
+                                flb_error("[engine] could not segregate backlog chunks");
+                                return -2;
+                            }
                         }
                         flb_engine_exit(config);
                     }

Original file line number	Diff line number	Diff line change
`@@ -946,7 +946,8 @@ int flb_engine_start(struct flb_config *config)`
`946`	`946`
`947`	`947`	`ret = sb_segregate_chunks(config);`
`948`	`948`
`949`		`- if (ret) {`
	`949`	`+ if (ret < 0)`
	`950`	`+ {`
`950`	`951`	`flb_error("[engine] could not segregate backlog chunks");`
`951`	`952`	`return -2;`
`952`	`953`	`}`
`@@ -1023,6 +1024,11 @@ int flb_engine_start(struct flb_config *config)`
`1023`	`1024`	`if (ret > 0 && (config->grace_count < config->grace \|\| config->grace == -1)) {`
`1024`	`1025`	`if (config->grace_count == 1) {`
`1025`	`1026`	`flb_task_running_print(config);`
	`1027`	`+ ret = sb_segregate_chunks(config);`
	`1028`	`+ if (ret < 0) {`
	`1029`	`+ flb_error("[engine] could not segregate backlog chunks");`
	`1030`	`+ return -2;`
	`1031`	`+ }`
`1026`	`1032`	`}`
`1027`	`1033`	`flb_engine_exit(config);`
`1028`	`1034`	`}`