source.h

Go to the documentation of this file.

#ifndef NDNDPDK_PDUMP_SOURCE_H
#define NDNDPDK_PDUMP_SOURCE_H

 
#include "../core/urcu.h"
#include "../iface/faceid.h"
#include "../vendor/pcg_basic.h"
#include "enum.h"
#include <urcu-pointer.h>
 
typedef struct PdumpSource PdumpSource;
 
typedef bool (*PdumpSource_Filter)(PdumpSource* s, struct rte_mbuf* pkt);

struct PdumpSource {
  struct rte_mempool* directMp;
  struct rte_ring* queue;
  PdumpSource_Filter filter;
  uint32_t mbufType;
  uint16_t mbufPort;
  bool mbufCopy;
};

__attribute__((nonnull)) void
PdumpSource_Process(PdumpSource* s, struct rte_mbuf** pkts, uint16_t count);

typedef struct PdumpSourceRef {
  PdumpSource* s;
} PdumpSourceRef;

__attribute__((nonnull(1))) PdumpSource*
PdumpSourceRef_Set(PdumpSourceRef* ref, PdumpSource* s);

__attribute__((nonnull)) static __rte_always_inline PdumpSource*
PdumpSourceRef_Get(PdumpSourceRef* ref) {
  return rcu_dereference(ref->s);
}

__attribute__((nonnull)) static __rte_always_inline bool
PdumpSourceRef_Process(PdumpSourceRef* ref, struct rte_mbuf** pkts, uint16_t count) {
  PdumpSource* s = PdumpSourceRef_Get(ref);
  if (s == NULL) {
    return false;
  }
  PdumpSource_Process(s, pkts, count);
  return true;
}

typedef struct PdumpFaceSource {
  PdumpSource base;
  pcg32_random_t rng;
  uint32_t sample[PdumpMaxNames];
  uint16_t nameL[PdumpMaxNames];
  uint8_t nameV[PdumpMaxNames * NameMaxLength];
} PdumpFaceSource;

__attribute__((nonnull)) bool
PdumpFaceSource_Filter(PdumpSource* s, struct rte_mbuf* pkt);
 
extern PdumpSourceRef gPdumpEthPortSources[RTE_MAX_ETHPORTS];

typedef struct PdumpEthPortUnmatchedCtx {
  PdumpSource* source;
  uint16_t count;
  struct rte_mbuf* pkts[MaxBurstSize];
} PdumpEthPortUnmatchedCtx;

static __rte_always_inline void
PdumpEthPortUnmatchedCtx_Init(PdumpEthPortUnmatchedCtx* ctx, uint16_t port) {
  PdumpSourceRef* ref = &gPdumpEthPortSources[port];
  ctx->source = PdumpSourceRef_Get(ref);
  ctx->count = 0;
  POISON(ctx->pkts);
}

static __rte_always_inline bool
PdumpEthPortUnmatchedCtx_Append(PdumpEthPortUnmatchedCtx* ctx, struct rte_mbuf* pkt) {
  if (ctx->source == NULL) {
    return false;
  }
  ctx->pkts[ctx->count++] = pkt;
  return true;
}

static __rte_always_inline void
PdumpEthPortUnmatchedCtx_Process(PdumpEthPortUnmatchedCtx* ctx) {
  if (ctx->source == NULL || ctx->count == 0) {
    return;
  }
  PdumpSource_Process(ctx->source, ctx->pkts, ctx->count);
  NULLize(ctx->source);
  POISON(ctx->pkts);
}
 
#endif // NDNDPDK_PDUMP_SOURCE_H