Code Review
/
deb_dpdk.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
New upstream version 17.11.3
[deb_dpdk.git]
/
examples
/
quota_watermark
/
qw
/
main.c
diff --git
a/examples/quota_watermark/qw/main.c
b/examples/quota_watermark/qw/main.c
index
fe17452
..
a9a89b9
100644
(file)
--- a/
examples/quota_watermark/qw/main.c
+++ b/
examples/quota_watermark/qw/main.c
@@
-210,7
+210,7
@@
receive_stage(__attribute__((unused)) void *args)
}
}
}
}
-static
void
+static
int
pipeline_stage(__attribute__((unused)) void *args)
{
int i, ret;
pipeline_stage(__attribute__((unused)) void *args)
{
int i, ret;
@@
-272,9
+272,11
@@
pipeline_stage(__attribute__((unused)) void *args)
}
}
}
}
}
}
+
+ return 0;
}
}
-static
void
+static
int
send_stage(__attribute__((unused)) void *args)
{
uint16_t nb_dq_pkts;
send_stage(__attribute__((unused)) void *args)
{
uint16_t nb_dq_pkts;
@@
-316,6
+318,8
@@
send_stage(__attribute__((unused)) void *args)
/* TODO: Check if nb_dq_pkts == nb_tx_pkts? */
}
}
/* TODO: Check if nb_dq_pkts == nb_tx_pkts? */
}
}
+
+ return 0;
}
int
}
int
@@
-375,15
+379,13
@@
main(int argc, char **argv)
if (is_bit_set(port_id, portmask))
init_ring(lcore_id, port_id);
if (is_bit_set(port_id, portmask))
init_ring(lcore_id, port_id);
- /* typecast is a workaround for GCC 4.3 bug */
- rte_eal_remote_launch((int (*)(void *))pipeline_stage,
+ rte_eal_remote_launch(pipeline_stage,
NULL, lcore_id);
}
}
/* Start send_stage() on the last slave core */
NULL, lcore_id);
}
}
/* Start send_stage() on the last slave core */
- /* typecast is a workaround for GCC 4.3 bug */
- rte_eal_remote_launch((int (*)(void *))send_stage, NULL, last_lcore_id);
+ rte_eal_remote_launch(send_stage, NULL, last_lcore_id);
/* Start receive_stage() on the master core */
receive_stage(NULL);
/* Start receive_stage() on the master core */
receive_stage(NULL);