no need to reset s.rows if error
Vladimir Bauer
3 years ago
| 340 | 340 | b := heap.Pop(&s.bHeap).(*Bar) |
| 341 | 341 | frame := <-b.frameCh |
| 342 | 342 | if frame.err != nil { |
| 343 | s.rows = s.rows[:0] | |
| 344 | 343 | return frame.err |
| 345 | 344 | } |
| 346 | 345 | var usedRows int |
| 408 | 407 | for i := len(s.rows) - 1; i >= 0; i-- { |
| 409 | 408 | _, err := cw.ReadFrom(s.rows[i]) |
| 410 | 409 | if err != nil { |
| 411 | s.rows = s.rows[:0] | |
| 412 | 410 | return err |
| 413 | 411 | } |
| 414 | 412 | } |