cs-entry.h

Go to the documentation of this file.

#ifndef NDNDPDK_PCCT_CS_ENTRY_H
#define NDNDPDK_PCCT_CS_ENTRY_H

 
#include "../dpdk/bdev.h"
#include "../ndni/packet.h"
#include "cs-struct.h"
 
extern const char* CsEntryKind_Strings_[];
 
__attribute__((returns_nonnull)) static inline const char*
CsEntryKind_ToString(CsEntryKind kind) {
  return CsEntryKind_Strings_[kind];
}

struct CsEntry {
  CsNode* prev;
  CsNode* next;
  struct PccEntry* pccEntry;
 
  RTE_MARKER zeroizeBegin_;
  union {
    Packet* data;

    uint64_t diskSlot;

    CsEntry* direct;
  };

  TscTime freshUntil;
 
  CsEntryKind kind;

  uint8_t nIndirects;
 
  CsListID arcList;
  RTE_MARKER zeroizeEnd_;

  CsEntry* indirect[CsMaxIndirects];

  BdevStoredPacket diskStored;
};
static_assert(CsMaxIndirects < UINT8_MAX, "");

__attribute__((nonnull)) static inline void
CsEntry_Init(CsEntry* entry) {
  memset(entry->zeroizeBegin_, 0, RTE_PTR_DIFF(entry->zeroizeEnd_, entry->zeroizeBegin_));
}

__attribute__((nonnull)) static __rte_always_inline CsEntry*
CsEntry_GetDirect(CsEntry* entry) {
  return unlikely(entry->kind == CsEntryIndirect) ? entry->direct : entry;
}

__attribute__((nonnull)) static inline void
CsEntry_FreeData(CsEntry* entry) {
  NDNDPDK_ASSERT(entry->kind == CsEntryMemory);
  rte_pktmbuf_free(Packet_ToMbuf(entry->data));
  NULLize(entry->data);
  entry->kind = CsEntryNone;
}

__attribute__((nonnull)) static inline bool
CsEntry_Assoc(CsEntry* indirect, CsEntry* direct) {
  NDNDPDK_ASSERT(direct->kind != CsEntryIndirect);
  if (unlikely(direct->nIndirects >= CsMaxIndirects)) {
    return false;
  }
 
  direct->indirect[direct->nIndirects++] = indirect;
  indirect->kind = CsEntryIndirect;
  indirect->direct = direct;
  return true;
}

__attribute__((nonnull)) static inline void
CsEntry_Disassoc(CsEntry* indirect) {
  NDNDPDK_ASSERT(indirect->kind == CsEntryIndirect);
  CsEntry* direct = indirect->direct;
 
  uint8_t i = 0;
  for (; i < direct->nIndirects; ++i) {
    if (direct->indirect[i] == indirect) {
      break;
    }
  }
  NDNDPDK_ASSERT(i < direct->nIndirects);
 
  direct->indirect[i] = direct->indirect[--direct->nIndirects];
  indirect->kind = CsEntryNone;
}
 
#endif // NDNDPDK_PCCT_CS_ENTRY_H