Method Enqueue

core/modules/drr.cc:358–383

}

void DRR::Enqueue(Flow *f, bess::Packet *newpkt, int *err) {
  // if the queue is full. drop the packet.
  if (llring_count(f->queue) >= max_queue_size_) {
    bess::Packet::Free(newpkt);
    return;
  }

  // creates a new queue if there is not enough space for the new packet
  // in the old queue
  if (llring_full(f->queue)) {
    uint32_t slots =
        RoundToPowerTwo(llring_count(f->queue) * kQueueGrowthFactor);
    f->queue = ResizeQueue(f->queue, slots, err);
    if (*err != 0) {
      bess::Packet::Free(newpkt);
      return;
    }
  }

  *err = llring_enqueue(f->queue, reinterpret_cast<void *>(newpkt));
  if (*err == 0) {
    f->timer = get_epoch_time();
  } else {
    bess::Packet::Free(newpkt);
  }
}

llring *DRR::ResizeQueue(llring *old_queue, uint32_t new_size, int *err) {
  llring *new_queue = AddQueue(new_size, err);