Lines Matching refs:xsks
155 struct xsk_socket_info *xsks[MAX_SOCKS];
221 for (i = 0; i < num_socks && xsks[i]; i++) {
226 rx_empty_polls_ps = (xsks[i]->app_stats.rx_empty_polls -
227 xsks[i]->app_stats.prev_rx_empty_polls) * 1000000000. / dt;
228 fill_fail_polls_ps = (xsks[i]->app_stats.fill_fail_polls -
229 xsks[i]->app_stats.prev_fill_fail_polls) * 1000000000. / dt;
230 copy_tx_sendtos_ps = (xsks[i]->app_stats.copy_tx_sendtos -
231 xsks[i]->app_stats.prev_copy_tx_sendtos) * 1000000000. / dt;
232 tx_wakeup_sendtos_ps = (xsks[i]->app_stats.tx_wakeup_sendtos -
233 xsks[i]->app_stats.prev_tx_wakeup_sendtos)
235 opt_polls_ps = (xsks[i]->app_stats.opt_polls -
236 xsks[i]->app_stats.prev_opt_polls) * 1000000000. / dt;
239 printf(fmt, "rx empty polls", rx_empty_polls_ps, xsks[i]->app_stats.rx_empty_polls);
241 xsks[i]->app_stats.fill_fail_polls);
243 xsks[i]->app_stats.copy_tx_sendtos);
245 xsks[i]->app_stats.tx_wakeup_sendtos);
246 printf(fmt, "opt polls", opt_polls_ps, xsks[i]->app_stats.opt_polls);
248 xsks[i]->app_stats.prev_rx_empty_polls = xsks[i]->app_stats.rx_empty_polls;
249 xsks[i]->app_stats.prev_fill_fail_polls = xsks[i]->app_stats.fill_fail_polls;
250 xsks[i]->app_stats.prev_copy_tx_sendtos = xsks[i]->app_stats.copy_tx_sendtos;
251 xsks[i]->app_stats.prev_tx_wakeup_sendtos = xsks[i]->app_stats.tx_wakeup_sendtos;
252 xsks[i]->app_stats.prev_opt_polls = xsks[i]->app_stats.opt_polls;
329 for (i = 0; i < num_socks && xsks[i]; i++) {
338 xsks[i]->drv_stats.intrs = n_ints - irqs_at_init;
340 intrs_ps = (xsks[i]->drv_stats.intrs - xsks[i]->drv_stats.prev_intrs) *
344 printf(fmt, "irqs", intrs_ps, xsks[i]->drv_stats.intrs);
346 xsks[i]->drv_stats.prev_intrs = xsks[i]->drv_stats.intrs;
358 for (i = 0; i < num_socks && xsks[i]; i++) {
363 rx_pps = (xsks[i]->ring_stats.rx_npkts - xsks[i]->ring_stats.prev_rx_npkts) *
365 tx_pps = (xsks[i]->ring_stats.tx_npkts - xsks[i]->ring_stats.prev_tx_npkts) *
374 printf(fmt, "rx", rx_pps, xsks[i]->ring_stats.rx_npkts);
375 printf(fmt, "tx", tx_pps, xsks[i]->ring_stats.tx_npkts);
377 xsks[i]->ring_stats.prev_rx_npkts = xsks[i]->ring_stats.rx_npkts;
378 xsks[i]->ring_stats.prev_tx_npkts = xsks[i]->ring_stats.tx_npkts;
381 if (!xsk_get_xdp_stats(xsk_socket__fd(xsks[i]->xsk), xsks[i])) {
382 dropped_pps = (xsks[i]->ring_stats.rx_dropped_npkts -
383 xsks[i]->ring_stats.prev_rx_dropped_npkts) *
385 rx_invalid_pps = (xsks[i]->ring_stats.rx_invalid_npkts -
386 xsks[i]->ring_stats.prev_rx_invalid_npkts) *
388 tx_invalid_pps = (xsks[i]->ring_stats.tx_invalid_npkts -
389 xsks[i]->ring_stats.prev_tx_invalid_npkts) *
391 full_pps = (xsks[i]->ring_stats.rx_full_npkts -
392 xsks[i]->ring_stats.prev_rx_full_npkts) *
394 fill_empty_pps = (xsks[i]->ring_stats.rx_fill_empty_npkts -
395 xsks[i]->ring_stats.prev_rx_fill_empty_npkts) *
397 tx_empty_pps = (xsks[i]->ring_stats.tx_empty_npkts -
398 xsks[i]->ring_stats.prev_tx_empty_npkts) *
402 xsks[i]->ring_stats.rx_dropped_npkts);
404 xsks[i]->ring_stats.rx_invalid_npkts);
406 xsks[i]->ring_stats.tx_invalid_npkts);
408 xsks[i]->ring_stats.rx_full_npkts);
410 xsks[i]->ring_stats.rx_fill_empty_npkts);
412 xsks[i]->ring_stats.tx_empty_npkts);
414 xsks[i]->ring_stats.prev_rx_dropped_npkts =
415 xsks[i]->ring_stats.rx_dropped_npkts;
416 xsks[i]->ring_stats.prev_rx_invalid_npkts =
417 xsks[i]->ring_stats.rx_invalid_npkts;
418 xsks[i]->ring_stats.prev_tx_invalid_npkts =
419 xsks[i]->ring_stats.tx_invalid_npkts;
420 xsks[i]->ring_stats.prev_rx_full_npkts =
421 xsks[i]->ring_stats.rx_full_npkts;
422 xsks[i]->ring_stats.prev_rx_fill_empty_npkts =
423 xsks[i]->ring_stats.rx_fill_empty_npkts;
424 xsks[i]->ring_stats.prev_tx_empty_npkts =
425 xsks[i]->ring_stats.tx_empty_npkts;
483 struct xsk_umem *umem = xsks[0]->umem->umem;
488 xsk_socket__delete(xsks[i]->xsk);
1224 fds[i].fd = xsk_socket__fd(xsks[i]->xsk);
1231 xsks[i]->app_stats.opt_polls++;
1238 rx_drop(xsks[i], fds);
1290 if (xsks[i]->outstanding_tx) {
1291 complete_tx_only(xsks[i], opt_batch_size);
1292 pending = !!xsks[i]->outstanding_tx;
1306 fds[0].fd = xsk_socket__fd(xsks[i]->xsk);
1315 xsks[i]->app_stats.opt_polls++;
1325 tx_only(xsks[i], &frame_nb[i], batch_size);
1394 fds[i].fd = xsk_socket__fd(xsks[i]->xsk);
1401 xsks[i]->app_stats.opt_polls++;
1408 l2fwd(xsks[i], fds);
1448 fprintf(stderr, "ERROR: no xsks map found: %s\n",
1454 int fd = xsk_socket__fd(xsks[i]->xsk);
1505 xsks[num_socks++] = xsk_configure_socket(umem, rx, tx);