Skip to content

Commit 71c78bf

Browse files
author
Darioush Jalali
authored
rpc: close Clients in tests (#29512)
1 parent e4ecaf8 commit 71c78bf

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

rpc/client_test.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -253,6 +253,7 @@ func TestClientBatchRequestLimit(t *testing.T) {
253253
defer server.Stop()
254254
server.SetBatchLimits(2, 100000)
255255
client := DialInProc(server)
256+
defer client.Close()
256257

257258
batch := []BatchElem{
258259
{Method: "foo"},
@@ -342,6 +343,7 @@ func testClientCancel(transport string, t *testing.T) {
342343
default:
343344
panic("unknown transport: " + transport)
344345
}
346+
defer client.Close()
345347

346348
// The actual test starts here.
347349
var (
@@ -592,6 +594,7 @@ func TestClientSubscriptionChannelClose(t *testing.T) {
592594

593595
srv.RegisterName("nftest", new(notificationTestService))
594596
client, _ := Dial(wsURL)
597+
defer client.Close()
595598

596599
for i := 0; i < 100; i++ {
597600
ch := make(chan int, 100)
@@ -708,7 +711,6 @@ func TestClientHTTP(t *testing.T) {
708711
errc = make(chan error, len(results))
709712
wantResult = echoResult{"a", 1, new(echoArgs)}
710713
)
711-
defer client.Close()
712714
for i := range results {
713715
i := i
714716
go func() {

rpc/websocket_test.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -187,6 +187,7 @@ func TestWebsocketPeerInfo(t *testing.T) {
187187
if err != nil {
188188
t.Fatal(err)
189189
}
190+
defer c.Close()
190191

191192
// Request peer information.
192193
var connInfo PeerInfo
@@ -273,6 +274,7 @@ func TestClientWebsocketLargeMessage(t *testing.T) {
273274
if err != nil {
274275
t.Fatal(err)
275276
}
277+
defer c.Close()
276278

277279
var r string
278280
if err := c.Call(&r, "test_largeResp"); err != nil {

0 commit comments

Comments
 (0)