power: add traffic pattern aware power control

[dpdk.git] / lib / librte_compressdev / rte_compressdev.c

diff --git a/lib/librte_compressdev/rte_compressdev.c b/lib/librte_compressdev/rte_compressdev.c
index 0ffc43b..9091dd6 100644 (file)
--- a/lib/librte_compressdev/rte_compressdev.c
+++ b/lib/librte_compressdev/rte_compressdev.c
@@ -31,6 +31,50 @@ static struct rte_compressdev_global compressdev_globals = {
 
 struct rte_compressdev_global *rte_compressdev_globals = &compressdev_globals;
 
+const struct rte_compressdev_capabilities * __rte_experimental
+rte_compressdev_capability_get(uint8_t dev_id,
+                       enum rte_comp_algorithm algo)
+{
+       const struct rte_compressdev_capabilities *capability;
+       struct rte_compressdev_info dev_info;
+       int i = 0;
+
+       if (dev_id >= compressdev_globals.nb_devs) {
+               COMPRESSDEV_LOG(ERR, "Invalid dev_id=%d", dev_id);
+               return NULL;
+       }
+       rte_compressdev_info_get(dev_id, &dev_info);
+
+       while ((capability = &dev_info.capabilities[i++])->algo !=
+                       RTE_COMP_ALGO_UNSPECIFIED){
+               if (capability->algo == algo)
+                       return capability;
+       }
+
+       return NULL;
+}
+
+const char * __rte_experimental
+rte_compressdev_get_feature_name(uint64_t flag)
+{
+       switch (flag) {
+       case RTE_COMPDEV_FF_HW_ACCELERATED:
+               return "HW_ACCELERATED";
+       case RTE_COMPDEV_FF_CPU_SSE:
+               return "CPU_SSE";
+       case RTE_COMPDEV_FF_CPU_AVX:
+               return "CPU_AVX";
+       case RTE_COMPDEV_FF_CPU_AVX2:
+               return "CPU_AVX2";
+       case RTE_COMPDEV_FF_CPU_AVX512:
+               return "CPU_AVX512";
+       case RTE_COMPDEV_FF_CPU_NEON:
+               return "CPU_NEON";
+       default:
+               return NULL;
+       }
+}
+
 static struct rte_compressdev *
 rte_compressdev_get_dev(uint8_t dev_id)
 {
@@ -73,6 +117,24 @@ rte_compressdev_is_valid_dev(uint8_t dev_id)
 }
 
 
+int __rte_experimental
+rte_compressdev_get_dev_id(const char *name)
+{
+       unsigned int i;
+
+       if (name == NULL)
+               return -1;
+
+       for (i = 0; i < rte_compressdev_globals->nb_devs; i++)
+               if ((strcmp(rte_compressdev_globals->devs[i].data->name, name)
+                               == 0) &&
+                               (rte_compressdev_globals->devs[i].attached ==
+                                               RTE_COMPRESSDEV_ATTACHED))
+                       return i;
+
+       return -1;
+}
+
 uint8_t __rte_experimental
 rte_compressdev_count(void)
 {
@@ -534,6 +596,46 @@ rte_compressdev_enqueue_burst(uint8_t dev_id, uint16_t qp_id,
                        dev->data->queue_pairs[qp_id], ops, nb_ops);
 }
 
+int __rte_experimental
+rte_compressdev_stats_get(uint8_t dev_id, struct rte_compressdev_stats *stats)
+{
+       struct rte_compressdev *dev;
+
+       if (!rte_compressdev_is_valid_dev(dev_id)) {
+               COMPRESSDEV_LOG(ERR, "Invalid dev_id=%d", dev_id);
+               return -ENODEV;
+       }
+
+       if (stats == NULL) {
+               COMPRESSDEV_LOG(ERR, "Invalid stats ptr");
+               return -EINVAL;
+       }
+
+       dev = &rte_comp_devices[dev_id];
+       memset(stats, 0, sizeof(*stats));
+
+       RTE_FUNC_PTR_OR_ERR_RET(*dev->dev_ops->stats_get, -ENOTSUP);
+       (*dev->dev_ops->stats_get)(dev, stats);
+       return 0;
+}
+
+void __rte_experimental
+rte_compressdev_stats_reset(uint8_t dev_id)
+{
+       struct rte_compressdev *dev;
+
+       if (!rte_compressdev_is_valid_dev(dev_id)) {
+               COMPRESSDEV_LOG(ERR, "Invalid dev_id=%" PRIu8, dev_id);
+               return;
+       }
+
+       dev = &rte_comp_devices[dev_id];
+
+       RTE_FUNC_PTR_OR_RET(*dev->dev_ops->stats_reset);
+       (*dev->dev_ops->stats_reset)(dev);
+}
+
+
 void __rte_experimental
 rte_compressdev_info_get(uint8_t dev_id, struct rte_compressdev_info *dev_info)
 {
@@ -662,10 +764,7 @@ rte_compressdev_name_get(uint8_t dev_id)
        return dev->data->name;
 }
 
-RTE_INIT(rte_compressdev_log);
-
-static void
-rte_compressdev_log(void)
+RTE_INIT(rte_compressdev_log)
 {
        compressdev_logtype = rte_log_register("lib.compressdev");
        if (compressdev_logtype >= 0)