aarifullin/neoneo-go
1
0
Fork 0
forked from TrueCloudLab/neoneo-go
Code Pull requests Activity

rpc/server: silence deadcode warning

Browse source
This commit is contained in:
Roman Khimov 2021-05-12 18:20:48 +03:00
parent 73ecbbb7c6
commit 8322607fd2
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
pkg/rpc/server/subscription_test.go
View file

@ -16,6 +16,8 @@ import (
"go.uber.org/atomic" "go.uber.org/atomic"
) )
const testOverflow = false
func wsReader(t *testing.T, ws *websocket.Conn, msgCh chan<- []byte, isFinished *atomic.Bool) { func wsReader(t *testing.T, ws *websocket.Conn, msgCh chan<- []byte, isFinished *atomic.Bool) {
for { for {
ws.SetReadDeadline(time.Now().Add(time.Second)) ws.SetReadDeadline(time.Now().Add(time.Second))
@ -428,7 +430,10 @@ func TestWSClientsLimit(t *testing.T) {
// that's going to happen because of network-level buffering, typical // that's going to happen because of network-level buffering, typical
// number seen in tests is around ~3500 events, but it's not reliable enough, // number seen in tests is around ~3500 events, but it's not reliable enough,
// thus this test is disabled. // thus this test is disabled.
func testSubscriptionOverflow(t *testing.T) { func TestSubscriptionOverflow(t *testing.T) {
if !testOverflow {
return
}
const blockCnt = notificationBufSize * 5 const blockCnt = notificationBufSize * 5
var receivedMiss bool var receivedMiss bool