fetcher.h

Go to the documentation of this file.

#ifndef NDNDPDK_FETCH_FETCHER_H
#define NDNDPDK_FETCH_FETCHER_H

 
#include "../core/uring.h"
#include "../dpdk/thread.h"
#include "../iface/face.h"
#include "../iface/pktqueue.h"
#include "logic.h"

typedef struct FetchTask {
  struct cds_hlist_node fthNode; 
  PktQueue queueD;
  FetchLogic logic;
  uint32_t segmentLen; 
  int fd;              
  uint8_t index;       
  int8_t worker;       

  InterestTemplate tpl;
} FetchTask;

typedef struct FetchThread {
  Uring ur;
  ThreadCtrl ctrl;
 
  struct rte_mempool* interestMp;
  struct cds_hlist_head tasksHead;
  pcg32_random_t nonceRng;
  uint32_t uringWaitLbound;
  FaceID face;
 
  uint32_t uringCapacity;
} FetchThread;
 
__attribute__((nonnull)) int
FetchThread_Run(FetchThread* fth);
 
#endif // NDNDPDK_FETCH_FETCHER_H