Explorar o código

HPCC-11341 - Add tracing for block splitters

Signed-off-by: Jake Smith <jake.smith@lexisnexis.com>
Jake Smith %!s(int64=11) %!d(string=hai) anos
pai
achega
5bc99b0f5f
Modificáronse 1 ficheiros con 7 adicións e 1 borrados
  1. 7 1
      thorlcr/thorutil/thbuf.cpp

+ 7 - 1
thorlcr/thorutil/thbuf.cpp

@@ -832,7 +832,13 @@ protected:
                 const rowcount_t &rowsWritten = parent.readerWait(rowsRead);
                 {
                     CriticalUnblock b(parent.crit);
-                    readWaitSem.wait();
+                    unsigned mins=0;
+                    loop
+                    {
+                        if (readWaitSem.wait(60000))
+                            break; // NB: will also be signal if aborting
+                        ActPrintLog(parent.activity, "output %d @ row # %"RCPF"d, has been blocked for %d minute(s)", output, rowsRead, ++mins);
+                    }
                 }
                 if (parent.isEof(rowsRead))
                     return 0;