cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

Merge pull request #5254 from turuslan/fix/chainxchg-buffered

Browse Source 
Chainxchg write response timeout
This commit is contained in:
Łukasz Magiera 2021-01-05 20:40:05 +01:00 committed by GitHub
commit a15080b563
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
chain/exchange/server.go
View File

@ -56,7 +56,11 @@ func (s *server) HandleStream(stream inet.Stream) {
} }
_ = stream.SetDeadline(time.Now().Add(WriteResDeadline)) _ = stream.SetDeadline(time.Now().Add(WriteResDeadline))
if err := cborutil.WriteCborRPC(stream, resp); err != nil { buffered := bufio.NewWriter(stream)
if err = cborutil.WriteCborRPC(buffered, resp); err == nil {
err = buffered.Flush()
}
if err != nil {
_ = stream.SetDeadline(time.Time{}) _ = stream.SetDeadline(time.Time{})
log.Warnw("failed to write back response for handle stream", log.Warnw("failed to write back response for handle stream",
"err", err, "peer", stream.Conn().RemotePeer()) "err", err, "peer", stream.Conn().RemotePeer())