From 31d77942053d465ec81c9a939cba5fd100c8f25a Mon Sep 17 00:00:00 2001
From: Shamser Ahmed <shamser.ahmed@lexisnexis.com>
Date: Fri, 1 Nov 2024 15:28:15 +0000
Subject: [PATCH] HPCC-32930 Capture and report start timings for activities
 derived from CInMemJoinBase

Capture start timing for input activities started asynchronously by CInMemJoinBase.

Signed-off-by: Shamser Ahmed <shamser.ahmed@lexisnexis.com>
---
 thorlcr/activities/lookupjoin/thlookupjoinslave.cpp | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/thorlcr/activities/lookupjoin/thlookupjoinslave.cpp b/thorlcr/activities/lookupjoin/thlookupjoinslave.cpp
index 69e0651c2bb..6b183cdef8f 100644
--- 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;
             }