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

1042

pkt = pkt_stream_get_next_rx_pkt(pkt_stream, &pkts_sent);

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

1073

pkt_stream->nb_rx_pkts++;

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

1087

pkt_stream_cancel(pkt_stream);

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

1107

struct pkt_stream *pkt_stream = xsk->pkt_stream;

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

1109

if (!pkt_stream) {

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

1114

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

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

1167

struct pkt_stream *pkt_stream = xsk->pkt_stream;

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

1173

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

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

1210

struct pkt *pkt = pkt_stream_get_next_tx_pkt(pkt_stream);

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

1216

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

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

1218

pkt_stream_cancel(pkt_stream);

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

1228

if (pkt_stream->verbatim) {

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

1248

if (pkt_stream->verbatim)

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

1249

pkt = pkt_stream_get_next_tx_pkt(pkt_stream);

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

1327

struct pkt_stream *pkt_stream;

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

1329

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

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

1330

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

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

1395

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

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

1396

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

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

1460

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

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

1464

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

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

1526

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

1543

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

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

1547

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

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

1566

pkt_stream_reset(pkt_stream);

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

1613

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

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

1829

pkt_stream_reset(ifobj2->xsk->pkt_stream);

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

1833

pkt_stream_reset(ifobj1->xsk->pkt_stream);

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

1948

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

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

1949

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

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

1950

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

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

1951

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

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

2015

struct pkt_stream *tmp;

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

2020

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

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

2025

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

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

2035

struct pkt_stream *tmp;

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

2040

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

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

2045

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

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

239

xsk->pkt_stream = test->tx_pkt_stream_default;

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

241

xsk->pkt_stream = test->rx_pkt_stream_default;

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

276

struct pkt_stream *tx_pkt_stream;

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

277

struct pkt_stream *rx_pkt_stream;

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

349

void pkt_stream_reset(struct pkt_stream *pkt_stream)

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

351

if (pkt_stream) {

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

352

pkt_stream->current_pkt_nb = 0;

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

353

pkt_stream->nb_rx_pkts = 0;

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

357

static struct pkt *pkt_stream_get_next_tx_pkt(struct pkt_stream *pkt_stream)

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

359

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

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

362

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

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

365

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

367

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

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

369

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

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

370

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

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

371

pkt_stream->current_pkt_nb++;

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

376

void pkt_stream_delete(struct pkt_stream *pkt_stream)

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

378

free(pkt_stream->pkts);

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

379

free(pkt_stream);

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

384

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

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

385

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

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

388

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

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

389

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

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

393

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

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

394

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

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

398

static struct pkt_stream *__pkt_stream_alloc(u32 nb_pkts)

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

400

struct pkt_stream *pkt_stream;

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

402

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

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

403

if (!pkt_stream)

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

406

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

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

407

if (!pkt_stream->pkts) {

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

408

free(pkt_stream);

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

412

pkt_stream->nb_pkts = nb_pkts;

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

413

return pkt_stream;

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

416

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

423

if (!pkt_stream->verbatim) {

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

433

next_frag = pkt_stream->current_pkt_nb;

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

435

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

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

449

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

456

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

460

pkt_set(pkt_stream, pkt, offset, len);

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

461

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

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

469

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

471

struct pkt_stream *pkt_stream;

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

474

pkt_stream = __pkt_stream_alloc(nb_pkts);

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

475

if (!pkt_stream)

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

478

pkt_stream->nb_pkts = nb_pkts;

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

479

pkt_stream->max_pkt_len = pkt_len;

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

481

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

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

483

pkt_stream_pkt_set(pkt_stream, pkt, 0, pkt_len);

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

487

return pkt_stream;

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

490

struct pkt_stream *pkt_stream_generate(u32 nb_pkts, u32 pkt_len)

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

495

static struct pkt_stream *pkt_stream_clone(struct pkt_stream *pkt_stream)

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

497

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

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

502

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

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

504

if (!ifobj->xsk->pkt_stream)

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

524

struct pkt_stream *pkt_stream;

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

527

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

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

528

if (!pkt_stream)

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

531

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

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

532

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

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

534

ifobj->xsk->pkt_stream = pkt_stream;

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

551

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

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

554

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

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

559

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

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

561

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

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

562

pkt_stream->pkts[0].len);

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

563

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

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

566

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

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

567

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

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

568

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

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

570

pkt_stream->nb_valid_entries /= 2;

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

577

struct pkt_stream *pkt_stream;

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

581

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

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

582

pkt_stream = __pkt_stream_generate(pkt_stream->nb_pkts / 2,

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

583

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

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

584

if (!pkt_stream)

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

586

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

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

588

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

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

589

pkt_stream = __pkt_stream_generate(pkt_stream->nb_pkts / 2,

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

590

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

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

591

if (!pkt_stream)

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

593

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

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

601

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

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

602

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

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

607

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

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

608

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

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

609

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

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

610

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

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

622

static void pkt_stream_cancel(struct pkt_stream *pkt_stream)

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

624

pkt_stream->current_pkt_nb--;

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

647

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

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

651

struct pkt_stream *pkt_stream;

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

653

pkt_stream = __pkt_stream_alloc(nb_frames);

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

654

if (!pkt_stream)

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

658

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

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

684

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

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

685

pkt_stream->max_pkt_len = pkt->len;

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

688

pkt_stream->nb_valid_entries++;

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

693

pkt_stream->nb_pkts = pkt_nb;

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

694

pkt_stream->verbatim = verbatim;

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

695

return pkt_stream;

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

700

struct pkt_stream *pkt_stream;

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

702

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

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

703

if (!pkt_stream)

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

705

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

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

707

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

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

708

if (!pkt_stream)

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

710

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

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

986

struct pkt_stream *pkt_stream = xsk->pkt_stream;

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

187

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

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

188

void pkt_stream_delete(struct pkt_stream *pkt_stream);

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

189

void pkt_stream_reset(struct pkt_stream *pkt_stream);

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

195

struct pkt_stream *tx_pkt_stream_default;

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

196

struct pkt_stream *rx_pkt_stream_default;

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

89

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;