aboutsummaryrefslogtreecommitdiff
path: root/platform/linux-dpdk/odp_schedule_eventdev.c
diff options
context:
space:
mode:
authorMatias Elo <matias.elo@nokia.com>2022-09-08 14:27:52 +0300
committerMatias Elo <matias.elo@nokia.com>2022-09-23 09:43:29 +0300
commit382572e149c4a5801301e10b4938fdcf0999c3f6 (patch)
tree8ef54d945e4bb7b4202b1d3af65255120700dc1c /platform/linux-dpdk/odp_schedule_eventdev.c
parentcad7fcbd3f193037ab07dd0ebe8e62ec2e763bbb (diff)
Port 1f683c665 "linux-gen: queue: remove an extra level of hierarchy from queue_entry_t"
Port original commit from linux-generic. Signed-off-by: Matias Elo <matias.elo@nokia.com> Reviewed-by: Jere Leppänen <jere.leppanen@nokia.com>
Diffstat (limited to 'platform/linux-dpdk/odp_schedule_eventdev.c')
-rw-r--r--platform/linux-dpdk/odp_schedule_eventdev.c22
1 files changed, 11 insertions, 11 deletions
diff --git a/platform/linux-dpdk/odp_schedule_eventdev.c b/platform/linux-dpdk/odp_schedule_eventdev.c
index 3c715ae36..8e5dbe7cf 100644
--- a/platform/linux-dpdk/odp_schedule_eventdev.c
+++ b/platform/linux-dpdk/odp_schedule_eventdev.c
@@ -138,8 +138,8 @@ static int resume_scheduling(uint8_t dev_id, uint8_t port_id)
if (!queue)
continue;
- queue_ids[nb_links] = queue->s.index;
- priorities[nb_links] = queue->s.eventdev.prio;
+ queue_ids[nb_links] = queue->index;
+ priorities[nb_links] = queue->eventdev.prio;
nb_links++;
}
}
@@ -178,8 +178,8 @@ static int link_group(int group, const odp_thrmask_t *mask, odp_bool_t unlink)
if (queue == NULL)
continue;
- queue_ids[nb_links] = queue->s.index;
- priorities[nb_links] = queue->s.eventdev.prio;
+ queue_ids[nb_links] = queue->index;
+ priorities[nb_links] = queue->eventdev.prio;
nb_links++;
}
@@ -255,10 +255,10 @@ static int rx_adapter_add_queues(uint8_t rx_adapter_id, uint8_t port_id,
int32_t rx_queue_id = pktin_idx[i];
memset(&ev, 0, sizeof(struct rte_event));
- ev.queue_id = queue->s.index;
+ ev.queue_id = queue->index;
ev.flow_id = 0;
- ev.priority = queue->s.eventdev.prio;
- ev.sched_type = event_schedule_type(queue->s.param.sched.sync);
+ ev.priority = queue->eventdev.prio;
+ ev.sched_type = event_schedule_type(queue->param.sched.sync);
memset(&qconf, 0,
sizeof(struct rte_event_eth_rx_adapter_queue_conf));
@@ -368,8 +368,8 @@ static int schedule_create_queue(uint32_t qi,
queue_entry_t *queue = qentry_from_index(qi);
odp_thrmask_t mask;
uint8_t dev_id = _odp_eventdev_gbl->dev_id;
- uint8_t queue_id = queue->s.index;
- uint8_t priority = queue->s.eventdev.prio;
+ uint8_t queue_id = queue->index;
+ uint8_t priority = queue->eventdev.prio;
int thr;
if (sched_param->group < 0 || sched_param->group >= NUM_SCHED_GRPS) {
@@ -396,9 +396,9 @@ static void schedule_destroy_queue(uint32_t qi)
{
queue_entry_t *queue = qentry_from_index(qi);
odp_thrmask_t mask;
- odp_schedule_group_t group = queue->s.param.sched.group;
+ odp_schedule_group_t group = queue->param.sched.group;
uint8_t dev_id = _odp_eventdev_gbl->dev_id;
- uint8_t queue_id = queue->s.index;
+ uint8_t queue_id = queue->index;
int thr;
odp_ticketlock_lock(&_odp_eventdev_gbl->grp_lock);