eal/freebsd: add config reattach in secondary process
[dpdk.git] / lib / librte_eal / freebsd / eal / eal.c
1 /* SPDX-License-Identifier: BSD-3-Clause
2  * Copyright(c) 2010-2018 Intel Corporation.
3  * Copyright(c) 2014 6WIND S.A.
4  */
5
6 #include <stdio.h>
7 #include <stdlib.h>
8 #include <stdint.h>
9 #include <string.h>
10 #include <stdarg.h>
11 #include <unistd.h>
12 #include <pthread.h>
13 #include <syslog.h>
14 #include <getopt.h>
15 #include <sys/file.h>
16 #include <stddef.h>
17 #include <errno.h>
18 #include <limits.h>
19 #include <sys/mman.h>
20 #include <sys/queue.h>
21 #include <sys/stat.h>
22
23 #include <rte_compat.h>
24 #include <rte_common.h>
25 #include <rte_debug.h>
26 #include <rte_memory.h>
27 #include <rte_launch.h>
28 #include <rte_eal.h>
29 #include <rte_eal_memconfig.h>
30 #include <rte_errno.h>
31 #include <rte_per_lcore.h>
32 #include <rte_lcore.h>
33 #include <rte_service_component.h>
34 #include <rte_log.h>
35 #include <rte_random.h>
36 #include <rte_cycles.h>
37 #include <rte_string_fns.h>
38 #include <rte_cpuflags.h>
39 #include <rte_interrupts.h>
40 #include <rte_bus.h>
41 #include <rte_dev.h>
42 #include <rte_devargs.h>
43 #include <rte_version.h>
44 #include <rte_vfio.h>
45 #include <rte_option.h>
46 #include <rte_atomic.h>
47 #include <malloc_heap.h>
48
49 #include "eal_private.h"
50 #include "eal_thread.h"
51 #include "eal_internal_cfg.h"
52 #include "eal_filesystem.h"
53 #include "eal_hugepages.h"
54 #include "eal_options.h"
55
56 #define MEMSIZE_IF_NO_HUGE_PAGE (64ULL * 1024ULL * 1024ULL)
57
58 /* Allow the application to print its usage message too if set */
59 static rte_usage_hook_t rte_application_usage_hook = NULL;
60 /* early configuration structure, when memory config is not mmapped */
61 static struct rte_mem_config early_mem_config;
62
63 /* define fd variable here, because file needs to be kept open for the
64  * duration of the program, as we hold a write lock on it in the primary proc */
65 static int mem_cfg_fd = -1;
66
67 static struct flock wr_lock = {
68                 .l_type = F_WRLCK,
69                 .l_whence = SEEK_SET,
70                 .l_start = offsetof(struct rte_mem_config, memsegs),
71                 .l_len = sizeof(early_mem_config.memsegs),
72 };
73
74 /* Address of global and public configuration */
75 static struct rte_config rte_config = {
76                 .mem_config = &early_mem_config,
77 };
78
79 /* internal configuration (per-core) */
80 struct lcore_config lcore_config[RTE_MAX_LCORE];
81
82 /* internal configuration */
83 struct internal_config internal_config;
84
85 /* used by rte_rdtsc() */
86 int rte_cycles_vmware_tsc_map;
87
88 /* platform-specific runtime dir */
89 static char runtime_dir[PATH_MAX];
90
91 static const char *default_runtime_dir = "/var/run";
92
93 int
94 eal_create_runtime_dir(void)
95 {
96         const char *directory = default_runtime_dir;
97         const char *xdg_runtime_dir = getenv("XDG_RUNTIME_DIR");
98         const char *fallback = "/tmp";
99         char tmp[PATH_MAX];
100         int ret;
101
102         if (getuid() != 0) {
103                 /* try XDG path first, fall back to /tmp */
104                 if (xdg_runtime_dir != NULL)
105                         directory = xdg_runtime_dir;
106                 else
107                         directory = fallback;
108         }
109         /* create DPDK subdirectory under runtime dir */
110         ret = snprintf(tmp, sizeof(tmp), "%s/dpdk", directory);
111         if (ret < 0 || ret == sizeof(tmp)) {
112                 RTE_LOG(ERR, EAL, "Error creating DPDK runtime path name\n");
113                 return -1;
114         }
115
116         /* create prefix-specific subdirectory under DPDK runtime dir */
117         ret = snprintf(runtime_dir, sizeof(runtime_dir), "%s/%s",
118                         tmp, eal_get_hugefile_prefix());
119         if (ret < 0 || ret == sizeof(runtime_dir)) {
120                 RTE_LOG(ERR, EAL, "Error creating prefix-specific runtime path name\n");
121                 return -1;
122         }
123
124         /* create the path if it doesn't exist. no "mkdir -p" here, so do it
125          * step by step.
126          */
127         ret = mkdir(tmp, 0700);
128         if (ret < 0 && errno != EEXIST) {
129                 RTE_LOG(ERR, EAL, "Error creating '%s': %s\n",
130                         tmp, strerror(errno));
131                 return -1;
132         }
133
134         ret = mkdir(runtime_dir, 0700);
135         if (ret < 0 && errno != EEXIST) {
136                 RTE_LOG(ERR, EAL, "Error creating '%s': %s\n",
137                         runtime_dir, strerror(errno));
138                 return -1;
139         }
140
141         return 0;
142 }
143
144 int
145 eal_clean_runtime_dir(void)
146 {
147         /* FreeBSD doesn't need this implemented for now, because, unlike Linux,
148          * FreeBSD doesn't create per-process files, so no need to clean up.
149          */
150         return 0;
151 }
152
153
154 const char *
155 rte_eal_get_runtime_dir(void)
156 {
157         return runtime_dir;
158 }
159
160 /* Return user provided mbuf pool ops name */
161 const char *
162 rte_eal_mbuf_user_pool_ops(void)
163 {
164         return internal_config.user_mbuf_pool_ops_name;
165 }
166
167 /* Return a pointer to the configuration structure */
168 struct rte_config *
169 rte_eal_get_configuration(void)
170 {
171         return &rte_config;
172 }
173
174 enum rte_iova_mode
175 rte_eal_iova_mode(void)
176 {
177         return rte_eal_get_configuration()->iova_mode;
178 }
179
180 /* parse a sysfs (or other) file containing one integer value */
181 int
182 eal_parse_sysfs_value(const char *filename, unsigned long *val)
183 {
184         FILE *f;
185         char buf[BUFSIZ];
186         char *end = NULL;
187
188         if ((f = fopen(filename, "r")) == NULL) {
189                 RTE_LOG(ERR, EAL, "%s(): cannot open sysfs value %s\n",
190                         __func__, filename);
191                 return -1;
192         }
193
194         if (fgets(buf, sizeof(buf), f) == NULL) {
195                 RTE_LOG(ERR, EAL, "%s(): cannot read sysfs value %s\n",
196                         __func__, filename);
197                 fclose(f);
198                 return -1;
199         }
200         *val = strtoul(buf, &end, 0);
201         if ((buf[0] == '\0') || (end == NULL) || (*end != '\n')) {
202                 RTE_LOG(ERR, EAL, "%s(): cannot parse sysfs value %s\n",
203                                 __func__, filename);
204                 fclose(f);
205                 return -1;
206         }
207         fclose(f);
208         return 0;
209 }
210
211
212 /* create memory configuration in shared/mmap memory. Take out
213  * a write lock on the memsegs, so we can auto-detect primary/secondary.
214  * This means we never close the file while running (auto-close on exit).
215  * We also don't lock the whole file, so that in future we can use read-locks
216  * on other parts, e.g. memzones, to detect if there are running secondary
217  * processes. */
218 static int
219 rte_eal_config_create(void)
220 {
221         void *rte_mem_cfg_addr;
222         int retval;
223
224         const char *pathname = eal_runtime_config_path();
225
226         if (internal_config.no_shconf)
227                 return 0;
228
229         if (mem_cfg_fd < 0){
230                 mem_cfg_fd = open(pathname, O_RDWR | O_CREAT, 0600);
231                 if (mem_cfg_fd < 0) {
232                         RTE_LOG(ERR, EAL, "Cannot open '%s' for rte_mem_config\n",
233                                 pathname);
234                         return -1;
235                 }
236         }
237
238         retval = ftruncate(mem_cfg_fd, sizeof(*rte_config.mem_config));
239         if (retval < 0){
240                 close(mem_cfg_fd);
241                 mem_cfg_fd = -1;
242                 RTE_LOG(ERR, EAL, "Cannot resize '%s' for rte_mem_config\n",
243                         pathname);
244                 return -1;
245         }
246
247         retval = fcntl(mem_cfg_fd, F_SETLK, &wr_lock);
248         if (retval < 0){
249                 close(mem_cfg_fd);
250                 mem_cfg_fd = -1;
251                 RTE_LOG(ERR, EAL, "Cannot create lock on '%s'. Is another primary "
252                         "process running?\n", pathname);
253                 return -1;
254         }
255
256         rte_mem_cfg_addr = mmap(NULL, sizeof(*rte_config.mem_config),
257                                 PROT_READ | PROT_WRITE, MAP_SHARED, mem_cfg_fd, 0);
258
259         if (rte_mem_cfg_addr == MAP_FAILED){
260                 RTE_LOG(ERR, EAL, "Cannot mmap memory for rte_config\n");
261                 close(mem_cfg_fd);
262                 mem_cfg_fd = -1;
263                 return -1;
264         }
265         memcpy(rte_mem_cfg_addr, &early_mem_config, sizeof(early_mem_config));
266         rte_config.mem_config = rte_mem_cfg_addr;
267
268         return 0;
269 }
270
271 /* attach to an existing shared memory config */
272 static int
273 rte_eal_config_attach(void)
274 {
275         void *rte_mem_cfg_addr;
276         const char *pathname = eal_runtime_config_path();
277
278         if (internal_config.no_shconf)
279                 return 0;
280
281         if (mem_cfg_fd < 0){
282                 mem_cfg_fd = open(pathname, O_RDWR);
283                 if (mem_cfg_fd < 0) {
284                         RTE_LOG(ERR, EAL, "Cannot open '%s' for rte_mem_config\n",
285                                 pathname);
286                         return -1;
287                 }
288         }
289
290         rte_mem_cfg_addr = mmap(NULL, sizeof(*rte_config.mem_config),
291                                 PROT_READ, MAP_SHARED, mem_cfg_fd, 0);
292         /* don't close the fd here, it will be closed on reattach */
293         if (rte_mem_cfg_addr == MAP_FAILED) {
294                 close(mem_cfg_fd);
295                 mem_cfg_fd = -1;
296                 RTE_LOG(ERR, EAL, "Cannot mmap memory for rte_config! error %i (%s)\n",
297                         errno, strerror(errno));
298                 return -1;
299         }
300
301         rte_config.mem_config = rte_mem_cfg_addr;
302
303         return 0;
304 }
305
306 /* reattach the shared config at exact memory location primary process has it */
307 static int
308 rte_eal_config_reattach(void)
309 {
310         struct rte_mem_config *mem_config;
311         void *rte_mem_cfg_addr;
312
313         if (internal_config.no_shconf)
314                 return 0;
315
316         /* save the address primary process has mapped shared config to */
317         rte_mem_cfg_addr =
318                         (void *)(uintptr_t)rte_config.mem_config->mem_cfg_addr;
319
320         /* unmap original config */
321         munmap(rte_config.mem_config, sizeof(struct rte_mem_config));
322
323         /* remap the config at proper address */
324         mem_config = (struct rte_mem_config *) mmap(rte_mem_cfg_addr,
325                         sizeof(*mem_config), PROT_READ | PROT_WRITE, MAP_SHARED,
326                         mem_cfg_fd, 0);
327         close(mem_cfg_fd);
328         mem_cfg_fd = -1;
329
330         if (mem_config == MAP_FAILED) {
331                 RTE_LOG(ERR, EAL, "Cannot mmap memory for rte_config! error %i (%s)\n",
332                                 errno, strerror(errno));
333                 return -1;
334         } else if (mem_config != rte_mem_cfg_addr) {
335                 /* errno is stale, don't use */
336                 RTE_LOG(ERR, EAL, "Cannot mmap memory for rte_config at [%p], got [%p]\n",
337                           rte_mem_cfg_addr, mem_config);
338                 return -1;
339         }
340
341         rte_config.mem_config = mem_config;
342
343         return 0;
344 }
345
346 /* Detect if we are a primary or a secondary process */
347 enum rte_proc_type_t
348 eal_proc_type_detect(void)
349 {
350         enum rte_proc_type_t ptype = RTE_PROC_PRIMARY;
351         const char *pathname = eal_runtime_config_path();
352
353         /* if there no shared config, there can be no secondary processes */
354         if (!internal_config.no_shconf) {
355                 /* if we can open the file but not get a write-lock we are a
356                  * secondary process. NOTE: if we get a file handle back, we
357                  * keep that open and don't close it to prevent a race condition
358                  * between multiple opens.
359                  */
360                 if (((mem_cfg_fd = open(pathname, O_RDWR)) >= 0) &&
361                                 (fcntl(mem_cfg_fd, F_SETLK, &wr_lock) < 0))
362                         ptype = RTE_PROC_SECONDARY;
363         }
364
365         RTE_LOG(INFO, EAL, "Auto-detected process type: %s\n",
366                         ptype == RTE_PROC_PRIMARY ? "PRIMARY" : "SECONDARY");
367
368         return ptype;
369 }
370
371 /* Sets up rte_config structure with the pointer to shared memory config.*/
372 static int
373 rte_config_init(void)
374 {
375         rte_config.process_type = internal_config.process_type;
376
377         switch (rte_config.process_type){
378         case RTE_PROC_PRIMARY:
379                 if (rte_eal_config_create() < 0)
380                         return -1;
381                 break;
382         case RTE_PROC_SECONDARY:
383                 if (rte_eal_config_attach() < 0)
384                         return -1;
385                 rte_eal_mcfg_wait_complete(rte_config.mem_config);
386                 if (rte_eal_config_reattach() < 0)
387                         return -1;
388                 break;
389         case RTE_PROC_AUTO:
390         case RTE_PROC_INVALID:
391                 RTE_LOG(ERR, EAL, "Invalid process type %d\n",
392                         rte_config.process_type);
393                 return -1;
394         }
395
396         return 0;
397 }
398
399 /* display usage */
400 static void
401 eal_usage(const char *prgname)
402 {
403         printf("\nUsage: %s ", prgname);
404         eal_common_usage();
405         /* Allow the application to print its usage message too if hook is set */
406         if ( rte_application_usage_hook ) {
407                 printf("===== Application Usage =====\n\n");
408                 rte_application_usage_hook(prgname);
409         }
410 }
411
412 /* Set a per-application usage message */
413 rte_usage_hook_t
414 rte_set_application_usage_hook( rte_usage_hook_t usage_func )
415 {
416         rte_usage_hook_t        old_func;
417
418         /* Will be NULL on the first call to denote the last usage routine. */
419         old_func                                        = rte_application_usage_hook;
420         rte_application_usage_hook      = usage_func;
421
422         return old_func;
423 }
424
425 static inline size_t
426 eal_get_hugepage_mem_size(void)
427 {
428         uint64_t size = 0;
429         unsigned i, j;
430
431         for (i = 0; i < internal_config.num_hugepage_sizes; i++) {
432                 struct hugepage_info *hpi = &internal_config.hugepage_info[i];
433                 if (strnlen(hpi->hugedir, sizeof(hpi->hugedir)) != 0) {
434                         for (j = 0; j < RTE_MAX_NUMA_NODES; j++) {
435                                 size += hpi->hugepage_sz * hpi->num_pages[j];
436                         }
437                 }
438         }
439
440         return (size < SIZE_MAX) ? (size_t)(size) : SIZE_MAX;
441 }
442
443 /* Parse the arguments for --log-level only */
444 static void
445 eal_log_level_parse(int argc, char **argv)
446 {
447         int opt;
448         char **argvopt;
449         int option_index;
450         const int old_optind = optind;
451         const int old_optopt = optopt;
452         const int old_optreset = optreset;
453         char * const old_optarg = optarg;
454
455         argvopt = argv;
456         optind = 1;
457         optreset = 1;
458
459         while ((opt = getopt_long(argc, argvopt, eal_short_options,
460                                   eal_long_options, &option_index)) != EOF) {
461
462                 int ret;
463
464                 /* getopt is not happy, stop right now */
465                 if (opt == '?')
466                         break;
467
468                 ret = (opt == OPT_LOG_LEVEL_NUM) ?
469                         eal_parse_common_option(opt, optarg, &internal_config) : 0;
470
471                 /* common parser is not happy */
472                 if (ret < 0)
473                         break;
474         }
475
476         /* restore getopt lib */
477         optind = old_optind;
478         optopt = old_optopt;
479         optreset = old_optreset;
480         optarg = old_optarg;
481 }
482
483 /* Parse the argument given in the command line of the application */
484 static int
485 eal_parse_args(int argc, char **argv)
486 {
487         int opt, ret;
488         char **argvopt;
489         int option_index;
490         char *prgname = argv[0];
491         const int old_optind = optind;
492         const int old_optopt = optopt;
493         const int old_optreset = optreset;
494         char * const old_optarg = optarg;
495
496         argvopt = argv;
497         optind = 1;
498         optreset = 1;
499         opterr = 0;
500
501         while ((opt = getopt_long(argc, argvopt, eal_short_options,
502                                   eal_long_options, &option_index)) != EOF) {
503
504                 /*
505                  * getopt didn't recognise the option, lets parse the
506                  * registered options to see if the flag is valid
507                  */
508                 if (opt == '?') {
509                         ret = rte_option_parse(argv[optind-1]);
510                         if (ret == 0)
511                                 continue;
512
513                         eal_usage(prgname);
514                         ret = -1;
515                         goto out;
516                 }
517
518                 ret = eal_parse_common_option(opt, optarg, &internal_config);
519                 /* common parser is not happy */
520                 if (ret < 0) {
521                         eal_usage(prgname);
522                         ret = -1;
523                         goto out;
524                 }
525                 /* common parser handled this option */
526                 if (ret == 0)
527                         continue;
528
529                 switch (opt) {
530                 case OPT_MBUF_POOL_OPS_NAME_NUM:
531                 {
532                         char *ops_name = strdup(optarg);
533                         if (ops_name == NULL)
534                                 RTE_LOG(ERR, EAL, "Could not store mbuf pool ops name\n");
535                         else {
536                                 /* free old ops name */
537                                 if (internal_config.user_mbuf_pool_ops_name !=
538                                                 NULL)
539                                         free(internal_config.user_mbuf_pool_ops_name);
540
541                                 internal_config.user_mbuf_pool_ops_name =
542                                                 ops_name;
543                         }
544                         break;
545                 }
546                 case 'h':
547                         eal_usage(prgname);
548                         exit(EXIT_SUCCESS);
549                 default:
550                         if (opt < OPT_LONG_MIN_NUM && isprint(opt)) {
551                                 RTE_LOG(ERR, EAL, "Option %c is not supported "
552                                         "on FreeBSD\n", opt);
553                         } else if (opt >= OPT_LONG_MIN_NUM &&
554                                    opt < OPT_LONG_MAX_NUM) {
555                                 RTE_LOG(ERR, EAL, "Option %s is not supported "
556                                         "on FreeBSD\n",
557                                         eal_long_options[option_index].name);
558                         } else {
559                                 RTE_LOG(ERR, EAL, "Option %d is not supported "
560                                         "on FreeBSD\n", opt);
561                         }
562                         eal_usage(prgname);
563                         ret = -1;
564                         goto out;
565                 }
566         }
567
568         /* create runtime data directory */
569         if (internal_config.no_shconf == 0 &&
570                         eal_create_runtime_dir() < 0) {
571                 RTE_LOG(ERR, EAL, "Cannot create runtime directory\n");
572                 ret = -1;
573                 goto out;
574         }
575
576         if (eal_adjust_config(&internal_config) != 0) {
577                 ret = -1;
578                 goto out;
579         }
580
581         /* sanity checks */
582         if (eal_check_common_options(&internal_config) != 0) {
583                 eal_usage(prgname);
584                 ret = -1;
585                 goto out;
586         }
587
588         if (optind >= 0)
589                 argv[optind-1] = prgname;
590         ret = optind-1;
591
592 out:
593         /* restore getopt lib */
594         optind = old_optind;
595         optopt = old_optopt;
596         optreset = old_optreset;
597         optarg = old_optarg;
598
599         return ret;
600 }
601
602 static int
603 check_socket(const struct rte_memseg_list *msl, void *arg)
604 {
605         int *socket_id = arg;
606
607         if (msl->external)
608                 return 0;
609
610         if (msl->socket_id == *socket_id && msl->memseg_arr.count != 0)
611                 return 1;
612
613         return 0;
614 }
615
616 static void
617 eal_check_mem_on_local_socket(void)
618 {
619         int socket_id;
620
621         socket_id = rte_lcore_to_socket_id(rte_config.master_lcore);
622
623         if (rte_memseg_list_walk(check_socket, &socket_id) == 0)
624                 RTE_LOG(WARNING, EAL, "WARNING: Master core has no memory on local socket!\n");
625 }
626
627
628 static int
629 sync_func(__attribute__((unused)) void *arg)
630 {
631         return 0;
632 }
633
634 inline static void
635 rte_eal_mcfg_complete(void)
636 {
637         /* ALL shared mem_config related INIT DONE */
638         if (rte_config.process_type == RTE_PROC_PRIMARY)
639                 rte_config.mem_config->magic = RTE_MAGIC;
640
641         internal_config.init_complete = 1;
642 }
643
644 /* return non-zero if hugepages are enabled. */
645 int rte_eal_has_hugepages(void)
646 {
647         return !internal_config.no_hugetlbfs;
648 }
649
650 /* Abstraction for port I/0 privilege */
651 int
652 rte_eal_iopl_init(void)
653 {
654         static int fd = -1;
655
656         if (fd < 0)
657                 fd = open("/dev/io", O_RDWR);
658
659         if (fd < 0)
660                 return -1;
661         /* keep fd open for iopl */
662         return 0;
663 }
664
665 static void rte_eal_init_alert(const char *msg)
666 {
667         fprintf(stderr, "EAL: FATAL: %s\n", msg);
668         RTE_LOG(ERR, EAL, "%s\n", msg);
669 }
670
671 /* Launch threads, called at application init(). */
672 int
673 rte_eal_init(int argc, char **argv)
674 {
675         int i, fctret, ret;
676         pthread_t thread_id;
677         static rte_atomic32_t run_once = RTE_ATOMIC32_INIT(0);
678         char cpuset[RTE_CPU_AFFINITY_STR_LEN];
679         char thread_name[RTE_MAX_THREAD_NAME_LEN];
680
681         /* checks if the machine is adequate */
682         if (!rte_cpu_is_supported()) {
683                 rte_eal_init_alert("unsupported cpu type.");
684                 rte_errno = ENOTSUP;
685                 return -1;
686         }
687
688         if (!rte_atomic32_test_and_set(&run_once)) {
689                 rte_eal_init_alert("already called initialization.");
690                 rte_errno = EALREADY;
691                 return -1;
692         }
693
694         thread_id = pthread_self();
695
696         eal_reset_internal_config(&internal_config);
697
698         /* set log level as early as possible */
699         eal_log_level_parse(argc, argv);
700
701         if (rte_eal_cpu_init() < 0) {
702                 rte_eal_init_alert("Cannot detect lcores.");
703                 rte_errno = ENOTSUP;
704                 return -1;
705         }
706
707         fctret = eal_parse_args(argc, argv);
708         if (fctret < 0) {
709                 rte_eal_init_alert("Invalid 'command line' arguments.");
710                 rte_errno = EINVAL;
711                 rte_atomic32_clear(&run_once);
712                 return -1;
713         }
714
715         /* FreeBSD always uses legacy memory model */
716         internal_config.legacy_mem = true;
717
718         if (eal_plugins_init() < 0) {
719                 rte_eal_init_alert("Cannot init plugins");
720                 rte_errno = EINVAL;
721                 rte_atomic32_clear(&run_once);
722                 return -1;
723         }
724
725         if (eal_option_device_parse()) {
726                 rte_errno = ENODEV;
727                 rte_atomic32_clear(&run_once);
728                 return -1;
729         }
730
731         if (rte_config_init() < 0) {
732                 rte_eal_init_alert("Cannot init config");
733                 return -1;
734         }
735
736         if (rte_eal_intr_init() < 0) {
737                 rte_eal_init_alert("Cannot init interrupt-handling thread");
738                 return -1;
739         }
740
741         if (rte_eal_alarm_init() < 0) {
742                 rte_eal_init_alert("Cannot init alarm");
743                 /* rte_eal_alarm_init sets rte_errno on failure. */
744                 return -1;
745         }
746
747         /* Put mp channel init before bus scan so that we can init the vdev
748          * bus through mp channel in the secondary process before the bus scan.
749          */
750         if (rte_mp_channel_init() < 0 && rte_errno != ENOTSUP) {
751                 rte_eal_init_alert("failed to init mp channel");
752                 if (rte_eal_process_type() == RTE_PROC_PRIMARY) {
753                         rte_errno = EFAULT;
754                         return -1;
755                 }
756         }
757
758         if (rte_bus_scan()) {
759                 rte_eal_init_alert("Cannot scan the buses for devices");
760                 rte_errno = ENODEV;
761                 rte_atomic32_clear(&run_once);
762                 return -1;
763         }
764
765         /* if no EAL option "--iova-mode=<pa|va>", use bus IOVA scheme */
766         if (internal_config.iova_mode == RTE_IOVA_DC) {
767                 /* autodetect the IOVA mapping mode (default is RTE_IOVA_PA) */
768                 rte_eal_get_configuration()->iova_mode =
769                         rte_bus_get_iommu_class();
770         } else {
771                 rte_eal_get_configuration()->iova_mode =
772                         internal_config.iova_mode;
773         }
774
775         if (internal_config.no_hugetlbfs == 0) {
776                 /* rte_config isn't initialized yet */
777                 ret = internal_config.process_type == RTE_PROC_PRIMARY ?
778                         eal_hugepage_info_init() :
779                         eal_hugepage_info_read();
780                 if (ret < 0) {
781                         rte_eal_init_alert("Cannot get hugepage information.");
782                         rte_errno = EACCES;
783                         rte_atomic32_clear(&run_once);
784                         return -1;
785                 }
786         }
787
788         if (internal_config.memory == 0 && internal_config.force_sockets == 0) {
789                 if (internal_config.no_hugetlbfs)
790                         internal_config.memory = MEMSIZE_IF_NO_HUGE_PAGE;
791                 else
792                         internal_config.memory = eal_get_hugepage_mem_size();
793         }
794
795         if (internal_config.vmware_tsc_map == 1) {
796 #ifdef RTE_LIBRTE_EAL_VMWARE_TSC_MAP_SUPPORT
797                 rte_cycles_vmware_tsc_map = 1;
798                 RTE_LOG (DEBUG, EAL, "Using VMWARE TSC MAP, "
799                                 "you must have monitor_control.pseudo_perfctr = TRUE\n");
800 #else
801                 RTE_LOG (WARNING, EAL, "Ignoring --vmware-tsc-map because "
802                                 "RTE_LIBRTE_EAL_VMWARE_TSC_MAP_SUPPORT is not set\n");
803 #endif
804         }
805
806         /* in secondary processes, memory init may allocate additional fbarrays
807          * not present in primary processes, so to avoid any potential issues,
808          * initialize memzones first.
809          */
810         if (rte_eal_memzone_init() < 0) {
811                 rte_eal_init_alert("Cannot init memzone");
812                 rte_errno = ENODEV;
813                 return -1;
814         }
815
816         if (rte_eal_memory_init() < 0) {
817                 rte_eal_init_alert("Cannot init memory");
818                 rte_errno = ENOMEM;
819                 return -1;
820         }
821
822         if (rte_eal_malloc_heap_init() < 0) {
823                 rte_eal_init_alert("Cannot init malloc heap");
824                 rte_errno = ENODEV;
825                 return -1;
826         }
827
828         if (rte_eal_tailqs_init() < 0) {
829                 rte_eal_init_alert("Cannot init tail queues for objects");
830                 rte_errno = EFAULT;
831                 return -1;
832         }
833
834         if (rte_eal_timer_init() < 0) {
835                 rte_eal_init_alert("Cannot init HPET or TSC timers");
836                 rte_errno = ENOTSUP;
837                 return -1;
838         }
839
840         eal_check_mem_on_local_socket();
841
842         eal_thread_init_master(rte_config.master_lcore);
843
844         ret = eal_thread_dump_affinity(cpuset, sizeof(cpuset));
845
846         RTE_LOG(DEBUG, EAL, "Master lcore %u is ready (tid=%p;cpuset=[%s%s])\n",
847                 rte_config.master_lcore, thread_id, cpuset,
848                 ret == 0 ? "" : "...");
849
850         RTE_LCORE_FOREACH_SLAVE(i) {
851
852                 /*
853                  * create communication pipes between master thread
854                  * and children
855                  */
856                 if (pipe(lcore_config[i].pipe_master2slave) < 0)
857                         rte_panic("Cannot create pipe\n");
858                 if (pipe(lcore_config[i].pipe_slave2master) < 0)
859                         rte_panic("Cannot create pipe\n");
860
861                 lcore_config[i].state = WAIT;
862
863                 /* create a thread for each lcore */
864                 ret = pthread_create(&lcore_config[i].thread_id, NULL,
865                                      eal_thread_loop, NULL);
866                 if (ret != 0)
867                         rte_panic("Cannot create thread\n");
868
869                 /* Set thread_name for aid in debugging. */
870                 snprintf(thread_name, sizeof(thread_name),
871                                 "lcore-slave-%d", i);
872                 rte_thread_setname(lcore_config[i].thread_id, thread_name);
873         }
874
875         /*
876          * Launch a dummy function on all slave lcores, so that master lcore
877          * knows they are all ready when this function returns.
878          */
879         rte_eal_mp_remote_launch(sync_func, NULL, SKIP_MASTER);
880         rte_eal_mp_wait_lcore();
881
882         /* initialize services so vdevs register service during bus_probe. */
883         ret = rte_service_init();
884         if (ret) {
885                 rte_eal_init_alert("rte_service_init() failed");
886                 rte_errno = ENOEXEC;
887                 return -1;
888         }
889
890         /* Probe all the buses and devices/drivers on them */
891         if (rte_bus_probe()) {
892                 rte_eal_init_alert("Cannot probe devices");
893                 rte_errno = ENOTSUP;
894                 return -1;
895         }
896
897         /* initialize default service/lcore mappings and start running. Ignore
898          * -ENOTSUP, as it indicates no service coremask passed to EAL.
899          */
900         ret = rte_service_start_with_defaults();
901         if (ret < 0 && ret != -ENOTSUP) {
902                 rte_errno = ENOEXEC;
903                 return -1;
904         }
905
906         /*
907          * Clean up unused files in runtime directory. We do this at the end of
908          * init and not at the beginning because we want to clean stuff up
909          * whether we are primary or secondary process, but we cannot remove
910          * primary process' files because secondary should be able to run even
911          * if primary process is dead.
912          *
913          * In no_shconf mode, no runtime directory is created in the first
914          * place, so no cleanup needed.
915          */
916         if (!internal_config.no_shconf && eal_clean_runtime_dir() < 0) {
917                 rte_eal_init_alert("Cannot clear runtime directory\n");
918                 return -1;
919         }
920
921         rte_eal_mcfg_complete();
922
923         /* Call each registered callback, if enabled */
924         rte_option_init();
925
926         return fctret;
927 }
928
929 int
930 rte_eal_cleanup(void)
931 {
932         rte_service_finalize();
933         rte_mp_channel_cleanup();
934         eal_cleanup_config(&internal_config);
935         return 0;
936 }
937
938 /* get core role */
939 enum rte_lcore_role_t
940 rte_eal_lcore_role(unsigned lcore_id)
941 {
942         return rte_config.lcore_role[lcore_id];
943 }
944
945 enum rte_proc_type_t
946 rte_eal_process_type(void)
947 {
948         return rte_config.process_type;
949 }
950
951 int rte_eal_has_pci(void)
952 {
953         return !internal_config.no_pci;
954 }
955
956 int rte_eal_create_uio_dev(void)
957 {
958         return internal_config.create_uio_dev;
959 }
960
961 enum rte_intr_mode
962 rte_eal_vfio_intr_mode(void)
963 {
964         return RTE_INTR_MODE_NONE;
965 }
966
967 int rte_vfio_setup_device(__rte_unused const char *sysfs_base,
968                       __rte_unused const char *dev_addr,
969                       __rte_unused int *vfio_dev_fd,
970                       __rte_unused struct vfio_device_info *device_info)
971 {
972         return -1;
973 }
974
975 int rte_vfio_release_device(__rte_unused const char *sysfs_base,
976                         __rte_unused const char *dev_addr,
977                         __rte_unused int fd)
978 {
979         return -1;
980 }
981
982 int rte_vfio_enable(__rte_unused const char *modname)
983 {
984         return -1;
985 }
986
987 int rte_vfio_is_enabled(__rte_unused const char *modname)
988 {
989         return 0;
990 }
991
992 int rte_vfio_noiommu_is_enabled(void)
993 {
994         return 0;
995 }
996
997 int rte_vfio_clear_group(__rte_unused int vfio_group_fd)
998 {
999         return 0;
1000 }
1001
1002 int
1003 rte_vfio_dma_map(uint64_t __rte_unused vaddr, __rte_unused uint64_t iova,
1004                   __rte_unused uint64_t len)
1005 {
1006         return -1;
1007 }
1008
1009 int
1010 rte_vfio_dma_unmap(uint64_t __rte_unused vaddr, uint64_t __rte_unused iova,
1011                     __rte_unused uint64_t len)
1012 {
1013         return -1;
1014 }
1015
1016 int
1017 rte_vfio_get_group_num(__rte_unused const char *sysfs_base,
1018                        __rte_unused const char *dev_addr,
1019                        __rte_unused int *iommu_group_num)
1020 {
1021         return -1;
1022 }
1023
1024 int
1025 rte_vfio_get_container_fd(void)
1026 {
1027         return -1;
1028 }
1029
1030 int
1031 rte_vfio_get_group_fd(__rte_unused int iommu_group_num)
1032 {
1033         return -1;
1034 }
1035
1036 int
1037 rte_vfio_container_create(void)
1038 {
1039         return -1;
1040 }
1041
1042 int
1043 rte_vfio_container_destroy(__rte_unused int container_fd)
1044 {
1045         return -1;
1046 }
1047
1048 int
1049 rte_vfio_container_group_bind(__rte_unused int container_fd,
1050                 __rte_unused int iommu_group_num)
1051 {
1052         return -1;
1053 }
1054
1055 int
1056 rte_vfio_container_group_unbind(__rte_unused int container_fd,
1057                 __rte_unused int iommu_group_num)
1058 {
1059         return -1;
1060 }
1061
1062 int
1063 rte_vfio_container_dma_map(__rte_unused int container_fd,
1064                         __rte_unused uint64_t vaddr,
1065                         __rte_unused uint64_t iova,
1066                         __rte_unused uint64_t len)
1067 {
1068         return -1;
1069 }
1070
1071 int
1072 rte_vfio_container_dma_unmap(__rte_unused int container_fd,
1073                         __rte_unused uint64_t vaddr,
1074                         __rte_unused uint64_t iova,
1075                         __rte_unused uint64_t len)
1076 {
1077         return -1;
1078 }