Lines Matching refs:ev_queue
1579 struct devx_async_event_queue ev_queue;
1583 static void devx_init_event_queue(struct devx_async_event_queue *ev_queue)
1585 spin_lock_init(&ev_queue->lock);
1586 INIT_LIST_HEAD(&ev_queue->event_list);
1587 init_waitqueue_head(&ev_queue->poll_wait);
1588 atomic_set(&ev_queue->bytes_in_use, 0);
1589 ev_queue->is_destroyed = 0;
1603 devx_init_event_queue(&ev_file->ev_queue);
1645 struct devx_async_event_queue *ev_queue = &ev_file->ev_queue;
1653 spin_lock_irqsave(&ev_queue->lock, flags);
1654 list_add_tail(&async_data->list, &ev_queue->event_list);
1655 spin_unlock_irqrestore(&ev_queue->lock, flags);
1657 wake_up_interruptible(&ev_queue->poll_wait);
1706 if (atomic_add_return(cmd_out_len, &ev_file->ev_queue.bytes_in_use) >
1708 atomic_sub(cmd_out_len, &ev_file->ev_queue.bytes_in_use);
1744 atomic_sub(cmd_out_len, &ev_file->ev_queue.bytes_in_use);
2435 struct devx_async_event_queue *ev_queue = &comp_ev_file->ev_queue;
2440 spin_lock_irq(&ev_queue->lock);
2442 while (list_empty(&ev_queue->event_list)) {
2443 spin_unlock_irq(&ev_queue->lock);
2449 ev_queue->poll_wait,
2450 (!list_empty(&ev_queue->event_list) ||
2451 ev_queue->is_destroyed))) {
2455 spin_lock_irq(&ev_queue->lock);
2456 if (ev_queue->is_destroyed) {
2457 spin_unlock_irq(&ev_queue->lock);
2462 event = list_entry(ev_queue->event_list.next,
2468 spin_unlock_irq(&ev_queue->lock);
2472 list_del(ev_queue->event_list.next);
2473 spin_unlock_irq(&ev_queue->lock);
2480 atomic_sub(event->cmd_out_len, &ev_queue->bytes_in_use);
2489 struct devx_async_event_queue *ev_queue = &comp_ev_file->ev_queue;
2492 poll_wait(filp, &ev_queue->poll_wait, wait);
2494 spin_lock_irq(&ev_queue->lock);
2495 if (ev_queue->is_destroyed)
2497 else if (!list_empty(&ev_queue->event_list))
2499 spin_unlock_irq(&ev_queue->lock);
2633 struct devx_async_event_queue *ev_queue = &comp_ev_file->ev_queue;
2636 spin_lock_irq(&ev_queue->lock);
2637 ev_queue->is_destroyed = 1;
2638 spin_unlock_irq(&ev_queue->lock);
2639 wake_up_interruptible(&ev_queue->poll_wait);
2643 spin_lock_irq(&comp_ev_file->ev_queue.lock);
2645 &comp_ev_file->ev_queue.event_list, list) {
2649 spin_unlock_irq(&comp_ev_file->ev_queue.lock);