HPCC-32930 Capture and report start timings for activities derived fr…

…om CInMemJoinBase Capture start timing for input activities started asynchronously by CInMemJoinBase. Signed-off-by: Shamser Ahmed <[email protected]>
hpcc-systems · Nov 1, 2024 · 31d7794 · 31d7794
1 parent 4c31ec4
commit 31d7794
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/thorlcr/activities/lookupjoin/thlookupjoinslave.cpp b/thorlcr/activities/lookupjoin/thlookupjoinslave.cpp
@@ -1449,7 +1449,10 @@ class CInMemJoinBase : public CSlaveActivity, public CAllOrLookupHelper<HELPER>,
     {
         try
         {
-            startInput(0);
+            {
+                LookAheadTimer t(slaveTimerStats, timeActivities);
+                startInput(0);
+            }
             if (ensureStartFTLookAhead(0))
                 setLookAhead(0, createRowStreamLookAhead(this, inputStream, queryRowInterfaces(input), LOOKUPJOINL_SMART_BUFFER_SIZE, ::canStall(input), grouped, RCUNBOUND, this), false);
             left.set(inputStream); // can be replaced by loader stream
@@ -1565,6 +1568,7 @@ class CInMemJoinBase : public CSlaveActivity, public CAllOrLookupHelper<HELPER>,
             CAsyncCallStart asyncLeftStart(std::bind(&CInMemJoinBase::startLeftInput, this));
             try
             {
+                ActivityTimer timer(slaveTimerStats, timeActivities);
                 startInput(1);
                 rhsStartedBefore = true;
             }