diff --git a/.github/workflows/CI_endurance.yml b/.github/workflows/CI_endurance.yml index 8f22e3f..4cea715 100644 --- a/.github/workflows/CI_endurance.yml +++ b/.github/workflows/CI_endurance.yml @@ -36,7 +36,9 @@ jobs: run: sudo sh -c "ulimit -n 8192" - name: Run Endurance Test (Group 1) + shell: bash run: | + set -euo pipefail go test -p=1 -v ./waku -count=1 -timeout=360m -run '^(TestStressMemoryUsageForThreeNodes|TestStressStoreQuery5kMessagesWithPagination|TestStressConnectDisconnect500Iteration|TestStressHighThroughput10kPublish)$' | tee testlogs1.log - name: Upload Test Logs (Group 1) @@ -83,7 +85,10 @@ jobs: run: sudo sh -c "ulimit -n 8192" - name: Run Endurance Test (Group 2) + + shell: bash run: | + set -euo pipefail go test -p=1 -v ./waku -count=1 -timeout=360m -run '^(TestStressRandomNodesInMesh|TestStress2Nodes500IterationTearDown|TestPeerExchangePXLoad)$' | tee testlogs2.log - name: Upload Test Logs (Group 2) diff --git a/waku/common/store.go b/waku/common/store.go index 066ad4e..fd73c9c 100644 --- a/waku/common/store.go +++ b/waku/common/store.go @@ -1,15 +1,15 @@ package common type StoreQueryRequest struct { - RequestId string `json:"requestId"` - IncludeData bool `json:"includeData"` + RequestId string `json:"request_id"` + IncludeData bool `json:"include_data"` PubsubTopic string `json:"pubsubTopic,omitempty"` ContentTopics *[]string `json:"contentTopics,omitempty"` TimeStart *int64 `json:"timeStart,omitempty"` TimeEnd *int64 `json:"timeEnd,omitempty"` MessageHashes *[]MessageHash `json:"messageHashes,omitempty"` PaginationCursor *MessageHash `json:"paginationCursor,omitempty"` - PaginationForward bool `json:"paginationForward"` + PaginationForward bool `json:"pagination_forward"` PaginationLimit *uint64 `json:"paginationLimit,omitempty"` } diff --git a/waku/stress_test.go b/waku/stress_test.go index b5600d9..80b54ee 100644 --- a/waku/stress_test.go +++ b/waku/stress_test.go @@ -86,7 +86,7 @@ func TestStressStoreQuery5kMessagesWithPagination(t *testing.T) { }() - iterations := 5000 + iterations := 3000 captureMemory(t.Name(), "at start") @@ -104,6 +104,7 @@ func TestStressStoreQuery5kMessagesWithPagination(t *testing.T) { TimeStart: queryTimestamp, IncludeData: true, PaginationLimit: proto.Uint64(50), + PaginationForward: false, } storedmsgs, err := wakuNode.GetStoredMessages(node2, storeQueryRequest) @@ -136,7 +137,7 @@ func TestStressHighThroughput10kPublish(t *testing.T) { captureMemory(t.Name(), "at start") - totalMessages := 2500 + totalMessages := 5 pubsubTopic := DefaultPubsubTopic for i := 0; i < totalMessages; i++ {