fwd.h

Go to the documentation of this file.

#ifndef NDNDPDK_FWDP_FWD_H
#define NDNDPDK_FWDP_FWD_H

 
#include "../core/running-stat.h"
#include "../dpdk/thread.h"
#include "../fib/fib.h"
#include "../fib/nexthop-filter.h"
#include "../iface/face.h"
#include "../iface/pktqueue.h"
#include "../pcct/cs.h"
#include "../pcct/pit.h"
#include "../strategyapi/api.h"
 
typedef struct FwFwdCtx FwFwdCtx;

typedef struct FwFwd {
  SgGlobal sgGlobal;
  ThreadCtrl ctrl;
  PktQueue queueI;
  PktQueue queueD;
  PktQueue queueN;
 
  Fib* fib;
  Pit* pit;
  Cs* cs;
 
  pcg32_random_t sgRng;
  PitSuppressConfig suppressCfg;
 
  uint8_t id;          
  uint8_t fibDynIndex; 
 
  uint64_t nNoFibMatch;   
  uint64_t nDupNonce;     
  uint64_t nSgNoFwd;      
  uint64_t nNackMismatch; 
 
  PacketMempools mp; 
 
  struct rte_ring* cryptoHelper; 

  RunningStat latencyStat;
} FwFwd;
 
__attribute__((nonnull)) int
FwFwd_Run(FwFwd* fwd);
 
__attribute__((nonnull)) void
FwFwd_RxInterest(FwFwd* fwd, FwFwdCtx* ctx);
 
__attribute__((nonnull)) void
FwFwd_RxData(FwFwd* fwd, FwFwdCtx* ctx);
 
__attribute__((nonnull)) void
FwFwd_RxNack(FwFwd* fwd, FwFwdCtx* ctx);

struct FwFwdCtx {
  FwFwd* fwd;             // T,F,I,D,N
  TscTime rxTime;         // T(=now),F,I,D,N
  SgEvent eventKind;      // T,F,I,D,N
  FibNexthopFilter nhFlt; // T,I,D,N
  union {
    Packet* npkt;
    struct rte_mbuf* pkt;
  }; // F,D,N
  FibEntry* fibEntry;       // T,I,D,N
  FibEntryDyn* fibEntryDyn; // T,I,D,N
  PitEntry* pitEntry;       // T,I,D,N
 
  // end of SgCtx fields
  RTE_MARKER endofSgCtx;
 
  PitUp* pitUp;       // N
  LpPitToken rxToken; // F,I,D,N
  uint32_t dnNonce;   // I
  int nForwarded;     // T,I,N
  FaceID rxFace;      // F,I,D
};

__attribute__((nonnull)) static inline void
FwFwdCtx_FreePkt(FwFwdCtx* ctx) {
  Packet_Free(ctx->npkt);
  NULLize(ctx->npkt);
}

__attribute__((nonnull(1))) static inline void
FwFwdCtx_SetFibEntry(FwFwdCtx* ctx, FibEntry* fibEntry) {
  ctx->fibEntry = fibEntry;
  if (likely(fibEntry != NULL)) {
    ctx->fibEntryDyn = FibEntry_PtrDyn(fibEntry, ctx->fwd->fibDynIndex);
  } else {
    ctx->fibEntryDyn = NULL;
  }
}
 
#endif // NDNDPDK_FWDP_FWD_H