X-Git-Url: http://git.droids-corp.org/?a=blobdiff_plain;f=lib%2Flibrte_compressdev%2Frte_compressdev.c;h=b3c5651dcc7bc5df77eb06bffe1faa9115af9366;hb=366a0500f432a862f37ab2ca220e60f5654eadd7;hp=9091dd6eed6e759f68f968815be8129ea2508b39;hpb=f8e9989606e7a9548a25ac10e2daae4c8af230cb;p=dpdk.git diff --git a/lib/librte_compressdev/rte_compressdev.c b/lib/librte_compressdev/rte_compressdev.c index 9091dd6eed..b3c5651dcc 100644 --- a/lib/librte_compressdev/rte_compressdev.c +++ b/lib/librte_compressdev/rte_compressdev.c @@ -7,6 +7,7 @@ #include #include +#include #include #include #include @@ -18,20 +19,16 @@ #define RTE_COMPRESSDEV_DETACHED (0) #define RTE_COMPRESSDEV_ATTACHED (1) -struct rte_compressdev rte_comp_devices[RTE_COMPRESS_MAX_DEVS]; - -struct rte_compressdev *rte_compressdevs = &rte_comp_devices[0]; +static struct rte_compressdev rte_comp_devices[RTE_COMPRESS_MAX_DEVS]; static struct rte_compressdev_global compressdev_globals = { - .devs = &rte_comp_devices[0], + .devs = rte_comp_devices, .data = { NULL }, .nb_devs = 0, .max_devs = RTE_COMPRESS_MAX_DEVS }; -struct rte_compressdev_global *rte_compressdev_globals = &compressdev_globals; - -const struct rte_compressdev_capabilities * __rte_experimental +const struct rte_compressdev_capabilities * rte_compressdev_capability_get(uint8_t dev_id, enum rte_comp_algorithm algo) { @@ -54,7 +51,7 @@ rte_compressdev_capability_get(uint8_t dev_id, return NULL; } -const char * __rte_experimental +const char * rte_compressdev_get_feature_name(uint64_t flag) { switch (flag) { @@ -70,6 +67,8 @@ rte_compressdev_get_feature_name(uint64_t flag) return "CPU_AVX512"; case RTE_COMPDEV_FF_CPU_NEON: return "CPU_NEON"; + case RTE_COMPDEV_FF_OP_DONE_IN_DEQUEUE: + return "OP_DONE_IN_DEQ"; default: return NULL; } @@ -78,10 +77,10 @@ rte_compressdev_get_feature_name(uint64_t flag) static struct rte_compressdev * rte_compressdev_get_dev(uint8_t dev_id) { - return &rte_compressdev_globals->devs[dev_id]; + return &compressdev_globals.devs[dev_id]; } -struct rte_compressdev * __rte_experimental +struct rte_compressdev * rte_compressdev_pmd_get_named_dev(const char *name) { struct rte_compressdev *dev; @@ -90,8 +89,8 @@ rte_compressdev_pmd_get_named_dev(const char *name) if (name == NULL) return NULL; - for (i = 0; i < rte_compressdev_globals->max_devs; i++) { - dev = &rte_compressdev_globals->devs[i]; + for (i = 0; i < compressdev_globals.max_devs; i++) { + dev = &compressdev_globals.devs[i]; if ((dev->attached == RTE_COMPRESSDEV_ATTACHED) && (strcmp(dev->data->name, name) == 0)) @@ -106,7 +105,7 @@ rte_compressdev_is_valid_dev(uint8_t dev_id) { struct rte_compressdev *dev = NULL; - if (dev_id >= rte_compressdev_globals->nb_devs) + if (dev_id >= compressdev_globals.nb_devs) return 0; dev = rte_compressdev_get_dev(dev_id); @@ -117,7 +116,7 @@ rte_compressdev_is_valid_dev(uint8_t dev_id) } -int __rte_experimental +int rte_compressdev_get_dev_id(const char *name) { unsigned int i; @@ -125,29 +124,29 @@ rte_compressdev_get_dev_id(const char *name) 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) + for (i = 0; i < compressdev_globals.nb_devs; i++) + if ((strcmp(compressdev_globals.devs[i].data->name, name) == 0) && - (rte_compressdev_globals->devs[i].attached == + (compressdev_globals.devs[i].attached == RTE_COMPRESSDEV_ATTACHED)) return i; return -1; } -uint8_t __rte_experimental +uint8_t rte_compressdev_count(void) { - return rte_compressdev_globals->nb_devs; + return compressdev_globals.nb_devs; } -uint8_t __rte_experimental +uint8_t rte_compressdev_devices_get(const char *driver_name, uint8_t *devices, uint8_t nb_devices) { uint8_t i, count = 0; - struct rte_compressdev *devs = rte_compressdev_globals->devs; - uint8_t max_devs = rte_compressdev_globals->max_devs; + struct rte_compressdev *devs = compressdev_globals.devs; + uint8_t max_devs = compressdev_globals.max_devs; for (i = 0; i < max_devs && count < nb_devices; i++) { @@ -166,7 +165,7 @@ rte_compressdev_devices_get(const char *driver_name, uint8_t *devices, return count; } -int __rte_experimental +int rte_compressdev_socket_id(uint8_t dev_id) { struct rte_compressdev *dev; @@ -223,7 +222,7 @@ rte_compressdev_find_free_device_index(void) return RTE_COMPRESS_MAX_DEVS; } -struct rte_compressdev * __rte_experimental +struct rte_compressdev * rte_compressdev_pmd_allocate(const char *name, int socket_id) { struct rte_compressdev *compressdev; @@ -254,8 +253,8 @@ rte_compressdev_pmd_allocate(const char *name, int socket_id) compressdev->data = compressdev_data; - snprintf(compressdev->data->name, RTE_COMPRESSDEV_NAME_MAX_LEN, - "%s", name); + strlcpy(compressdev->data->name, name, + RTE_COMPRESSDEV_NAME_MAX_LEN); compressdev->data->dev_id = dev_id; compressdev->data->socket_id = socket_id; @@ -269,7 +268,7 @@ rte_compressdev_pmd_allocate(const char *name, int socket_id) return compressdev; } -int __rte_experimental +int rte_compressdev_pmd_release_device(struct rte_compressdev *compressdev) { int ret; @@ -289,7 +288,7 @@ rte_compressdev_pmd_release_device(struct rte_compressdev *compressdev) return 0; } -uint16_t __rte_experimental +uint16_t rte_compressdev_queue_pair_count(uint8_t dev_id) { struct rte_compressdev *dev; @@ -414,7 +413,7 @@ rte_compressdev_queue_pairs_release(struct rte_compressdev *dev) return 0; } -int __rte_experimental +int rte_compressdev_configure(uint8_t dev_id, struct rte_compressdev_config *config) { struct rte_compressdev *dev; @@ -448,7 +447,7 @@ rte_compressdev_configure(uint8_t dev_id, struct rte_compressdev_config *config) return (*dev->dev_ops->dev_configure)(dev, config); } -int __rte_experimental +int rte_compressdev_start(uint8_t dev_id) { struct rte_compressdev *dev; @@ -480,7 +479,7 @@ rte_compressdev_start(uint8_t dev_id) return 0; } -void __rte_experimental +void rte_compressdev_stop(uint8_t dev_id) { struct rte_compressdev *dev; @@ -504,7 +503,7 @@ rte_compressdev_stop(uint8_t dev_id) dev->data->dev_started = 0; } -int __rte_experimental +int rte_compressdev_close(uint8_t dev_id) { struct rte_compressdev *dev; @@ -539,7 +538,7 @@ rte_compressdev_close(uint8_t dev_id) return 0; } -int __rte_experimental +int rte_compressdev_queue_pair_setup(uint8_t dev_id, uint16_t queue_pair_id, uint32_t max_inflight_ops, int socket_id) { @@ -574,11 +573,11 @@ rte_compressdev_queue_pair_setup(uint8_t dev_id, uint16_t queue_pair_id, max_inflight_ops, socket_id); } -uint16_t __rte_experimental +uint16_t rte_compressdev_dequeue_burst(uint8_t dev_id, uint16_t qp_id, struct rte_comp_op **ops, uint16_t nb_ops) { - struct rte_compressdev *dev = &rte_compressdevs[dev_id]; + struct rte_compressdev *dev = &rte_comp_devices[dev_id]; nb_ops = (*dev->dequeue_burst) (dev->data->queue_pairs[qp_id], ops, nb_ops); @@ -586,17 +585,17 @@ rte_compressdev_dequeue_burst(uint8_t dev_id, uint16_t qp_id, return nb_ops; } -uint16_t __rte_experimental +uint16_t rte_compressdev_enqueue_burst(uint8_t dev_id, uint16_t qp_id, struct rte_comp_op **ops, uint16_t nb_ops) { - struct rte_compressdev *dev = &rte_compressdevs[dev_id]; + struct rte_compressdev *dev = &rte_comp_devices[dev_id]; return (*dev->enqueue_burst)( dev->data->queue_pairs[qp_id], ops, nb_ops); } -int __rte_experimental +int rte_compressdev_stats_get(uint8_t dev_id, struct rte_compressdev_stats *stats) { struct rte_compressdev *dev; @@ -619,7 +618,7 @@ rte_compressdev_stats_get(uint8_t dev_id, struct rte_compressdev_stats *stats) return 0; } -void __rte_experimental +void rte_compressdev_stats_reset(uint8_t dev_id) { struct rte_compressdev *dev; @@ -636,7 +635,7 @@ rte_compressdev_stats_reset(uint8_t dev_id) } -void __rte_experimental +void rte_compressdev_info_get(uint8_t dev_id, struct rte_compressdev_info *dev_info) { struct rte_compressdev *dev; @@ -656,7 +655,7 @@ rte_compressdev_info_get(uint8_t dev_id, struct rte_compressdev_info *dev_info) dev_info->driver_name = dev->device->driver->name; } -int __rte_experimental +int rte_compressdev_private_xform_create(uint8_t dev_id, const struct rte_comp_xform *xform, void **priv_xform) @@ -681,7 +680,7 @@ rte_compressdev_private_xform_create(uint8_t dev_id, return 0; } -int __rte_experimental +int rte_compressdev_private_xform_free(uint8_t dev_id, void *priv_xform) { struct rte_compressdev *dev; @@ -704,7 +703,7 @@ rte_compressdev_private_xform_free(uint8_t dev_id, void *priv_xform) return 0; } -int __rte_experimental +int rte_compressdev_stream_create(uint8_t dev_id, const struct rte_comp_xform *xform, void **stream) @@ -730,7 +729,7 @@ rte_compressdev_stream_create(uint8_t dev_id, } -int __rte_experimental +int rte_compressdev_stream_free(uint8_t dev_id, void *stream) { struct rte_compressdev *dev; @@ -753,7 +752,7 @@ rte_compressdev_stream_free(uint8_t dev_id, void *stream) return 0; } -const char * __rte_experimental +const char * rte_compressdev_name_get(uint8_t dev_id) { struct rte_compressdev *dev = rte_compressdev_get_dev(dev_id);