Method ProcessBatch

core/modules/drr.cc:123–149

}

void DRR::ProcessBatch(Context *, bess::PacketBatch *batch) {
  int err = 0;

  // insert packets in the batch into their corresponding flows
  int cnt = batch->cnt();
  for (int i = 0; i < cnt; i++) {
    bess::Packet *pkt = batch->pkts()[i];

    // TODO(joshua): Add support for fragmented packets.
    FlowId id = GetId(pkt);
    auto it = flows_.Find(id);

    // if the Flow doesn't exist create one
    // and add the packet to the new Flow
    if (it == nullptr) {
      if (llring_full(flow_ring_)) {
        bess::Packet::Free(pkt);
      } else {
        AddNewFlow(pkt, id, &err);
        assert(err == 0);
      }
    } else {
      Enqueue(it->second, pkt, &err);
      assert(err == 0);
    }
  }
}

struct task_result DRR::RunTask(Context *ctx, bess::PacketBatch *batch,
                                void *) {