From 97be51930cfba4d8b2bc3d2bfba6e627b6f3e792 Mon Sep 17 00:00:00 2001 From: Rafael Matias Date: Mon, 25 Mar 2019 22:56:47 +0100 Subject: [PATCH] cmd/swarm/swarm-smoke-pss: close rpc clients --- cmd/swarm/swarm-smoke-pss/pss.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/cmd/swarm/swarm-smoke-pss/pss.go b/cmd/swarm/swarm-smoke-pss/pss.go index b80a867a53..02a006f5c0 100644 --- a/cmd/swarm/swarm-smoke-pss/pss.go +++ b/cmd/swarm/swarm-smoke-pss/pss.go @@ -31,7 +31,6 @@ type pssNode struct { pubkey string client *rpc.Client deregisterFunc func() - msgC chan pss.APIMsg } type pssSession struct { @@ -162,17 +161,21 @@ func pssSetup() *pssSession { log.Error("error calling host for subscribe", "err", err) continue } + + var dFn = func() { + sub.Unsubscribe() + rpcClient.Close() + } session.nodes = append(session.nodes, &pssNode{ hostIdx: i, addr: []byte(addr), client: rpcClient, pubkey: pubkey, - deregisterFunc: sub.Unsubscribe, + deregisterFunc: dFn, }, ) } - return session }