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

fix buffered reads

Browse Source
This commit is contained in:
vyzo 2022-01-30 15:11:18 +02:00
parent 72333147d3
commit 4b8369c071
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
blockstore/splitstore/checkpoint.go
View File

@ -90,7 +90,7 @@ func readRawCid(buf *bufio.Reader, hbuf []byte) (cid.Cid, error) {
hbuf = hbuf[:int(sz)] hbuf = hbuf[:int(sz)]
} }
if _, err := buf.Read(hbuf); err != nil { if _, err := io.ReadFull(buf, hbuf); err != nil {
return cid.Undef, xerrors.Errorf("error reading hash: %w", err) // wrap EOF, it's corrupt return cid.Undef, xerrors.Errorf("error reading hash: %w", err) // wrap EOF, it's corrupt
} }

2
blockstore/splitstore/markset_map.go
View File

@ -71,7 +71,7 @@ func (e *MapMarkSetEnv) Recover(name string) (MarkSet, error) {
} }
key := make([]byte, int(sz)) key := make([]byte, int(sz))
if _, err = buf.Read(key); err != nil { if _, err = io.ReadFull(buf, key); err != nil {
break break
} }