diff --git a/test/e2e/benchmark/main.go b/test/e2e/benchmark/main.go index be4eb1e126..bc2c19cf30 100644 --- a/test/e2e/benchmark/main.go +++ b/test/e2e/benchmark/main.go @@ -18,6 +18,8 @@ func main() { {"LargeNetworkBigBlock8MB", LargeNetworkBigBlock8MB}, {"LargeNetworkBigBlock32MB", LargeNetworkBigBlock32MB}, {"LargeNetworkBigBlock64MB", LargeNetworkBigBlock64MB}, + {"LargeNetworkBigBlock64MBLatency", LargeNetworkBigBlock64MBLatency}, + {"LargeNetworkBigBlock8MBLatency", LargeNetworkBigBlock8MBLatency}, } // check the test name passed as an argument and run it diff --git a/test/e2e/benchmark/throughput.go b/test/e2e/benchmark/throughput.go index b919093d8a..c38debbf3d 100644 --- a/test/e2e/benchmark/throughput.go +++ b/test/e2e/benchmark/throughput.go @@ -179,3 +179,25 @@ func LargeNetworkBigBlock64MB(logger *log.Logger) error { manifest.BlobSequences = 2 return runBenchmarkTest(logger, "LargeNetworkBigBlock64MB", manifest) } + +func LargeNetworkBigBlock64MBLatency(logger *log.Logger) error { + manifest := bigBlockManifest + manifest.MaxBlockBytes = 64 * testnet.MB + manifest.Validators = 50 + manifest.TxClients = 50 + manifest.BlobSequences = 2 + manifest.EnableLatency = true + manifest.LatencyParams = LatencyParams{70, 0} + return runBenchmarkTest(logger, "LargeNetworkBigBlock64MBLatency", manifest) +} +func LargeNetworkBigBlock8MBLatency(logger *log.Logger) error { + manifest := bigBlockManifest + manifest.MaxBlockBytes = 8 * testnet.MB + manifest.Validators = 50 + manifest.TxClients = 50 + manifest.BlobSequences = 2 + manifest.EnableLatency = true + manifest.LatencyParams = LatencyParams{70, 0} + manifest.TestDuration = 10 * time.Minute + return runBenchmarkTest(logger, "LargeNetworkBigBlock8MBLatency", manifest) +} diff --git a/test/e2e/testnet/testnet.go b/test/e2e/testnet/testnet.go index 4b3beebe99..d907cd2eda 100644 --- a/test/e2e/testnet/testnet.go +++ b/test/e2e/testnet/testnet.go @@ -339,7 +339,7 @@ func (t *Testnet) WaitToSync() error { if err != nil { return fmt.Errorf("failed to initialize client for node %s: %w", node.Name, err) } - for i := 0; i < 10; i++ { + for i := 0; i < 100; i++ { resp, err := client.Status(context.Background()) if err == nil { if resp.SyncInfo.LatestBlockHeight > 0 { @@ -350,7 +350,7 @@ func (t *Testnet) WaitToSync() error { } else { err = errors.New("error getting status") } - if i == 9 { + if i == 99 { return fmt.Errorf("failed to start node %s: %w", node.Name, err) } log.Info().Str("name", node.Name).Int("attempt", i).Msg(