producer.h

Go to the documentation of this file.

#ifndef NDNDPDK_TGPRODUCER_PRODUCER_H
#define NDNDPDK_TGPRODUCER_PRODUCER_H

 
#include "../dpdk/thread.h"
#include "../iface/face.h"
#include "../iface/pktqueue.h"
#include "../vendor/pcg_basic.h"
#include "enum.h"
 
typedef uint8_t TgpReplyID;
 
typedef struct TgpReply {
  uint64_t nInterests;
  DataGen dataGen;
  uint8_t kind;
  uint8_t nackReason;
} TgpReply;

typedef struct TgpPattern {
  uint32_t nWeights;
  uint8_t nReplies;
  TgpReplyID weight[TgpMaxSumWeight];
  TgpReply reply[TgpMaxReplies];
} TgpPattern;

typedef struct Tgp {
  ThreadCtrl ctrl;
  PktQueue rxQueue;
  PacketMempools mp; 
  FaceID face;
  uint8_t nPatterns;
 
  uint64_t nNoMatch;
  uint64_t nAllocError;
  pcg32_random_t replyRng;
 
  uint16_t prefixL[TgpMaxPatterns];
  uint8_t prefixV[TgpMaxPatterns * NameMaxLength];
  TgpPattern pattern[TgpMaxPatterns];
} Tgp;
 
__attribute__((nonnull)) int
Tgp_Run(Tgp* p);
 
#endif // NDNDPDK_TGPRODUCER_PRODUCER_H