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