aboutsummaryrefslogtreecommitdiffstats
path: root/src/plugins/dpdk/device/node.c
diff options
context:
space:
mode:
authorJohn Lo <loj@cisco.com>2018-03-09 19:48:42 -0500
committerDamjan Marion <dmarion.lists@gmail.com>2018-03-11 19:28:04 +0000
commiteeef247aef46684f2537644b9ef1ade2e313437e (patch)
treec210a29cd6a25d10577652a159cef437388aa4c0 /src/plugins/dpdk/device/node.c
parentaaacfbc5b15b0653489ad2e80db48151a4375ece (diff)
dpdk-input node packet trace intermittent on IP forwading path
Packet trace initiated by dpdk-input node would occasionally not fully function if next node is ip4-input. Change packet trace saving order in the quad-loop so "sho trace" will display trace in packet receive order. Fold calling of vlib_trace_buffer() into dpdk_add_trace(). Change-Id: I9d7a9bf3b9391f95590e66150b26b0b15912d803 Signed-off-by: John Lo <loj@cisco.com>
Diffstat (limited to 'src/plugins/dpdk/device/node.c')
-rw-r--r--src/plugins/dpdk/device/node.c73
1 files changed, 37 insertions, 36 deletions
diff --git a/src/plugins/dpdk/device/node.c b/src/plugins/dpdk/device/node.c
index fa0fa904e7c..7edcc36e593 100644
--- a/src/plugins/dpdk/device/node.c
+++ b/src/plugins/dpdk/device/node.c
@@ -69,11 +69,12 @@ dpdk_rx_error_from_mb (struct rte_mbuf *mb, u32 * next, u8 * error)
}
static_always_inline void
-dpdk_add_trace (vlib_main_t * vm,
- vlib_node_runtime_t * node,
- dpdk_device_t * xd,
- u16 queue_id, vlib_buffer_t * b, struct rte_mbuf *mb)
+dpdk_add_trace (vlib_main_t * vm, vlib_node_runtime_t * node, u32 next,
+ dpdk_device_t * xd, u16 queue_id,
+ vlib_buffer_t * b, struct rte_mbuf *mb)
{
+ vlib_trace_buffer (vm, node, next, b, /* follow_chain */ 0);
+
dpdk_rx_dma_trace_t *t0 = vlib_add_trace (vm, node, b, sizeof t0[0]);
t0->queue_index = queue_id;
t0->device_index = xd->device_index;
@@ -377,34 +378,33 @@ dpdk_device_input (dpdk_main_t * dm, dpdk_device_t * xd,
&next0, &next1, &next2, &next3,
b0, b1, b2, b3);
- switch (n_trace)
- {
- default:
- vlib_trace_buffer (vm, node, next3, b3, /* follow_chain */ 0);
- dpdk_add_trace (vm, node, xd, queue_id, b3, mb3);
- n_trace--;
- case 3:
- vlib_trace_buffer (vm, node, next2, b2, /* follow_chain */ 0);
- dpdk_add_trace (vm, node, xd, queue_id, b2, mb2);
- n_trace--;
- case 2:
- vlib_trace_buffer (vm, node, next1, b1, /* follow_chain */ 0);
- dpdk_add_trace (vm, node, xd, queue_id, b1, mb1);
- n_trace--;
- case 1:
- vlib_trace_buffer (vm, node, next0, b0, /* follow_chain */ 0);
- dpdk_add_trace (vm, node, xd, queue_id, b0, mb0);
- n_trace--;
- case 0:
- break;
- }
-
vlib_validate_buffer_enqueue_x4 (vm, node, next_index,
to_next, n_left_to_next,
bi0, bi1, bi2, bi3,
next0, next1, next2, next3);
n_buffers -= 4;
mb_index += 4;
+
+ if (n_trace)
+ {
+ dpdk_add_trace (vm, node, next0, xd, queue_id, b0, mb0);
+ n_trace--;
+ }
+ if (n_trace)
+ {
+ dpdk_add_trace (vm, node, next1, xd, queue_id, b1, mb1);
+ n_trace--;
+ }
+ if (n_trace)
+ {
+ dpdk_add_trace (vm, node, next2, xd, queue_id, b2, mb2);
+ n_trace--;
+ }
+ if (n_trace)
+ {
+ dpdk_add_trace (vm, node, next3, xd, queue_id, b3, mb3);
+ n_trace--;
+ }
}
while (n_buffers > 0 && n_left_to_next > 0)
{
@@ -464,18 +464,17 @@ dpdk_device_input (dpdk_main_t * dm, dpdk_device_t * xd,
vnet_feature_start_device_input_x1 (xd->vlib_sw_if_index, &next0,
b0);
- if (n_trace != 0)
- {
- vlib_trace_buffer (vm, node, next0, b0, /* follow_chain */ 0);
- dpdk_add_trace (vm, node, xd, queue_id, b0, mb0);
- n_trace--;
- }
-
vlib_validate_buffer_enqueue_x1 (vm, node, next_index,
to_next, n_left_to_next,
bi0, next0);
n_buffers--;
mb_index++;
+
+ if (n_trace)
+ {
+ dpdk_add_trace (vm, node, next0, xd, queue_id, b0, mb0);
+ n_trace--;
+ }
}
vlib_put_next_frame (vm, node, next_index, n_left_to_next);
}
@@ -584,13 +583,15 @@ CLIB_MULTIARCH_FN (dpdk_input) (vlib_main_t * vm, vlib_node_runtime_t * node,
continue; /* Do not poll slave to a bonded interface */
u32 n_trace = vlib_get_trace_count (vm, node);
if (PREDICT_TRUE(n_trace == 0))
- n_rx_packets += dpdk_device_input_mseg (dm, xd, node, thread_index, dq->queue_id, 0);
+ n_rx_packets += dpdk_device_input_mseg (dm, xd, node, thread_index,
+ dq->queue_id, 0);
else
{
u32 n_tr_packets = dpdk_device_input_mseg (dm, xd, node, thread_index,
- dq->queue_id, n_trace);
+ dq->queue_id, n_trace);
n_rx_packets += n_tr_packets;
- vlib_set_trace_count (vm, node, n_trace - clib_min(n_trace, n_tr_packets));
+ vlib_set_trace_count (vm, node,
+ n_trace - clib_min(n_trace, n_tr_packets));
}
}
/* *INDENT-ON* */