Lines Matching refs:ev_file
35 struct devx_async_cmd_event_file *ev_file; member
76 struct devx_async_event_file *ev_file; member
1700 struct devx_async_cmd_event_file *ev_file; in UVERBS_HANDLER() local
1706 ev_file = container_of(uobj, struct devx_async_cmd_event_file, in UVERBS_HANDLER()
1708 devx_init_event_queue(&ev_file->ev_queue); in UVERBS_HANDLER()
1709 mlx5_cmd_init_async_ctx(mdev->mdev, &ev_file->async_ctx); in UVERBS_HANDLER()
1718 struct devx_async_event_file *ev_file; in UVERBS_HANDLER() local
1732 ev_file = container_of(uobj, struct devx_async_event_file, in UVERBS_HANDLER()
1734 spin_lock_init(&ev_file->lock); in UVERBS_HANDLER()
1735 INIT_LIST_HEAD(&ev_file->event_list); in UVERBS_HANDLER()
1736 init_waitqueue_head(&ev_file->poll_wait); in UVERBS_HANDLER()
1738 ev_file->omit_data = 1; in UVERBS_HANDLER()
1739 INIT_LIST_HEAD(&ev_file->subscribed_events_list); in UVERBS_HANDLER()
1740 ev_file->dev = dev; in UVERBS_HANDLER()
1749 struct devx_async_cmd_event_file *ev_file = async_data->ev_file; in devx_query_callback() local
1750 struct devx_async_event_queue *ev_queue = &ev_file->ev_queue; in devx_query_callback()
1782 struct devx_async_cmd_event_file *ev_file; in UVERBS_HANDLER() local
1808 ev_file = container_of(fd_uobj, struct devx_async_cmd_event_file, in UVERBS_HANDLER()
1811 if (atomic_add_return(cmd_out_len, &ev_file->ev_queue.bytes_in_use) > in UVERBS_HANDLER()
1813 atomic_sub(cmd_out_len, &ev_file->ev_queue.bytes_in_use); in UVERBS_HANDLER()
1831 async_data->ev_file = ev_file; in UVERBS_HANDLER()
1834 err = mlx5_cmd_exec_cb(&ev_file->async_ctx, cmd_in, in UVERBS_HANDLER()
1849 atomic_sub(cmd_out_len, &ev_file->ev_queue.bytes_in_use); in UVERBS_HANDLER()
2009 struct devx_async_event_file *ev_file; in UVERBS_HANDLER() local
2037 ev_file = container_of(fd_uobj, struct devx_async_event_file, in UVERBS_HANDLER()
2105 uverbs_uobject_get(&ev_file->uobj); in UVERBS_HANDLER()
2118 event_sub->ev_file = ev_file; in UVERBS_HANDLER()
2135 spin_lock_irq(&ev_file->lock); in UVERBS_HANDLER()
2137 &ev_file->subscribed_events_list); in UVERBS_HANDLER()
2138 spin_unlock_irq(&ev_file->lock); in UVERBS_HANDLER()
2172 uverbs_uobject_put(&event_sub->ev_file->uobj); in UVERBS_HANDLER()
2451 struct devx_async_event_file *ev_file; in deliver_event() local
2455 ev_file = event_sub->ev_file; in deliver_event()
2457 if (ev_file->omit_data) { in deliver_event()
2458 spin_lock_irqsave(&ev_file->lock, flags); in deliver_event()
2460 ev_file->is_destroyed) { in deliver_event()
2461 spin_unlock_irqrestore(&ev_file->lock, flags); in deliver_event()
2465 list_add_tail(&event_sub->event_list, &ev_file->event_list); in deliver_event()
2466 spin_unlock_irqrestore(&ev_file->lock, flags); in deliver_event()
2467 wake_up_interruptible(&ev_file->poll_wait); in deliver_event()
2474 spin_lock_irqsave(&ev_file->lock, flags); in deliver_event()
2475 ev_file->is_overflow_err = 1; in deliver_event()
2476 spin_unlock_irqrestore(&ev_file->lock, flags); in deliver_event()
2483 spin_lock_irqsave(&ev_file->lock, flags); in deliver_event()
2484 if (!ev_file->is_destroyed) in deliver_event()
2485 list_add_tail(&event_data->list, &ev_file->event_list); in deliver_event()
2488 spin_unlock_irqrestore(&ev_file->lock, flags); in deliver_event()
2489 wake_up_interruptible(&ev_file->poll_wait); in deliver_event()
2682 struct devx_async_event_file *ev_file = filp->private_data; in devx_async_event_read() local
2690 omit_data = ev_file->omit_data; in devx_async_event_read()
2692 spin_lock_irq(&ev_file->lock); in devx_async_event_read()
2694 if (ev_file->is_overflow_err) { in devx_async_event_read()
2695 ev_file->is_overflow_err = 0; in devx_async_event_read()
2696 spin_unlock_irq(&ev_file->lock); in devx_async_event_read()
2701 while (list_empty(&ev_file->event_list)) { in devx_async_event_read()
2702 spin_unlock_irq(&ev_file->lock); in devx_async_event_read()
2707 if (wait_event_interruptible(ev_file->poll_wait, in devx_async_event_read()
2708 (!list_empty(&ev_file->event_list) || in devx_async_event_read()
2709 ev_file->is_destroyed))) { in devx_async_event_read()
2713 spin_lock_irq(&ev_file->lock); in devx_async_event_read()
2714 if (ev_file->is_destroyed) { in devx_async_event_read()
2715 spin_unlock_irq(&ev_file->lock); in devx_async_event_read()
2721 event_sub = list_first_entry(&ev_file->event_list, in devx_async_event_read()
2727 event = list_first_entry(&ev_file->event_list, in devx_async_event_read()
2735 spin_unlock_irq(&ev_file->lock); in devx_async_event_read()
2744 spin_unlock_irq(&ev_file->lock); in devx_async_event_read()
2760 struct devx_async_event_file *ev_file = filp->private_data; in devx_async_event_poll() local
2763 poll_wait(filp, &ev_file->poll_wait, wait); in devx_async_event_poll()
2765 spin_lock_irq(&ev_file->lock); in devx_async_event_poll()
2766 if (ev_file->is_destroyed) in devx_async_event_poll()
2768 else if (!list_empty(&ev_file->event_list)) in devx_async_event_poll()
2770 spin_unlock_irq(&ev_file->lock); in devx_async_event_poll()
2782 uverbs_uobject_put(&event_sub->ev_file->uobj); in devx_free_subscription()
2822 struct devx_async_event_file *ev_file = in devx_async_event_destroy_uobj() local
2826 struct mlx5_ib_dev *dev = ev_file->dev; in devx_async_event_destroy_uobj()
2828 spin_lock_irq(&ev_file->lock); in devx_async_event_destroy_uobj()
2829 ev_file->is_destroyed = 1; in devx_async_event_destroy_uobj()
2832 if (ev_file->omit_data) { in devx_async_event_destroy_uobj()
2835 list_for_each_entry_safe(event_sub, tmp, &ev_file->event_list, in devx_async_event_destroy_uobj()
2842 list_for_each_entry_safe(entry, tmp, &ev_file->event_list, in devx_async_event_destroy_uobj()
2849 spin_unlock_irq(&ev_file->lock); in devx_async_event_destroy_uobj()
2850 wake_up_interruptible(&ev_file->poll_wait); in devx_async_event_destroy_uobj()
2855 &ev_file->subscribed_events_list, file_list) { in devx_async_event_destroy_uobj()