use ReadFull (#40) (#8240)

* use ReadFull

* fix error checking
This commit is contained in:
Feng Shao
2026-02-07 12:51:47 +08:00
committed by GitHub
parent 2163570d16
commit 963398ac8c

View File

@@ -98,7 +98,7 @@ func (c *commandFsMetaLoad) Do(args []string, commandEnv *CommandEnv, writer io.
var wg sync.WaitGroup
for {
if n, err := dst.Read(sizeBuf); n != 4 {
if _, err := io.ReadFull(dst, sizeBuf); err != nil {
if err == io.EOF {
return nil
}
@@ -109,7 +109,7 @@ func (c *commandFsMetaLoad) Do(args []string, commandEnv *CommandEnv, writer io.
data := make([]byte, int(size))
if n, err := dst.Read(data); n != len(data) {
if _, err := io.ReadFull(dst, data); err != nil {
return err
}