rangereader.go 961 B

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
  1. package filex
  2. import (
  3. "errors"
  4. "os"
  5. )
  6. // errExceedFileSize indicates that the file size is exceeded.
  7. var errExceedFileSize = errors.New("exceed file size")
  8. // A RangeReader is used to read a range of content from a file.
  9. type RangeReader struct {
  10. file *os.File
  11. start int64
  12. stop int64
  13. }
  14. // NewRangeReader returns a RangeReader, which will read the range of content from file.
  15. func NewRangeReader(file *os.File, start, stop int64) *RangeReader {
  16. return &RangeReader{
  17. file: file,
  18. start: start,
  19. stop: stop,
  20. }
  21. }
  22. // Read reads the range of content into p.
  23. func (rr *RangeReader) Read(p []byte) (n int, err error) {
  24. stat, err := rr.file.Stat()
  25. if err != nil {
  26. return 0, err
  27. }
  28. if rr.stop < rr.start || rr.start >= stat.Size() {
  29. return 0, errExceedFileSize
  30. }
  31. if rr.stop-rr.start < int64(len(p)) {
  32. p = p[:rr.stop-rr.start]
  33. }
  34. n, err = rr.file.ReadAt(p, rr.start)
  35. if err != nil {
  36. return n, err
  37. }
  38. rr.start += int64(n)
  39. return
  40. }