HPCC-32933 Only count the first iteration time input processing for t…

…he purposes of lookahead Signed-off-by: Shamser Ahmed <[email protected]>
hpcc-systems · Nov 13, 2024 · b687edd · b687edd
1 parent 07fe69e
commit b687edd
Showing 1 changed file with 19 additions and 5 deletions.
diff --git a/thorlcr/activities/loop/thloopslave.cpp b/thorlcr/activities/loop/thloopslave.cpp
@@ -306,13 +306,27 @@ class CLoopSlaveActivity : public CLoopSlaveActivityBase
                 {
                     OwnedConstThorRow ret;
                     {
-                        LookAheadTimer t(slaveTimerStats, timeActivities);
-                        ret.setown(curInput->nextRow());
-                        if (!ret)
+                        if (loopCounter==1)
                         {
-                            ret.setown(curInput->nextRow()); // more cope with groups somehow....
+                            // the time used in first iteration is lookahead time
+                            LookAheadTimer t(slaveTimerStats, timeActivities);
+                            ret.setown(curInput->nextRow());
                             if (!ret)
-                                break;
+                            {
+                                ret.setown(curInput->nextRow()); // more cope with groups somehow....
+                                if (!ret)
+                                    break;
+                            }
+                        }
+                        else
+                        {
+                            ret.setown(curInput->nextRow());
+                            if (!ret)
+                            {
+                                ret.setown(curInput->nextRow()); // more cope with groups somehow....
+                                if (!ret)
+                                    break;
+                            }
                         }
                     }