NDN-DPDK
High-Speed Named Data Networking Forwarder
All Data Structures Files Functions Variables Typedefs Enumerations Enumerator Macros Pages
Data Structures | Typedefs | Functions
logic.h File Reference
#include "../core/rttest.h"
#include "tcpcubic.h"
#include "window.h"

Go to the source code of this file.

Data Structures

struct  FetchLogic
 Fetcher congestion control and scheduling logic. More...
 
struct  FetchLogicRxData
 

Typedefs

typedef struct FetchLogic FetchLogic
 Fetcher congestion control and scheduling logic. More...
 
typedef struct FetchLogicRxData FetchLogicRxData
 

Functions

typedef TAILQ_HEAD (FetchRetxQueue, FetchSeg) FetchRetxQueue
 
void FetchLogic_Init (FetchLogic *fl, uint32_t winCapacity, int numaSocket)
 
void FetchLogic_Free (FetchLogic *fl)
 
void FetchLogic_Reset (FetchLogic *fl, uint64_t segmentBegin, uint64_t segmentEnd)
 
size_t FetchLogic_TxInterestBurst (FetchLogic *fl, uint64_t *segNums, size_t limit, TscTime now)
 Request to transmit a burst of Interests. More...
 
void FetchLogic_RxDataBurst (FetchLogic *fl, const FetchLogicRxData *pkts, size_t count, TscTime now)
 Notify Data arrival. More...
 

Typedef Documentation

◆ FetchLogic

typedef struct FetchLogic FetchLogic

Fetcher congestion control and scheduling logic.

◆ FetchLogicRxData

Function Documentation

◆ FetchLogic_Free()

void FetchLogic_Free ( FetchLogic fl)

◆ FetchLogic_Init()

void FetchLogic_Init ( FetchLogic fl,
uint32_t  winCapacity,
int  numaSocket 
)

◆ FetchLogic_Reset()

void FetchLogic_Reset ( FetchLogic fl,
uint64_t  segmentBegin,
uint64_t  segmentEnd 
)

◆ FetchLogic_RxDataBurst()

void FetchLogic_RxDataBurst ( FetchLogic fl,
const FetchLogicRxData pkts,
size_t  count,
TscTime  now 
)

Notify Data arrival.

Parameters
pktsfields extracted from arrived Data.
countsize of pkts array.

◆ FetchLogic_TxInterestBurst()

size_t FetchLogic_TxInterestBurst ( FetchLogic fl,
uint64_t *  segNums,
size_t  limit,
TscTime  now 
)

Request to transmit a burst of Interests.

Parameters
[out]segNumssegment numbers to retrieve.
limitsize of segNums array.

◆ TAILQ_HEAD()

typedef TAILQ_HEAD ( FetchRetxQueue  ,
FetchSeg   
)