logos-messaging/logos-messaging-go-bindings
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-go-bindings.git synced 2026-01-04 06:53:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

Reduce sleep time in long test & reduce iterations to 1k in pagination test

Browse Source
This commit is contained in:
aya 2025-05-18 22:36:55 +03:00
parent 878c57ae95
commit 453322161d
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
.github/workflows/CI_endurance.yml vendored
View File

@ -39,7 +39,7 @@ jobs:
shell: bash shell: bash
run: | run: |
set -euo pipefail 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) - name: Upload Test Logs (Group 1)
uses: actions/upload-artifact@v4 uses: actions/upload-artifact@v4
@ -89,7 +89,7 @@ jobs:
shell: bash shell: bash
run: | run: |
set -euo pipefail 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) - name: Upload Test Logs (Group 2)
uses: actions/upload-artifact@v4 uses: actions/upload-artifact@v4

8
waku/stress_test.go
View File

@ -86,7 +86,7 @@ func TestStressStoreQuery5kMessagesWithPagination(t *testing.T) {
}() }()
iterations := 3000 iterations := 1000
captureMemory(t.Name(), "at start") captureMemory(t.Name(), "at start")
@ -111,7 +111,7 @@ func TestStressStoreQuery5kMessagesWithPagination(t *testing.T) {
require.NoError(t, err, "Failed to query store messages") require.NoError(t, err, "Failed to query store messages")
require.Greater(t, len(*storedmsgs.Messages), 0, "Expected at least one stored message") 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") captureMemory(t.Name(), "at end")
@ -178,7 +178,7 @@ func TestStressConnectDisconnect1kIteration(t *testing.T) {
for i := 1; i <= iterations; i++ { for i := 1; i <= iterations; i++ {
err := node0.ConnectPeer(node1) err := node0.ConnectPeer(node1)
require.NoError(t, err, "Iteration %d: node0 failed to connect to node1", i) 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() count, err := node0.GetNumConnectedPeers()
require.NoError(t, err, "Iteration %d: failed to get peers for node0", i) require.NoError(t, err, "Iteration %d: failed to get peers for node0", i)
Debug("Iteration %d: node0 sees %d connected peers", i, count) Debug("Iteration %d: node0 sees %d connected peers", i, count)
@ -192,7 +192,7 @@ func TestStressConnectDisconnect1kIteration(t *testing.T) {
err = node0.DisconnectPeer(node1) err = node0.DisconnectPeer(node1)
require.NoError(t, err, "Iteration %d: node0 failed to disconnect from node1", i) require.NoError(t, err, "Iteration %d: node0 failed to disconnect from node1", i)
Debug("Iteration %d: node0 disconnected 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") captureMemory(t.Name(), "at end")
} }