gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #3543 from nats-io/fix_flappers_update_cov_go

Browse Source 
Fix some flappers and update Go version for nightly code coverage
This commit is contained in:
Ivan Kozlovic
2022-10-10 17:28:22 -06:00
committed by GitHub
parent ccfc818e8b a98af54d92
commit 04c4cce4e9
2 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
.github/workflows/cov.yaml vendored
View File

@@ -22,7 +22,7 @@ jobs:
- name: Set up Go
uses: actions/setup-go@v2
with:
go-version: 1.17.x
go-version: 1.19.x
- name: Run code coverage
shell: bash --noprofile --norc -x -eo pipefail {0}

10
server/gateway_test.go
View File

@@ -568,6 +568,8 @@ func TestGatewayHeaderSupport(t *testing.T) {
// s1 should have an outbound gateway to s2.
waitForOutboundGateways(t, s1, 1, time.Second)
// and an inbound too
waitForInboundGateways(t, s1, 1, time.Second)
// s2 should have an inbound gateway
waitForInboundGateways(t, s2, 1, time.Second)
// and an outbound too
@@ -585,6 +587,9 @@ func TestGatewayHeaderSupport(t *testing.T) {
t.Fatalf("Error receiving msg from server: %v\n", err)
}
// Wait for interest to be registered on s2
checkGWInterestOnlyModeInterestOn(t, s2, "A", globalAccountName, "foo")
b, _, _ := newClientForServer(s2)
defer b.close()
@@ -633,6 +638,8 @@ func TestGatewayHeaderDeliverStrippedMsg(t *testing.T) {
// s1 should have an outbound gateway to s2.
waitForOutboundGateways(t, s1, 1, time.Second)
// and an inbound too
waitForInboundGateways(t, s1, 1, time.Second)
// s2 should have an inbound gateway
waitForInboundGateways(t, s2, 1, time.Second)
// and an outbound too
@@ -650,6 +657,9 @@ func TestGatewayHeaderDeliverStrippedMsg(t *testing.T) {
t.Fatalf("Error receiving msg from server: %v\n", err)
}
// Wait for interest to be registered on s2
checkGWInterestOnlyModeInterestOn(t, s2, "A", globalAccountName, "foo")
b, _, _ := newClientForServer(s2)
defer b.close()