d/numam-dpdk
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

pipeline: fix emit instruction for invalid headers

Browse Source 
Fix the emit instruction for the pathological case of all headers to
be emitted being invalid. In this case, the for loop was essentially
skipped and the last emitted header (or an invalid memory location)
getting corrupted by setting its size to 0 through the assignment to
ho->n_bytes right after the for loop.

Fixes: d60dbdc88a ("pipeline: create inline functions for emit instruction")
Cc: stable@dpdk.org

Signed-off-by: Cristian Dumitrescu <cristian.dumitrescu@intel.com>
Signed-off-by: Venkata Suresh Kumar P <venkata.suresh.kumar.p@intel.com>
Signed-off-by: Yogesh Jangra <yogesh.jangra@intel.com>
This commit is contained in:
Cristian Dumitrescu 2022-04-27 22:56:52 +01:00 committed by Thomas Monjalon
parent 924de7b8e6
commit 775be5b539
1 changed files with 16 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
lib/pipeline/rte_swx_pipeline_internal.h
View File

@ -1840,9 +1840,9 @@ __instr_hdr_emit_many_exec(struct rte_swx_pipeline *p __rte_unused,
{
uint64_t valid_headers = t->valid_headers;
uint32_t n_headers_out = t->n_headers_out;
struct header_out_runtime *ho = &t->headers_out[n_headers_out - 1];
struct header_out_runtime *ho = NULL;
uint8_t *ho_ptr = NULL;
uint32_t ho_nbytes = 0, first = 1, i;
uint32_t ho_nbytes = 0, i;
for (i = 0; i < n_emit; i++) {
uint32_t header_id = ip->io.hdr.header_id[i];
@ -1854,18 +1854,21 @@ __instr_hdr_emit_many_exec(struct rte_swx_pipeline *p __rte_unused,
uint8_t *hi_ptr = t->structs[struct_id];
if (!MASK64_BIT_GET(valid_headers, header_id))
continue;
if (!MASK64_BIT_GET(valid_headers, header_id)) {
TRACE("[Thread %2u]: emit header %u (invalid)\n",
p->thread_id,
header_id);
TRACE("[Thread %2u]: emit header %u\n",
continue;
}
TRACE("[Thread %2u]: emit header %u (valid)\n",
p->thread_id,
header_id);
/* Headers. */
if (first) {
first = 0;
if (!t->n_headers_out) {
if (!ho) {
if (!n_headers_out) {
ho = &t->headers_out[0];
ho->ptr0 = hi_ptr0;
@ -1878,6 +1881,8 @@ __instr_hdr_emit_many_exec(struct rte_swx_pipeline *p __rte_unused,
continue;
} else {
ho = &t->headers_out[n_headers_out - 1];
ho_ptr = ho->ptr;
ho_nbytes = ho->n_bytes;
}
@ -1899,7 +1904,8 @@ __instr_hdr_emit_many_exec(struct rte_swx_pipeline *p __rte_unused,
}
}
ho->n_bytes = ho_nbytes;
if (ho)
ho->n_bytes = ho_nbytes;
t->n_headers_out = n_headers_out;
}