| 599 | } |
| 600 | |
| 601 | void ScanRange::InitInternal(DiskIoMgr* io_mgr, RequestContext* reader) { |
| 602 | DCHECK(!read_in_flight_); |
| 603 | io_mgr_ = io_mgr; |
| 604 | reader_ = reader; |
| 605 | buffer_manager_->Init(); |
| 606 | cancel_status_ = Status::OK(); |
| 607 | eosr_queued_ = false; |
| 608 | blocked_on_buffer_ = false; |
| 609 | bytes_read_ = 0; |
| 610 | sub_range_pos_ = {}; |
| 611 | file_reader_->ResetState(); |
| 612 | if (local_buffer_reader_ != nullptr) local_buffer_reader_->ResetState(); |
| 613 | unique_lock<mutex> scan_range_lock(lock_); |
| 614 | DCHECK(Validate(scan_range_lock)) << DebugString(); |
| 615 | } |
| 616 | |
| 617 | void ScanRange::SetFileReader(unique_ptr<FileReader> file_reader) { |
| 618 | file_reader_ = move(file_reader); |
no test coverage detected