Merge ../aio-fixes
This commit is contained in:
7
fs/aio.c
7
fs/aio.c
@@ -812,16 +812,20 @@ void exit_aio(struct mm_struct *mm)
|
||||
static void put_reqs_available(struct kioctx *ctx, unsigned nr)
|
||||
{
|
||||
struct kioctx_cpu *kcpu;
|
||||
unsigned long flags;
|
||||
|
||||
preempt_disable();
|
||||
kcpu = this_cpu_ptr(ctx->cpu);
|
||||
|
||||
local_irq_save(flags);
|
||||
kcpu->reqs_available += nr;
|
||||
|
||||
while (kcpu->reqs_available >= ctx->req_batch * 2) {
|
||||
kcpu->reqs_available -= ctx->req_batch;
|
||||
atomic_add(ctx->req_batch, &ctx->reqs_available);
|
||||
}
|
||||
|
||||
local_irq_restore(flags);
|
||||
preempt_enable();
|
||||
}
|
||||
|
||||
@@ -829,10 +833,12 @@ static bool get_reqs_available(struct kioctx *ctx)
|
||||
{
|
||||
struct kioctx_cpu *kcpu;
|
||||
bool ret = false;
|
||||
unsigned long flags;
|
||||
|
||||
preempt_disable();
|
||||
kcpu = this_cpu_ptr(ctx->cpu);
|
||||
|
||||
local_irq_save(flags);
|
||||
if (!kcpu->reqs_available) {
|
||||
int old, avail = atomic_read(&ctx->reqs_available);
|
||||
|
||||
@@ -851,6 +857,7 @@ static bool get_reqs_available(struct kioctx *ctx)
|
||||
ret = true;
|
||||
kcpu->reqs_available--;
|
||||
out:
|
||||
local_irq_restore(flags);
|
||||
preempt_enable();
|
||||
return ret;
|
||||
}
|
||||
|
Reference in New Issue
Block a user