From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mail-pl1-f181.google.com (mail-pl1-f181.google.com [209.85.214.181]) by dpdk.org (Postfix) with ESMTP id 37E5510A3 for ; Wed, 31 Oct 2018 19:41:52 +0100 (CET) Received: by mail-pl1-f181.google.com with SMTP id b9-v6so7693015pls.7 for ; Wed, 31 Oct 2018 11:41:52 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:references:in-reply-to:from:date:message-id:subject:to; bh=RFu4sQDgGAZF3w55oVa63+OPnTSV/ayGf4W9mnqBa6k=; b=XmuT2xQSq3cK0uii/9oAJ6VXYyluS6QTT9SdVmfmUnOvt9/bIOdAzfTo8bMlACHOMs KKn/22NbLOsKodWEfjEYUd1sKQMUPNs/clMbHFLumOZjutRMSnG+vaE9X1DZHEP0GxKA XREBJAxS87Bva3zztCBQLF+4QHpfPQ5WMfRsXo5ITDgAehPoTI/ydlSlKeG/6GUAhHhF mDrvMv1ATSp7mLeOTueEfZXmfAeKpEWjxwlXYo+ahtC2hxLOQGKq/lcIYyc762OozRCG H33sFWTC/tbDD7f6oSdvk1nC45YpPEZYCTzsczmXIO8li+gVal2FVnLE59vA60EKKUEs XzKQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:references:in-reply-to:from:date :message-id:subject:to; bh=RFu4sQDgGAZF3w55oVa63+OPnTSV/ayGf4W9mnqBa6k=; b=jFD7vZbGIPrxgzsRgiQp8f9Gjkh9ySvgzwh/il9PCsD+EnSd08/v0PYz1uegX1yUyY Ovklk5tlKqrgFWr3cjpINcOvfbRQTe5AVLJ8pCuPb5VzBnQBLYYt5RQ2XWl8XkiQPzoc zTmjofuUIYkATgDax/L/0WFkpQ0QnwVIO3K4Fed5jWk/jrpYLY7vjhrYtrMKVQ/pL4Gh 6cyuOJyvI3yZdvYXZTmnfvAt29LQ5oBocbEcRAf1e0YJ+J/kzaBIz+R9wj/V8J0dRUc0 7mMZh1K3ZKXfY83+Ef83YHwqoETpReoD/jfpFf51y0GlglZCDE7doZ7yNieXFFvzW5j+ AEKA== X-Gm-Message-State: AGRZ1gKuINhsamXfyrJyzmESfqkL40ePnN0faEv9451M0rP5sNzirChv 5/8lCuTvOAsCbHWemixa98IzWoLNG2nM/DVfG+f4ayvh X-Google-Smtp-Source: AJdET5d/xXZ+ZxXNGn0nYX3PLCHT98R3tvzFlUP8qZ2LKscWQeRE6JHyDJSvZRFjUW4wVTCgcRegx2NMokpqyC+rQNw= X-Received: by 2002:a17:902:3a5:: with SMTP id d34-v6mr4505495pld.231.1541011311047; Wed, 31 Oct 2018 11:41:51 -0700 (PDT) MIME-Version: 1.0 References: In-Reply-To: From: Avinash Chaurasia Date: Thu, 1 Nov 2018 00:11:10 +0530 Message-ID: To: dev@dpdk.org Content-Type: text/plain; charset="UTF-8" X-Content-Filtered-By: Mailman/MimeDel 2.1.15 Subject: [dpdk-dev] Fwd: Not able to receive packet via api rte_eth_rx_burst X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: DPDK patches and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , X-List-Received-Date: Wed, 31 Oct 2018 18:41:52 -0000 I am not able to figure out any problem with my code, I am using testpmd in txonly mode (./x86_64-native-linuxapp-gcc/app/testpmd -- --forward-mode=txonly) as a transmitter on one machine and this code as a receiver on another machine. ---------- Forwarded message --------- From: Avinash Chaurasia Date: Wed, Oct 31, 2018 at 8:36 PM Subject: Not able to receive packet via api rte_eth_rx_burst To: I have modified rxtx_callback example to just receive on single port. However it is not working rte_eth_stats_get() shows packets are present in ethernet ring via the field ipackets but rte_eth_rx_burst is not returning any packets. Code is included here, please let me know what I am doing wrong. //* SPDX-License-Identifier: BSD-3-Clause * Copyright(c) 2010-2015 Intel Corporation */ #include #include #include #include #include #include #include #include #include #include #include #include #include #define MAX_SOURCE_SIZE (0x100000) #define RX_RING_SIZE 1024 #define TX_RING_SIZE 1024 #define NUM_MBUFS 8191 #define MBUF_CACHE_SIZE 250 #define BURST_SIZE 32 static const struct rte_eth_conf port_conf_default = { .rxmode = { .max_rx_pkt_len = ETHER_MAX_LEN, }, }; static struct { uint64_t total_cycles; uint64_t total_pkts; } latency_numbers; static volatile bool force_quit; struct rte_mempool *mbuf_pool; static void signal_handler(int signum) { struct rte_eth_stats eth_stats; int i; if (signum == SIGINT || signum == SIGTERM) { printf("\n\nSignal %d received, preparing to exit...\n", signum); RTE_ETH_FOREACH_DEV(i) { rte_eth_stats_get(i, ð_stats); printf("Total number of packets received %llu, dropped rx full %llu and rest= %llu, %llu, %llu\n", eth_stats.ipackets, eth_stats.imissed, eth_stats.ierrors, eth_stats.rx_nombuf, eth_stats.q_ipackets[0]); } force_quit = true; } } struct ether_addr addr; /* * Initialises a given port using global settings and with the rx buffers * coming from the mbuf_pool passed as parameter */ static inline int port_init(uint16_t port, struct rte_mempool *mbuf_pool) { struct rte_eth_conf port_conf = port_conf_default; const uint16_t rx_rings = 1, tx_rings = 1; uint16_t nb_rxd = RX_RING_SIZE; uint16_t nb_txd = TX_RING_SIZE; int retval; uint16_t q; struct rte_eth_dev_info dev_info; struct rte_eth_txconf txconf; if (!rte_eth_dev_is_valid_port(port)) return -1; rte_eth_dev_info_get(port, &dev_info); if (dev_info.tx_offload_capa & DEV_TX_OFFLOAD_MBUF_FAST_FREE) port_conf.txmode.offloads |= DEV_TX_OFFLOAD_MBUF_FAST_FREE; retval = rte_eth_dev_configure(port, rx_rings, tx_rings, &port_conf); if (retval != 0) return retval; retval = rte_eth_dev_adjust_nb_rx_tx_desc(port, &nb_rxd, &nb_txd); if (retval != 0) { printf("Error in adjustment\n"); return retval; } for (q = 0; q < rx_rings; q++) { retval = rte_eth_rx_queue_setup(port, q, nb_rxd, rte_eth_dev_socket_id(port), NULL, mbuf_pool); if (retval < 0) { printf("RX queue setup prob\n"); return retval; } } txconf = dev_info.default_txconf; txconf.offloads = port_conf.txmode.offloads; for (q = 0; q < tx_rings; q++) { retval = rte_eth_tx_queue_setup(port, q, nb_txd, rte_eth_dev_socket_id(port), &txconf); if (retval < 0) return retval; } retval = rte_eth_dev_start(port); if (retval < 0) { printf("Error in start\n"); return retval; } rte_eth_macaddr_get(port, &addr); printf("Port %u MAC: %02"PRIx8" %02"PRIx8" %02"PRIx8 " %02"PRIx8" %02"PRIx8" %02"PRIx8"\n", (unsigned)port, addr.addr_bytes[0], addr.addr_bytes[1], addr.addr_bytes[2], addr.addr_bytes[3], addr.addr_bytes[4], addr.addr_bytes[5]); rte_eth_promiscuous_enable(port); return 0; } /* * Main thread that does the work, reading from INPUT_PORT * and writing to OUTPUT_PORT */ static __attribute__((noreturn)) void lcore_main(void) { uint16_t port; struct ether_hdr *eth_hdr; //struct ether_addr addr; //rte_eth_macaddr_get(portid, &addr); struct ipv4_hdr *ipv4_hdr; int32_t i; RTE_ETH_FOREACH_DEV(port) { if (rte_eth_dev_socket_id(port) > 0 && rte_eth_dev_socket_id(port) != (int)rte_socket_id()) printf("WARNING, port %u is on remote NUMA node to " "polling thread.\n\tPerformance will " "not be optimal.\n", port); } printf("\nCore %u forwarding packets. [Ctrl+C to quit]\n", rte_lcore_id()); for (;;) { RTE_ETH_FOREACH_DEV(port) { struct rte_mbuf *bufs[BURST_SIZE]; const uint16_t nb_rx = rte_eth_rx_burst(port, 0,bufs, BURST_SIZE); for(i = 0; i < nb_rx; i++) { ipv4_hdr = rte_pktmbuf_mtod_offset(bufs[i], struct ipv4_hdr *, sizeof(struct ether_hdr)); printf("Packet ip received %d\n", ipv4_hdr->src_addr); } if (unlikely(nb_rx == 0)) continue; const uint16_t nb_tx = 0; // = rte_eth_tx_burst(port ^ 1, 0, bufs, nb_rx); if (unlikely(nb_tx < nb_rx)) { uint16_t buf; for (buf = nb_tx; buf < nb_rx; buf++) rte_pktmbuf_free(bufs[buf]); } } if(force_quit) break; } } /* Main function, does initialisation and calls the per-lcore functions */ int main(int argc, char *argv[]) { uint16_t nb_ports; uint16_t portid, port; /* init EAL */ int ret = rte_eal_init(argc, argv); if (ret < 0) rte_exit(EXIT_FAILURE, "Error with EAL initialization\n"); argc -= ret; argv += ret; force_quit = false; signal(SIGINT, signal_handler); signal(SIGTERM, signal_handler); nb_ports = rte_eth_dev_count_avail(); printf("size ordered %lld\n", NUM_MBUFS *nb_ports); mbuf_pool = rte_pktmbuf_pool_create("MBUF_POOL", NUM_MBUFS * nb_ports, MBUF_CACHE_SIZE, 0, RTE_MBUF_DEFAULT_BUF_SIZE, rte_socket_id()); if (nb_ports < 1) rte_exit(EXIT_FAILURE, "Error: number of ports must be greater than %d\n", nb_ports); if (mbuf_pool == NULL) rte_exit(EXIT_FAILURE, "Cannot create mbuf pool\n"); // initialize all ports RTE_ETH_FOREACH_DEV(portid) if (port_init(portid, mbuf_pool) != 0) rte_exit(EXIT_FAILURE, "Cannot init port %"PRIu8"\n", portid); if (rte_lcore_count() > 1) printf("\nWARNING: Too much enabled lcores - " "App uses only 1 lcore\n"); // call lcore_main on master core only lcore_main(); return 0; } Thanks Avinash Kumar Chaurasia