Lines Matching refs:ev_file
35 struct devx_async_cmd_event_file *ev_file; member
76 struct devx_async_event_file *ev_file; member
1574 struct devx_async_cmd_event_file *ev_file; in UVERBS_HANDLER() local
1580 ev_file = container_of(uobj, struct devx_async_cmd_event_file, in UVERBS_HANDLER()
1582 devx_init_event_queue(&ev_file->ev_queue); in UVERBS_HANDLER()
1583 mlx5_cmd_init_async_ctx(mdev->mdev, &ev_file->async_ctx); in UVERBS_HANDLER()
1592 struct devx_async_event_file *ev_file; in UVERBS_HANDLER() local
1606 ev_file = container_of(uobj, struct devx_async_event_file, in UVERBS_HANDLER()
1608 spin_lock_init(&ev_file->lock); in UVERBS_HANDLER()
1609 INIT_LIST_HEAD(&ev_file->event_list); in UVERBS_HANDLER()
1610 init_waitqueue_head(&ev_file->poll_wait); in UVERBS_HANDLER()
1612 ev_file->omit_data = 1; in UVERBS_HANDLER()
1613 INIT_LIST_HEAD(&ev_file->subscribed_events_list); in UVERBS_HANDLER()
1614 ev_file->dev = dev; in UVERBS_HANDLER()
1623 struct devx_async_cmd_event_file *ev_file = async_data->ev_file; in devx_query_callback() local
1624 struct devx_async_event_queue *ev_queue = &ev_file->ev_queue; in devx_query_callback()
1656 struct devx_async_cmd_event_file *ev_file; in UVERBS_HANDLER() local
1682 ev_file = container_of(fd_uobj, struct devx_async_cmd_event_file, in UVERBS_HANDLER()
1685 if (atomic_add_return(cmd_out_len, &ev_file->ev_queue.bytes_in_use) > in UVERBS_HANDLER()
1687 atomic_sub(cmd_out_len, &ev_file->ev_queue.bytes_in_use); in UVERBS_HANDLER()
1705 async_data->ev_file = ev_file; in UVERBS_HANDLER()
1708 err = mlx5_cmd_exec_cb(&ev_file->async_ctx, cmd_in, in UVERBS_HANDLER()
1723 atomic_sub(cmd_out_len, &ev_file->ev_queue.bytes_in_use); in UVERBS_HANDLER()
1883 struct devx_async_event_file *ev_file; in UVERBS_HANDLER() local
1912 ev_file = container_of(fd_uobj, struct devx_async_event_file, in UVERBS_HANDLER()
1981 uverbs_uobject_get(&ev_file->uobj); in UVERBS_HANDLER()
1994 event_sub->ev_file = ev_file; in UVERBS_HANDLER()
2011 spin_lock_irq(&ev_file->lock); in UVERBS_HANDLER()
2013 &ev_file->subscribed_events_list); in UVERBS_HANDLER()
2014 spin_unlock_irq(&ev_file->lock); in UVERBS_HANDLER()
2048 uverbs_uobject_put(&event_sub->ev_file->uobj); in UVERBS_HANDLER()
2263 struct devx_async_event_file *ev_file; in deliver_event() local
2267 ev_file = event_sub->ev_file; in deliver_event()
2269 if (ev_file->omit_data) { in deliver_event()
2270 spin_lock_irqsave(&ev_file->lock, flags); in deliver_event()
2272 ev_file->is_destroyed) { in deliver_event()
2273 spin_unlock_irqrestore(&ev_file->lock, flags); in deliver_event()
2277 list_add_tail(&event_sub->event_list, &ev_file->event_list); in deliver_event()
2278 spin_unlock_irqrestore(&ev_file->lock, flags); in deliver_event()
2279 wake_up_interruptible(&ev_file->poll_wait); in deliver_event()
2286 spin_lock_irqsave(&ev_file->lock, flags); in deliver_event()
2287 ev_file->is_overflow_err = 1; in deliver_event()
2288 spin_unlock_irqrestore(&ev_file->lock, flags); in deliver_event()
2295 spin_lock_irqsave(&ev_file->lock, flags); in deliver_event()
2296 if (!ev_file->is_destroyed) in deliver_event()
2297 list_add_tail(&event_data->list, &ev_file->event_list); in deliver_event()
2300 spin_unlock_irqrestore(&ev_file->lock, flags); in deliver_event()
2301 wake_up_interruptible(&ev_file->poll_wait); in deliver_event()
2494 struct devx_async_event_file *ev_file = filp->private_data; in devx_async_event_read() local
2502 omit_data = ev_file->omit_data; in devx_async_event_read()
2504 spin_lock_irq(&ev_file->lock); in devx_async_event_read()
2506 if (ev_file->is_overflow_err) { in devx_async_event_read()
2507 ev_file->is_overflow_err = 0; in devx_async_event_read()
2508 spin_unlock_irq(&ev_file->lock); in devx_async_event_read()
2513 while (list_empty(&ev_file->event_list)) { in devx_async_event_read()
2514 spin_unlock_irq(&ev_file->lock); in devx_async_event_read()
2519 if (wait_event_interruptible(ev_file->poll_wait, in devx_async_event_read()
2520 (!list_empty(&ev_file->event_list) || in devx_async_event_read()
2521 ev_file->is_destroyed))) { in devx_async_event_read()
2525 spin_lock_irq(&ev_file->lock); in devx_async_event_read()
2526 if (ev_file->is_destroyed) { in devx_async_event_read()
2527 spin_unlock_irq(&ev_file->lock); in devx_async_event_read()
2533 event_sub = list_first_entry(&ev_file->event_list, in devx_async_event_read()
2539 event = list_first_entry(&ev_file->event_list, in devx_async_event_read()
2547 spin_unlock_irq(&ev_file->lock); in devx_async_event_read()
2556 spin_unlock_irq(&ev_file->lock); in devx_async_event_read()
2572 struct devx_async_event_file *ev_file = filp->private_data; in devx_async_event_poll() local
2575 poll_wait(filp, &ev_file->poll_wait, wait); in devx_async_event_poll()
2577 spin_lock_irq(&ev_file->lock); in devx_async_event_poll()
2578 if (ev_file->is_destroyed) in devx_async_event_poll()
2580 else if (!list_empty(&ev_file->event_list)) in devx_async_event_poll()
2582 spin_unlock_irq(&ev_file->lock); in devx_async_event_poll()
2594 uverbs_uobject_put(&event_sub->ev_file->uobj); in devx_free_subscription()
2635 struct devx_async_event_file *ev_file = in devx_async_event_destroy_uobj() local
2639 struct mlx5_ib_dev *dev = ev_file->dev; in devx_async_event_destroy_uobj()
2641 spin_lock_irq(&ev_file->lock); in devx_async_event_destroy_uobj()
2642 ev_file->is_destroyed = 1; in devx_async_event_destroy_uobj()
2645 if (ev_file->omit_data) { in devx_async_event_destroy_uobj()
2648 list_for_each_entry_safe(event_sub, tmp, &ev_file->event_list, in devx_async_event_destroy_uobj()
2655 list_for_each_entry_safe(entry, tmp, &ev_file->event_list, in devx_async_event_destroy_uobj()
2662 spin_unlock_irq(&ev_file->lock); in devx_async_event_destroy_uobj()
2663 wake_up_interruptible(&ev_file->poll_wait); in devx_async_event_destroy_uobj()
2668 &ev_file->subscribed_events_list, file_list) { in devx_async_event_destroy_uobj()