pcct.h

Go to the documentation of this file.

#ifndef NDNDPDK_PCCT_PCCT_H
#define NDNDPDK_PCCT_PCCT_H

 
#include "cs-struct.h"
#include "pcc-entry.h"
#include "pit-struct.h"

typedef struct Pcct {
  struct rte_mempool* mp;   
  PccEntry* keyHt;          
  struct rte_hash* tokenHt; 
  uint64_t lastToken;       
 
  Pit pit;
  Cs cs;
 
  uint32_t nKeyHtBuckets;
} Pcct;
 
static __rte_always_inline Pcct*
Pcct_FromPit(const Pit* pit) {
  return container_of(pit, Pcct, pit);
}
 
static __rte_always_inline Pcct*
Pcct_FromCs(const Cs* cs) {
  return container_of(cs, Pcct, cs);
}

__attribute__((nonnull)) bool
Pcct_Init(Pcct* pcct, const char* id, uint32_t maxEntries, int numaSocket);

__attribute__((nonnull)) void
Pcct_Clear(Pcct* pcct);

__attribute__((nonnull)) PccEntry*
Pcct_Insert(Pcct* pcct, const PccSearch* search, bool* isNew);

__attribute__((nonnull)) void
Pcct_Erase(Pcct* pcct, PccEntry* entry);

__attribute__((nonnull)) uint64_t
Pcct_AddToken(Pcct* pcct, PccEntry* entry);

__attribute__((nonnull)) void
Pcct_RemoveToken(Pcct* pcct, PccEntry* entry);

__attribute__((nonnull)) PccEntry*
Pcct_FindByToken(const Pcct* pcct, uint64_t token);
 
// Burst size of PCCT erasing.
#define PCCT_ERASE_BURST 32

typedef struct PcctEraseBatch {
  Pcct* pcct;
  int nEntries;
  void* objs[PCCT_ERASE_BURST * (2 + PccKeyMaxExts)];
} PcctEraseBatch;

__attribute__((nonnull)) static inline PcctEraseBatch
PcctEraseBatch_New(Pcct* pcct) {
  return (PcctEraseBatch){.pcct = pcct};
}
 
__attribute__((nonnull)) void
PcctEraseBatch_EraseBurst_(PcctEraseBatch* peb);

__attribute__((nonnull)) static inline void
PcctEraseBatch_Append(PcctEraseBatch* peb, PccEntry* entry) {
  peb->objs[peb->nEntries] = entry;
  if (unlikely(++peb->nEntries == PCCT_ERASE_BURST)) {
    PcctEraseBatch_EraseBurst_(peb);
  }
}

__attribute__((nonnull)) static inline void
PcctEraseBatch_Finish(PcctEraseBatch* peb) {
  if (likely(peb->nEntries > 0)) {
    PcctEraseBatch_EraseBurst_(peb);
  }
  peb->pcct = NULL;
}
 
#endif // NDNDPDK_PCCT_PCCT_H