From ebafeda598060212b921b4fb8e86b8ca378d8feb Mon Sep 17 00:00:00 2001 From: Shamser Ahmed Date: Fri, 1 Nov 2024 15:56:41 +0000 Subject: [PATCH] HPCC-32931 Capture and report execute timings for splitters Signed-off-by: Shamser Ahmed --- thorlcr/activities/nsplitter/thnsplitterslave.cpp | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/thorlcr/activities/nsplitter/thnsplitterslave.cpp b/thorlcr/activities/nsplitter/thnsplitterslave.cpp index d1d8f2e2e8e..6e337a7a7a7 100644 --- 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())