Method ProcessArguments

core/modules/flowgen.cc:183–256

}

CommandResponse FlowGen::ProcessArguments(const bess::pb::FlowGenArg &arg) {
  if (arg.template_().length() == 0) {
    return CommandFailure(EINVAL, "must specify 'template'");
  }

  if (arg.template_().length() > MAX_TEMPLATE_SIZE) {
    return CommandFailure(EINVAL, "'template' is too big");
  }

  template_size_ = arg.template_().length();

  memset(templ_, 0, MAX_TEMPLATE_SIZE);
  bess::utils::Copy(templ_, arg.template_().c_str(), template_size_);
  CommandResponse err = UpdateBaseAddresses();
  if (err.error().code() != 0) {
    return err;
  }

  total_pps_ = arg.pps();
  if (std::isnan(total_pps_) || total_pps_ < 0.0) {
    return CommandFailure(EINVAL, "invalid 'pps'");
  }

  flow_rate_ = arg.flow_rate();
  if (std::isnan(flow_rate_) || flow_rate_ < 0.0) {
    return CommandFailure(EINVAL, "invalid 'flow_rate'");
  }

  flow_duration_ = arg.flow_duration();
  if (std::isnan(flow_duration_) || flow_duration_ < 0.0) {
    return CommandFailure(EINVAL, "invalid 'flow_duration'");
  }

  if (arg.arrival() == "uniform") {
    arrival_ = Arrival::kUniform;
  } else if (arg.arrival() == "exponential") {
    arrival_ = Arrival::kExponential;
  } else {
    return CommandFailure(
        EINVAL, "'arrival' must be either 'uniform' or 'exponential'");
  }

  if (arg.duration() == "uniform") {
    duration_ = Duration::kUniform;
  } else if (arg.duration() == "pareto") {
    duration_ = Duration::kPareto;
  } else {
    return CommandFailure(EINVAL,
                          "'duration' must be either 'uniform' or 'pareto'");
  }

  if (arg.quick_rampup()) {
    quick_rampup_ = 1;
  }

  ip_src_range_ = arg.ip_src_range();
  ip_dst_range_ = arg.ip_dst_range();