|
@@ -110,31 +110,14 @@ static ssize_t timerfd_read(struct file *file, char __user *buf, size_t count,
|
|
|
struct timerfd_ctx *ctx = file->private_data;
|
|
|
ssize_t res;
|
|
|
u64 ticks = 0;
|
|
|
- DECLARE_WAITQUEUE(wait, current);
|
|
|
|
|
|
if (count < sizeof(ticks))
|
|
|
return -EINVAL;
|
|
|
spin_lock_irq(&ctx->wqh.lock);
|
|
|
- res = -EAGAIN;
|
|
|
- if (!ctx->ticks && !(file->f_flags & O_NONBLOCK)) {
|
|
|
- __add_wait_queue(&ctx->wqh, &wait);
|
|
|
- for (res = 0;;) {
|
|
|
- set_current_state(TASK_INTERRUPTIBLE);
|
|
|
- if (ctx->ticks) {
|
|
|
- res = 0;
|
|
|
- break;
|
|
|
- }
|
|
|
- if (signal_pending(current)) {
|
|
|
- res = -ERESTARTSYS;
|
|
|
- break;
|
|
|
- }
|
|
|
- spin_unlock_irq(&ctx->wqh.lock);
|
|
|
- schedule();
|
|
|
- spin_lock_irq(&ctx->wqh.lock);
|
|
|
- }
|
|
|
- __remove_wait_queue(&ctx->wqh, &wait);
|
|
|
- __set_current_state(TASK_RUNNING);
|
|
|
- }
|
|
|
+ if (file->f_flags & O_NONBLOCK)
|
|
|
+ res = -EAGAIN;
|
|
|
+ else
|
|
|
+ res = wait_event_interruptible_locked_irq(ctx->wqh, ctx->ticks);
|
|
|
if (ctx->ticks) {
|
|
|
ticks = ctx->ticks;
|
|
|
if (ctx->expired && ctx->tintv.tv64) {
|