Method DoScheduleRpc

src/tabletnode/remote_tabletnode.cc:764–790

}

void RemoteTabletNode::DoScheduleRpc(RpcSchedule* rpc_schedule) {
  RpcTask* rpc = NULL;
  bool status = rpc_schedule->DequeueRpc(&rpc);
  CHECK(status);
  std::string table_name;

  switch (rpc->rpc_type) {
    case RPC_READ: {
      ReadRpc* read_rpc = (ReadRpc*)rpc;
      table_name = read_rpc->request->tablet_name();
      DoReadTablet(read_rpc->controller, read_rpc->start_micros, read_rpc->request,
                   read_rpc->response, read_rpc->done, read_rpc->timer);
    } break;
    case RPC_SCAN: {
      ScanRpc* scan_rpc = (ScanRpc*)rpc;
      table_name = scan_rpc->request->table_name();
      scan_pending_counter.Dec();
      DoScanTablet(scan_rpc->controller, scan_rpc->request, scan_rpc->response, scan_rpc->done);
    } break;
    default:
      abort();
  }

  delete rpc;
  status = rpc_schedule->FinishRpc(table_name);
  CHECK(status);
}

}  // namespace tabletnode
}  // namespace tera