Method SetUniqueGateIdx

core/module_graph.cc:143–182

}

void ModuleGraph::SetUniqueGateIdx() {
  bess::utils::extended_priority_queue<bess::OGate *> ogates_queue;
  bess::utils::extended_priority_queue<bess::IGate *, IGateGreater>
      igates_queue;
  std::unordered_set<bess::IGate *> igates_pushed;

  for (auto const &e : all_modules_) {
    std::vector<bess::OGate *> ogates = e.second->ogates();
    for (size_t i = 0; i < ogates.size(); i++) {
      if (!ogates[i]) {
        continue;
      }

      ogates_queue.push(ogates[i]);

      bess::IGate *igate = ogates[i]->igate();
      if (igates_pushed.count(igate) != 0) {
        continue;
      }

      igates_pushed.insert(igate);
      igates_queue.push(igate);
    }
  }

  gate_cnt_ = 0;
  while (!igates_queue.empty()) {
    bess::IGate *igate = igates_queue.top();
    igates_queue.pop();

    igate->SetUniqueIdx(gate_cnt_++);
  }

  while (!ogates_queue.empty()) {
    bess::OGate *ogate = ogates_queue.top();
    ogates_queue.pop();

    ogate->SetUniqueIdx(gate_cnt_++);
  }
}

void ModuleGraph::ConfigureTasks() {
  for (int i = 0; i < Worker::kMaxWorkers; i++) {