void AsyncScanRpcRetryingCaller::CompleteWhenError()

in src/hbase/client/async-scan-rpc-retrying-caller.cc [283:297]


void AsyncScanRpcRetryingCaller::CompleteWhenError(bool close_scanner) {
  VLOG(5) << "Scan: CompleteWhenError, scanner_id:" << scanner_id_;
  results_cache_->Clear();
  if (close_scanner) {
    CloseScanner();
  }
  if (next_start_row_when_error_) {
    // TODO: HBASE-17583 adds include start / stop row to the Scan. Once we rebase and implement
    // those options in Scan , we can start using that here.
    scan_->SetStartRow(include_next_start_row_when_error_
                           ? *next_start_row_when_error_
                           : BytesUtil::CreateClosestRowAfter(*next_start_row_when_error_));
  }
  promise_->setValue(true);
}