logic.h

Go to the documentation of this file.

#ifndef NDNDPDK_FETCH_LOGIC_H
#define NDNDPDK_FETCH_LOGIC_H

 
#include "../core/rttest.h"
#include "tcpcubic.h"
#include "window.h"
 
typedef TAILQ_HEAD(FetchRetxQueue, FetchSeg) FetchRetxQueue;

typedef struct FetchLogic {
  FetchWindow win;
  RttEst rtte;
  TcpCubic ca;
  struct cds_list_head retxQ;
  MinSched* sched;
  uint64_t segmentEnd; 
  TscTime startTime;   
  TscTime finishTime;  
  TscTime nextCwndDec; 
  uint64_t nTxRetx;    
  uint64_t nRxData;    
  uint32_t nInFlight;  
} FetchLogic;
 
__attribute__((nonnull)) void
FetchLogic_Init(FetchLogic* fl, uint32_t winCapacity, int numaSocket);
 
__attribute__((nonnull)) void
FetchLogic_Free(FetchLogic* fl);
 
__attribute__((nonnull)) void
FetchLogic_Reset(FetchLogic* fl, uint64_t segmentBegin, uint64_t segmentEnd);

__attribute__((nonnull)) size_t
FetchLogic_TxInterestBurst(FetchLogic* fl, uint64_t* segNums, size_t limit, TscTime now);
 
typedef struct FetchLogicRxData {
  uint64_t segNum;
  uint8_t congMark;
  bool isFinalBlock;
} FetchLogicRxData;

__attribute__((nonnull)) void
FetchLogic_RxDataBurst(FetchLogic* fl, const FetchLogicRxData* pkts, size_t count, TscTime now);
 
#endif // NDNDPDK_FETCH_LOGIC_H