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
net/ice/base: add accessors to get/set time reference
[dpdk.git]
/
drivers
/
event
/
opdl
/
opdl_evdev_init.c
diff --git
a/drivers/event/opdl/opdl_evdev_init.c
b/drivers/event/opdl/opdl_evdev_init.c
index
1454de5
..
15aae47
100644
(file)
--- a/
drivers/event/opdl/opdl_evdev_init.c
+++ b/
drivers/event/opdl/opdl_evdev_init.c
@@
-35,7
+35,7
@@
enqueue_check(struct opdl_port *p,
p->id,
ev[i].queue_id,
p->next_external_qid);
p->id,
ev[i].queue_id,
p->next_external_qid);
- rte_errno =
-
EINVAL;
+ rte_errno = EINVAL;
return 0;
}
}
return 0;
}
}
@@
-63,7
+63,7
@@
enqueue_check(struct opdl_port *p,
} else {
if (num > 0 &&
ev[0].queue_id != p->next_external_qid) {
} else {
if (num > 0 &&
ev[0].queue_id != p->next_external_qid) {
- rte_errno =
-
EINVAL;
+ rte_errno = EINVAL;
return 0;
}
}
return 0;
}
}
@@
-116,7
+116,7
@@
opdl_rx_error_enqueue(struct opdl_port *p,
RTE_SET_USED(ev);
RTE_SET_USED(num);
RTE_SET_USED(ev);
RTE_SET_USED(num);
- rte_errno =
-
ENOSPC;
+ rte_errno = ENOSPC;
return 0;
}
return 0;
}
@@
-145,7
+145,7
@@
opdl_rx_enqueue(struct opdl_port *p,
if (enqueued < num)
if (enqueued < num)
- rte_errno =
-
ENOSPC;
+ rte_errno = ENOSPC;
return enqueued;
}
return enqueued;
}
@@
-164,7
+164,7
@@
opdl_tx_error_dequeue(struct opdl_port *p,
RTE_SET_USED(ev);
RTE_SET_USED(num);
RTE_SET_USED(ev);
RTE_SET_USED(num);
- rte_errno =
-
ENOSPC;
+ rte_errno = ENOSPC;
return 0;
}
return 0;
}
@@
-240,7
+240,7
@@
opdl_claim(struct opdl_port *p, struct rte_event ev[], uint16_t num)
"Attempt to dequeue num of events larger than port (%d) max",
opdl_pmd_dev_id(p->opdl),
p->id);
"Attempt to dequeue num of events larger than port (%d) max",
opdl_pmd_dev_id(p->opdl),
p->id);
- rte_errno =
-
EINVAL;
+ rte_errno = EINVAL;
return 0;
}
return 0;
}
@@
-733,6
+733,9
@@
initialise_all_other_ports(struct rte_eventdev *dev)
queue->ports[queue->nb_ports] = port;
port->instance_id = queue->nb_ports;
queue->nb_ports++;
queue->ports[queue->nb_ports] = port;
port->instance_id = queue->nb_ports;
queue->nb_ports++;
+ opdl_stage_set_queue_id(stage_inst,
+ port->queue_id);
+
} else if (queue->q_pos == OPDL_Q_POS_END) {
/* tx port */
} else if (queue->q_pos == OPDL_Q_POS_END) {
/* tx port */