dev/ena/ena_datapath.c

333 ena_rx_hash_mbuf(struct ena_ring *rx_ring, struct ena_com_rx_ctx *ena_rx_ctx,
339 		mbuf->m_pkthdr.flowid = ena_rx_ctx->hash;
348 		    ena_rx_ctx->l3_proto != ENA_ETH_IO_L3_PROTO_UNKNOWN) {
354 		if (ena_rx_ctx->frag &&
355 		    (ena_rx_ctx->l3_proto != ENA_ETH_IO_L3_PROTO_UNKNOWN)) {
360 		switch (ena_rx_ctx->l3_proto) {
362 			switch (ena_rx_ctx->l4_proto) {
374 			switch (ena_rx_ctx->l4_proto) {
401  * @ena_rx_ctx: metadata for this packet(s)
407     struct ena_com_rx_ctx *ena_rx_ctx, uint16_t *next_to_clean)
412 	unsigned int descs = ena_rx_ctx->descs;
436 	mbuf->m_data = mtodo(mbuf, ena_rx_ctx->pkt_offset);
438 		"Mbuf data offset=%u\n", ena_rx_ctx->pkt_offset);
442 	ena_rx_hash_mbuf(rx_ring, ena_rx_ctx, mbuf);
509 ena_rx_checksum(struct ena_ring *rx_ring, struct ena_com_rx_ctx *ena_rx_ctx,
514 	if (unlikely((ena_rx_ctx->l3_proto == ENA_ETH_IO_L3_PROTO_IPV4) &&
515 	    ena_rx_ctx->l3_csum_err)) {
524 	if ((ena_rx_ctx->l4_proto == ENA_ETH_IO_L4_PROTO_TCP) ||
525 	    (ena_rx_ctx->l4_proto == ENA_ETH_IO_L4_PROTO_UDP)) {
526 		if (ena_rx_ctx->l4_csum_err) {
547 	struct ena_com_rx_ctx ena_rx_ctx;
580 		ena_rx_ctx.ena_bufs = rx_ring->ena_bufs;
581 		ena_rx_ctx.max_bufs = adapter->max_rx_sgl_size;
582 		ena_rx_ctx.descs = 0;
583 		ena_rx_ctx.pkt_offset = 0;
587 		rc = ena_com_rx_pkt(io_cq, io_sq, &ena_rx_ctx);
602 		if (unlikely(ena_rx_ctx.descs == 0))
607 		    rx_ring->qid, ena_rx_ctx.descs, ena_rx_ctx.l3_proto,
608 		    ena_rx_ctx.l4_proto, ena_rx_ctx.hash);
612 		    &ena_rx_ctx, &next_to_clean);
617 			for (i = 0; i < ena_rx_ctx.descs; ++i) {
630 			ena_rx_checksum(rx_ring, &ena_rx_ctx, mbuf);
646 		    (ena_rx_ctx.l4_proto == ENA_ETH_IO_L4_PROTO_TCP)) {