4 * Copyright(c) 2010-2014 Intel Corporation. All rights reserved.
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions
11 * * Redistributions of source code must retain the above copyright
12 * notice, this list of conditions and the following disclaimer.
13 * * Redistributions in binary form must reproduce the above copyright
14 * notice, this list of conditions and the following disclaimer in
15 * the documentation and/or other materials provided with the
17 * * Neither the name of Intel Corporation nor the names of its
18 * contributors may be used to endorse or promote products derived
19 * from this software without specific prior written permission.
21 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
22 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
23 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
24 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
25 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
26 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
27 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
28 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
29 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
30 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
31 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
38 #include <rte_config.h>
40 #include <rte_ether.h>
41 #include <rte_string_fns.h>
43 #include <rte_byteorder.h>
45 /* Number of packets to attempt to read from queue. */
46 #define PKT_READ_SIZE ((uint16_t)32)
48 /* Define common names for structures shared between ovs_dpdk and client. */
49 #define MP_CLIENT_RXQ_NAME "dpdkr%u_tx"
50 #define MP_CLIENT_TXQ_NAME "dpdkr%u_rx"
52 #define RTE_LOGTYPE_APP RTE_LOGTYPE_USER1
56 /* Our client id number - tells us which rx queue to read, and tx
59 static uint8_t client_id = 0;
65 * Given the rx queue name template above, get the queue name.
67 static inline const char *
68 get_rx_queue_name(unsigned id)
70 /* Buffer for return value. Size calculated by %u being replaced
71 * by maximum 3 digits (plus an extra byte for safety).
73 static char buffer[sizeof(MP_CLIENT_RXQ_NAME) + 2];
75 snprintf(buffer, sizeof(buffer) - 1, MP_CLIENT_RXQ_NAME, id);
80 * Given the tx queue name template above, get the queue name.
82 static inline const char *
83 get_tx_queue_name(unsigned id)
85 /* Buffer for return value. Size calculated by %u being replaced
86 * by maximum 3 digits (plus an extra byte for safety).
88 static char buffer[sizeof(MP_CLIENT_TXQ_NAME) + 2];
90 snprintf(buffer, sizeof(buffer) - 1, MP_CLIENT_TXQ_NAME, id);
95 * Print a usage message.
98 usage(const char *progname)
100 printf("\nUsage: %s [EAL args] -- -n <client_id>\n", progname);
104 * Convert the client id number from a string to an int.
107 parse_client_num(const char *client)
110 unsigned long temp = 0;
112 if (client == NULL || *client == '\0') {
116 temp = strtoul(client, &end, BASE_10);
117 /* If valid string argument is provided, terminating '/0' character
118 * is stored in 'end'. */
119 if (end == NULL || *end != '\0') {
123 client_id = (uint8_t)temp;
128 * Parse the application arguments to the client app.
131 parse_app_args(int argc, char *argv[])
133 int option_index = 0, opt = 0;
134 char **argvopt = argv;
135 const char *progname = NULL;
136 static struct option lgopts[] = {
141 while ((opt = getopt_long(argc, argvopt, "n:", lgopts,
142 &option_index)) != EOF) {
145 if (parse_client_num(optarg) != 0) {
160 * Application main function - loops through
161 * receiving and processing packets. Never returns
164 main(int argc, char *argv[])
166 struct rte_ring *rx_ring = NULL;
167 struct rte_ring *tx_ring = NULL;
169 void *pkts[PKT_READ_SIZE];
172 if ((retval = rte_eal_init(argc, argv)) < 0) {
179 if (parse_app_args(argc, argv) < 0) {
180 rte_exit(EXIT_FAILURE, "Invalid command-line arguments\n");
183 rx_ring = rte_ring_lookup(get_rx_queue_name(client_id));
184 if (rx_ring == NULL) {
185 rte_exit(EXIT_FAILURE,
186 "Cannot get RX ring - is server process running?\n");
189 tx_ring = rte_ring_lookup(get_tx_queue_name(client_id));
190 if (tx_ring == NULL) {
191 rte_exit(EXIT_FAILURE,
192 "Cannot get TX ring - is server process running?\n");
195 RTE_LOG(INFO, APP, "Finished Process Init.\n");
197 printf("\nClient process %d handling packets\n", client_id);
198 printf("[Press Ctrl-C to quit ...]\n");
201 unsigned rx_pkts = PKT_READ_SIZE;
203 /* Try dequeuing max possible packets first, if that fails, get the
204 * most we can. Loop body should only execute once, maximum.
206 while (unlikely(rte_ring_dequeue_bulk(rx_ring, pkts, rx_pkts) != 0) &&
208 rx_pkts = (uint16_t)RTE_MIN(rte_ring_count(rx_ring), PKT_READ_SIZE);
213 /* blocking enqueue */
215 rslt = rte_ring_enqueue_bulk(tx_ring, pkts, rx_pkts);
216 } while (rslt == -ENOBUFS);
221 if (!(pkt % 100000)) {
222 printf("pkt %d %d\n", pkt, no_pkt);