libfoedus-core
FOEDUS Core Library
numa_thread_scope.hpp
Go to the documentation of this file.
1 /*
2  * Copyright (c) 2014-2015, Hewlett-Packard Development Company, LP.
3  * This program is free software; you can redistribute it and/or modify it
4  * under the terms of the GNU General Public License as published by the Free
5  * Software Foundation; either version 2 of the License, or (at your option)
6  * any later version.
7  *
8  * This program is distributed in the hope that it will be useful, but WITHOUT
9  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
10  * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
11  * more details. You should have received a copy of the GNU General Public
12  * License along with this program; if not, write to the Free Software
13  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
14  *
15  * HP designates this particular file as subject to the "Classpath" exception
16  * as provided by HP in the LICENSE.txt file that accompanied this code.
17  */
18 #ifndef FOEDUS_THREAD_NUMA_THREAD_SCOPE_HPP_
19 #define FOEDUS_THREAD_NUMA_THREAD_SCOPE_HPP_
20 
21 #include <numa.h>
22 
24 
25 namespace foedus {
26 namespace thread {
34  explicit NumaThreadScope(int numa_node) {
35  if (::numa_available() >= 0) {
36  numa_node = assorted::mod_numa_node(numa_node);
37  ::numa_run_on_node(numa_node);
39  }
40  }
42  if (::numa_available() >= 0) {
44  }
45  }
46 };
47 
48 } // namespace thread
49 } // namespace foedus
50 #endif // FOEDUS_THREAD_NUMA_THREAD_SCOPE_HPP_
struct bitmask * numa_all_nodes_ptr
int numa_run_on_node(int node)
Root package of FOEDUS (Fast Optimistic Engine for Data Unification Services).
Definition: assert_nd.hpp:44
Pin the current thread to the given NUMA node in this object's scope.
int numa_available(void)
void numa_set_localalloc(void)
int mod_numa_node(int numa_node)
In order to run even on a non-numa machine or a machine with fewer sockets, we allow specifying arbit...
int numa_run_on_node_mask(struct bitmask *mask)