engine: send backlog chunks on shutdown

Signed-off-by: Wesley Pettit <[email protected]>

Author: PettitWesley

src/flb_engine.c

@@ -964,7 +964,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;
     }
@@ -1049,6 +1050,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;
+                            }
                         }
                         if ((mem_chunks + fs_chunks) > 0) {
                             flb_info("[engine] pending chunk count: memory=%d, filesystem=%d; grace_timer=%d",