HPCC-32922 Capture lookahead timings for join activities

Signed-off-by: Shamser Ahmed <[email protected]>
hpcc-systems · Oct 31, 2024 · 888ad90 · 888ad90
1 parent 9d3734f
commit 888ad90
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 2 deletions.
diff --git a/thorlcr/activities/join/thjoinslave.cpp b/thorlcr/activities/join/thjoinslave.cpp
@@ -265,8 +265,10 @@ class JoinSlaveActivity : public CSlaveActivity, implements ILookAheadStopNotify
     {
         try
         {
-            startInput(secondaryInputIndex);
-
+            {
+                LookAheadTimer t(slaveTimerStats, timeActivities);
+                startInput(secondaryInputIndex);
+            }
             if (ensureStartFTLookAhead(secondaryInputIndex))
             {
                 IThorDataLink *secondaryInput = queryInput(secondaryInputIndex);

diff --git a/thorlcr/activities/keyedjoin/thkeyedjoinslave.cpp b/thorlcr/activities/keyedjoin/thkeyedjoinslave.cpp
@@ -2662,6 +2662,7 @@ class CKeyedJoinSlave : public CSlaveActivity, implements IJoinProcessor, implem
     }
     void readAhead()
     {
+        LookAheadTimer t(slaveTimerStats, timeActivities);
         endOfInput = false;
         CJoinGroup *groupStart = nullptr;
         unsigned __int64 preFiltered = 0;

diff --git a/thorlcr/activities/lookupjoin/thlookupjoinslave.cpp b/thorlcr/activities/lookupjoin/thlookupjoinslave.cpp
@@ -1447,6 +1447,7 @@ class CInMemJoinBase : public CSlaveActivity, public CAllOrLookupHelper<HELPER>,
     IBitSet *queryRhsChannelStopSet() { dbgassertex(0 == queryJobChannelNumber()); return rhsChannelStop; }
     void startLeftInput()
     {
+        LookAheadTimer t(slaveTimerStats, timeActivities);
         try
         {
             startInput(0);
@@ -1565,6 +1566,7 @@ class CInMemJoinBase : public CSlaveActivity, public CAllOrLookupHelper<HELPER>,
             CAsyncCallStart asyncLeftStart(std::bind(&CInMemJoinBase::startLeftInput, this));
             try
             {
+                ActivityTimer s(slaveTimerStats, timeActivities);
                 startInput(1);
                 rhsStartedBefore = true;
             }
@@ -2827,6 +2829,7 @@ class CLookupJoinActivityBase : public CInMemJoinBase<HTHELPER, IHThorHashJoinAr
     }
     virtual void start() override
     {
+        ActivityTimer t(slaveTimerStats, timeActivities);
         PARENT::start();
         dbgassertex(isSmart() || (leftITDL->isGrouped() == grouped)); // std. lookup join expects these to match
     }