store.h

Go to the documentation of this file.

#ifndef NDNDPDK_DISK_STORE_H
#define NDNDPDK_DISK_STORE_H

 
#include "../dpdk/bdev.h"
#include "../dpdk/hashtable.h"
#include "../dpdk/spdk-thread.h"
#include "../ndni/packet.h"
 
typedef struct DiskStore DiskStore;

typedef struct DiskStoreSlimRequest {
  Packet* next;
  DiskStore* store;
  uint64_t slotID;
} DiskStoreSlimRequest;

typedef struct DiskStoreRequest {
  DiskStoreSlimRequest s;
  union {
    Packet* npkt;
    struct rte_mbuf* pkt;
  };
  BdevRequest breq;
} DiskStoreRequest;

typedef void (*DiskStore_GetDataCb)(Packet* npkt, uintptr_t ctx);

struct DiskStore {
  Bdev bdev;
  uint64_t nBlocksPerSlot;
  struct rte_hash* requestHt;
  DiskStoreRequest* requestArray;
  struct spdk_thread* th;
  struct spdk_io_channel* ch;
  DiskStore_GetDataCb getDataCb;
  uintptr_t getDataCtx;
 
  uint64_t nPutDataBegin;
  uint64_t nPutDataFinish[2]; // 0=failure, 1=success
  uint64_t nGetDataBegin;
  uint64_t nGetDataReuse;
  uint64_t nGetDataSuccess;
  uint64_t nGetDataFailure;
};

__attribute__((nonnull)) static inline bool
DiskStore_PutPrepare(DiskStore* store, Packet* npkt, BdevStoredPacket* sp) {
  return Bdev_WritePrepare(&store->bdev, Packet_ToMbuf(npkt), sp);
}

__attribute__((nonnull)) void
DiskStore_PutData(DiskStore* store, uint64_t slotID, Packet* npkt, BdevStoredPacket* sp);

__attribute__((nonnull)) void
DiskStore_GetData(DiskStore* store, uint64_t slotID, Packet* npkt, struct rte_mbuf* dataBuf,
                  BdevStoredPacket* sp);
 
#endif // NDNDPDK_DISK_STORE_H