(data []byte)
| 89 | } |
| 90 | |
| 91 | func (i *inputStatsReader) Read(data []byte) (int, error) { |
| 92 | n, err := i.r.Read(data) |
| 93 | if i.sz != 0 { |
| 94 | atomic.AddInt64(&i.n, int64(n)) |
| 95 | atomic.AddInt64(&i.s.processedSize, int64(n)) |
| 96 | } |
| 97 | return n, err |
| 98 | } |
| 99 | |
| 100 | func (i *inputStatsReader) Close() error { |
| 101 | // If we knew the size of the file in advanced, and it's not been fully |
no outgoing calls