RepoMirrors/mars
1
0
Fork 0
mirror of https://github.com/schoebel/mars synced 2025-02-26 01:20:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

logger: disable irqs during spinlocks

Browse Source
This commit is contained in:
Thomas Schoebel-Theuer 2017-05-16 10:07:31 +02:00
parent bb2f82503c
commit 95ff42b7de
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
kernel/mars_trans_logger.c
View File

@ -117,18 +117,22 @@ EXPORT_SYMBOL_GPL(global_writeback);
static static
void add_to_group(struct writeback_group *gr, struct trans_logger_brick *brick) void add_to_group(struct writeback_group *gr, struct trans_logger_brick *brick)
{ {
write_lock(&gr->lock); unsigned long flags;
write_lock_irqsave(&gr->lock, flags);
list_add_tail(&brick->group_head, &gr->group_anchor); list_add_tail(&brick->group_head, &gr->group_anchor);
write_unlock(&gr->lock); write_unlock_irqrestore(&gr->lock, flags);
} }
static static
void remove_from_group(struct writeback_group *gr, struct trans_logger_brick *brick) void remove_from_group(struct writeback_group *gr, struct trans_logger_brick *brick)
{ {
write_lock(&gr->lock); unsigned long flags;
write_lock_irqsave(&gr->lock, flags);
list_del_init(&brick->group_head); list_del_init(&brick->group_head);
gr->leader = NULL; gr->leader = NULL;
write_unlock(&gr->lock); write_unlock_irqrestore(&gr->lock, flags);
} }
static static
@ -136,6 +140,7 @@ struct trans_logger_brick *elect_leader(struct writeback_group *gr)
{ {
struct trans_logger_brick *res = gr->leader; struct trans_logger_brick *res = gr->leader;
struct list_head *tmp; struct list_head *tmp;
unsigned long flags;
if (res && gr->until_percent >= 0) { if (res && gr->until_percent >= 0) {
loff_t used = atomic64_read(&res->shadow_mem_used); loff_t used = atomic64_read(&res->shadow_mem_used);
@ -143,7 +148,7 @@ struct trans_logger_brick *elect_leader(struct writeback_group *gr)
goto done; goto done;
} }
read_lock(&gr->lock); read_lock_irqsave(&gr->lock, flags);
for (tmp = gr->group_anchor.next; tmp != &gr->group_anchor; tmp = tmp->next) { for (tmp = gr->group_anchor.next; tmp != &gr->group_anchor; tmp = tmp->next) {
struct trans_logger_brick *test = container_of(tmp, struct trans_logger_brick, group_head); struct trans_logger_brick *test = container_of(tmp, struct trans_logger_brick, group_head);
loff_t new_used = atomic64_read(&test->shadow_mem_used); loff_t new_used = atomic64_read(&test->shadow_mem_used);
@ -153,7 +158,7 @@ struct trans_logger_brick *elect_leader(struct writeback_group *gr)
gr->biggest = new_used; gr->biggest = new_used;
} }
} }
read_unlock(&gr->lock); read_unlock_irqrestore(&gr->lock, flags);
gr->leader = res; gr->leader = res;