Function cryptodev_cb_init

dpdk/lib/cryptodev/rte_cryptodev.c:672–744

}

static int
cryptodev_cb_init(struct rte_cryptodev *dev)
{
	struct rte_cryptodev_cb_rcu *list;
	struct rte_rcu_qsbr *qsbr;
	uint16_t qp_id;
	size_t size;

	/* Max thread set to 1, as one DP thread accessing a queue-pair */
	const uint32_t max_threads = 1;

	dev->enq_cbs = rte_zmalloc(NULL,
				   sizeof(struct rte_cryptodev_cb_rcu) *
				   dev->data->nb_queue_pairs, 0);
	if (dev->enq_cbs == NULL) {
		CDEV_LOG_ERR("Failed to allocate memory for enq callbacks");
		return -ENOMEM;
	}

	dev->deq_cbs = rte_zmalloc(NULL,
				   sizeof(struct rte_cryptodev_cb_rcu) *
				   dev->data->nb_queue_pairs, 0);
	if (dev->deq_cbs == NULL) {
		CDEV_LOG_ERR("Failed to allocate memory for deq callbacks");
		rte_free(dev->enq_cbs);
		return -ENOMEM;
	}

	/* Create RCU QSBR variable */
	size = rte_rcu_qsbr_get_memsize(max_threads);

	for (qp_id = 0; qp_id < dev->data->nb_queue_pairs; qp_id++) {
		list = &dev->enq_cbs[qp_id];
		qsbr = rte_zmalloc(NULL, size, RTE_CACHE_LINE_SIZE);
		if (qsbr == NULL) {
			CDEV_LOG_ERR("Failed to allocate memory for RCU on "
				"queue_pair_id=%d", qp_id);
			goto cb_init_err;
		}

		if (rte_rcu_qsbr_init(qsbr, max_threads)) {
			CDEV_LOG_ERR("Failed to initialize for RCU on "
				"queue_pair_id=%d", qp_id);
			goto cb_init_err;
		}

		list->qsbr = qsbr;
	}

	for (qp_id = 0; qp_id < dev->data->nb_queue_pairs; qp_id++) {
		list = &dev->deq_cbs[qp_id];
		qsbr = rte_zmalloc(NULL, size, RTE_CACHE_LINE_SIZE);
		if (qsbr == NULL) {
			CDEV_LOG_ERR("Failed to allocate memory for RCU on "
				"queue_pair_id=%d", qp_id);
			goto cb_init_err;
		}