uring.h

Go to the documentation of this file.

#ifndef NDNDPDK_CORE_URING_H
#define NDNDPDK_CORE_URING_H

 
#include "common.h"
 
#include <liburing.h>

typedef struct Uring {
  struct io_uring uring;
 
  uint64_t nAllocErrs;      
  uint64_t nSubmitted;      
  uint64_t nSubmitNonBlock; 
  uint64_t nSubmitWait;     
 
  uint32_t nQueued;  
  uint32_t nPending; 
} Uring;

__attribute__((nonnull)) bool
Uring_Init(Uring* ur, uint32_t capacity);

__attribute__((nonnull)) bool
Uring_Free(Uring* ur);

__attribute__((nonnull)) static __rte_always_inline struct io_uring_sqe*
Uring_GetSqe(Uring* ur) {
  struct io_uring_sqe* sqe = io_uring_get_sqe(&ur->uring);
  if (unlikely(sqe == NULL)) {
    ++ur->nAllocErrs;
  } else {
    ++ur->nQueued;
  }
  return sqe;
}
 
__attribute__((nonnull)) void
Uring_Submit_(Uring* ur, uint32_t waitLBound, uint32_t cqeBurst);

__attribute__((nonnull)) static __rte_always_inline void
Uring_Submit(Uring* ur, uint32_t waitLBound, uint32_t cqeBurst) {
  if (ur->nQueued > 0) {
    Uring_Submit_(ur, waitLBound, cqeBurst);
  }
}

__attribute__((nonnull)) static inline uint32_t
Uring_PeekCqes(Uring* ur, struct io_uring_cqe* cqes[], size_t count) {
  if (ur->nPending == 0) {
    return 0;
  }
 
  uint32_t n = io_uring_peek_batch_cqe(&ur->uring, cqes, count);
  ur->nPending -= n;
  return n;
}

__attribute__((nonnull)) static __rte_always_inline void
Uring_SeenCqes(Uring* ur, uint32_t n) {
  io_uring_cq_advance(&ur->uring, n);
}
 
#endif // NDNDPDK_CORE_URING_H