Method WakeUpPendingRequest

src/sdk/table_impl.cc:1832–1894

}

void TableImpl::WakeUpPendingRequest(const TabletMetaNode& node) {
  meta_mutex_.AssertHeld();
  const std::string& start_key = node.meta.key_range().key_start();
  const std::string& end_key = node.meta.key_range().key_end();
  const std::string& server_addr = node.meta.server_addr();
  int64_t meta_timestamp = node.update_time;

  std::vector<SdkTask*> mutation_list;
  std::vector<SdkTask*> reader_list;
  std::vector<SdkTask*> batch_mutation_list;

  std::map<std::string, std::list<int64_t> >::iterator it =
      pending_task_id_list_.lower_bound(start_key);
  while (it != pending_task_id_list_.end()) {
    if (!end_key.empty() && it->first >= end_key) {
      break;
    }
    std::list<int64_t>& task_id_list = it->second;
    for (std::list<int64_t>::iterator itask = task_id_list.begin(); itask != task_id_list.end();
         ++itask) {
      perf_counter_.meta_update_cnt.Inc();
      int64_t task_id = *itask;
      SdkTask* task = task_pool_.GetTask(task_id);
      if (task == NULL) {
        VLOG(10) << "task " << task_id << " timeout when update meta success";
        continue;
      }
      task->SetMetaTimeStamp(meta_timestamp);

      switch (task->Type()) {
        case SdkTask::READ: {
          reader_list.push_back(task);
        } break;
        case SdkTask::MUTATION: {
          mutation_list.push_back(task);
        } break;
        case SdkTask::BATCH_MUTATION: {
          batch_mutation_list.push_back(task);
        } break;
        case SdkTask::SCAN: {
          ScanTask* scan_task = (ScanTask*)task;
          CommitScan(scan_task, server_addr);
        } break;
        default:
          CHECK(false);
          break;
      }
    }
    std::map<std::string, std::list<int64_t> >::iterator tmp = it;
    ++it;
    pending_task_id_list_.erase(tmp);
  }

  if (mutation_list.size() > 0) {
    PackSdkTasks(server_addr, mutation_list, SdkTask::MUTATION);
  }
  if (reader_list.size() > 0) {
    PackSdkTasks(server_addr, reader_list, SdkTask::READ);