Method connect_proxy

runners/BaseRunner.cpp:506–535

 */

void BaseRunner::connect_proxy() {
  LOG(DEBUG) << "connecting to proxy";
  if (!runner_config_) {
    LOG(DEBUG) << "no root contract";
    return;
  }

  auto proxy = runner_config_->root_contract_config->get_random_proxy();
  if (!proxy) {
    LOG(WARNING) << "cannot connection to a proxy: no proxies in root contract";
    return;
  }

  td::IPAddress dst_addr =
      connect_to_proxy_to_client_address_ ? proxy->address_for_clients : proxy->address_for_workers;
  if (get_proxy_target_by_address(dst_addr)) {
    LOG(DEBUG) << "duplicate";
    /* duplicate */
    return;
  }
  auto target_id = generate_unique_uint64();
  auto p = allocate_proxy_target(target_id, dst_addr);
  if (!p) {
    LOG(WARNING) << "cannot allocate proxy target";
    return;
  }
  td::actor::send_closure(client_, &TcpClient::add_outbound_address, target_id, dst_addr, remote_app_type_proxy());
  CHECK(proxy_targets_.emplace(target_id, std::move(p)).second);
  LOG(INFO) << "OK, connecting to " << dst_addr;
}

void BaseRunner::disconnect_proxy(TcpClient::TargetId target_id) {
  LOG(INFO) << "disconnecting from proxy...";