From 0fec708b3d58670ff791c02662c28d6a60dc95c1 Mon Sep 17 00:00:00 2001
From: Rene Krenn <rkrenn@sipwise.com>
Date: Tue, 8 Feb 2022 15:45:44 +0100
Subject: [PATCH] TT#161550 fix suspending fileprocessor workers with multiple
 files

Change-Id: I0090194b78d0915246ffe6fdf1352acac0f9fbf4
(cherry picked from commit 879bf33795d7577726d2d806c3d6fafdc5d7542b)
---
 lib/NGCP/BulkProcessor/FileProcessor.pm | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/lib/NGCP/BulkProcessor/FileProcessor.pm b/lib/NGCP/BulkProcessor/FileProcessor.pm
index c2eeecb..813a697 100644
--- a/lib/NGCP/BulkProcessor/FileProcessor.pm
+++ b/lib/NGCP/BulkProcessor/FileProcessor.pm
@@ -144,6 +144,7 @@ sub process {
                                                 errorstates                 => \%errorstates,
                                                 readertid                   => $reader->tid(),
                                                 process_code                => $process_code,
+                                                single_file                 => $single_file,
                                                 init_process_context_code   => $init_process_context_code,
                                                 uninit_process_context_code => $uninit_process_context_code,
                                                 instance                    => $self,
@@ -491,9 +492,12 @@ sub _process {
                         last;
                     }
 
-                } else {
+                } elsif ($context->{single_file}) {
                     filethreadingdebug('[' . $tid . '] shutting down processor thread (end of data - empty block) ...',getlogger(__PACKAGE__));
                     last;
+                } else {
+                    #yield();
+                    sleep($thread_sleep_secs);
                 }
             } else {
                 #yield();