Method CommandReset

core/modules/worker_split.cc:41–63

}

CommandResponse WorkerSplit::CommandReset(const bess::pb::WorkerSplitArg &arg) {
  if (arg.worker_gates().empty()) {
    for (int i = 0; i < Worker::kMaxWorkers; i++) {
      gates_[i] = i;
    }
    return CommandSuccess();
  }

  for (size_t i = 0; i < Worker::kMaxWorkers; i++) {
    gates_[i] = -1;
  }

  for (auto it : arg.worker_gates()) {
    gate_idx_t ogate = it.second;
    if (ogate >= MAX_GATES) {
      return CommandFailure(EINVAL, "output gate must be less than %" PRIu16,
                            MAX_GATES);
    }
    gates_[it.first] = ogate;
  }

  return CommandSuccess();
}

void WorkerSplit::ProcessBatch(Context *ctx, bess::PacketBatch *batch) {
  int gate = gates_[ctx->wid];