Method EmitPacket

core/module.h:528–579

}

inline void Module::EmitPacket(Context *ctx, bess::Packet *pkt,
                               gate_idx_t ogate_idx) {
  // Check if valid ogate is set
  if (unlikely(ogates_.size() <= ogate_idx) || unlikely(!ogates_[ogate_idx])) {
    DropPacket(ctx, pkt);
    return;
  }

  Task *task = ctx->task;

  // Put a packet into the ogate
  bess::OGate *ogate = ogates_[ogate_idx];
  bess::IGate *igate = ogate->igate();
  bess::PacketBatch *batch = task->get_gate_batch(ogate);
  if (!batch) {
    if (!ogate->hooks().empty()) {
      // Having separate batch to run ogate hooks
      batch = task->AllocPacketBatch();
      task->set_gate_batch(ogate, batch);
      ctx->gate_with_hook[ctx->gate_with_hook_cnt++] = ogate_idx;
    } else {
      // If no ogate hooks, just use next igate batch
      batch = task->get_gate_batch(igate);
      if (batch == nullptr) {
        batch = task->AllocPacketBatch();
        task->AddToRun(igate, batch);
        task->set_gate_batch(ogate, batch);
      } else {
        task->set_gate_batch(ogate, task->get_gate_batch(igate));
      }
      ctx->gate_without_hook[ctx->gate_without_hook_cnt++] = ogate_idx;
    }
  }

  if (static_cast<size_t>(batch->cnt()) >= bess::PacketBatch::kMaxBurst) {
    if (!ogate->hooks().empty()) {
      for (auto &hook : ogate->hooks()) {
        hook->ProcessBatch(task->get_gate_batch(ogate));
      }
      task->AddToRun(igate, task->get_gate_batch(ogate));
      batch = task->AllocPacketBatch();
      task->set_gate_batch(ogate, batch);
    } else {
      // allocate a new batch and push
      batch = task->AllocPacketBatch();
      task->set_gate_batch(ogate, batch);
      task->AddToRun(igate, batch);
    }
  }

  batch->add(pkt);
}

inline void Module::ProcessOGates(Context *ctx) {
  Task *task = ctx->task;