Method ScanMetaTableCallBack

src/sdk/table_impl.cc:1639–1722

}

void TableImpl::ScanMetaTableCallBack(std::string key_start, std::string key_end,
                                      std::string expand_key_end, int64_t start_time,
                                      ScanTabletRequest* request, ScanTabletResponse* response,
                                      bool failed, int error_code) {
  perf_counter_.get_meta.Add(get_micros() - start_time);
  perf_counter_.get_meta_cnt.Inc();
  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) {
    VLOG(10) << "fail to scan meta table [" << request->start() << ", " << request->end()
             << "]: " << StatusCodeToString(err);
    {
      MutexLock lock(&meta_mutex_);
      GiveupUpdateTabletMeta(key_start, key_end);
    }
    ThreadPool::Task retry_task = std::bind(&TableImpl::ScanMetaTableAsyncInLock, this, key_start,
                                            key_end, expand_key_end, true);
    thread_pool_->DelayTask(FLAGS_tera_sdk_update_meta_internal, retry_task);
    delete request;
    delete response;
    return;
  }

  std::string return_start, return_end;
  const RowResult& scan_result = response->results();
  for (int32_t i = 0; i < scan_result.key_values_size(); i++) {
    const KeyValuePair& kv = scan_result.key_values(i);

    TabletMeta meta;
    ParseMetaTableKeyValue(kv.key(), kv.value(), &meta);

    if (i == 0) {
      return_start = meta.key_range().key_start();
    }
    if (i == scan_result.key_values_size() - 1) {
      return_end = meta.key_range().key_end();
    }

    MutexLock lock(&meta_mutex_);
    UpdateTabletMetaList(meta);
  }