85 	struct rte_compressdev *dev;  in rte_compressdev_pmd_get_named_dev()  local
92 		dev = &compressdev_globals.devs[i];  in rte_compressdev_pmd_get_named_dev()
94 		if ((dev->attached == RTE_COMPRESSDEV_ATTACHED) &&  in rte_compressdev_pmd_get_named_dev()
95 				(strcmp(dev->data->name, name) == 0))  in rte_compressdev_pmd_get_named_dev()
96 			return dev;  in rte_compressdev_pmd_get_named_dev()
105 	struct rte_compressdev *dev = NULL;  in rte_compressdev_is_valid_dev()  local
110 	dev = rte_compressdev_get_dev(dev_id);  in rte_compressdev_is_valid_dev()
111 	if (dev->attached != RTE_COMPRESSDEV_ATTACHED)  in rte_compressdev_is_valid_dev()
170 	struct rte_compressdev *dev;  in rte_compressdev_socket_id()  local
175 	dev = rte_compressdev_get_dev(dev_id);  in rte_compressdev_socket_id()
177 	return dev->data->socket_id;  in rte_compressdev_socket_id()
293 	struct rte_compressdev *dev;  in rte_compressdev_queue_pair_count()  local
295 	dev = &rte_comp_devices[dev_id];  in rte_compressdev_queue_pair_count()
296 	return dev->data->nb_queue_pairs;  in rte_compressdev_queue_pair_count()
300 rte_compressdev_queue_pairs_config(struct rte_compressdev *dev,  in rte_compressdev_queue_pairs_config()  argument
307 	if ((dev == NULL) || (nb_qpairs < 1)) {  in rte_compressdev_queue_pairs_config()
309 							dev, nb_qpairs);  in rte_compressdev_queue_pairs_config()
314 			nb_qpairs, dev->data->dev_id);  in rte_compressdev_queue_pairs_config()
318 	RTE_FUNC_PTR_OR_ERR_RET(*dev->dev_ops->dev_infos_get, -ENOTSUP);  in rte_compressdev_queue_pairs_config()
319 	(*dev->dev_ops->dev_infos_get)(dev, &dev_info);  in rte_compressdev_queue_pairs_config()
324 				nb_qpairs, dev->data->dev_id);  in rte_compressdev_queue_pairs_config()
328 	if (dev->data->queue_pairs == NULL) { /* first time configuration */  in rte_compressdev_queue_pairs_config()
329 		dev->data->queue_pairs = rte_zmalloc_socket(  in rte_compressdev_queue_pairs_config()
331 				sizeof(dev->data->queue_pairs[0]) * nb_qpairs,  in rte_compressdev_queue_pairs_config()
334 		if (dev->data->queue_pairs == NULL) {  in rte_compressdev_queue_pairs_config()
335 			dev->data->nb_queue_pairs = 0;  in rte_compressdev_queue_pairs_config()
343 		uint16_t old_nb_queues = dev->data->nb_queue_pairs;  in rte_compressdev_queue_pairs_config()
345 		qp = dev->data->queue_pairs;  in rte_compressdev_queue_pairs_config()
347 		RTE_FUNC_PTR_OR_ERR_RET(*dev->dev_ops->queue_pair_release,  in rte_compressdev_queue_pairs_config()
351 			ret = (*dev->dev_ops->queue_pair_release)(dev, i);  in rte_compressdev_queue_pairs_config()
372 		dev->data->queue_pairs = qp;  in rte_compressdev_queue_pairs_config()
375 	dev->data->nb_queue_pairs = nb_qpairs;  in rte_compressdev_queue_pairs_config()
380 rte_compressdev_queue_pairs_release(struct rte_compressdev *dev)  in rte_compressdev_queue_pairs_release()  argument
385 	if (dev == NULL) {  in rte_compressdev_queue_pairs_release()
386 		COMPRESSDEV_LOG(ERR, "invalid param: dev %p", dev);  in rte_compressdev_queue_pairs_release()
390 	num_qps = dev->data->nb_queue_pairs;  in rte_compressdev_queue_pairs_release()
396 			dev->data->nb_queue_pairs, dev->data->dev_id);  in rte_compressdev_queue_pairs_release()
398 	RTE_FUNC_PTR_OR_ERR_RET(*dev->dev_ops->queue_pair_release,  in rte_compressdev_queue_pairs_release()
402 		ret = (*dev->dev_ops->queue_pair_release)(dev, i);  in rte_compressdev_queue_pairs_release()
407 	rte_free(dev->data->queue_pairs);  in rte_compressdev_queue_pairs_release()
408 	dev->data->queue_pairs = NULL;  in rte_compressdev_queue_pairs_release()
409 	dev->data->nb_queue_pairs = 0;  in rte_compressdev_queue_pairs_release()
417 	struct rte_compressdev *dev;  in rte_compressdev_configure()  local
425 	dev = &rte_comp_devices[dev_id];  in rte_compressdev_configure()
427 	if (dev->data->dev_started) {  in rte_compressdev_configure()
433 	RTE_FUNC_PTR_OR_ERR_RET(*dev->dev_ops->dev_configure, -ENOTSUP);  in rte_compressdev_configure()
436 	diag = rte_compressdev_queue_pairs_config(dev, config->nb_queue_pairs,  in rte_compressdev_configure()
445 	return (*dev->dev_ops->dev_configure)(dev, config);  in rte_compressdev_configure()
451 	struct rte_compressdev *dev;  in rte_compressdev_start()  local
461 	dev = &rte_comp_devices[dev_id];  in rte_compressdev_start()
463 	RTE_FUNC_PTR_OR_ERR_RET(*dev->dev_ops->dev_start, -ENOTSUP);  in rte_compressdev_start()
465 	if (dev->data->dev_started != 0) {  in rte_compressdev_start()
471 	diag = (*dev->dev_ops->dev_start)(dev);  in rte_compressdev_start()
473 		dev->data->dev_started = 1;  in rte_compressdev_start()
483 	struct rte_compressdev *dev;  in rte_compressdev_stop()  local
490 	dev = &rte_comp_devices[dev_id];  in rte_compressdev_stop()
492 	RTE_FUNC_PTR_OR_RET(*dev->dev_ops->dev_stop);  in rte_compressdev_stop()
494 	if (dev->data->dev_started == 0) {  in rte_compressdev_stop()
500 	(*dev->dev_ops->dev_stop)(dev);  in rte_compressdev_stop()
501 	dev->data->dev_started = 0;  in rte_compressdev_stop()
507 	struct rte_compressdev *dev;  in rte_compressdev_close()  local
515 	dev = &rte_comp_devices[dev_id];  in rte_compressdev_close()
518 	if (dev->data->dev_started == 1) {  in rte_compressdev_close()
525 	retval = rte_compressdev_queue_pairs_release(dev);  in rte_compressdev_close()
530 	RTE_FUNC_PTR_OR_ERR_RET(*dev->dev_ops->dev_close, -ENOTSUP);  in rte_compressdev_close()
531 	retval = (*dev->dev_ops->dev_close)(dev);  in rte_compressdev_close()
543 	struct rte_compressdev *dev;  in rte_compressdev_queue_pair_setup()  local
550 	dev = &rte_comp_devices[dev_id];  in rte_compressdev_queue_pair_setup()
551 	if (queue_pair_id >= dev->data->nb_queue_pairs) {  in rte_compressdev_queue_pair_setup()
556 	if (dev->data->dev_started) {  in rte_compressdev_queue_pair_setup()
568 	RTE_FUNC_PTR_OR_ERR_RET(*dev->dev_ops->queue_pair_setup, -ENOTSUP);  in rte_compressdev_queue_pair_setup()
570 	return (*dev->dev_ops->queue_pair_setup)(dev, queue_pair_id,  in rte_compressdev_queue_pair_setup()
578 	struct rte_compressdev *dev = &rte_comp_devices[dev_id];  in rte_compressdev_dequeue_burst()  local
580 	nb_ops = (*dev->dequeue_burst)  in rte_compressdev_dequeue_burst()
581 			(dev->data->queue_pairs[qp_id], ops, nb_ops);  in rte_compressdev_dequeue_burst()
590 	struct rte_compressdev *dev = &rte_comp_devices[dev_id];  in rte_compressdev_enqueue_burst()  local
592 	return (*dev->enqueue_burst)(  in rte_compressdev_enqueue_burst()
593 			dev->data->queue_pairs[qp_id], ops, nb_ops);  in rte_compressdev_enqueue_burst()
599 	struct rte_compressdev *dev;  in rte_compressdev_stats_get()  local
611 	dev = &rte_comp_devices[dev_id];  in rte_compressdev_stats_get()
614 	RTE_FUNC_PTR_OR_ERR_RET(*dev->dev_ops->stats_get, -ENOTSUP);  in rte_compressdev_stats_get()
615 	(*dev->dev_ops->stats_get)(dev, stats);  in rte_compressdev_stats_get()
622 	struct rte_compressdev *dev;  in rte_compressdev_stats_reset()  local
629 	dev = &rte_comp_devices[dev_id];  in rte_compressdev_stats_reset()
631 	RTE_FUNC_PTR_OR_RET(*dev->dev_ops->stats_reset);  in rte_compressdev_stats_reset()
632 	(*dev->dev_ops->stats_reset)(dev);  in rte_compressdev_stats_reset()
639 	struct rte_compressdev *dev;  in rte_compressdev_info_get()  local
646 	dev = &rte_comp_devices[dev_id];  in rte_compressdev_info_get()
650 	RTE_FUNC_PTR_OR_RET(*dev->dev_ops->dev_infos_get);  in rte_compressdev_info_get()
651 	(*dev->dev_ops->dev_infos_get)(dev, dev_info);  in rte_compressdev_info_get()
653 	dev_info->driver_name = dev->device->driver->name;  in rte_compressdev_info_get()
661 	struct rte_compressdev *dev;  in rte_compressdev_private_xform_create()  local
664 	dev = rte_compressdev_get_dev(dev_id);  in rte_compressdev_private_xform_create()
666 	if (xform == NULL || priv_xform == NULL || dev == NULL)  in rte_compressdev_private_xform_create()
669 	RTE_FUNC_PTR_OR_ERR_RET(*dev->dev_ops->private_xform_create, -ENOTSUP);  in rte_compressdev_private_xform_create()
670 	ret = (*dev->dev_ops->private_xform_create)(dev, xform, priv_xform);  in rte_compressdev_private_xform_create()
684 	struct rte_compressdev *dev;  in rte_compressdev_private_xform_free()  local
687 	dev = rte_compressdev_get_dev(dev_id);  in rte_compressdev_private_xform_free()
689 	if (dev == NULL || priv_xform == NULL)  in rte_compressdev_private_xform_free()
692 	RTE_FUNC_PTR_OR_ERR_RET(*dev->dev_ops->private_xform_free, -ENOTSUP);  in rte_compressdev_private_xform_free()
693 	ret = dev->dev_ops->private_xform_free(dev, priv_xform);  in rte_compressdev_private_xform_free()
709 	struct rte_compressdev *dev;  in rte_compressdev_stream_create()  local
712 	dev = rte_compressdev_get_dev(dev_id);  in rte_compressdev_stream_create()
714 	if (xform == NULL || dev == NULL || stream == NULL)  in rte_compressdev_stream_create()
717 	RTE_FUNC_PTR_OR_ERR_RET(*dev->dev_ops->stream_create, -ENOTSUP);  in rte_compressdev_stream_create()
718 	ret = (*dev->dev_ops->stream_create)(dev, xform, stream);  in rte_compressdev_stream_create()
733 	struct rte_compressdev *dev;  in rte_compressdev_stream_free()  local
736 	dev = rte_compressdev_get_dev(dev_id);  in rte_compressdev_stream_free()
738 	if (dev == NULL || stream == NULL)  in rte_compressdev_stream_free()
741 	RTE_FUNC_PTR_OR_ERR_RET(*dev->dev_ops->stream_free, -ENOTSUP);  in rte_compressdev_stream_free()
742 	ret = dev->dev_ops->stream_free(dev, stream);  in rte_compressdev_stream_free()
756 	struct rte_compressdev *dev = rte_compressdev_get_dev(dev_id);  in rte_compressdev_name_get()  local
758 	if (dev == NULL)  in rte_compressdev_name_get()
761 	return dev->data->name;  in rte_compressdev_name_get()