Method CommandUpdate

core/modules/flowgen.cc:277–347

}

CommandResponse FlowGen::CommandUpdate(const bess::pb::FlowGenArg &arg) {
  if (arg.template_().length() > 0) {
    LOG(INFO) << "Updating FlowGen 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_);
  }

  double prev_pps = 0;
  if (!(std::isnan(arg.pps()) || arg.pps() == 0.0)) {
    if (arg.pps() < 0) {
      return CommandFailure(EINVAL, "pps cannot be negative");
    }

    LOG(INFO) << "Updating FlowGen pps" << arg.pps();
    prev_pps = total_pps_;
    total_pps_ = arg.pps();
  }

  double prev_flowrate = 0;
  if (!(std::isnan(arg.flow_rate()) || arg.flow_rate() == 0.0)) {
    if (arg.flow_rate() < 0) {
      return CommandFailure(EINVAL, "flow rate cannot be negative");
    }

    LOG(INFO) << "Updating FlowGen flow rate" << arg.flow_rate();

    prev_flowrate = flow_rate_;
    flow_rate_ = arg.flow_rate();
  }

  if (flow_rate_ > total_pps_) {
    flow_rate_ = prev_flowrate;
    total_pps_ = prev_pps;
    return CommandFailure(EINVAL, "flow rate cannot be more than pps");
  }

  if (!(std::isnan(arg.flow_duration()) || arg.flow_duration() == 0.0)) {
    if (arg.flow_duration() < 0) {
      return CommandFailure(EINVAL, "flow duration cannot be negative");
    }

    LOG(INFO) << "Updating FlowGen flow duration" << arg.flow_duration();
    flow_duration_ = arg.flow_duration();
  }

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