git.droids-corp.org
/
dpdk.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
examples/fips_validation: fix buffer overflow
[dpdk.git]
/
lib
/
librte_eventdev
/
rte_eventdev.c
diff --git
a/lib/librte_eventdev/rte_eventdev.c
b/lib/librte_eventdev/rte_eventdev.c
index
b987e07
..
82c177c
100644
(file)
--- a/
lib/librte_eventdev/rte_eventdev.c
+++ b/
lib/librte_eventdev/rte_eventdev.c
@@
-35,6
+35,7
@@
#include "rte_eventdev.h"
#include "rte_eventdev_pmd.h"
#include "rte_eventdev.h"
#include "rte_eventdev_pmd.h"
+#include "rte_eventdev_trace.h"
static struct rte_eventdev rte_event_devices[RTE_EVENT_MAX_DEVS];
static struct rte_eventdev rte_event_devices[RTE_EVENT_MAX_DEVS];
@@
-524,6
+525,7
@@
rte_event_dev_configure(uint8_t dev_id,
}
dev->data->event_dev_cap = info.event_dev_cap;
}
dev->data->event_dev_cap = info.event_dev_cap;
+ rte_eventdev_trace_configure(dev_id, dev_conf, diag);
return diag;
}
return diag;
}
@@
-650,6
+652,7
@@
rte_event_queue_setup(uint8_t dev_id, uint8_t queue_id,
}
dev->data->queues_cfg[queue_id] = *queue_conf;
}
dev->data->queues_cfg[queue_id] = *queue_conf;
+ rte_eventdev_trace_queue_setup(dev_id, queue_id, queue_conf);
return (*dev->dev_ops->queue_setup)(dev, queue_id, queue_conf);
}
return (*dev->dev_ops->queue_setup)(dev, queue_id, queue_conf);
}
@@
-766,6
+769,7
@@
rte_event_port_setup(uint8_t dev_id, uint8_t port_id,
if (!diag)
diag = rte_event_port_unlink(dev_id, port_id, NULL, 0);
if (!diag)
diag = rte_event_port_unlink(dev_id, port_id, NULL, 0);
+ rte_eventdev_trace_port_setup(dev_id, port_id, port_conf, diag);
if (diag < 0)
return diag;
if (diag < 0)
return diag;
@@
-936,6
+940,7
@@
rte_event_port_link(uint8_t dev_id, uint8_t port_id,
for (i = 0; i < diag; i++)
links_map[queues[i]] = (uint8_t)priorities[i];
for (i = 0; i < diag; i++)
links_map[queues[i]] = (uint8_t)priorities[i];
+ rte_eventdev_trace_port_link(dev_id, port_id, nb_links, diag);
return diag;
}
return diag;
}
@@
-1001,6
+1006,7
@@
rte_event_port_unlink(uint8_t dev_id, uint8_t port_id,
for (i = 0; i < diag; i++)
links_map[queues[i]] = EVENT_QUEUE_SERVICE_PRIORITY_INVALID;
for (i = 0; i < diag; i++)
links_map[queues[i]] = EVENT_QUEUE_SERVICE_PRIORITY_INVALID;
+ rte_eventdev_trace_port_unlink(dev_id, port_id, nb_unlinks, diag);
return diag;
}
return diag;
}
@@
-1213,6
+1219,7
@@
rte_event_dev_start(uint8_t dev_id)
}
diag = (*dev->dev_ops->dev_start)(dev);
}
diag = (*dev->dev_ops->dev_start)(dev);
+ rte_eventdev_trace_start(dev_id, diag);
if (diag == 0)
dev->data->dev_started = 1;
else
if (diag == 0)
dev->data->dev_started = 1;
else
@@
-1257,6
+1264,7
@@
rte_event_dev_stop(uint8_t dev_id)
dev->data->dev_started = 0;
(*dev->dev_ops->dev_stop)(dev);
dev->data->dev_started = 0;
(*dev->dev_ops->dev_stop)(dev);
+ rte_eventdev_trace_stop(dev_id);
}
int
}
int
@@
-1275,6
+1283,7
@@
rte_event_dev_close(uint8_t dev_id)
return -EBUSY;
}
return -EBUSY;
}
+ rte_eventdev_trace_close(dev_id);
return (*dev->dev_ops->dev_close)(dev);
}
return (*dev->dev_ops->dev_close)(dev);
}
@@
-1364,14
+1373,17
@@
rte_event_pmd_allocate(const char *name, int socket_id)
eventdev->data = eventdev_data;
eventdev->data = eventdev_data;
- strlcpy(eventdev->data->name, name, RTE_EVENTDEV_NAME_MAX_LEN);
+ if (rte_eal_process_type() == RTE_PROC_PRIMARY) {
- eventdev->data->dev_id = dev_id;
- eventdev->data->socket_id = socket_id;
- eventdev->data->dev_started = 0;
+ strlcpy(eventdev->data->name, name,
+ RTE_EVENTDEV_NAME_MAX_LEN);
- eventdev->attached = RTE_EVENTDEV_ATTACHED;
+ eventdev->data->dev_id = dev_id;
+ eventdev->data->socket_id = socket_id;
+ eventdev->data->dev_started = 0;
+ }
+ eventdev->attached = RTE_EVENTDEV_ATTACHED;
eventdev_globals.nb_devs++;
}
eventdev_globals.nb_devs++;
}