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>
47 /* Number of packets to attempt to read from queue. */
48 #define PKT_READ_SIZE ((uint16_t)32)
50 /* Define common names for structures shared between ovs_dpdk and client. */
51 #define MP_CLIENT_RXQ_NAME "dpdkr%u_tx"
52 #define MP_CLIENT_TXQ_NAME "dpdkr%u_rx"
54 #define RTE_LOGTYPE_APP RTE_LOGTYPE_USER1
56 /* Our client id number - tells us which rx queue to read, and tx
59 static unsigned int client_id;
62 * Given the rx queue name template above, get the queue name.
64 static inline const char *
65 get_rx_queue_name(unsigned int id)
67 /* Buffer for return value. */
68 static char buffer[RTE_RING_NAMESIZE];
70 snprintf(buffer, sizeof(buffer), MP_CLIENT_RXQ_NAME, id);
75 * Given the tx queue name template above, get the queue name.
77 static inline const char *
78 get_tx_queue_name(unsigned int id)
80 /* Buffer for return value. */
81 static char buffer[RTE_RING_NAMESIZE];
83 snprintf(buffer, sizeof(buffer), MP_CLIENT_TXQ_NAME, id);
88 * Print a usage message.
91 usage(const char *progname)
93 printf("\nUsage: %s [EAL args] -- -n <client_id>\n", progname);
97 * Convert the client id number from a string to an usigned int.
100 parse_client_num(const char *client)
102 if (str_to_uint(client, 10, &client_id)) {
110 * Parse the application arguments to the client app.
113 parse_app_args(int argc, char *argv[])
115 int option_index = 0, opt = 0;
116 char **argvopt = argv;
117 const char *progname = NULL;
118 static struct option lgopts[] = {
123 while ((opt = getopt_long(argc, argvopt, "n:", lgopts,
124 &option_index)) != EOF) {
127 if (parse_client_num(optarg) != 0) {
142 * Application main function - loops through
143 * receiving and processing packets. Never returns
146 main(int argc, char *argv[])
148 struct rte_ring *rx_ring = NULL;
149 struct rte_ring *tx_ring = NULL;
151 void *pkts[PKT_READ_SIZE];
154 if ((retval = rte_eal_init(argc, argv)) < 0) {
161 if (parse_app_args(argc, argv) < 0) {
162 rte_exit(EXIT_FAILURE, "Invalid command-line arguments\n");
165 rx_ring = rte_ring_lookup(get_rx_queue_name(client_id));
166 if (rx_ring == NULL) {
167 rte_exit(EXIT_FAILURE,
168 "Cannot get RX ring - is server process running?\n");
171 tx_ring = rte_ring_lookup(get_tx_queue_name(client_id));
172 if (tx_ring == NULL) {
173 rte_exit(EXIT_FAILURE,
174 "Cannot get TX ring - is server process running?\n");
177 RTE_LOG(INFO, APP, "Finished Process Init.\n");
179 printf("\nClient process %d handling packets\n", client_id);
180 printf("[Press Ctrl-C to quit ...]\n");
183 unsigned rx_pkts = PKT_READ_SIZE;
185 /* Try dequeuing max possible packets first, if that fails, get the
186 * most we can. Loop body should only execute once, maximum.
188 while (unlikely(rte_ring_dequeue_bulk(rx_ring, pkts, rx_pkts) != 0) &&
190 rx_pkts = (uint16_t)RTE_MIN(rte_ring_count(rx_ring), PKT_READ_SIZE);
194 /* blocking enqueue */
196 rslt = rte_ring_enqueue_bulk(tx_ring, pkts, rx_pkts);
197 } while (rslt == -ENOBUFS);