Method Init

core/modules/nat.cc:65–113

TODO(torek): move this to set/get runtime config

// TODO(torek): move this to set/get runtime config
CommandResponse NAT::Init(const bess::pb::NATArg &arg) {
  // Check before committing any changes.
  for (const auto &address_range : arg.ext_addrs()) {
    for (const auto &range : address_range.port_ranges()) {
      if (range.begin() >= range.end() || range.begin() > UINT16_MAX ||
          range.end() > UINT16_MAX) {
        return CommandFailure(EINVAL, "Port range for address %s is malformed",
                              address_range.ext_addr().c_str());
      }
    }
  }

  for (const auto &address_range : arg.ext_addrs()) {
    auto ext_addr = address_range.ext_addr();
    be32_t addr;

    bool ret = bess::utils::ParseIpv4Address(ext_addr, &addr);
    if (!ret) {
      return CommandFailure(EINVAL, "invalid IP address %s", ext_addr.c_str());
    }

    ext_addrs_.push_back(addr);
    // Add a port range list
    std::vector<PortRange> port_list;
    if (address_range.port_ranges().size() == 0) {
      port_list.emplace_back(PortRange{
          .begin = 0u, .end = 65535u, .suspended = false,
      });
    }
    for (const auto &range : address_range.port_ranges()) {
      port_list.emplace_back(PortRange{
          .begin = (uint16_t)range.begin(),
          .end = (uint16_t)range.end(),
          // Control plane gets to decide if the port range can be used.
          .suspended = range.suspended()});
    }
    port_ranges_.push_back(port_list);
  }

  if (ext_addrs_.empty()) {
    return CommandFailure(EINVAL,
                          "at least one external IP address must be specified");
  }

  // Sort so that GetInitialArg is predictable and consistent.
  std::sort(ext_addrs_.begin(), ext_addrs_.end());

  return CommandSuccess();
}

CommandResponse NAT::GetInitialArg(const bess::pb::EmptyArg &) {
  bess::pb::NATArg resp;