aboutsummaryrefslogtreecommitdiffstats
path: root/swarm/network/stream/messages.go
diff options
context:
space:
mode:
authorJanos Guljas <janos@resenje.org>2018-09-24 23:40:22 +0800
committerJanos Guljas <janos@resenje.org>2018-09-24 23:56:00 +0800
commit9e99a0c2b94daa351325688702e2a49e34f60dbf (patch)
treea66c070a9c55eff5dda766cb35b013657eab37df /swarm/network/stream/messages.go
parent1f45ba9bb1c19489a6c8bf9caf100e56dcb79788 (diff)
downloadgo-tangerine-9e99a0c2b94daa351325688702e2a49e34f60dbf.tar
go-tangerine-9e99a0c2b94daa351325688702e2a49e34f60dbf.tar.gz
go-tangerine-9e99a0c2b94daa351325688702e2a49e34f60dbf.tar.bz2
go-tangerine-9e99a0c2b94daa351325688702e2a49e34f60dbf.tar.lz
go-tangerine-9e99a0c2b94daa351325688702e2a49e34f60dbf.tar.xz
go-tangerine-9e99a0c2b94daa351325688702e2a49e34f60dbf.tar.zst
go-tangerine-9e99a0c2b94daa351325688702e2a49e34f60dbf.zip
cmd/swarm, swarm: add stream peer servers limit
Diffstat (limited to 'swarm/network/stream/messages.go')
-rw-r--r--swarm/network/stream/messages.go10
1 files changed, 6 insertions, 4 deletions
diff --git a/swarm/network/stream/messages.go b/swarm/network/stream/messages.go
index 2e1a81e82..482af25f5 100644
--- a/swarm/network/stream/messages.go
+++ b/swarm/network/stream/messages.go
@@ -84,11 +84,13 @@ func (p *Peer) handleSubscribeMsg(ctx context.Context, req *SubscribeMsg) (err e
defer func() {
if err != nil {
- if e := p.Send(context.TODO(), SubscribeErrorMsg{
+ // The error will be sent as a subscribe error message
+ // and will not be returned as it will prevent any new message
+ // exchange between peers over p2p. Instead, error will be returned
+ // only if there is one from sending subscribe error message.
+ err = p.Send(context.TODO(), SubscribeErrorMsg{
Error: err.Error(),
- }); e != nil {
- log.Error("send stream subscribe error message", "err", err)
- }
+ })
}
}()