Adding additional load runner to verify reorg

integration-tests/ccip-tests/chaos/reorg_suite.go

@@ -92,23 +92,23 @@ func (r *ReorgSuite) RunReorgBelowFinalityThreshold(startDelay time.Duration) {
 		require.NoError(r.t, err)
 		time.Sleep(r.Cfg.ExperimentDuration)
 
-		blocksBackDst := int(r.Cfg.DstFinalityDepth) - r.Cfg.FinalityDelta
-		r.Logger.Info().
-			Str("URL", r.SrcClient.URL).
-			Str("Case", "below finality").
-			Int("BlocksBack", blocksBackDst).
-			Msg("Rewinding blocks on dst chain")
-		err = r.DstClient.GethSetHead(blocksBackDst)
-		assert.NoError(r.t, err)
-		err = PostGrafanaAnnotation(
-			r.Logger,
-			r.GrafanaClient,
-			r.Cfg.dashboardUID,
-			fmt.Sprintf("rewinded dest chain for %d blocks back, finality is: %d", blocksBackDst, r.Cfg.DstFinalityDepth),
-			nil,
-		)
-		require.NoError(r.t, err)
-		time.Sleep(r.Cfg.ExperimentDuration)
+		//blocksBackDst := int(r.Cfg.DstFinalityDepth) - r.Cfg.FinalityDelta
+		//r.Logger.Info().
+		//	Str("URL", r.SrcClient.URL).
+		//	Str("Case", "below finality").
+		//	Int("BlocksBack", blocksBackDst).
+		//	Msg("Rewinding blocks on dst chain")
+		//err = r.DstClient.GethSetHead(blocksBackDst)
+		//assert.NoError(r.t, err)
+		//err = PostGrafanaAnnotation(
+		//	r.Logger,
+		//	r.GrafanaClient,
+		//	r.Cfg.dashboardUID,
+		//	fmt.Sprintf("rewinded dest chain for %d blocks back, finality is: %d", blocksBackDst, r.Cfg.DstFinalityDepth),
+		//	nil,
+		//)
+		//require.NoError(r.t, err)
+		//time.Sleep(r.Cfg.ExperimentDuration)
 	}()
 }
 

integration-tests/ccip-tests/load/ccip_test.go

@@ -84,6 +84,7 @@ func TestLoadCCIPStableRPSReorgsBelowFinality(t *testing.T) {
 	})
 	rs := setupReorgSuite(t, testArgs)
 	testArgs.TriggerLoadByLane()
+	testArgs.WaitForLoadStart()
 	rs.RunReorgBelowFinalityThreshold(1 * time.Minute)
 	testArgs.TriggerLoadByLane()
 	testArgs.Wait()

integration-tests/ccip-tests/load/helper.go

@@ -365,17 +365,25 @@ func (l *LoadArgs) AddToRunnerGroup(gen *wasp.Generator) {
 	})
 }
 
-func (l *LoadArgs) Wait() {
+func (l *LoadArgs) WaitForLoadStart() {
 	l.lggr.Info().Msg("Waiting for load to start on all lanes")
 	// wait for load runner to start
 	l.LoadStarterWg.Wait()
-	l.lggr.Info().Msg("Waiting for load to finish on all lanes")
+	l.lggr.Info().Msg("Load started on all lanes")
+}
+
+func (l *LoadArgs) WaitForLoadToFinish() {
 	// wait for load runner to finish
 	err := l.RunnerWg.Wait()
 	require.NoError(l.t, err, "load run is failed")
 	l.lggr.Info().Msg("Load finished on all lanes")
 }
 
+func (l *LoadArgs) Wait() {
+	l.WaitForLoadStart()
+	l.WaitForLoadToFinish()
+}
+
 func (l *LoadArgs) ApplyChaos() {
 	testEnv := l.TestSetupArgs.Env
 	if testEnv == nil || testEnv.K8Env == nil {

integration-tests/ccip-tests/testconfig/tomls/ccip-reorg.toml

@@ -56,11 +56,8 @@ PriceMax = '200 gwei'
 LimitDefault = 6000000
 FeeCapDefault = '200 gwei'
 """
-
-[CCIP.Groups.load.LoadProfile]
-TestDuration = '3m'
-
-
+[CCIP.Groups.load]
+BiDirectionalLane = true
 [CCIP.Groups.load.LoadProfile]
 RequestPerUnitTime = [1]          # number of ccip requests to be sent per unit time
 TimeUnit = '10s'                  # unit of time for RequestPerUnitTime