gh0s7/mckernel
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

support for backlog

Browse Source 
Change-Id: Id8f503234e7afaa284e6b97dc264eb3a2af145c7
This commit is contained in:
Tomoki Shirasawa
2019-11-15 15:49:18 +09:00
committed by Masamichi Takagi
parent e069694c12
commit 37605740a4
5 changed files with 71 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

53
kernel/cls.c
View File

@ -17,6 +17,7 @@
#include <ihk/lock.h>
#include <ihk/mm.h>
#include <ihk/page_alloc.h>
#include <kmalloc.h>
#include <cls.h>
#include <page.h>
#include <rusage_private.h>
@ -42,6 +43,7 @@ void cpu_local_var_init(void)
clv[i].monitor = monitor->cpu + i;
clv[i].rusage = rusage.cpu + i;
INIT_LIST_HEAD(&clv[i].smp_func_req_list);
INIT_LIST_HEAD(&clv[i].backlog_list);
#ifdef ENABLE_PER_CPU_ALLOC_CACHE
clv[i].free_chunks.rb_node = NULL;
#endif
@ -67,3 +69,54 @@ void preempt_disable(void)
if (cpu_local_var_initialized)
++cpu_local_var(no_preempt);
}
int add_backlog(int (*func)(void *arg), void *arg)
{
struct backlog *bl;
struct cpu_local_var *v = get_this_cpu_local_var();
unsigned long irqstate;
if (!(bl = kmalloc(sizeof(struct backlog), IHK_MC_AP_NOWAIT))) {
return -ENOMEM;
}
INIT_LIST_HEAD(&bl->list);
bl->func = func;
bl->arg = arg;
irqstate = ihk_mc_spinlock_lock(&v->backlog_lock);
list_add_tail(&bl->list, &v->backlog_list);
ihk_mc_spinlock_unlock(&v->backlog_lock, irqstate);
irqstate = ihk_mc_spinlock_lock(&v->runq_lock);
v->flags |= CPU_FLAG_NEED_RESCHED;
ihk_mc_spinlock_unlock(&v->runq_lock, irqstate);
set_timer(0);
return 0;
}
void do_backlog(void)
{
unsigned long irqstate;
struct list_head list;
struct cpu_local_var *v = get_this_cpu_local_var();
struct backlog *bl;
struct backlog *next;
INIT_LIST_HEAD(&list);
irqstate = ihk_mc_spinlock_lock(&v->backlog_lock);
list_for_each_entry_safe(bl, next, &v->backlog_list, list) {
list_del(&bl->list);
list_add_tail(&bl->list, &list);
}
ihk_mc_spinlock_unlock(&v->backlog_lock, irqstate);
list_for_each_entry_safe(bl, next, &list, list) {
list_del(&bl->list);
if (bl->func(bl->arg)) {
irqstate = ihk_mc_spinlock_lock(&v->backlog_lock);
list_add_tail(&bl->list, &v->backlog_list);
ihk_mc_spinlock_unlock(&v->backlog_lock, irqstate);
}
else {
kfree(bl);
}
}
}