regexdev: implement API functions

[dpdk.git] / drivers / crypto / nitrox / nitrox_qp.h

diff --git a/drivers/crypto/nitrox/nitrox_qp.h b/drivers/crypto/nitrox/nitrox_qp.h
index cf0102f..d42d53f 100644 (file)
--- a/drivers/crypto/nitrox/nitrox_qp.h
+++ b/drivers/crypto/nitrox/nitrox_qp.h
@@ -11,11 +11,19 @@
 
 struct nitrox_softreq;
 
+struct command_queue {
+       const struct rte_memzone *mz;
+       uint8_t *dbell_csr_addr;
+       uint8_t *ring;
+       uint8_t instr_size;
+};
+
 struct rid {
        struct nitrox_softreq *sr;
 };
 
 struct nitrox_qp {
+       struct command_queue cmdq;
        struct rid *ridq;
        uint32_t count;
        uint32_t head;
@@ -26,12 +34,68 @@ struct nitrox_qp {
        rte_atomic16_t pending_count;
 };
 
+static inline uint16_t
+nitrox_qp_free_count(struct nitrox_qp *qp)
+{
+       uint16_t pending_count = rte_atomic16_read(&qp->pending_count);
+
+       RTE_ASSERT(qp->count >= pending_count);
+       return (qp->count - pending_count);
+}
+
 static inline bool
 nitrox_qp_is_empty(struct nitrox_qp *qp)
 {
        return (rte_atomic16_read(&qp->pending_count) == 0);
 }
 
+static inline uint16_t
+nitrox_qp_used_count(struct nitrox_qp *qp)
+{
+       return rte_atomic16_read(&qp->pending_count);
+}
+
+static inline struct nitrox_softreq *
+nitrox_qp_get_softreq(struct nitrox_qp *qp)
+{
+       uint32_t tail = qp->tail % qp->count;
+
+       rte_smp_rmb();
+       return qp->ridq[tail].sr;
+}
+
+static inline void
+nitrox_ring_dbell(struct nitrox_qp *qp, uint16_t cnt)
+{
+       struct command_queue *cmdq = &qp->cmdq;
+
+       if (!cnt)
+               return;
+
+       rte_io_wmb();
+       rte_write64(cnt, cmdq->dbell_csr_addr);
+}
+
+static inline void
+nitrox_qp_enqueue(struct nitrox_qp *qp, void *instr, struct nitrox_softreq *sr)
+{
+       uint32_t head = qp->head % qp->count;
+
+       qp->head++;
+       memcpy(&qp->cmdq.ring[head * qp->cmdq.instr_size],
+              instr, qp->cmdq.instr_size);
+       qp->ridq[head].sr = sr;
+       rte_smp_wmb();
+       rte_atomic16_inc(&qp->pending_count);
+}
+
+static inline void
+nitrox_qp_dequeue(struct nitrox_qp *qp)
+{
+       qp->tail++;
+       rte_atomic16_dec(&qp->pending_count);
+}
+
 int nitrox_qp_setup(struct nitrox_qp *qp, uint8_t *bar_addr,
                    const char *dev_name, uint32_t nb_descriptors,
                    uint8_t inst_size, int socket_id);