rxloop.h

Go to the documentation of this file.

#ifndef NDNDPDK_IFACE_RXLOOP_H
#define NDNDPDK_IFACE_RXLOOP_H

 
#include "../dpdk/thread.h"
#include "face.h"
#include "input-demux.h"
#include <rte_bitset.h>

typedef struct RxGroupBurstCtx {
  RTE_BITSET_DECLARE(dropBits, MaxBurstSize);
  uint16_t nRx;
  RTE_MARKER zeroizeEnd_;
  struct rte_mbuf* pkts[MaxBurstSize];
} RxGroupBurstCtx;

__attribute__((nonnull)) static inline void
RxGroupBurstCtx_Drop(RxGroupBurstCtx* ctx, uint16_t i) {
  rte_bitset_set(ctx->dropBits, i);
}
 
typedef struct RxGroup RxGroup;

typedef void (*RxGroup_RxBurstFunc)(RxGroup* rxg, RxGroupBurstCtx* ctx);

struct RxGroup {
  struct cds_hlist_node rxlNode;
  RxGroup_RxBurstFunc rxBurst;
  int rxThread; 
};

typedef struct RxLoop {
  ThreadCtrl ctrl;
  InputDemuxes demuxes;
 
  struct cds_hlist_head head;
} RxLoop;
 
__attribute__((nonnull)) int
RxLoop_Run(RxLoop* rxl);
 
#endif // NDNDPDK_IFACE_RXLOOP_H