TT#161550 fix suspending fileprocessor workers with multiple files

Change-Id: I0090194b78d0915246ffe6fdf1352acac0f9fbf4 (cherry picked from commit 879bf33795)
4 years ago · b7555c633e
parent ec2d625e51
commit b7555c633e
1 changed files with 5 additions and 1 deletions
--- 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();