X-Git-Url: http://git.droids-corp.org/?a=blobdiff_plain;f=lib%2Flibrte_eal%2Flinuxapp%2Feal%2Feal_lcore.c;h=560039bcdd0ea3b27919ee56fadfcee3613a3b14;hb=b2b5baa02945354b9bade697840f6f24d4d1a722;hp=03f4ba3a13dac70beeb43bf488bb37e3ed90a7f4;hpb=2ef79b212a79e87afd16fd75376c1e0d49ca2942;p=dpdk.git

diff --git a/lib/librte_eal/linuxapp/eal/eal_lcore.c b/lib/librte_eal/linuxapp/eal/eal_lcore.c
index 03f4ba3a13..560039bcdd 100644
--- a/lib/librte_eal/linuxapp/eal/eal_lcore.c
+++ b/lib/librte_eal/linuxapp/eal/eal_lcore.c
@@ -1,13 +1,13 @@
 /*-
  *   BSD LICENSE
- * 
+ *
  *   Copyright(c) 2010-2014 Intel Corporation. All rights reserved.
  *   All rights reserved.
- * 
+ *
  *   Redistribution and use in source and binary forms, with or without
  *   modification, are permitted provided that the following conditions
  *   are met:
- * 
+ *
  *     * Redistributions of source code must retain the above copyright
  *       notice, this list of conditions and the following disclaimer.
  *     * Redistributions in binary form must reproduce the above copyright
@@ -17,7 +17,7 @@
  *     * Neither the name of Intel Corporation nor the names of its
  *       contributors may be used to endorse or promote products derived
  *       from this software without specific prior written permission.
- * 
+ *
  *   THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  *   "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  *   LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
@@ -45,17 +45,18 @@
 
 #include "eal_private.h"
 #include "eal_filesystem.h"
+#include "eal_thread.h"
 
 #define SYS_CPU_DIR "/sys/devices/system/cpu/cpu%u"
 #define CORE_ID_FILE "topology/core_id"
-#define PHYS_PKG_FILE "topology/physical_package_id"
+#define NUMA_NODE_PATH "/sys/devices/system/node"
 
 /* Check if a cpu is present by the presence of the cpu information for it */
 static int
 cpu_detected(unsigned lcore_id)
 {
 	char path[PATH_MAX];
-	int len = rte_snprintf(path, sizeof(path), SYS_CPU_DIR
+	int len = snprintf(path, sizeof(path), SYS_CPU_DIR
 		"/"CORE_ID_FILE, lcore_id);
 	if (len <= 0 || (unsigned)len >= sizeof(path))
 		return 0;
@@ -65,56 +66,26 @@ cpu_detected(unsigned lcore_id)
 	return 1;
 }
 
-/* Get CPU socket id (NUMA node) by reading directory
- * /sys/devices/system/cpu/cpuX looking for symlink "nodeY"
- * which gives the NUMA topology information.
- * Note: physical package id != NUMA node, but we use it as a
- * fallback for kernels which don't create a nodeY link
+/*
+ * Get CPU socket id (NUMA node) for a logical core.
+ *
+ * This searches each nodeX directories in /sys for the symlink for the given
+ * lcore_id and returns the numa node where the lcore is found. If lcore is not
+ * found on any numa node, returns zero.
  */
-static unsigned
-cpu_socket_id(unsigned lcore_id)
+unsigned
+eal_cpu_socket_id(unsigned lcore_id)
 {
-	const char node_prefix[] = "node";
-	const size_t prefix_len = sizeof(node_prefix) - 1;
-	char path[PATH_MAX];
-	DIR *d;
-	unsigned long id = 0;
-	struct dirent *e;
-	char *endptr = NULL;
-
-	int len = rte_snprintf(path, sizeof(path),
-			       SYS_CPU_DIR, lcore_id);
-	if (len <= 0 || (unsigned)len >= sizeof(path))
-		goto err;
+	unsigned socket;
 
-	d = opendir(path);
-	if (!d)
-		goto err;
+	for (socket = 0; socket < RTE_MAX_NUMA_NODES; socket++) {
+		char path[PATH_MAX];
 
-	while ((e = readdir(d)) != NULL) {
-		if (strncmp(e->d_name, node_prefix, prefix_len) == 0) {
-			id = strtoul(e->d_name+prefix_len, &endptr, 0);
-			break;
-		}
+		snprintf(path, sizeof(path), "%s/node%u/cpu%u", NUMA_NODE_PATH,
+				socket, lcore_id);
+		if (access(path, F_OK) == 0)
+			return socket;
 	}
-	closedir(d);
-	if (endptr == NULL || *endptr!='\0' || endptr == e->d_name+prefix_len) {
-		RTE_LOG(WARNING, EAL, "Cannot read numa node link "
-				"for lcore %u - using physical package id instead\n",
-				lcore_id);
-
-		len = rte_snprintf(path, sizeof(path), SYS_CPU_DIR "/%s",
-				lcore_id, PHYS_PKG_FILE);
-		if (len <= 0 || (unsigned)len >= sizeof(path))
-			goto err;
-		if (eal_parse_sysfs_value(path, &id) != 0)
-			goto err;
-	}
-	return (unsigned)id;
-
-err:
-	RTE_LOG(ERR, EAL, "Error getting NUMA socket information from %s "
-			"for lcore %u - assuming NUMA socket 0\n", SYS_CPU_DIR, lcore_id);
 	return 0;
 }
 
@@ -125,7 +96,7 @@ cpu_core_id(unsigned lcore_id)
 	char path[PATH_MAX];
 	unsigned long id;
 
-	int len = rte_snprintf(path, sizeof(path), SYS_CPU_DIR "/%s", lcore_id, CORE_ID_FILE);
+	int len = snprintf(path, sizeof(path), SYS_CPU_DIR "/%s", lcore_id, CORE_ID_FILE);
 	if (len <= 0 || (unsigned)len >= sizeof(path))
 		goto err;
 	if (eal_parse_sysfs_value(path, &id) != 0)
@@ -156,15 +127,23 @@ rte_eal_cpu_init(void)
 	 * ones and enable them by default.
 	 */
 	for (lcore_id = 0; lcore_id < RTE_MAX_LCORE; lcore_id++) {
+		/* init cpuset for per lcore config */
+		CPU_ZERO(&lcore_config[lcore_id].cpuset);
+
+		/* in 1:1 mapping, record related cpu detected state */
 		lcore_config[lcore_id].detected = cpu_detected(lcore_id);
 		if (lcore_config[lcore_id].detected == 0) {
 			config->lcore_role[lcore_id] = ROLE_OFF;
 			continue;
 		}
+
+		/* By default, lcore 1:1 map to cpu id */
+		CPU_SET(lcore_id, &lcore_config[lcore_id].cpuset);
+
 		/* By default, each detected core is enabled */
 		config->lcore_role[lcore_id] = ROLE_RTE;
 		lcore_config[lcore_id].core_id = cpu_core_id(lcore_id);
-		lcore_config[lcore_id].socket_id = cpu_socket_id(lcore_id);
+		lcore_config[lcore_id].socket_id = eal_cpu_socket_id(lcore_id);
 		if (lcore_config[lcore_id].socket_id >= RTE_MAX_NUMA_NODES)
 #ifdef RTE_EAL_ALLOW_INV_SOCKET_ID
 			lcore_config[lcore_id].socket_id = 0;
@@ -181,6 +160,9 @@ rte_eal_cpu_init(void)
 	}
 	/* Set the count of enabled logical cores of the EAL configuration */
 	config->lcore_count = count;
+	RTE_LOG(DEBUG, EAL, "Support maximum %u logical core(s) by configuration.\n",
+		RTE_MAX_LCORE);
+	RTE_LOG(DEBUG, EAL, "Detected %u lcore(s)\n", config->lcore_count);
 
 	return 0;
 }