HPCC-32933 Track lookahead time for loop activity

Signed-off-by: Shamser Ahmed <[email protected]>
hpcc-systems · Nov 6, 2024 · 07fe69e · 07fe69e
1 parent 1751abf
commit 07fe69e
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/thorlcr/activities/loop/thloopslave.cpp b/thorlcr/activities/loop/thloopslave.cpp
@@ -304,12 +304,16 @@ class CLoopSlaveActivity : public CLoopSlaveActivityBase
             {
                 while (!abortSoon)
                 {
-                    OwnedConstThorRow ret = (void *)curInput->nextRow();
-                    if (!ret)
+                    OwnedConstThorRow ret;
                     {
-                        ret.setown(curInput->nextRow()); // more cope with groups somehow....
+                        LookAheadTimer t(slaveTimerStats, timeActivities);
+                        ret.setown(curInput->nextRow());
                         if (!ret)
-                            break;
+                        {
+                            ret.setown(curInput->nextRow()); // more cope with groups somehow....
+                            if (!ret)
+                                break;
+                        }
                     }
 
                     if (finishedLooping ||