bdev.h

Go to the documentation of this file.

#ifndef NDNDPDK_DPDK_BDEV_H
#define NDNDPDK_DPDK_BDEV_H

 
#include "bdev-enum.h"
#include "mbuf.h"
#include <spdk/bdev.h>
 
enum {
  BdevBlockSize = 512,

  BdevMaxMbufSegs = 31,
};
 
extern uint8_t* BdevFiller_;

typedef struct BdevStoredPacket {
  uint16_t pktLen;                   
  uint16_t saveTotal;                
  uint16_t saveLen[BdevMaxMbufSegs]; 
  uint8_t headTail[BdevMaxMbufSegs]; 
} BdevStoredPacket;
 
__attribute__((nonnull)) static __rte_always_inline void
BdevStoredPacket_Copy(BdevStoredPacket* restrict dst, const BdevStoredPacket* restrict src) {
  if (src->pktLen == src->saveTotal) { // no head or tail
    goto COPY0;
  } else if (src->saveLen[1] == 0) { // single segment
    dst->headTail[0] = src->headTail[0];
    dst->headTail[1] = src->headTail[1];
  COPY0:
    dst->pktLen = src->pktLen;
    dst->saveTotal = src->saveTotal;
    dst->saveLen[0] = src->saveLen[0];
    dst->saveLen[1] = src->saveLen[1];
  } else { // multiple segments
    *dst = *src;
  }
}

__attribute__((nonnull)) static inline uint32_t
BdevStoredPacket_ComputeBlockCount(BdevStoredPacket* sp) {
  return SPDK_CEIL_DIV(sp->saveTotal, BdevBlockSize);
}
 
typedef struct BdevRequest BdevRequest;
typedef void (*BdevRequestCb)(BdevRequest* req, int res);

struct BdevRequest {
  struct rte_mbuf* pkt;
  BdevStoredPacket* sp;
  BdevRequestCb cb;
  struct rte_mbuf* bounce_;
  struct iovec iov_[BdevMaxMbufSegs + 1];
};

typedef struct Bdev {
  struct spdk_bdev_desc* desc;
  struct rte_mempool* bounceMp;
  uint32_t bufAlign;
  BdevWriteMode writeMode;
} Bdev;

__attribute__((nonnull)) void
Bdev_ReadPacket(Bdev* bd, struct spdk_io_channel* ch, uint64_t blockOffset, BdevRequest* req);

__attribute__((nonnull)) bool
Bdev_WritePrepare(Bdev* bd, struct rte_mbuf* pkt, BdevStoredPacket* sp);

__attribute__((nonnull)) void
Bdev_WritePacket(Bdev* bd, struct spdk_io_channel* ch, uint64_t blockOffset, BdevRequest* req);
 
#endif // NDNDPDK_SPDK_BDEV_H