diff --git a/.github/workflows/CI_endurance.yml b/.github/workflows/CI_endurance.yml index 009bd18..00a4d4d 100644 --- a/.github/workflows/CI_endurance.yml +++ b/.github/workflows/CI_endurance.yml @@ -39,7 +39,7 @@ jobs: shell: bash run: | set -euo pipefail - go test -p=1 -v ./waku -count=1 -timeout=360m -run '^(TestStressMemoryUsageForThreeNodes|TestStressStoreQuery5kMessagesWithPagination|TestStressHighThroughput10kPublish|TestStressLargePayloadEphemeralMessagesEndurance)$' | tee testlogs1.log + go test -p=1 -v ./waku -count=1 -timeout=360m -run '^(TestStressMemoryUsageForThreeNodes|TestStressStoreQuery5kMessagesWithPagination|TestStressHighThroughput10kPublish|TestStressLargePayloadEphemeralMessagesEndurance|TestStressConnectDisconnect1kIteration)$' | tee testlogs1.log - name: Upload Test Logs (Group 1) uses: actions/upload-artifact@v4 @@ -89,7 +89,7 @@ jobs: shell: bash run: | set -euo pipefail - go test -p=1 -v ./waku -count=1 -timeout=360m -run '^(TestStressRandomNodesInMesh|TestStress2Nodes2kIterationTearDown|TestPeerExchangePXLoad|TestStressConnectDisconnect1kIteration)$' | tee testlogs2.log + go test -p=1 -v ./waku -count=1 -timeout=360m -run '^(TestStressRandomNodesInMesh|TestStress2Nodes2kIterationTearDown|TestPeerExchangePXLoad)$' | tee testlogs2.log - name: Upload Test Logs (Group 2) uses: actions/upload-artifact@v4 diff --git a/waku/stress_test.go b/waku/stress_test.go index 436f0ff..4948895 100644 --- a/waku/stress_test.go +++ b/waku/stress_test.go @@ -86,7 +86,7 @@ func TestStressStoreQuery5kMessagesWithPagination(t *testing.T) { }() - iterations := 3000 + iterations := 1000 captureMemory(t.Name(), "at start") @@ -111,7 +111,7 @@ func TestStressStoreQuery5kMessagesWithPagination(t *testing.T) { require.NoError(t, err, "Failed to query store messages") require.Greater(t, len(*storedmsgs.Messages), 0, "Expected at least one stored message") } - Debug("##Iteration #%d",iterations) + Debug("##Iteration #%d",i) } captureMemory(t.Name(), "at end") @@ -178,7 +178,7 @@ func TestStressConnectDisconnect1kIteration(t *testing.T) { for i := 1; i <= iterations; i++ { err := node0.ConnectPeer(node1) require.NoError(t, err, "Iteration %d: node0 failed to connect to node1", i) - time.Sleep(1 * time.Second) + time.Sleep(150 * time.Millisecond) count, err := node0.GetNumConnectedPeers() require.NoError(t, err, "Iteration %d: failed to get peers for node0", i) Debug("Iteration %d: node0 sees %d connected peers", i, count) @@ -192,7 +192,7 @@ func TestStressConnectDisconnect1kIteration(t *testing.T) { err = node0.DisconnectPeer(node1) require.NoError(t, err, "Iteration %d: node0 failed to disconnect from node1", i) Debug("Iteration %d: node0 disconnected from node1", i) - time.Sleep(2 * time.Second) + time.Sleep(250 * time.Millisecond) } captureMemory(t.Name(), "at end") }