void AsyncScanRpcRetryingCaller::CompleteOrNext()

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

• 13 lines of code
• 5 McCabe index (conditional complexity)

void AsyncScanRpcRetryingCaller::CompleteOrNext(std::shared_ptr<pb::ScanResponse> resp) {
  VLOG(5) << "Scan: CompleteOrNext, scanner_id" << scanner_id_
          << ", response:" << resp->ShortDebugString();

  if (resp->has_more_results() && !resp->more_results()) {
    // RS tells us there is no more data for the whole scan
    CompleteNoMoreResults();
    return;
  }
  // TODO: Implement Scan::limit(), and check the limit here

  if (resp->has_more_results_in_region() && !resp->more_results_in_region()) {
    // TODO: check whether Scan is reversed here
    CompleteWhenNoMoreResultsInRegion();
    return;
  }
  Next();
}