blob: 089570fc01bfa137d3d7ae55093851f480a260f3 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
#include "xmrstak/backend/cpu/hwlocMemory.hpp"
#ifndef CONF_NO_HWLOC
#include "xmrstak/misc/console.hpp"
#include <hwloc.h>
/** pin memory to NUMA node
*
* Set the default memory policy for the current thread to bind memory to the
* NUMA node.
*
* @param puId core id
*/
void bindMemoryToNUMANode( size_t puId )
{
int depth;
hwloc_topology_t topology;
hwloc_topology_init(&topology);
hwloc_topology_load(topology);
if(!hwloc_topology_get_support(topology)->membind->set_thisthread_membind)
{
printer::inst()->print_msg(L0, "hwloc: set_thisthread_membind not supported");
hwloc_topology_destroy(topology);
return;
}
depth = hwloc_get_type_depth(topology, HWLOC_OBJ_PU);
for( uint32_t i = 0;
i < hwloc_get_nbobjs_by_depth(topology, depth);
i++ )
{
hwloc_obj_t pu = hwloc_get_obj_by_depth(topology, depth, i);
if( pu->os_index == puId )
{
if( 0 > hwloc_set_membind_nodeset(
topology,
pu->nodeset,
HWLOC_MEMBIND_BIND,
HWLOC_MEMBIND_THREAD))
{
printer::inst()->print_msg(L0, "hwloc: can't bind memory");
}
else
{
printer::inst()->print_msg(L0, "hwloc: memory pinned");
break;
}
}
}
hwloc_topology_destroy(topology);
}
#else
void bindMemoryToNUMANode( size_t )
{
}
#endif
|
