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 23:13:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

make modifications for jobs

Browse Source
This commit is contained in:
aya 2025-04-06 21:57:48 +02:00
parent 99cc621c88
commit 722005d150
2 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -37,7 +37,7 @@ jobs:
- name: Run Endurance Test (Group 1)
run: |
go test -p=1 -v ./waku -count=1 -timeout=360m -run '^(TestStressMemoryUsageForThreeNodes|TestStressStoreQuery5kMessagesWithPagination|TestStressHighThroughput10kPublish|TestStressConnectDisconnect500Iteration)$' | tee testlogs1.log
go test -p=1 -v ./waku -count=1 -timeout=360m -run '^(TestStressMemoryUsageForThreeNodes|TestStressStoreQuery5kMessagesWithPagination|TestStressConnectDisconnect500Iteration|TestStressHighThroughput10kPublish)$' | tee testlogs1.log
- name: Upload Test Logs (Group 1)
uses: actions/upload-artifact@v4
@ -78,7 +78,7 @@ jobs:
- name: Run Endurance Test (Group 2)
run: |
go test -p=1 -v ./waku -count=1 -timeout=360m -run '^(TestStressRandomNodesInMesh|TestStressLargePayloadEphemeralMessagesEndurance|TestStress2Nodes500IterationTearDown|TestPeerExchangePXLoad)$' | tee testlogs2.log
go test -p=1 -v ./waku -count=1 -timeout=360m -run '^(TestStressRandomNodesInMesh|TestStress2Nodes500IterationTearDown|TestPeerExchangePXLoad)$' | tee testlogs2.log
- name: Upload Test Logs (Group 2)
uses: actions/upload-artifact@v4

14
waku/stress_test.go
View File

@ -92,7 +92,7 @@ func TestStressStoreQuery5kMessagesWithPagination(t *testing.T) {
}()
var memStats runtime.MemStats
iterations := 50
iterations := 500
runtime.ReadMemStats(&memStats)
initialHeapAlloc := memStats.HeapAlloc
@ -157,7 +157,7 @@ func TestStressHighThroughput10kPublish(t *testing.T) {
Debug("Memory usage BEFORE sending => HeapAlloc: %d KB, RSS: %d KB", startHeapKB, startRSSKB)
totalMessages := 1500
totalMessages := 1000
pubsubTopic := DefaultPubsubTopic
for i := 0; i < totalMessages; i++ {
@ -320,17 +320,21 @@ func TestStressLargePayloadEphemeralMessagesEndurance(t *testing.T) {
nodePubCfg.Relay = true
publisher, err := StartWakuNode("publisher", &nodePubCfg)
require.NoError(t, err)
defer publisher.StopAndDestroy()
nodeRecvCfg := DefaultWakuConfig
nodeRecvCfg.Relay = true
receiver, err := StartWakuNode("receiver", &nodeRecvCfg)
require.NoError(t, err)
defer receiver.StopAndDestroy()
err = receiver.RelaySubscribe(DefaultPubsubTopic)
require.NoError(t, err)
defer func() {
publisher.StopAndDestroy()
time.Sleep(30 * time.Second)
receiver.StopAndDestroy()
}()
err = publisher.ConnectPeer(receiver)
require.NoError(t, err)
@ -373,7 +377,7 @@ func TestStressLargePayloadEphemeralMessagesEndurance(t *testing.T) {
endRSSKB, err := utils.GetRSSKB()
require.NoError(t, err)
Debug("After endurance test: HeapAlloc = %d KB, RSS = %d KB", endHeapKB, endRSSKB)
time.Sleep(10 * time.Second)
}
func TestStress2Nodes500IterationTearDown(t *testing.T) {