ehmry/genode
ehmry/genode
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

hw: consider affinity location in Platform_thread

Browse Source 
ref #1076
This commit is contained in:
Martin Stein 2014-03-06 14:30:37 +01:00 committed by Norman Feske
parent 49bf33e404
commit a586828844
3 changed files with 30 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
base-hw/src/core/include/platform.h
View File

@ -120,6 +120,11 @@ namespace Genode {
while (1) ;
return 0;
}
Affinity::Space affinity_space() const
{
return Affinity::Space(PROCESSORS);
}
};
}

15
base-hw/src/core/include/platform_thread.h
View File

@ -63,6 +63,8 @@ namespace Genode {
*/
bool _main_thread;
Affinity::Location _location;
/**
* Common construction part
*/
@ -116,11 +118,10 @@ namespace Genode {
/**
* Run this thread
*
* \param ip initial instruction pointer
* \param sp initial stack pointer
* \param cpu_id kernel name of targeted CPU
* \param ip initial instruction pointer
* \param sp initial stack pointer
*/
int start(void * const ip, void * const sp, unsigned const cpu_id = 0);
int start(void * const ip, void * const sp);
/**
* Pause this thread
@ -154,13 +155,15 @@ namespace Genode {
/**
* Set the executing CPU for this thread
*
* \param location targeted location in affinity space
*/
void affinity(Affinity::Location) { }
void affinity(Affinity::Location const & location);
/**
* Get the executing CPU for this thread
*/
Affinity::Location affinity() { return Affinity::Location(); };
Affinity::Location affinity() const;
/**
* Return the address space to which the thread is bound

19
base-hw/src/core/platform_thread.cc
View File

@ -160,8 +160,16 @@ int Platform_thread::join_pd(unsigned const pd_id, bool const main_thread,
}
int Platform_thread::start(void * const ip, void * const sp,
unsigned int const cpu_id)
void Platform_thread::affinity(Affinity::Location const & location)
{
_location = location;
}
Affinity::Location Platform_thread::affinity() const { return _location; }
int Platform_thread::start(void * const ip, void * const sp)
{
/* attach UTCB in case of a main thread */
if (_main_thread) {
@ -188,9 +196,14 @@ int Platform_thread::start(void * const ip, void * const sp,
PERR("failed to initialize thread registers");
return -1;
}
/* determine kernel name of targeted processor */
unsigned processor_id;
if (_location.valid()) { processor_id = _location.xpos(); }
else { processor_id = Processor_driver::primary_id(); }
/* start executing new thread */
_utcb_phys->start_info()->init(_id, _utcb);
_tlb = Kernel::start_thread(_id, cpu_id, _pd_id, _utcb_phys);
_tlb = Kernel::start_thread(_id, processor_id, _pd_id, _utcb_phys);
if (!_tlb) {
PERR("failed to start thread");
return -1;