diff options
| author | Emery Hemingway <githubjunk@spam.works> | 2017-09-16 01:02:59 -0500 |
|---|---|---|
| committer | Andreas Rumpf <rumpf_a@web.de> | 2017-09-16 08:02:59 +0200 |
| commit | 9258672cee32ca82fcf1494447cd9020602df567 (patch) | |
| tree | f197e714a836d6376557f49b0165af8baf786045 /lib/genode_cpp | |
| parent | 248caaf27eb67556aea23c3ceff204237d4df9c3 (diff) | |
| download | Nim-9258672cee32ca82fcf1494447cd9020602df567.tar.gz | |
balance Genode CPU pinning, deadlock at Genode exit (#6317)
* Genode: balance thread CPU affinities Genode threads are pinned by defaut to the same CPU as the initial component entrypoint thread. Thread affinities are also permanent. This patch pins new threads to CPUs in a round-robin manner. Arbitrary CPU pinning is not exposed and the 'nimPinToCpu' has no effect. * Genode: guarantee that 'quit' will not return On Genode exits are handled by whatever component is acting as parent. The caller has no guarentee that the parent implementation will halt the caller's threads, so explicitly deadlock the 'quit' procedure.
Diffstat (limited to 'lib/genode_cpp')
| -rw-r--r-- | lib/genode_cpp/threads.h | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/lib/genode_cpp/threads.h b/lib/genode_cpp/threads.h index 043f808f1..a7cb2f17b 100644 --- a/lib/genode_cpp/threads.h +++ b/lib/genode_cpp/threads.h @@ -31,8 +31,12 @@ struct Nim::SysThread void entry() override { (_func)(_arg); } - Thread(Genode::Env &env, Genode::size_t stack_size, Entry func, void *arg) - : Genode::Thread(env, "nim-thread", stack_size), _func(func), _arg(arg) + Thread(Genode::Env &env, Genode::size_t stack_size, Entry func, void *arg, int affinity) + : Genode::Thread(env, "nim-thread", stack_size, + env.cpu().affinity_space().location_of_index(affinity), + Genode::Cpu_session::Weight(Genode::Cpu_session::Weight::DEFAULT_WEIGHT-1), + env.cpu()), + _func(func), _arg(arg) { Genode::Thread::start(); } @@ -40,8 +44,8 @@ struct Nim::SysThread Genode::Constructible<Thread> _thread; - void initThread(Genode::Env *env, Genode::size_t stack_size, Entry func, void *arg) { - _thread.construct(*env, stack_size, func, arg); } + void initThread(Genode::Env *env, Genode::size_t stack_size, Entry func, void *arg, int aff) { + _thread.construct(*env, stack_size, func, arg, aff); } void joinThread() { _thread->join(); } |