tools/testing/selftests/bpf/prog_tests/test_xsk.c

1029

pkt = pkt_stream_get_next_rx_pkt(pkt_stream, &pkts_sent);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1060

pkt_stream->nb_rx_pkts++;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1074

pkt_stream_cancel(pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1094

struct pkt_stream *pkt_stream = xsk->pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1096

if (!pkt_stream) {

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1101

if (pkt_stream->nb_rx_pkts == pkt_stream->nb_valid_entries) {

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1153

struct pkt_stream *pkt_stream = xsk->pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1159

buffer_len = pkt_get_buffer_len(umem, pkt_stream->max_pkt_len);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1196

struct pkt *pkt = pkt_stream_get_next_tx_pkt(pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1202

nb_frags = pkt_nb_frags(umem->frame_size, pkt_stream, pkt);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1204

pkt_stream_cancel(pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1214

if (pkt_stream->verbatim) {

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1234

if (pkt_stream->verbatim)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1235

pkt = pkt_stream_get_next_tx_pkt(pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1314

struct pkt_stream *pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1316

pkt_stream = ifobject->xsk_arr[i].pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1317

if (!pkt_stream || pkt_stream->current_pkt_nb >= pkt_stream->nb_pkts) {

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1383

if (stats.rx_dropped == ifobject->xsk->pkt_stream->nb_pkts / 2 ||

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1384

stats.rx_dropped == ifobject->xsk->pkt_stream->nb_pkts / 2 - 1)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1448

if (stats.tx_invalid_descs != ifobject->xsk->pkt_stream->nb_pkts / 2) {

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1452

ifobject->xsk->pkt_stream->nb_pkts);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1503

static int xsk_populate_fill_ring(struct xsk_umem_info *umem, struct pkt_stream *pkt_stream,

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1520

struct pkt *pkt = pkt_stream_get_next_rx_pkt(pkt_stream, &nb_pkts);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1524

for (i = 0; i < pkt_nb_frags(rx_frame_size, pkt_stream, pkt); i++) {

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1543

pkt_stream_reset(pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1584

ret = xsk_populate_fill_ring(ifobject->umem, ifobject->xsk->pkt_stream,

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1800

pkt_stream_reset(ifobj2->xsk->pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1804

pkt_stream_reset(ifobj1->xsk->pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1923

test->ifobj_tx->xsk_arr[0].pkt_stream = NULL;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1924

test->ifobj_rx->xsk_arr[0].pkt_stream = NULL;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1925

test->ifobj_tx->xsk_arr[1].pkt_stream = test->tx_pkt_stream_default;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1926

test->ifobj_rx->xsk_arr[1].pkt_stream = test->rx_pkt_stream_default;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1989

struct pkt_stream *tmp;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1994

test->ifobj_tx->xsk->pkt_stream = tmp;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

1999

test->ifobj_rx->xsk->pkt_stream = tmp;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

2009

struct pkt_stream *tmp;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

2014

test->ifobj_tx->xsk->pkt_stream = tmp;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

2019

test->ifobj_rx->xsk->pkt_stream = tmp;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

241

ifobj->xsk_arr[j].pkt_stream = test->tx_pkt_stream_default;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

243

ifobj->xsk_arr[j].pkt_stream = test->rx_pkt_stream_default;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

275

struct pkt_stream *tx_pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

276

struct pkt_stream *rx_pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

336

void pkt_stream_reset(struct pkt_stream *pkt_stream)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

338

if (pkt_stream) {

tools/testing/selftests/bpf/prog_tests/test_xsk.c

339

pkt_stream->current_pkt_nb = 0;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

340

pkt_stream->nb_rx_pkts = 0;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

344

static struct pkt *pkt_stream_get_next_tx_pkt(struct pkt_stream *pkt_stream)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

346

if (pkt_stream->current_pkt_nb >= pkt_stream->nb_pkts)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

349

return &pkt_stream->pkts[pkt_stream->current_pkt_nb++];

tools/testing/selftests/bpf/prog_tests/test_xsk.c

352

static struct pkt *pkt_stream_get_next_rx_pkt(struct pkt_stream *pkt_stream, u32 *pkts_sent)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

354

while (pkt_stream->current_pkt_nb < pkt_stream->nb_pkts) {

tools/testing/selftests/bpf/prog_tests/test_xsk.c

356

if (pkt_stream->pkts[pkt_stream->current_pkt_nb].valid)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

357

return &pkt_stream->pkts[pkt_stream->current_pkt_nb++];

tools/testing/selftests/bpf/prog_tests/test_xsk.c

358

pkt_stream->current_pkt_nb++;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

363

void pkt_stream_delete(struct pkt_stream *pkt_stream)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

365

free(pkt_stream->pkts);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

366

free(pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

371

struct pkt_stream *tx_pkt_stream = test->ifobj_tx->xsk->pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

372

struct pkt_stream *rx_pkt_stream = test->ifobj_rx->xsk->pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

375

pkt_stream_delete(test->ifobj_tx->xsk->pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

376

test->ifobj_tx->xsk->pkt_stream = test->tx_pkt_stream_default;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

380

pkt_stream_delete(test->ifobj_rx->xsk->pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

381

test->ifobj_rx->xsk->pkt_stream = test->rx_pkt_stream_default;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

385

static struct pkt_stream *__pkt_stream_alloc(u32 nb_pkts)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

387

struct pkt_stream *pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

389

pkt_stream = calloc(1, sizeof(*pkt_stream));

tools/testing/selftests/bpf/prog_tests/test_xsk.c

390

if (!pkt_stream)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

393

pkt_stream->pkts = calloc(nb_pkts, sizeof(*pkt_stream->pkts));

tools/testing/selftests/bpf/prog_tests/test_xsk.c

394

if (!pkt_stream->pkts) {

tools/testing/selftests/bpf/prog_tests/test_xsk.c

395

free(pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

399

pkt_stream->nb_pkts = nb_pkts;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

400

return pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

403

static u32 pkt_nb_frags(u32 frame_size, struct pkt_stream *pkt_stream, struct pkt *pkt)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

410

if (!pkt_stream->verbatim) {

tools/testing/selftests/bpf/prog_tests/test_xsk.c

420

next_frag = pkt_stream->current_pkt_nb;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

422

while (next_frag++ < pkt_stream->nb_pkts) {

tools/testing/selftests/bpf/prog_tests/test_xsk.c

436

static void pkt_set(struct pkt_stream *pkt_stream, struct pkt *pkt, int offset, u32 len)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

443

static void pkt_stream_pkt_set(struct pkt_stream *pkt_stream, struct pkt *pkt, int offset, u32 len)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

447

pkt_set(pkt_stream, pkt, offset, len);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

448

pkt_stream->nb_valid_entries += pkt->valid - prev_pkt_valid;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

456

static struct pkt_stream *__pkt_stream_generate(u32 nb_pkts, u32 pkt_len, u32 nb_start, u32 nb_off)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

458

struct pkt_stream *pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

461

pkt_stream = __pkt_stream_alloc(nb_pkts);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

462

if (!pkt_stream)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

465

pkt_stream->nb_pkts = nb_pkts;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

466

pkt_stream->max_pkt_len = pkt_len;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

468

struct pkt *pkt = &pkt_stream->pkts[i];

tools/testing/selftests/bpf/prog_tests/test_xsk.c

470

pkt_stream_pkt_set(pkt_stream, pkt, 0, pkt_len);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

474

return pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

477

struct pkt_stream *pkt_stream_generate(u32 nb_pkts, u32 pkt_len)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

482

static struct pkt_stream *pkt_stream_clone(struct pkt_stream *pkt_stream)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

484

return pkt_stream_generate(pkt_stream->nb_pkts, pkt_stream->pkts[0].len);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

489

ifobj->xsk->pkt_stream = pkt_stream_generate(nb_pkts, pkt_len);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

491

if (!ifobj->xsk->pkt_stream)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

511

struct pkt_stream *pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

514

pkt_stream = pkt_stream_clone(ifobj->xsk->pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

515

if (!pkt_stream)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

518

for (i = 1; i < ifobj->xsk->pkt_stream->nb_pkts; i += 2)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

519

pkt_stream_pkt_set(pkt_stream, &pkt_stream->pkts[i], offset, pkt_len);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

521

ifobj->xsk->pkt_stream = pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

538

struct pkt_stream *pkt_stream = test->ifobj_tx->xsk->pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

541

if (test->ifobj_rx->xsk->pkt_stream != test->rx_pkt_stream_default)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

546

pkt_stream_delete(test->ifobj_rx->xsk->pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

548

test->ifobj_rx->xsk->pkt_stream = pkt_stream_generate(pkt_stream->nb_pkts,

tools/testing/selftests/bpf/prog_tests/test_xsk.c

549

pkt_stream->pkts[0].len);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

550

if (!test->ifobj_rx->xsk->pkt_stream)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

553

pkt_stream = test->ifobj_rx->xsk->pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

554

for (i = 1; i < pkt_stream->nb_pkts; i += 2)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

555

pkt_stream->pkts[i].valid = false;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

557

pkt_stream->nb_valid_entries /= 2;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

564

struct pkt_stream *pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

568

pkt_stream = test->ifobj_tx->xsk_arr[i].pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

569

pkt_stream = __pkt_stream_generate(pkt_stream->nb_pkts / 2,

tools/testing/selftests/bpf/prog_tests/test_xsk.c

570

pkt_stream->pkts[0].len, i, 2);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

571

if (!pkt_stream)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

573

test->ifobj_tx->xsk_arr[i].pkt_stream = pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

575

pkt_stream = test->ifobj_rx->xsk_arr[i].pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

576

pkt_stream = __pkt_stream_generate(pkt_stream->nb_pkts / 2,

tools/testing/selftests/bpf/prog_tests/test_xsk.c

577

pkt_stream->pkts[0].len, i, 2);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

578

if (!pkt_stream)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

580

test->ifobj_rx->xsk_arr[i].pkt_stream = pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

588

struct pkt_stream *later_free_tx = test->ifobj_tx->xsk->pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

589

struct pkt_stream *later_free_rx = test->ifobj_rx->xsk->pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

594

if (test->ifobj_tx->xsk_arr[i].pkt_stream != later_free_tx)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

595

pkt_stream_delete(test->ifobj_tx->xsk_arr[i].pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

596

if (test->ifobj_rx->xsk_arr[i].pkt_stream != later_free_rx)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

597

pkt_stream_delete(test->ifobj_rx->xsk_arr[i].pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

609

static void pkt_stream_cancel(struct pkt_stream *pkt_stream)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

611

pkt_stream->current_pkt_nb--;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

634

static struct pkt_stream *__pkt_stream_generate_custom(struct ifobject *ifobj, struct pkt *frames,

tools/testing/selftests/bpf/prog_tests/test_xsk.c

638

struct pkt_stream *pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

640

pkt_stream = __pkt_stream_alloc(nb_frames);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

641

if (!pkt_stream)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

645

struct pkt *pkt = &pkt_stream->pkts[pkt_nb];

tools/testing/selftests/bpf/prog_tests/test_xsk.c

671

if (pkt->valid && pkt->len > pkt_stream->max_pkt_len)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

672

pkt_stream->max_pkt_len = pkt->len;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

675

pkt_stream->nb_valid_entries++;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

680

pkt_stream->nb_pkts = pkt_nb;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

681

pkt_stream->verbatim = verbatim;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

682

return pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

687

struct pkt_stream *pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

689

pkt_stream = __pkt_stream_generate_custom(test->ifobj_tx, pkts, nb_pkts, true);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

690

if (!pkt_stream)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

692

test->ifobj_tx->xsk->pkt_stream = pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

694

pkt_stream = __pkt_stream_generate_custom(test->ifobj_rx, pkts, nb_pkts, false);

tools/testing/selftests/bpf/prog_tests/test_xsk.c

695

if (!pkt_stream)

tools/testing/selftests/bpf/prog_tests/test_xsk.c

697

test->ifobj_rx->xsk->pkt_stream = pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.c

973

struct pkt_stream *pkt_stream = xsk->pkt_stream;

tools/testing/selftests/bpf/prog_tests/test_xsk.h

186

struct pkt_stream *pkt_stream_generate(u32 nb_pkts, u32 pkt_len);

tools/testing/selftests/bpf/prog_tests/test_xsk.h

187

void pkt_stream_delete(struct pkt_stream *pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.h

188

void pkt_stream_reset(struct pkt_stream *pkt_stream);

tools/testing/selftests/bpf/prog_tests/test_xsk.h

194

struct pkt_stream *tx_pkt_stream_default;

tools/testing/selftests/bpf/prog_tests/test_xsk.h

195

struct pkt_stream *rx_pkt_stream_default;

tools/testing/selftests/bpf/prog_tests/test_xsk.h

88

struct pkt_stream *pkt_stream;

tools/testing/selftests/bpf/xskxceiver.c

338

struct pkt_stream *rx_pkt_stream_default;

tools/testing/selftests/bpf/xskxceiver.c

339

struct pkt_stream *tx_pkt_stream_default;