Method ResizeQueue

core/modules/drr.cc:385–409

}

llring *DRR::ResizeQueue(llring *old_queue, uint32_t new_size, int *err) {
  llring *new_queue = AddQueue(new_size, err);
  if (*err != 0) {
    return nullptr;
  }

  // migrates packets from the old queue
  if (old_queue) {
    bess::Packet *pkt;

    while (llring_dequeue(old_queue, reinterpret_cast<void **>(&pkt)) == 0) {
      *err = llring_enqueue(new_queue, pkt);
      if (*err == -LLRING_ERR_NOBUF) {
        bess::Packet::Free(pkt);
        *err = 0;
      } else if (*err != 0) {
        std::free(new_queue);
        return nullptr;
      }
    }

    std::free(old_queue);
  }
  return new_queue;
}

CommandResponse DRR::SetQuantumSize(uint32_t size) {
  if (size == 0) {