[dpdk-dev,v4,10/20] eal/dev: implement device iteration
Checks
Commit Message
Use the iteration hooks in the abstraction layers to perform the
requested filtering on the internal device lists.
Signed-off-by: Gaetan Rivet <gaetan.rivet@6wind.com>
---
lib/librte_eal/common/eal_common_dev.c | 187 ++++++++++++++++++++++++++++++++
lib/librte_eal/common/include/rte_dev.h | 25 +++++
lib/librte_eal/rte_eal_version.map | 1 +
3 files changed, 213 insertions(+)
Comments
HI Gaetan
From: Gaetan Rivet, Friday, March 30, 2018 12:24 AM
> +/* '\0' forbidden in sym */
> +static const char *
> +strfirstof(const char *str,
> + const char *sym)
> +{
> + const char *s;
> +
> + for (s = str; s[0] != '\0'; s++) {
> + const char *c;
> +
> + for (c = sym; c[0] != '\0'; c++) {
> + if (c[0] == s[0])
> + return s;
> + }
> + }
> + return NULL;
> +}
> +
I think you can use strcspn() instead...
On Mon, Apr 09, 2018 at 07:28:00AM +0000, Matan Azrad wrote:
> HI Gaetan
>
> From: Gaetan Rivet, Friday, March 30, 2018 12:24 AM
> > +/* '\0' forbidden in sym */
> > +static const char *
> > +strfirstof(const char *str,
> > + const char *sym)
> > +{
> > + const char *s;
> > +
> > + for (s = str; s[0] != '\0'; s++) {
> > + const char *c;
> > +
> > + for (c = sym; c[0] != '\0'; c++) {
> > + if (c[0] == s[0])
> > + return s;
> > + }
> > + }
> > + return NULL;
> > +}
> > +
>
> I think you can use strcspn() instead...
>
Indeed, didn't know about it, I will change it.
@@ -20,6 +20,28 @@
#include "eal_private.h"
+struct dev_next_ctx {
+ struct rte_dev_iterator *it;
+ const char *busstr;
+ const char *clsstr;
+};
+
+#define CTX(it, busstr, clsstr) \
+ (&(const struct dev_next_ctx){ \
+ .it = it, \
+ .busstr = busstr, \
+ .clsstr = clsstr, \
+ })
+
+#define ITCTX(ptr) \
+ (((struct dev_next_ctx *)(intptr_t)ptr)->it)
+
+#define BUSCTX(ptr) \
+ (((struct dev_next_ctx *)(intptr_t)ptr)->busstr)
+
+#define CLSCTX(ptr) \
+ (((struct dev_next_ctx *)(intptr_t)ptr)->clsstr)
+
static int cmp_detached_dev_name(const struct rte_device *dev,
const void *_name)
{
@@ -354,3 +376,168 @@ rte_dev_iterator_init(struct rte_dev_iterator *it,
}
return -rte_errno;
}
+
+/* '\0' forbidden in sym */
+static const char *
+strfirstof(const char *str,
+ const char *sym)
+{
+ const char *s;
+
+ for (s = str; s[0] != '\0'; s++) {
+ const char *c;
+
+ for (c = sym; c[0] != '\0'; c++) {
+ if (c[0] == s[0])
+ return s;
+ }
+ }
+ return NULL;
+}
+
+static char *
+dev_str_sane_copy(const char *str)
+{
+ const char *end;
+ char *copy;
+
+ end = strfirstof(str, ",/");
+ if (end != NULL &&
+ end[0] == ',') {
+ copy = strdup(end + 1);
+ } else {
+ /* '/' or '\0' */
+ copy = strdup("");
+ }
+ if (copy == NULL) {
+ rte_errno = ENOMEM;
+ } else {
+ char *slash;
+
+ slash = strchr(copy, '/');
+ if (slash != NULL)
+ slash[0] = '\0';
+ }
+ return copy;
+}
+
+static int
+class_next_dev_cmp(const struct rte_class *cls,
+ const void *ctx)
+{
+ struct rte_dev_iterator *it;
+ const char *clsstr = NULL;
+ void *dev;
+
+ if (cls->dev_iterate == NULL)
+ return 1;
+ it = ITCTX(ctx);
+ clsstr = CLSCTX(ctx);
+ dev = it->class_device;
+ /* it->clsstr != NULL means a class
+ * was specified in the devstr.
+ */
+ if (it->clsstr != NULL && cls != it->cls)
+ return 1;
+ /* If an error occured previously,
+ * no need to test further.
+ */
+ if (rte_errno != 0)
+ return -1;
+ dev = cls->dev_iterate(dev, clsstr, it);
+ it->class_device = dev;
+ return dev == NULL;
+}
+
+static int
+bus_next_dev_cmp(const struct rte_bus *bus,
+ const void *ctx)
+{
+ struct rte_device *dev = NULL;
+ struct rte_class *cls = NULL;
+ struct rte_dev_iterator *it;
+ const char *busstr = NULL;
+
+ if (bus->dev_iterate == NULL)
+ return 1;
+ it = ITCTX(ctx);
+ busstr = BUSCTX(ctx);
+ dev = it->device;
+ /* it->busstr != NULL means a bus
+ * was specified in the devstr.
+ */
+ if (it->busstr != NULL && bus != it->bus)
+ return 1;
+ /* If an error occured previously,
+ * no need to test further.
+ */
+ if (rte_errno != 0)
+ return -1;
+ if (it->clsstr == NULL) {
+ dev = bus->dev_iterate(dev, busstr, it);
+ goto end;
+ }
+ /* clsstr != NULL */
+ if (dev == NULL) {
+next_dev_on_bus:
+ dev = bus->dev_iterate(dev, busstr, it);
+ it->device = dev;
+ }
+ if (dev == NULL)
+ return 1;
+ if (it->cls != NULL)
+ cls = TAILQ_PREV(it->cls, rte_class_list, next);
+ cls = rte_class_find(cls, class_next_dev_cmp, ctx);
+ if (cls != NULL) {
+ it->cls = cls;
+ goto end;
+ }
+ goto next_dev_on_bus;
+end:
+ it->device = dev;
+ return dev == NULL;
+}
+__rte_experimental
+struct rte_device *
+rte_dev_iterator_next(struct rte_dev_iterator *it)
+{
+ struct rte_bus *bus = NULL;
+ int old_errno = rte_errno;
+ char *busstr = NULL;
+ char *clsstr = NULL;
+
+ rte_errno = 0;
+ if (it->busstr == NULL && it->clsstr == NULL) {
+ /* Invalid iterator. */
+ rte_errno = EINVAL;
+ return NULL;
+ }
+ if (it->bus != NULL)
+ bus = TAILQ_PREV(it->bus, rte_bus_list, next);
+ if (it->busstr != NULL) {
+ busstr = dev_str_sane_copy(it->busstr);
+ if (busstr == NULL)
+ goto out;
+ }
+ if (it->clsstr != NULL) {
+ clsstr = dev_str_sane_copy(it->clsstr);
+ if (clsstr == NULL)
+ goto out;
+ }
+ while ((bus = rte_bus_find(bus, bus_next_dev_cmp,
+ CTX(it, busstr, clsstr)))) {
+ if (it->device != NULL) {
+ it->bus = bus;
+ goto out;
+ }
+ if (it->busstr != NULL ||
+ rte_errno != 0)
+ break;
+ }
+ if (rte_errno == 0)
+ rte_errno = old_errno;
+out:
+ free(busstr);
+ free(clsstr);
+ return it->device;
+}
@@ -333,6 +333,31 @@ typedef void *(*rte_dev_iterate_t)(const void *start,
int __rte_experimental
rte_dev_iterator_init(struct rte_dev_iterator *it, const char *str);
+/**
+ * Iterates on a device iterator.
+ *
+ * Generates a new rte_device handle corresponding to the next element
+ * in the list described in comprehension by the iterator.
+ *
+ * The next object is returned, and the iterator is updated.
+ *
+ * @param it
+ * Device iterator handle.
+ *
+ * @return
+ * An rte_device handle if found.
+ * NULL if an error occurred (rte_errno is set).
+ * NULL if no device could be found (rte_errno is not set).
+ */
+struct rte_device * __rte_experimental
+rte_dev_iterator_next(struct rte_dev_iterator *it);
+
+#define RTE_DEV_FOREACH(dev, devstr, it) \
+ for (rte_dev_iterator_init(it, devstr), \
+ dev = rte_dev_iterator_next(it); \
+ dev != NULL; \
+ dev = rte_dev_iterator_next(it))
+
#ifdef __cplusplus
}
#endif
@@ -229,6 +229,7 @@ EXPERIMENTAL {
rte_mp_request;
rte_mp_reply;
rte_dev_iterator_init;
+ rte_dev_iterator_next;
rte_service_attr_get;
rte_service_attr_reset_all;
rte_service_component_register;