rarias/ovni
rarias/ovni
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Allow inter-process remote affinity events

Browse Source 
A thread can change the affinity of another thread if is running in a
different process, as long as it is in the same loom.
This commit is contained in:
Rodrigo Arias 2021-10-11 16:27:28 +02:00
parent 11b85f03c2
commit f1fa68e4df
1 changed files with 30 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
emu_ovni.c
View File

@ -472,16 +472,44 @@ pre_affinity_set(struct ovni_emu *emu)
static void static void
pre_affinity_remote(struct ovni_emu *emu) pre_affinity_remote(struct ovni_emu *emu)
{ {
int cpuid, tid; int i, cpuid, tid;
struct ovni_cpu *newcpu; struct ovni_cpu *newcpu;
struct ovni_ethread *remote_th; struct ovni_ethread *remote_th;
struct ovni_loom *loom;
struct ovni_eproc *proc;
cpuid = emu->cur_ev->payload.i32[0]; cpuid = emu->cur_ev->payload.i32[0];
tid = emu->cur_ev->payload.i32[1]; tid = emu->cur_ev->payload.i32[1];
remote_th = emu_get_thread(emu->cur_proc, tid); remote_th = emu_get_thread(emu->cur_proc, tid);
assert(remote_th); if(remote_th == NULL)
{
/* Search the thread in other processes of the loom if
* not found in the current one */
loom = emu->cur_loom;
for(i=0; i<loom->nprocs; i++)
{
proc = &loom->proc[i];
/* Skip the current process */
if(proc == emu->cur_proc)
continue;
remote_th = emu_get_thread(proc, tid);
if(remote_th)
break;
}
if(remote_th == NULL)
{
err("thread tid %d not found: cannot set affinity remotely\n",
tid);
abort();
}
}
/* The remote_th cannot be in states dead or unknown */ /* The remote_th cannot be in states dead or unknown */
assert(remote_th->state != TH_ST_DEAD assert(remote_th->state != TH_ST_DEAD