pit-up.h

Go to the documentation of this file.

#ifndef NDNDPDK_PCCT_PIT_UP_H
#define NDNDPDK_PCCT_PIT_UP_H

 
#include "../iface/faceid.h"
#include "pit-suppress-config.h"
 
typedef struct PitEntry PitEntry;
 
#define PIT_UP_MAX_REJ_NONCES 6

typedef struct PitUp {
  uint32_t nonce;   
  FaceID face;      
  bool canBePrefix; 
  uint8_t nack;     
 
  TscTime lastTx;       
  TscDuration suppress; 
  uint16_t nTx;         
  uint8_t nexthopIndex; 

  uint32_t rejectedNonces[PIT_UP_MAX_REJ_NONCES];
} __rte_cache_aligned PitUp;
static_assert(sizeof(PitUp) <= RTE_CACHE_LINE_SIZE, "");
 
__attribute__((nonnull)) static inline void
PitUp_Reset(PitUp* up, FaceID face) {
  *up = (const PitUp){.face = face};
}

__attribute__((nonnull)) static inline bool
PitUp_ShouldSuppress(PitUp* up, TscTime now) {
  return up->lastTx + up->suppress > now;
}

__attribute__((nonnull)) static inline void
PitUp_AddRejectedNonce(PitUp* up, uint32_t nonce) {
  memmove(&up->rejectedNonces[1], &up->rejectedNonces[0],
          sizeof(up->rejectedNonces) - sizeof(up->rejectedNonces[0]));
  up->rejectedNonces[0] = nonce;
}

__attribute__((nonnull)) bool
PitUp_ChooseNonce(PitUp* up, PitEntry* entry, TscTime now, uint32_t* nonce);

__attribute__((nonnull)) void
PitUp_RecordTx(PitUp* up, PitEntry* entry, TscTime now, uint32_t nonce,
               const PitSuppressConfig* suppressCfg);
 
#endif // NDNDPDK_PCCT_PIT_UP_H