Method ScanCallBack

src/sdk/table_impl.cc:502–545

}

void TableImpl::ScanCallBack(ScanTask* scan_task, ScanTabletRequest* request,
                             ScanTabletResponse* response, bool failed, int error_code) {
  perf_counter_.rpc_s.Add(get_micros() - request->timestamp());
  perf_counter_.rpc_s_cnt.Inc();
  ResultStreamImpl* stream = scan_task->stream;

  if (failed) {
    if (error_code == sofa::pbrpc::RPC_ERROR_SERVER_SHUTDOWN ||
        error_code == sofa::pbrpc::RPC_ERROR_SERVER_UNREACHABLE ||
        error_code == sofa::pbrpc::RPC_ERROR_SERVER_UNAVAILABLE) {
      response->set_status(kServerError);
    } else if (error_code == sofa::pbrpc::RPC_ERROR_REQUEST_CANCELED ||
               error_code == sofa::pbrpc::RPC_ERROR_SEND_BUFFER_FULL) {
      response->set_status(kClientError);
    } else if (error_code == sofa::pbrpc::RPC_ERROR_CONNECTION_CLOSED ||
               error_code == sofa::pbrpc::RPC_ERROR_RESOLVE_ADDRESS) {
      response->set_status(kConnectError);
    } else if (error_code == sofa::pbrpc::RPC_ERROR_REQUEST_TIMEOUT) {
      response->set_status(kRPCTimeout);
    } else {
      response->set_status(kRPCError);
    }
  }

  StatusCode err = response->status();
  if (err != kTabletNodeOk && err != kSnapshotNotExist) {
    VLOG(10) << "fail to scan table: " << name_ << " errcode: " << StatusCodeToString(err);
  }

  scan_task->SetInternalError(err);
  if (err == kKeyNotInRange || err == kConnectError) {
    ScheduleUpdateMeta(stream->GetScanDesc()->GetStartRowKey(), scan_task->GetMetaTimeStamp());
  }
  if (err == kNotPermission) {
    // Couldn't stop session_retry
    // TODO: scan add Cancel() method for this scaning tablet
    VLOG(10) << "fail to scan table: " << name_ << " errcode: " << StatusCodeToString(err);
  }
  stream->OnFinish(request, response);
  stream->ReleaseRpcHandle(request, response);
  task_pool_.PopTask(scan_task->GetId());
  CHECK_EQ(scan_task->GetRef(), 2);
  delete scan_task;
}

void TableImpl::SetReadTimeout(int64_t timeout_ms) {}