HPCC-32931 Capture and report execute timings for splitters

Signed-off-by: Shamser Ahmed <[email protected]>
hpcc-systems · Nov 4, 2024 · ebafeda · ebafeda
1 parent 4c31ec4
commit ebafeda
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/thorlcr/activities/nsplitter/thnsplitterslave.cpp b/thorlcr/activities/nsplitter/thnsplitterslave.cpp
@@ -217,7 +217,10 @@ class NSplitterSlaveActivity : public CSlaveActivity, implements ISharedSmartBuf
                 assertex(((unsigned)-1) != connectedOutputCount);
                 activeOutputCount = connectedOutputCount;
 
-                PARENT::start();
+                {
+                    ActivityTimer t(slaveTimerStats, queryTimeActivities());
+                    PARENT::start();
+                }
                 initMetaInfo(cachedMetaInfo);
                 cachedMetaInfo.suppressLookAhead = spill; // only suppress downstream lookaheads if this is a spilling splitter
 
@@ -299,6 +302,7 @@ class NSplitterSlaveActivity : public CSlaveActivity, implements ISharedSmartBuf
     }
     inline const void *nextRow(unsigned outIdx, rowcount_t current)
     {
+        ActivityTimer t(slaveTimerStats, queryTimeActivities());
         if (1 == activeOutputCount) // will be true, if only 1 input connected, or only 1 input was active (others stopped) when it started reading
             return inputStream->nextRow();
         if (recsReady == current && writeAheadException.get())