import/import.go

@@ -223,16 +223,13 @@ func (i *ImportReader) Close() error {
 func (i *ImportReader) Read(p []byte) (n int, err error) {
 	n, err = i.reader.Read(p)
 	if err != nil {
-		if err == io.EOF {
-			return n, err
-		}
 		return 0, err
 	}
 
 	// Update cumulative bytes read
 	i.bytesRead += uint64(n)
 
-	err = i.ReadBytes(0)
+	err = i.ReadBytes(n)
 	if err != nil {
 		return 0, err
 	}
@@ -241,9 +238,6 @@ func (i *ImportReader) Read(p []byte) (n int, err error) {
 }
 
 func (i *ImportReader) ReadBytes(n int) (err error) {
-	if n > 0 {
-		i.bytesRead += uint64(n)
-	}
 	stageProgress := float64(100) / float64(i.totalStages)
 
 	// Calculate progress based on bytes read