fix: track after buffer write
This commit is contained in:
parent
c984d72cfd
commit
0b000bfc89
|
@ -63,14 +63,14 @@ func (v *Verifier) Read(p []byte) (int, error) {
|
||||||
return n, errors.Join(ErrVerifyFailed, err)
|
return n, errors.Join(ErrVerifyFailed, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
v.read += uint64(bytesRead)
|
||||||
|
v.buffer.Write(buf[:bytesRead]) // Append new data to the buffer
|
||||||
|
|
||||||
timeEnd := time.Now()
|
timeEnd := time.Now()
|
||||||
v.verifyTime += timeEnd.Sub(timeStart)
|
v.verifyTime += timeEnd.Sub(timeStart)
|
||||||
averageVerifyTime := v.verifyTime / time.Duration(v.read/VERIFY_CHUNK_SIZE)
|
averageVerifyTime := v.verifyTime / time.Duration(v.read/VERIFY_CHUNK_SIZE)
|
||||||
v.logger.Debug("Verification time", zap.Duration("duration", timeEnd.Sub(timeStart)), zap.Duration("average", averageVerifyTime))
|
v.logger.Debug("Verification time", zap.Duration("duration", timeEnd.Sub(timeStart)), zap.Duration("average", averageVerifyTime))
|
||||||
|
|
||||||
v.read += uint64(bytesRead)
|
|
||||||
v.buffer.Write(buf[:bytesRead]) // Append new data to the buffer
|
|
||||||
|
|
||||||
if err == io.EOF {
|
if err == io.EOF {
|
||||||
// If EOF, break the loop as no more data can be read
|
// If EOF, break the loop as no more data can be read
|
||||||
break
|
break
|
||||||
|
|
Loading…
Reference in New Issue