pktqueue.h

Go to the documentation of this file.

#ifndef NDNDPDK_IFACE_PKTQUEUE_H
#define NDNDPDK_IFACE_PKTQUEUE_H

 
#include "common.h"

typedef enum __rte_packed_begin PktQueuePopAct {
  PktQueuePopActPlain,
  PktQueuePopActDelay,
  PktQueuePopActCoDel,
} __rte_packed_end PktQueuePopAct;

typedef struct PktQueue {
  struct rte_ring* ring;     
  TscDuration target;        
  TscDuration interval;      
  uint32_t dequeueBurstSize; 
  uint32_t count;            
  uint32_t lastCount;        
  uint16_t recInvSqrt;       
  bool dropping;             
  PktQueuePopAct pop;        
  TscTime firstAboveTime;    
  TscTime dropNext;          
  TscDuration sojourn;       
  uint64_t nDrops;           
} PktQueue;

__attribute__((nonnull)) static inline uint32_t
PktQueue_Push(PktQueue* q, struct rte_mbuf* pkts[], uint32_t count) {
  return Mbuf_EnqueueVector(pkts, count, q->ring, false);
}

typedef struct PktQueuePopResult {
  uint32_t count; 
  bool drop;      
} PktQueuePopResult;
 
typedef PktQueuePopResult (*PktQueue_PopFunc)(PktQueue* q, struct rte_mbuf* pkts[], uint32_t count,
                                              TscTime now);
extern const PktQueue_PopFunc PktQueue_PopJmp[];

__attribute__((nonnull)) static inline PktQueuePopResult
PktQueue_Pop(PktQueue* q, struct rte_mbuf* pkts[], uint32_t count, TscTime now) {
  return PktQueue_PopJmp[q->pop](q, pkts, count, now);
}
 
#endif // NDNDPDK_IFACE_PKTQUEUE_H