File tree Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -197,7 +197,9 @@ func (s *SignatureNotifier) sendOneMsgToPeer(m *signatureItem) error {
197197 }
198198
199199 ret := make ([]byte , 8 )
200- _ , err = stream .Read (ret )
200+ if _ , err := stream .Read (ret ); err != nil {
201+ return errors .Wrapf (err , "fail to read response from stream" )
202+ }
201203
202204 return err
203205}
Original file line number Diff line number Diff line change @@ -171,14 +171,14 @@ func (c *Communication) readFromStream(stream network.Stream) {
171171
172172 payload , err := ReadStreamWithBuffer (stream )
173173 if err != nil {
174- c .logger .Error ().Err (err ).Str (logs .Peer , peerID ).Msg ("fail to read from stream" )
174+ c .logger .Error ().Err (err ).Str (logs .Peer , peerID ).Msg ("Failed to read from stream" )
175175 c .streamMgr .AddStream ("UNKNOWN" , stream )
176176 return
177177 }
178178
179179 var wrappedMsg messages.WrappedMessage
180180 if err := json .Unmarshal (payload , & wrappedMsg ); nil != err {
181- c .logger .Error ().Err (err ).Msg ("fail to unmarshal wrapped message bytes " )
181+ c .logger .Error ().Err (err ).Msg ("Failed to unmarshal WrappedMessage " )
182182 c .streamMgr .AddStream ("UNKNOWN" , stream )
183183 return
184184 }
You can’t perform that action at this time.
0 commit comments