remove trailing whitespaces
[dpdk.git] / app / test-pmd / parameters.c
1 /*-
2  *   BSD LICENSE
3  *
4  *   Copyright(c) 2010-2014 Intel Corporation. All rights reserved.
5  *   All rights reserved.
6  *
7  *   Redistribution and use in source and binary forms, with or without
8  *   modification, are permitted provided that the following conditions
9  *   are met:
10  *
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
16  *       distribution.
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.
20  *
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.
32  */
33
34 #include <errno.h>
35 #include <getopt.h>
36 #include <stdarg.h>
37 #include <stdio.h>
38 #include <stdlib.h>
39 #include <signal.h>
40 #include <string.h>
41 #include <time.h>
42 #include <fcntl.h>
43 #include <sys/types.h>
44 #include <errno.h>
45
46 #include <sys/queue.h>
47 #include <sys/stat.h>
48
49 #include <stdint.h>
50 #include <unistd.h>
51 #include <inttypes.h>
52
53 #include <rte_common.h>
54 #include <rte_byteorder.h>
55 #include <rte_log.h>
56 #include <rte_debug.h>
57 #include <rte_cycles.h>
58 #include <rte_memory.h>
59 #include <rte_memzone.h>
60 #include <rte_launch.h>
61 #include <rte_tailq.h>
62 #include <rte_eal.h>
63 #include <rte_per_lcore.h>
64 #include <rte_lcore.h>
65 #include <rte_atomic.h>
66 #include <rte_branch_prediction.h>
67 #include <rte_ring.h>
68 #include <rte_mempool.h>
69 #include <rte_interrupts.h>
70 #include <rte_pci.h>
71 #include <rte_ether.h>
72 #include <rte_ethdev.h>
73 #include <rte_string_fns.h>
74 #ifdef RTE_LIBRTE_CMDLINE
75 #include <cmdline_parse.h>
76 #include <cmdline_parse_etheraddr.h>
77 #endif
78
79 #include "testpmd.h"
80
81 static void
82 usage(char* progname)
83 {
84         printf("usage: %s "
85 #ifdef RTE_LIBRTE_CMDLINE
86                "[--interactive|-i] "
87 #endif
88                "[--help|-h] | [--auto-start|-a] | ["
89                "--coremask=COREMASK --portmask=PORTMASK --numa "
90                "--mbuf-size= | --total-num-mbufs= | "
91                "--nb-cores= | --nb-ports= | "
92 #ifdef RTE_LIBRTE_CMDLINE
93                "--eth-peers-configfile= | "
94                "--eth-peer=X,M:M:M:M:M:M | "
95 #endif
96                "--pkt-filter-mode= |"
97                "--rss-ip | --rss-udp | "
98                "--rxpt= | --rxht= | --rxwt= | --rxfreet= | "
99                "--txpt= | --txht= | --txwt= | --txfreet= | "
100                "--txrst= | --txqflags= ]\n",
101                progname);
102 #ifdef RTE_LIBRTE_CMDLINE
103         printf("  --interactive: run in interactive mode.\n");
104 #endif
105         printf("  --auto-start: start forwarding on init "
106                "[always when non-interactive].\n");
107         printf("  --help: display this message and quit.\n");
108         printf("  --nb-cores=N: set the number of forwarding cores "
109                "(1 <= N <= %d).\n", nb_lcores);
110         printf("  --nb-ports=N: set the number of forwarding ports "
111                "(1 <= N <= %d).\n", nb_ports);
112         printf("  --coremask=COREMASK: hexadecimal bitmask of cores running "
113                "the packet forwarding test. The master lcore is reserved for "
114                "command line parsing only, and cannot be masked on for "
115                "packet forwarding.\n");
116         printf("  --portmask=PORTMASK: hexadecimal bitmask of ports used "
117                "by the packet forwarding test.\n");
118         printf("  --numa: enable NUMA-aware allocation of RX/TX rings and of "
119                "RX memory buffers (mbufs).\n");
120         printf("  --port-numa-config=(port,socket)[,(port,socket)]: "
121                "specify the socket on which the memory pool "
122                "used by the port will be allocated.\n");
123         printf("  --ring-numa-config=(port,flag,socket)[,(port,flag,socket)]: "
124                "specify the socket on which the TX/RX rings for "
125                "the port will be allocated "
126                "(flag: 1 for RX; 2 for TX; 3 for RX and TX).\n");
127         printf("  --socket-num=N: set socket from which all memory is allocated "
128                "in NUMA mode.\n");
129         printf("  --mbuf-size=N: set the data size of mbuf to N bytes.\n");
130         printf("  --total-num-mbufs=N: set the number of mbufs to be allocated "
131                "in mbuf pools.\n");
132         printf("  --max-pkt-len=N: set the maximum size of packet to N bytes.\n");
133 #ifdef RTE_LIBRTE_CMDLINE
134         printf("  --eth-peers-configfile=name: config file with ethernet addresses "
135                "of peer ports.\n");
136         printf("  --eth-peer=X,M:M:M:M:M:M: set the MAC address of the X peer "
137                "port (0 <= X < %d).\n", RTE_MAX_ETHPORTS);
138 #endif
139         printf("  --pkt-filter-mode=N: set Flow Director mode "
140                "(N: none (default mode) or signature or perfect).\n");
141         printf("  --pkt-filter-report-hash=N: set Flow Director report mode "
142                "(N: none  or match (default) or always).\n");
143         printf("  --pkt-filter-size=N: set Flow Director mode "
144                "(N: 64K (default mode) or 128K or 256K).\n");
145         printf("  --pkt-filter-flexbytes-offset=N: set flexbytes-offset. "
146                "The offset is defined in word units counted from the "
147                "first byte of the destination Ethernet MAC address. "
148                "0 <= N <= 32.\n");
149         printf("  --pkt-filter-drop-queue=N: set drop-queue. "
150                "In perfect mode, when you add a rule with queue = -1 "
151                "the packet will be enqueued into the rx drop-queue. "
152                "If the drop-queue doesn't exist, the packet is dropped. "
153                "By default drop-queue=127.\n");
154         printf("  --crc-strip: enable CRC stripping by hardware.\n");
155         printf("  --enable-rx-cksum: enable rx hardware checksum offload.\n");
156         printf("  --disable-hw-vlan: disable hardware vlan.\n");
157         printf("  --enable-drop-en: enable per queue packet drop.\n");
158         printf("  --disable-rss: disable rss.\n");
159         printf("  --port-topology=N: set port topology (N: paired (default) or "
160                "chained).\n");
161         printf("  --forward-mode=N: set forwarding mode (N: %s).\n",
162                list_pkt_forwarding_modes());
163         printf("  --rss-ip: set RSS functions to IPv4/IPv6 only .\n");
164         printf("  --rss-udp: set RSS functions to IPv4/IPv6 + UDP.\n");
165         printf("  --rxq=N: set the number of RX queues per port to N.\n");
166         printf("  --rxd=N: set the number of descriptors in RX rings to N.\n");
167         printf("  --txq=N: set the number of TX queues per port to N.\n");
168         printf("  --txd=N: set the number of descriptors in TX rings to N.\n");
169         printf("  --burst=N: set the number of packets per burst to N.\n");
170         printf("  --mbcache=N: set the cache of mbuf memory pool to N.\n");
171         printf("  --rxpt=N: set prefetch threshold register of RX rings to N "
172                "(0 <= N <= 16).\n");
173         printf("  --rxht=N: set the host threshold register of RX rings to N "
174                "(0 <= N <= 16).\n");
175         printf("  --rxfreet=N: set the free threshold of RX descriptors to N "
176                "(0 <= N < value of rxd).\n");
177         printf("  --rxwt=N: set the write-back threshold register of RX rings "
178                "to N (0 <= N <= 16).\n");
179         printf("  --txpt=N: set the prefetch threshold register of TX rings "
180                "to N (0 <= N <= 16).\n");
181         printf("  --txht=N: set the nhost threshold register of TX rings to N "
182                "(0 <= N <= 16).\n");
183         printf("  --txwt=N: set the write-back threshold register of TX rings "
184                "to N (0 <= N <= 16).\n");
185         printf("  --txfreet=N: set the transmit free threshold of TX rings to N "
186                "(0 <= N <= value of txd).\n");
187         printf("  --txrst=N: set the transmit RS bit threshold of TX rings to N "
188                "(0 <= N <= value of txd).\n");
189         printf("  --txqflags=0xXXXXXXXX: hexadecimal bitmask of TX queue flags "
190                "(0 <= N <= 0x7FFFFFFF).\n");
191         printf("  --tx-queue-stats-mapping=(port,queue,mapping)[,(port,queue,mapping]: "
192                "tx queues statistics counters mapping "
193                "(0 <= mapping <= %d).\n", RTE_ETHDEV_QUEUE_STAT_CNTRS - 1);
194         printf("  --rx-queue-stats-mapping=(port,queue,mapping)[,(port,queue,mapping]: "
195                "rx queues statistics counters mapping "
196                "(0 <= mapping <= %d).\n", RTE_ETHDEV_QUEUE_STAT_CNTRS - 1);
197         printf("  --no-flush-rx: Don't flush RX streams before forwarding."
198                " Used mainly with PCAP drivers.\n");
199         printf("  --txpkts=X[,Y]*: set TX segment sizes.\n");
200         printf("  --disable-link-check: disable check on link status when "
201                "starting/stopping ports.\n");
202 }
203
204 #ifdef RTE_LIBRTE_CMDLINE
205 static int
206 init_peer_eth_addrs(char *config_filename)
207 {
208         FILE *config_file;
209         portid_t i;
210         char buf[50];
211
212         config_file = fopen(config_filename, "r");
213         if (config_file == NULL) {
214                 perror("Failed to open eth config file\n");
215                 return -1;
216         }
217
218         for (i = 0; i < RTE_MAX_ETHPORTS; i++) {
219
220                 if (fgets(buf, sizeof(buf), config_file) == NULL)
221                         break;
222
223                 if (cmdline_parse_etheraddr(NULL, buf, &peer_eth_addrs[i]) < 0 ){
224                         printf("Bad MAC address format on line %d\n", i+1);
225                         fclose(config_file);
226                         return -1;
227                 }
228         }
229         fclose(config_file);
230         nb_peer_eth_addrs = (portid_t) i;
231         return 0;
232 }
233 #endif
234
235 /*
236  * Parse the coremask given as argument (hexadecimal string) and set
237  * the global configuration of forwarding cores.
238  */
239 static void
240 parse_fwd_coremask(const char *coremask)
241 {
242         char *end;
243         unsigned long long int cm;
244
245         /* parse hexadecimal string */
246         end = NULL;
247         cm = strtoull(coremask, &end, 16);
248         if ((coremask[0] == '\0') || (end == NULL) || (*end != '\0'))
249                 rte_exit(EXIT_FAILURE, "Invalid fwd core mask\n");
250         else if (set_fwd_lcores_mask((uint64_t) cm) < 0)
251                 rte_exit(EXIT_FAILURE, "coremask is not valid\n");
252 }
253
254 /*
255  * Parse the coremask given as argument (hexadecimal string) and set
256  * the global configuration of forwarding cores.
257  */
258 static void
259 parse_fwd_portmask(const char *portmask)
260 {
261         char *end;
262         unsigned long long int pm;
263
264         /* parse hexadecimal string */
265         end = NULL;
266         pm = strtoull(portmask, &end, 16);
267         if ((portmask[0] == '\0') || (end == NULL) || (*end != '\0'))
268                 rte_exit(EXIT_FAILURE, "Invalid fwd port mask\n");
269         else
270                 set_fwd_ports_mask((uint64_t) pm);
271 }
272
273
274 static int
275 parse_queue_stats_mapping_config(const char *q_arg, int is_rx)
276 {
277         char s[256];
278         const char *p, *p0 = q_arg;
279         char *end;
280         enum fieldnames {
281                 FLD_PORT = 0,
282                 FLD_QUEUE,
283                 FLD_STATS_COUNTER,
284                 _NUM_FLD
285         };
286         unsigned long int_fld[_NUM_FLD];
287         char *str_fld[_NUM_FLD];
288         int i;
289         unsigned size;
290
291         /* reset from value set at definition */
292         is_rx ? (nb_rx_queue_stats_mappings = 0) : (nb_tx_queue_stats_mappings = 0);
293
294         while ((p = strchr(p0,'(')) != NULL) {
295                 ++p;
296                 if((p0 = strchr(p,')')) == NULL)
297                         return -1;
298
299                 size = p0 - p;
300                 if(size >= sizeof(s))
301                         return -1;
302
303                 rte_snprintf(s, sizeof(s), "%.*s", size, p);
304                 if (rte_strsplit(s, sizeof(s), str_fld, _NUM_FLD, ',') != _NUM_FLD)
305                         return -1;
306                 for (i = 0; i < _NUM_FLD; i++){
307                         errno = 0;
308                         int_fld[i] = strtoul(str_fld[i], &end, 0);
309                         if (errno != 0 || end == str_fld[i] || int_fld[i] > 255)
310                                 return -1;
311                 }
312                 /* Check mapping field is in correct range (0..RTE_ETHDEV_QUEUE_STAT_CNTRS-1) */
313                 if (int_fld[FLD_STATS_COUNTER] >= RTE_ETHDEV_QUEUE_STAT_CNTRS) {
314                         printf("Stats counter not in the correct range 0..%d\n",
315                                         RTE_ETHDEV_QUEUE_STAT_CNTRS - 1);
316                         return -1;
317                 }
318
319                 if (is_rx ? (nb_rx_queue_stats_mappings >= MAX_RX_QUEUE_STATS_MAPPINGS) :
320                     (nb_tx_queue_stats_mappings >= MAX_TX_QUEUE_STATS_MAPPINGS)) {
321                         printf("exceeded max number of %s queue statistics mappings: %hu\n",
322                                is_rx ? "RX" : "TX",
323                                is_rx ? nb_rx_queue_stats_mappings : nb_tx_queue_stats_mappings);
324                         return -1;
325                 }
326                 if (!is_rx) {
327                         tx_queue_stats_mappings_array[nb_tx_queue_stats_mappings].port_id =
328                                 (uint8_t)int_fld[FLD_PORT];
329                         tx_queue_stats_mappings_array[nb_tx_queue_stats_mappings].queue_id =
330                                 (uint8_t)int_fld[FLD_QUEUE];
331                         tx_queue_stats_mappings_array[nb_tx_queue_stats_mappings].stats_counter_id =
332                                 (uint8_t)int_fld[FLD_STATS_COUNTER];
333                         ++nb_tx_queue_stats_mappings;
334                 }
335                 else {
336                         rx_queue_stats_mappings_array[nb_rx_queue_stats_mappings].port_id =
337                                 (uint8_t)int_fld[FLD_PORT];
338                         rx_queue_stats_mappings_array[nb_rx_queue_stats_mappings].queue_id =
339                                 (uint8_t)int_fld[FLD_QUEUE];
340                         rx_queue_stats_mappings_array[nb_rx_queue_stats_mappings].stats_counter_id =
341                                 (uint8_t)int_fld[FLD_STATS_COUNTER];
342                         ++nb_rx_queue_stats_mappings;
343                 }
344
345         }
346 /* Reassign the rx/tx_queue_stats_mappings pointer to point to this newly populated array rather */
347 /* than to the default array (that was set at its definition) */
348         is_rx ? (rx_queue_stats_mappings = rx_queue_stats_mappings_array) :
349                 (tx_queue_stats_mappings = tx_queue_stats_mappings_array);
350         return 0;
351 }
352
353 static int
354 parse_portnuma_config(const char *q_arg)
355 {
356         char s[256];
357         const char *p, *p0 = q_arg;
358         char *end;
359         uint8_t i,port_id,socket_id;
360         unsigned size;
361         enum fieldnames {
362                 FLD_PORT = 0,
363                 FLD_SOCKET,
364                 _NUM_FLD
365         };
366         unsigned long int_fld[_NUM_FLD];
367         char *str_fld[_NUM_FLD];
368
369         /* reset from value set at definition */
370         while ((p = strchr(p0,'(')) != NULL) {
371                 ++p;
372                 if((p0 = strchr(p,')')) == NULL)
373                         return -1;
374
375                 size = p0 - p;
376                 if(size >= sizeof(s))
377                         return -1;
378
379                 rte_snprintf(s, sizeof(s), "%.*s", size, p);
380                 if (rte_strsplit(s, sizeof(s), str_fld, _NUM_FLD, ',') != _NUM_FLD)
381                         return -1;
382                 for (i = 0; i < _NUM_FLD; i++) {
383                         errno = 0;
384                         int_fld[i] = strtoul(str_fld[i], &end, 0);
385                         if (errno != 0 || end == str_fld[i] || int_fld[i] > 255)
386                                 return -1;
387                 }
388                 port_id = (uint8_t)int_fld[FLD_PORT];
389                 if (port_id >= nb_ports) {
390                         printf("Invalid port, range is [0, %d]\n", nb_ports - 1);
391                         return -1;
392                 }
393                 socket_id = (uint8_t)int_fld[FLD_SOCKET];
394                 if(socket_id >= MAX_SOCKET) {
395                         printf("Invalid socket id, range is [0, %d]\n",
396                                  MAX_SOCKET - 1);
397                         return -1;
398                 }
399                 port_numa[port_id] = socket_id;
400         }
401
402         return 0;
403 }
404
405 static int
406 parse_ringnuma_config(const char *q_arg)
407 {
408         char s[256];
409         const char *p, *p0 = q_arg;
410         char *end;
411         uint8_t i,port_id,ring_flag,socket_id;
412         unsigned size;
413         enum fieldnames {
414                 FLD_PORT = 0,
415                 FLD_FLAG,
416                 FLD_SOCKET,
417                 _NUM_FLD
418         };
419         unsigned long int_fld[_NUM_FLD];
420         char *str_fld[_NUM_FLD];
421         #define RX_RING_ONLY 0x1
422         #define TX_RING_ONLY 0x2
423         #define RXTX_RING    0x3
424
425         /* reset from value set at definition */
426         while ((p = strchr(p0,'(')) != NULL) {
427                 ++p;
428                 if((p0 = strchr(p,')')) == NULL)
429                         return -1;
430
431                 size = p0 - p;
432                 if(size >= sizeof(s))
433                         return -1;
434
435                 rte_snprintf(s, sizeof(s), "%.*s", size, p);
436                 if (rte_strsplit(s, sizeof(s), str_fld, _NUM_FLD, ',') != _NUM_FLD)
437                         return -1;
438                 for (i = 0; i < _NUM_FLD; i++) {
439                         errno = 0;
440                         int_fld[i] = strtoul(str_fld[i], &end, 0);
441                         if (errno != 0 || end == str_fld[i] || int_fld[i] > 255)
442                                 return -1;
443                 }
444                 port_id = (uint8_t)int_fld[FLD_PORT];
445                 if (port_id >= nb_ports) {
446                         printf("Invalid port, range is [0, %d]\n", nb_ports - 1);
447                         return -1;
448                 }
449                 socket_id = (uint8_t)int_fld[FLD_SOCKET];
450                 if (socket_id >= MAX_SOCKET) {
451                         printf("Invalid socket id, range is [0, %d]\n",
452                                 MAX_SOCKET - 1);
453                         return -1;
454                 }
455                 ring_flag = (uint8_t)int_fld[FLD_FLAG];
456                 if ((ring_flag < RX_RING_ONLY) || (ring_flag > RXTX_RING)) {
457                         printf("Invalid ring-flag=%d config for port =%d\n",
458                                 ring_flag,port_id);
459                         return -1;
460                 }
461
462                 switch (ring_flag & RXTX_RING) {
463                 case RX_RING_ONLY:
464                         rxring_numa[port_id] = socket_id;
465                         break;
466                 case TX_RING_ONLY:
467                         txring_numa[port_id] = socket_id;
468                         break;
469                 case RXTX_RING:
470                         rxring_numa[port_id] = socket_id;
471                         txring_numa[port_id] = socket_id;
472                         break;
473                 default:
474                         printf("Invalid ring-flag=%d config for port=%d\n",
475                                 ring_flag,port_id);
476                         break;
477                 }
478         }
479
480         return 0;
481 }
482
483 static unsigned int
484 parse_item_list(char* str, unsigned int max_items, unsigned int *parsed_items)
485 {
486         unsigned int nb_item;
487         unsigned int value;
488         unsigned int i;
489         int value_ok;
490         char c;
491
492         /*
493          * First parse all items in the list and store their value.
494          */
495         value = 0;
496         nb_item = 0;
497         value_ok = 0;
498         for (i = 0; i < strlen(str); i++) {
499                 c = str[i];
500                 if ((c >= '0') && (c <= '9')) {
501                         value = (unsigned int) (value * 10 + (c - '0'));
502                         value_ok = 1;
503                         continue;
504                 }
505                 if (c != ',') {
506                         printf("character %c is not a decimal digit\n", c);
507                         return (0);
508                 }
509                 if (! value_ok) {
510                         printf("No valid value before comma\n");
511                         return (0);
512                 }
513                 if (nb_item < max_items) {
514                         parsed_items[nb_item] = value;
515                         value_ok = 0;
516                         value = 0;
517                 }
518                 nb_item++;
519         }
520
521         if (nb_item >= max_items)
522                 rte_exit(EXIT_FAILURE, "too many txpkt segments!\n");
523
524         parsed_items[nb_item++] = value;
525
526         return (nb_item);
527 }
528
529 void
530 launch_args_parse(int argc, char** argv)
531 {
532         int n, opt;
533         char **argvopt;
534         int opt_idx;
535         enum { TX, RX };
536
537         static struct option lgopts[] = {
538                 { "help",                       0, 0, 0 },
539 #ifdef RTE_LIBRTE_CMDLINE
540                 { "interactive",                0, 0, 0 },
541                 { "auto-start",                 0, 0, 0 },
542                 { "eth-peers-configfile",       1, 0, 0 },
543                 { "eth-peer",                   1, 0, 0 },
544 #endif
545                 { "ports",                      1, 0, 0 },
546                 { "nb-cores",                   1, 0, 0 },
547                 { "nb-ports",                   1, 0, 0 },
548                 { "coremask",                   1, 0, 0 },
549                 { "portmask",                   1, 0, 0 },
550                 { "numa",                       0, 0, 0 },
551                 { "mp-anon",                    0, 0, 0 },
552                 { "port-numa-config",           1, 0, 0 },
553                 { "ring-numa-config",           1, 0, 0 },
554                 { "socket-num",                 1, 0, 0 },
555                 { "mbuf-size",                  1, 0, 0 },
556                 { "total-num-mbufs",            1, 0, 0 },
557                 { "max-pkt-len",                1, 0, 0 },
558                 { "pkt-filter-mode",            1, 0, 0 },
559                 { "pkt-filter-report-hash",     1, 0, 0 },
560                 { "pkt-filter-size",            1, 0, 0 },
561                 { "pkt-filter-flexbytes-offset",1, 0, 0 },
562                 { "pkt-filter-drop-queue",      1, 0, 0 },
563                 { "crc-strip",                  0, 0, 0 },
564                 { "enable-rx-cksum",            0, 0, 0 },
565                 { "disable-hw-vlan",            0, 0, 0 },
566                 { "enable-drop-en",            0, 0, 0 },
567                 { "disable-rss",                0, 0, 0 },
568                 { "port-topology",              1, 0, 0 },
569                 { "forward-mode",               1, 0, 0 },
570                 { "rss-ip",                     0, 0, 0 },
571                 { "rss-udp",                    0, 0, 0 },
572                 { "rxq",                        1, 0, 0 },
573                 { "txq",                        1, 0, 0 },
574                 { "rxd",                        1, 0, 0 },
575                 { "txd",                        1, 0, 0 },
576                 { "burst",                      1, 0, 0 },
577                 { "mbcache",                    1, 0, 0 },
578                 { "txpt",                       1, 0, 0 },
579                 { "txht",                       1, 0, 0 },
580                 { "txwt",                       1, 0, 0 },
581                 { "txfreet",                    1, 0, 0 },
582                 { "txrst",                      1, 0, 0 },
583                 { "txqflags",                   1, 0, 0 },
584                 { "rxpt",                       1, 0, 0 },
585                 { "rxht",                       1, 0, 0 },
586                 { "rxwt",                       1, 0, 0 },
587                 { "rxfreet",                    1, 0, 0 },
588                 { "tx-queue-stats-mapping",     1, 0, 0 },
589                 { "rx-queue-stats-mapping",     1, 0, 0 },
590                 { "no-flush-rx",        0, 0, 0 },
591                 { "txpkts",                     1, 0, 0 },
592                 { "disable-link-check",         0, 0, 0 },
593                 { 0, 0, 0, 0 },
594         };
595
596         argvopt = argv;
597
598 #ifdef RTE_LIBRTE_CMDLINE
599 #define SHORTOPTS "i"
600 #else
601 #define SHORTOPTS ""
602 #endif
603         while ((opt = getopt_long(argc, argvopt, SHORTOPTS "ah",
604                                  lgopts, &opt_idx)) != EOF) {
605                 switch (opt) {
606 #ifdef RTE_LIBRTE_CMDLINE
607                 case 'i':
608                         printf("Interactive-mode selected\n");
609                         interactive = 1;
610                         break;
611 #endif
612                 case 'a':
613                         printf("Auto-start selected\n");
614                         auto_start = 1;
615                         break;
616
617                 case 0: /*long options */
618                         if (!strcmp(lgopts[opt_idx].name, "help")) {
619                                 usage(argv[0]);
620                                 rte_exit(EXIT_SUCCESS, "Displayed help\n");
621                         }
622 #ifdef RTE_LIBRTE_CMDLINE
623                         if (!strcmp(lgopts[opt_idx].name, "interactive")) {
624                                 printf("Interactive-mode selected\n");
625                                 interactive = 1;
626                         }
627                         if (!strcmp(lgopts[opt_idx].name, "auto-start")) {
628                                 printf("Auto-start selected\n");
629                                 auto_start = 1;
630                         }
631                         if (!strcmp(lgopts[opt_idx].name,
632                                     "eth-peers-configfile")) {
633                                 if (init_peer_eth_addrs(optarg) != 0)
634                                         rte_exit(EXIT_FAILURE,
635                                                  "Cannot open logfile\n");
636                         }
637                         if (!strcmp(lgopts[opt_idx].name, "eth-peer")) {
638                                 char *port_end;
639                                 uint8_t c, peer_addr[6];
640
641                                 errno = 0;
642                                 n = strtoul(optarg, &port_end, 10);
643                                 if (errno != 0 || port_end == optarg || *port_end++ != ',')
644                                         rte_exit(EXIT_FAILURE,
645                                                  "Invalid eth-peer: %s", optarg);
646                                 if (n >= RTE_MAX_ETHPORTS)
647                                         rte_exit(EXIT_FAILURE,
648                                                  "eth-peer: port %d >= RTE_MAX_ETHPORTS(%d)\n",
649                                                  n, RTE_MAX_ETHPORTS);
650
651                                 if (cmdline_parse_etheraddr(NULL, port_end, &peer_addr) < 0 )
652                                         rte_exit(EXIT_FAILURE,
653                                                  "Invalid ethernet address: %s\n",
654                                                  port_end);
655                                 for (c = 0; c < 6; c++)
656                                         peer_eth_addrs[n].addr_bytes[c] =
657                                                 peer_addr[c];
658                                 nb_peer_eth_addrs++;
659                         }
660 #endif
661                         if (!strcmp(lgopts[opt_idx].name, "nb-ports")) {
662                                 n = atoi(optarg);
663                                 if (n > 0 && n <= nb_ports)
664                                         nb_fwd_ports = (uint8_t) n;
665                                 else
666                                         rte_exit(EXIT_FAILURE,
667                                                  "nb-ports should be > 0 and <= %d\n",
668                                                  nb_ports);
669                         }
670                         if (!strcmp(lgopts[opt_idx].name, "nb-cores")) {
671                                 n = atoi(optarg);
672                                 if (n > 0 && n <= nb_lcores)
673                                         nb_fwd_lcores = (uint8_t) n;
674                                 else
675                                         rte_exit(EXIT_FAILURE,
676                                                  "nb-cores should be > 0 and <= %d\n",
677                                                  nb_lcores);
678                         }
679                         if (!strcmp(lgopts[opt_idx].name, "coremask"))
680                                 parse_fwd_coremask(optarg);
681                         if (!strcmp(lgopts[opt_idx].name, "portmask"))
682                                 parse_fwd_portmask(optarg);
683                         if (!strcmp(lgopts[opt_idx].name, "numa")) {
684                                 numa_support = 1;
685                                 memset(port_numa,NUMA_NO_CONFIG,RTE_MAX_ETHPORTS);
686                                 memset(rxring_numa,NUMA_NO_CONFIG,RTE_MAX_ETHPORTS);
687                                 memset(txring_numa,NUMA_NO_CONFIG,RTE_MAX_ETHPORTS);
688                         }
689                         if (!strcmp(lgopts[opt_idx].name, "mp-anon")) {
690                                 mp_anon = 1;
691                         }
692                         if (!strcmp(lgopts[opt_idx].name, "port-numa-config")) {
693                                 if (parse_portnuma_config(optarg))
694                                         rte_exit(EXIT_FAILURE,
695                                            "invalid port-numa configuration\n");
696                         }
697                         if (!strcmp(lgopts[opt_idx].name, "ring-numa-config"))
698                                 if (parse_ringnuma_config(optarg))
699                                         rte_exit(EXIT_FAILURE,
700                                            "invalid ring-numa configuration\n");
701                         if (!strcmp(lgopts[opt_idx].name, "socket-num")) {
702                                 n = atoi(optarg);
703                                 if(n < MAX_SOCKET)
704                                         socket_num = (uint8_t)n;
705                                 else
706                                         rte_exit(EXIT_FAILURE,
707                                                 "The socket number should be < %d\n",
708                                                 MAX_SOCKET);
709                         }
710                         if (!strcmp(lgopts[opt_idx].name, "mbuf-size")) {
711                                 n = atoi(optarg);
712                                 if (n > 0 && n <= 0xFFFF)
713                                         mbuf_data_size = (uint16_t) n;
714                                 else
715                                         rte_exit(EXIT_FAILURE,
716                                                  "mbuf-size should be > 0 and < 65536\n");
717                         }
718                         if (!strcmp(lgopts[opt_idx].name, "total-num-mbufs")) {
719                                 n = atoi(optarg);
720                                 if (n > 1024)
721                                         param_total_num_mbufs = (unsigned)n;
722                                 else
723                                         rte_exit(EXIT_FAILURE,
724                                                  "total-num-mbufs should be > 1024\n");
725                         }
726                         if (!strcmp(lgopts[opt_idx].name, "max-pkt-len")) {
727                                 n = atoi(optarg);
728                                 if (n >= ETHER_MIN_LEN) {
729                                         rx_mode.max_rx_pkt_len = (uint32_t) n;
730                                         if (n > ETHER_MAX_LEN)
731                                             rx_mode.jumbo_frame = 1;
732                                 } else
733                                         rte_exit(EXIT_FAILURE,
734                                                  "Invalid max-pkt-len=%d - should be > %d\n",
735                                                  n, ETHER_MIN_LEN);
736                         }
737                         if (!strcmp(lgopts[opt_idx].name, "pkt-filter-mode")) {
738                                 if (!strcmp(optarg, "signature"))
739                                         fdir_conf.mode =
740                                                 RTE_FDIR_MODE_SIGNATURE;
741                                 else if (!strcmp(optarg, "perfect"))
742                                         fdir_conf.mode = RTE_FDIR_MODE_PERFECT;
743                                 else if (!strcmp(optarg, "none"))
744                                         fdir_conf.mode = RTE_FDIR_MODE_NONE;
745                                 else
746                                         rte_exit(EXIT_FAILURE,
747                                                  "pkt-mode-invalid %s invalid - must be: "
748                                                  "none, signature or perfect\n",
749                                                  optarg);
750                         }
751                         if (!strcmp(lgopts[opt_idx].name,
752                                     "pkt-filter-report-hash")) {
753                                 if (!strcmp(optarg, "none"))
754                                         fdir_conf.status =
755                                                 RTE_FDIR_NO_REPORT_STATUS;
756                                 else if (!strcmp(optarg, "match"))
757                                         fdir_conf.status =
758                                                 RTE_FDIR_REPORT_STATUS;
759                                 else if (!strcmp(optarg, "always"))
760                                         fdir_conf.status =
761                                                 RTE_FDIR_REPORT_STATUS_ALWAYS;
762                                 else
763                                         rte_exit(EXIT_FAILURE,
764                                                  "pkt-filter-report-hash %s invalid "
765                                                  "- must be: none or match or always\n",
766                                                  optarg);
767                         }
768                         if (!strcmp(lgopts[opt_idx].name, "pkt-filter-size")) {
769                                 if (!strcmp(optarg, "64K"))
770                                         fdir_conf.pballoc =
771                                                 RTE_FDIR_PBALLOC_64K;
772                                 else if (!strcmp(optarg, "128K"))
773                                         fdir_conf.pballoc =
774                                                 RTE_FDIR_PBALLOC_128K;
775                                 else if (!strcmp(optarg, "256K"))
776                                         fdir_conf.pballoc =
777                                                 RTE_FDIR_PBALLOC_256K;
778                                 else
779                                         rte_exit(EXIT_FAILURE, "pkt-filter-size %s invalid -"
780                                                  " must be: 64K or 128K or 256K\n",
781                                                  optarg);
782                         }
783                         if (!strcmp(lgopts[opt_idx].name,
784                                     "pkt-filter-flexbytes-offset")) {
785                                 n = atoi(optarg);
786                                 if ( n >= 0 && n <= (int) 32)
787                                         fdir_conf.flexbytes_offset =
788                                                 (uint8_t) n;
789                                 else
790                                         rte_exit(EXIT_FAILURE,
791                                                  "flexbytes %d invalid - must"
792                                                  "be  >= 0 && <= 32\n", n);
793                         }
794                         if (!strcmp(lgopts[opt_idx].name,
795                                     "pkt-filter-drop-queue")) {
796                                 n = atoi(optarg);
797                                 if (n >= 0)
798                                         fdir_conf.drop_queue = (uint8_t) n;
799                                 else
800                                         rte_exit(EXIT_FAILURE,
801                                                  "drop queue %d invalid - must"
802                                                  "be >= 0 \n", n);
803                         }
804                         if (!strcmp(lgopts[opt_idx].name, "crc-strip"))
805                                 rx_mode.hw_strip_crc = 1;
806                         if (!strcmp(lgopts[opt_idx].name, "enable-rx-cksum"))
807                                 rx_mode.hw_ip_checksum = 1;
808
809                         if (!strcmp(lgopts[opt_idx].name, "disable-hw-vlan")) {
810                                 rx_mode.hw_vlan_filter = 0;
811                                 rx_mode.hw_vlan_strip  = 0;
812                                 rx_mode.hw_vlan_extend = 0;
813                         }
814
815                         if (!strcmp(lgopts[opt_idx].name, "enable-drop-en"))
816                                 rx_drop_en = 1;
817
818                         if (!strcmp(lgopts[opt_idx].name, "disable-rss"))
819                                 rss_hf = 0;
820                         if (!strcmp(lgopts[opt_idx].name, "port-topology")) {
821                                 if (!strcmp(optarg, "paired"))
822                                         port_topology = PORT_TOPOLOGY_PAIRED;
823                                 else if (!strcmp(optarg, "chained"))
824                                         port_topology = PORT_TOPOLOGY_CHAINED;
825                                 else if (!strcmp(optarg, "loop"))
826                                         port_topology = PORT_TOPOLOGY_LOOP;
827                                 else
828                                         rte_exit(EXIT_FAILURE, "port-topology %s invalid -"
829                                                  " must be: paired or chained \n",
830                                                  optarg);
831                         }
832                         if (!strcmp(lgopts[opt_idx].name, "forward-mode"))
833                                 set_pkt_forwarding_mode(optarg);
834                         if (!strcmp(lgopts[opt_idx].name, "rss-ip"))
835                                 rss_hf = ETH_RSS_IPV4 | ETH_RSS_IPV6;
836                         if (!strcmp(lgopts[opt_idx].name, "rss-udp"))
837                                 rss_hf = ETH_RSS_IPV4 |
838                                                 ETH_RSS_IPV6 | ETH_RSS_IPV4_UDP;
839                         if (!strcmp(lgopts[opt_idx].name, "rxq")) {
840                                 n = atoi(optarg);
841                                 if (n >= 1 && n <= (int) MAX_QUEUE_ID)
842                                         nb_rxq = (queueid_t) n;
843                                 else
844                                         rte_exit(EXIT_FAILURE, "rxq %d invalid - must be"
845                                                   " >= 1 && <= %d\n", n,
846                                                   (int) MAX_QUEUE_ID);
847                         }
848                         if (!strcmp(lgopts[opt_idx].name, "txq")) {
849                                 n = atoi(optarg);
850                                 if (n >= 1 && n <= (int) MAX_QUEUE_ID)
851                                         nb_txq = (queueid_t) n;
852                                 else
853                                         rte_exit(EXIT_FAILURE, "txq %d invalid - must be"
854                                                   " >= 1 && <= %d\n", n,
855                                                   (int) MAX_QUEUE_ID);
856                         }
857                         if (!strcmp(lgopts[opt_idx].name, "rxd")) {
858                                 n = atoi(optarg);
859                                 if (n > 0)
860                                         nb_rxd = (uint16_t) n;
861                                 else
862                                         rte_exit(EXIT_FAILURE, "rxd must be > 0\n");
863                         }
864                         if (!strcmp(lgopts[opt_idx].name, "txd")) {
865                                 n = atoi(optarg);
866                                 if (n > 0)
867                                         nb_txd = (uint16_t) n;
868                                 else
869                                         rte_exit(EXIT_FAILURE, "txd must be in > 0\n");
870                         }
871                         if (!strcmp(lgopts[opt_idx].name, "burst")) {
872                                 n = atoi(optarg);
873                                 if ((n >= 1) && (n <= MAX_PKT_BURST))
874                                         nb_pkt_per_burst = (uint16_t) n;
875                                 else
876                                         rte_exit(EXIT_FAILURE,
877                                                  "burst must >= 1 and <= %d]",
878                                                  MAX_PKT_BURST);
879                         }
880                         if (!strcmp(lgopts[opt_idx].name, "mbcache")) {
881                                 n = atoi(optarg);
882                                 if ((n >= 0) &&
883                                     (n <= RTE_MEMPOOL_CACHE_MAX_SIZE))
884                                         mb_mempool_cache = (uint16_t) n;
885                                 else
886                                         rte_exit(EXIT_FAILURE,
887                                                  "mbcache must be >= 0 and <= %d\n",
888                                                  RTE_MEMPOOL_CACHE_MAX_SIZE);
889                         }
890                         if (!strcmp(lgopts[opt_idx].name, "txpt")) {
891                                 n = atoi(optarg);
892                                 if (n >= 0)
893                                         tx_thresh.pthresh = (uint8_t)n;
894                                 else
895                                         rte_exit(EXIT_FAILURE, "txpt must be >= 0\n");
896                         }
897                         if (!strcmp(lgopts[opt_idx].name, "txht")) {
898                                 n = atoi(optarg);
899                                 if (n >= 0)
900                                         tx_thresh.hthresh = (uint8_t)n;
901                                 else
902                                         rte_exit(EXIT_FAILURE, "txht must be >= 0\n");
903                         }
904                         if (!strcmp(lgopts[opt_idx].name, "txwt")) {
905                                 n = atoi(optarg);
906                                 if (n >= 0)
907                                         tx_thresh.wthresh = (uint8_t)n;
908                                 else
909                                         rte_exit(EXIT_FAILURE, "txwt must be >= 0\n");
910                         }
911                         if (!strcmp(lgopts[opt_idx].name, "txfreet")) {
912                                 n = atoi(optarg);
913                                 if (n >= 0)
914                                         tx_free_thresh = (uint16_t)n;
915                                 else
916                                         rte_exit(EXIT_FAILURE, "txfreet must be >= 0\n");
917                         }
918                         if (!strcmp(lgopts[opt_idx].name, "txrst")) {
919                                 n = atoi(optarg);
920                                 if (n >= 0)
921                                         tx_rs_thresh = (uint16_t)n;
922                                 else
923                                         rte_exit(EXIT_FAILURE, "txrst must be >= 0\n");
924                         }
925                         if (!strcmp(lgopts[opt_idx].name, "txqflags")) {
926                                 char *end = NULL;
927                                 n = strtoul(optarg, &end, 16);
928                                 if (n >= 0)
929                                         txq_flags = (uint32_t)n;
930                                 else
931                                         rte_exit(EXIT_FAILURE,
932                                                  "txqflags must be >= 0\n");
933                         }
934                         if (!strcmp(lgopts[opt_idx].name, "rxpt")) {
935                                 n = atoi(optarg);
936                                 if (n >= 0)
937                                         rx_thresh.pthresh = (uint8_t)n;
938                                 else
939                                         rte_exit(EXIT_FAILURE, "rxpt must be >= 0\n");
940                         }
941                         if (!strcmp(lgopts[opt_idx].name, "rxht")) {
942                                 n = atoi(optarg);
943                                 if (n >= 0)
944                                         rx_thresh.hthresh = (uint8_t)n;
945                                 else
946                                         rte_exit(EXIT_FAILURE, "rxht must be >= 0\n");
947                         }
948                         if (!strcmp(lgopts[opt_idx].name, "rxwt")) {
949                                 n = atoi(optarg);
950                                 if (n >= 0)
951                                         rx_thresh.wthresh = (uint8_t)n;
952                                 else
953                                         rte_exit(EXIT_FAILURE, "rxwt must be >= 0\n");
954                         }
955                         if (!strcmp(lgopts[opt_idx].name, "rxd")) {
956                                 n = atoi(optarg);
957                                 if (n > 0) {
958                                         if (rx_free_thresh >= n)
959                                                 rte_exit(EXIT_FAILURE,
960                                                          "rxd must be > "
961                                                          "rx_free_thresh(%d)\n",
962                                                          (int)rx_free_thresh);
963                                         else
964                                                 nb_rxd = (uint16_t) n;
965                                 } else
966                                         rte_exit(EXIT_FAILURE,
967                                                  "rxd(%d) invalid - must be > 0\n",
968                                                  n);
969                         }
970                         if (!strcmp(lgopts[opt_idx].name, "txd")) {
971                                 n = atoi(optarg);
972                                 if (n > 0)
973                                         nb_txd = (uint16_t) n;
974                                 else
975                                         rte_exit(EXIT_FAILURE, "txd must be in > 0\n");
976                         }
977                         if (!strcmp(lgopts[opt_idx].name, "txpt")) {
978                                 n = atoi(optarg);
979                                 if (n >= 0)
980                                         tx_thresh.pthresh = (uint8_t)n;
981                                 else
982                                         rte_exit(EXIT_FAILURE, "txpt must be >= 0\n");
983                         }
984                         if (!strcmp(lgopts[opt_idx].name, "txht")) {
985                                 n = atoi(optarg);
986                                 if (n >= 0)
987                                         tx_thresh.hthresh = (uint8_t)n;
988                                 else
989                                         rte_exit(EXIT_FAILURE, "txht must be >= 0\n");
990                         }
991                         if (!strcmp(lgopts[opt_idx].name, "txwt")) {
992                                 n = atoi(optarg);
993                                 if (n >= 0)
994                                         tx_thresh.wthresh = (uint8_t)n;
995                                 else
996                                         rte_exit(EXIT_FAILURE, "txwt must be >= 0\n");
997                         }
998                         if (!strcmp(lgopts[opt_idx].name, "rxpt")) {
999                                 n = atoi(optarg);
1000                                 if (n >= 0)
1001                                         rx_thresh.pthresh = (uint8_t)n;
1002                                 else
1003                                         rte_exit(EXIT_FAILURE, "rxpt must be >= 0\n");
1004                         }
1005                         if (!strcmp(lgopts[opt_idx].name, "rxht")) {
1006                                 n = atoi(optarg);
1007                                 if (n >= 0)
1008                                         rx_thresh.hthresh = (uint8_t)n;
1009                                 else
1010                                         rte_exit(EXIT_FAILURE, "rxht must be >= 0\n");
1011                         }
1012                         if (!strcmp(lgopts[opt_idx].name, "rxwt")) {
1013                                 n = atoi(optarg);
1014                                 if (n >= 0)
1015                                         rx_thresh.wthresh = (uint8_t)n;
1016                                 else
1017                                         rte_exit(EXIT_FAILURE, "rxwt must be >= 0\n");
1018                         }
1019                         if (!strcmp(lgopts[opt_idx].name, "rxfreet")) {
1020                                 n = atoi(optarg);
1021                                 if (n >= 0)
1022                                         rx_free_thresh = (uint16_t)n;
1023                                 else
1024                                         rte_exit(EXIT_FAILURE, "rxfreet must be >= 0\n");
1025                         }
1026                         if (!strcmp(lgopts[opt_idx].name, "tx-queue-stats-mapping")) {
1027                                 if (parse_queue_stats_mapping_config(optarg, TX)) {
1028                                         rte_exit(EXIT_FAILURE,
1029                                                  "invalid TX queue statistics mapping config entered\n");
1030                                 }
1031                         }
1032                         if (!strcmp(lgopts[opt_idx].name, "rx-queue-stats-mapping")) {
1033                                 if (parse_queue_stats_mapping_config(optarg, RX)) {
1034                                         rte_exit(EXIT_FAILURE,
1035                                                  "invalid RX queue statistics mapping config entered\n");
1036                                 }
1037                         }
1038                         if (!strcmp(lgopts[opt_idx].name, "txpkts")) {
1039                                 unsigned seg_lengths[RTE_MAX_SEGS_PER_PKT];
1040                                 unsigned int nb_segs;
1041
1042                                 nb_segs = parse_item_list(optarg, RTE_MAX_SEGS_PER_PKT, seg_lengths);
1043                                 if (nb_segs > 0)
1044                                         set_tx_pkt_segments(seg_lengths, nb_segs);
1045                                 else
1046                                         rte_exit(EXIT_FAILURE, "bad txpkts\n");
1047                         }
1048                         if (!strcmp(lgopts[opt_idx].name, "no-flush-rx"))
1049                                 no_flush_rx = 1;
1050                         if (!strcmp(lgopts[opt_idx].name, "disable-link-check"))
1051                                 no_link_check = 1;
1052
1053                         break;
1054                 case 'h':
1055                         usage(argv[0]);
1056                         rte_exit(EXIT_SUCCESS, "Displayed help\n");
1057                         break;
1058                 default:
1059                         usage(argv[0]);
1060                         rte_exit(EXIT_FAILURE,
1061                                  "Command line is incomplete or incorrect\n");
1062                         break;
1063                 }
1064         }
1065 }