From d9a8d81e01f49d8d19f0d7908a29bc93a4bfa4a6 Mon Sep 17 00:00:00 2001 From: Steven Allen Date: Wed, 7 Mar 2018 22:06:17 -0800 Subject: [PATCH] transport refactor update License: MIT Signed-off-by: Steven Allen --- network/ipfs_impl.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/network/ipfs_impl.go b/network/ipfs_impl.go index e2a0612..9388a65 100644 --- a/network/ipfs_impl.go +++ b/network/ipfs_impl.go @@ -54,7 +54,7 @@ type streamMessageSender struct { } func (s *streamMessageSender) Close() error { - return s.s.Close() + return inet.FullClose(s.s) } func (s *streamMessageSender) Reset() error { @@ -119,13 +119,13 @@ func (bsnet *impl) SendMessage( return err } - err = msgToStream(ctx, s, outgoing) - if err != nil { + if err = msgToStream(ctx, s, outgoing); err != nil { s.Reset() - } else { - s.Close() + return err } - return err + // Yes, return this error. We have no reason to believe that the block + // was actually *sent* unless we see the EOF. + return inet.FullClose(s) } func (bsnet *impl) SetDelegate(r Receiver) { -- GitLab