Backport of NDBT_Test functionality to identify parallel steps

Originally committed in :
commit 4329a1385304788d642d0dec34174a6cd7842eb7
Author: Frazer Clement <[email protected]>
Date:   Fri Oct 8 23:54:33 2021 +0100

    Bug #32478380 DEADLOCK TIMEOUT DUE TO PROBLEM IN REDO LOG QUEUE HANDLING

Originally
Approved by : Maitrayi Sabaratnam <[email protected]>

Change-Id: Idcd159d0da98b6ed4c8542895fcfbaa962a75240

Author: frazerclement

storage/ndb/test/include/NDBT_Test.hpp

@@ -1,5 +1,5 @@
 /*
-   Copyright (c) 2003, 2024, Oracle and/or its affiliates.
+   Copyright (c) 2003, 2025, Oracle and/or its affiliates.
 
    This program is free software; you can redistribute it and/or modify
    it under the terms of the GNU General Public License, version 2.0,
@@ -121,6 +121,18 @@ class NDBT_Context {
    * Get config by beeing friend to ndb_cluster_connection_impl - ugly
    */
   NdbApiConfig const& getConfig() const;
+
+  /**
+   * get a subrange of records - useful for splitting work amongst
+   * threads and avoiding contention.
+   */
+  static
+  void getRecordSubRange(int records,
+                         int rangeCount,
+                         int rangeId,
+                         int& startRecord,
+                         int& stopRecord);
+
 private:
   friend class NDBT_Step;
   friend class NDBT_TestSuite;
@@ -161,13 +173,17 @@ class NDBT_Step {
   const char* getName() { return name; }
   int getStepNo() { return step_no; }
   void setStepNo(int n) { step_no = n; }
+  /* Parallel steps : Step x/y (x counting from 0) */
+  int getStepTypeNo() { return step_type_no; }
+  int getStepTypeCount() { return step_type_count; }
 protected:
   NDBT_Context* m_ctx;
   const char* name;
   NDBT_TESTFUNC* func;
   NDBT_TestCase* testcase;
   int step_no;
-
+  int step_type_no;
+  int step_type_count;
 private:
   int setUp(Ndb_cluster_connection&);
   void tearDown();
@@ -182,7 +198,9 @@ class NDBT_ParallelStep : public NDBT_Step {
 public:
   NDBT_ParallelStep(NDBT_TestCase* ptest,
 		    const char* pname,
-		    NDBT_TESTFUNC* pfunc);
+		    NDBT_TESTFUNC* pfunc,
+                    int num = 0,
+                    int count = 1);
   virtual ~NDBT_ParallelStep() {}
 };
 
@@ -503,7 +521,7 @@ C##suitname():NDBT_TestSuite(#suitname){ \
 // Add a number of equal steps to the testcase
 #define STEPS(stepfunc, num) \
   { int i; for (i = 0; i < num; i++){ \
-    pts = new NDBT_ParallelStep(pt, #stepfunc, stepfunc); \
+    pts = new NDBT_ParallelStep(pt, #stepfunc, stepfunc, i, num);     \
     pt->addStep(pts);\
   } }
 

storage/ndb/test/src/NDBT_Test.cpp

@@ -1,5 +1,5 @@
 /*
-   Copyright (c) 2003, 2024, Oracle and/or its affiliates.
+   Copyright (c) 2003, 2025, Oracle and/or its affiliates.
 
    This program is free software; you can redistribute it and/or modify
    it under the terms of the GNU General Public License, version 2.0,
@@ -280,10 +280,35 @@ void NDBT_Context::setNumLoops(int _loops){
   loops = _loops;
 }
 
+void NDBT_Context::getRecordSubRange(int records,
+                                     int rangeCount,
+                                     int rangeId,
+                                     int& startRecord,
+                                     int& stopRecord)
+{
+  int recordsPerStep = records / rangeCount;
+  if (recordsPerStep == 0)
+  {
+    recordsPerStep = 1;
+  }
+  startRecord = rangeId * recordsPerStep;
+  stopRecord = startRecord + recordsPerStep;
+
+  if (stopRecord > records)
+  {
+    stopRecord = records;
+  }
+  if (startRecord >= records)
+  {
+    startRecord = stopRecord = 0;
+  }
+}
+
 NDBT_Step::NDBT_Step(NDBT_TestCase* ptest, const char* pname,
                      NDBT_TESTFUNC* pfunc) :
   m_ctx(NULL), name(pname), func(pfunc),
-  testcase(ptest), step_no(-1), m_ndb(NULL)
+  testcase(ptest), step_no(-1), step_type_no(0),
+  step_type_count(1), m_ndb(NULL)
 {
 }
 
@@ -389,9 +414,14 @@ NDBT_Context* NDBT_Step::getContext(){
 
 
 NDBT_ParallelStep::NDBT_ParallelStep(NDBT_TestCase* ptest, 
-				     const char* pname, 
-				     NDBT_TESTFUNC* pfunc)
+                                     const char* pname,
+                                     NDBT_TESTFUNC* pfunc,
+                                     int num,
+                                     int count)
   : NDBT_Step(ptest, pname, pfunc) {
+  require(num < count);
+  step_type_no = num;
+  step_type_count = count;
 }
 NDBT_Verifier::NDBT_Verifier(NDBT_TestCase* ptest, 
 			     const char* pname,