Handle the case where the requested amount is larger than the chunk

rpcpool · Oct 8, 2023 · 71ad5b5 · 71ad5b5
1 parent 3279987
commit 71ad5b5
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/readahead/readahead.go b/readahead/readahead.go
@@ -57,6 +57,12 @@ func (cr *CachingReader) Read(p []byte) (int, error) {
 		return 0, nil
 	}
 
+	if len(p) > cr.chunkSize {
+		cr.buffer.Reset() // clear buffer
+		// If the read is larger than the chunk size, read directly from the file
+		return cr.file.Read(p)
+	}
+
 	// Refill the buffer if needed
 	if cr.buffer.Len() < len(p) {
 		tmp := make([]byte, cr.chunkSize)