Lines Matching refs:ev_file
35 struct devx_async_cmd_event_file *ev_file; member
76 struct devx_async_event_file *ev_file; member
1575 struct devx_async_cmd_event_file *ev_file; in UVERBS_HANDLER() local
1581 ev_file = container_of(uobj, struct devx_async_cmd_event_file, in UVERBS_HANDLER()
1583 devx_init_event_queue(&ev_file->ev_queue); in UVERBS_HANDLER()
1584 mlx5_cmd_init_async_ctx(mdev->mdev, &ev_file->async_ctx); in UVERBS_HANDLER()
1593 struct devx_async_event_file *ev_file; in UVERBS_HANDLER() local
1607 ev_file = container_of(uobj, struct devx_async_event_file, in UVERBS_HANDLER()
1609 spin_lock_init(&ev_file->lock); in UVERBS_HANDLER()
1610 INIT_LIST_HEAD(&ev_file->event_list); in UVERBS_HANDLER()
1611 init_waitqueue_head(&ev_file->poll_wait); in UVERBS_HANDLER()
1613 ev_file->omit_data = 1; in UVERBS_HANDLER()
1614 INIT_LIST_HEAD(&ev_file->subscribed_events_list); in UVERBS_HANDLER()
1615 ev_file->dev = dev; in UVERBS_HANDLER()
1624 struct devx_async_cmd_event_file *ev_file = async_data->ev_file; in devx_query_callback() local
1625 struct devx_async_event_queue *ev_queue = &ev_file->ev_queue; in devx_query_callback()
1657 struct devx_async_cmd_event_file *ev_file; in UVERBS_HANDLER() local
1683 ev_file = container_of(fd_uobj, struct devx_async_cmd_event_file, in UVERBS_HANDLER()
1686 if (atomic_add_return(cmd_out_len, &ev_file->ev_queue.bytes_in_use) > in UVERBS_HANDLER()
1688 atomic_sub(cmd_out_len, &ev_file->ev_queue.bytes_in_use); in UVERBS_HANDLER()
1706 async_data->ev_file = ev_file; in UVERBS_HANDLER()
1709 err = mlx5_cmd_exec_cb(&ev_file->async_ctx, cmd_in, in UVERBS_HANDLER()
1724 atomic_sub(cmd_out_len, &ev_file->ev_queue.bytes_in_use); in UVERBS_HANDLER()
1882 struct devx_async_event_file *ev_file; in UVERBS_HANDLER() local
1911 ev_file = container_of(fd_uobj, struct devx_async_event_file, in UVERBS_HANDLER()
1978 uverbs_uobject_get(&ev_file->uobj); in UVERBS_HANDLER()
1991 event_sub->ev_file = ev_file; in UVERBS_HANDLER()
2008 spin_lock_irq(&ev_file->lock); in UVERBS_HANDLER()
2010 &ev_file->subscribed_events_list); in UVERBS_HANDLER()
2011 spin_unlock_irq(&ev_file->lock); in UVERBS_HANDLER()
2045 uverbs_uobject_put(&event_sub->ev_file->uobj); in UVERBS_HANDLER()
2260 struct devx_async_event_file *ev_file; in deliver_event() local
2264 ev_file = event_sub->ev_file; in deliver_event()
2266 if (ev_file->omit_data) { in deliver_event()
2267 spin_lock_irqsave(&ev_file->lock, flags); in deliver_event()
2269 ev_file->is_destroyed) { in deliver_event()
2270 spin_unlock_irqrestore(&ev_file->lock, flags); in deliver_event()
2274 list_add_tail(&event_sub->event_list, &ev_file->event_list); in deliver_event()
2275 spin_unlock_irqrestore(&ev_file->lock, flags); in deliver_event()
2276 wake_up_interruptible(&ev_file->poll_wait); in deliver_event()
2283 spin_lock_irqsave(&ev_file->lock, flags); in deliver_event()
2284 ev_file->is_overflow_err = 1; in deliver_event()
2285 spin_unlock_irqrestore(&ev_file->lock, flags); in deliver_event()
2292 spin_lock_irqsave(&ev_file->lock, flags); in deliver_event()
2293 if (!ev_file->is_destroyed) in deliver_event()
2294 list_add_tail(&event_data->list, &ev_file->event_list); in deliver_event()
2297 spin_unlock_irqrestore(&ev_file->lock, flags); in deliver_event()
2298 wake_up_interruptible(&ev_file->poll_wait); in deliver_event()
2491 struct devx_async_event_file *ev_file = filp->private_data; in devx_async_event_read() local
2499 omit_data = ev_file->omit_data; in devx_async_event_read()
2501 spin_lock_irq(&ev_file->lock); in devx_async_event_read()
2503 if (ev_file->is_overflow_err) { in devx_async_event_read()
2504 ev_file->is_overflow_err = 0; in devx_async_event_read()
2505 spin_unlock_irq(&ev_file->lock); in devx_async_event_read()
2510 while (list_empty(&ev_file->event_list)) { in devx_async_event_read()
2511 spin_unlock_irq(&ev_file->lock); in devx_async_event_read()
2516 if (wait_event_interruptible(ev_file->poll_wait, in devx_async_event_read()
2517 (!list_empty(&ev_file->event_list) || in devx_async_event_read()
2518 ev_file->is_destroyed))) { in devx_async_event_read()
2522 spin_lock_irq(&ev_file->lock); in devx_async_event_read()
2523 if (ev_file->is_destroyed) { in devx_async_event_read()
2524 spin_unlock_irq(&ev_file->lock); in devx_async_event_read()
2530 event_sub = list_first_entry(&ev_file->event_list, in devx_async_event_read()
2536 event = list_first_entry(&ev_file->event_list, in devx_async_event_read()
2544 spin_unlock_irq(&ev_file->lock); in devx_async_event_read()
2553 spin_unlock_irq(&ev_file->lock); in devx_async_event_read()
2569 struct devx_async_event_file *ev_file = filp->private_data; in devx_async_event_poll() local
2572 poll_wait(filp, &ev_file->poll_wait, wait); in devx_async_event_poll()
2574 spin_lock_irq(&ev_file->lock); in devx_async_event_poll()
2575 if (ev_file->is_destroyed) in devx_async_event_poll()
2577 else if (!list_empty(&ev_file->event_list)) in devx_async_event_poll()
2579 spin_unlock_irq(&ev_file->lock); in devx_async_event_poll()
2591 uverbs_uobject_put(&event_sub->ev_file->uobj); in devx_free_subscription()
2632 struct devx_async_event_file *ev_file = in devx_async_event_destroy_uobj() local
2636 struct mlx5_ib_dev *dev = ev_file->dev; in devx_async_event_destroy_uobj()
2638 spin_lock_irq(&ev_file->lock); in devx_async_event_destroy_uobj()
2639 ev_file->is_destroyed = 1; in devx_async_event_destroy_uobj()
2642 if (ev_file->omit_data) { in devx_async_event_destroy_uobj()
2645 list_for_each_entry_safe(event_sub, tmp, &ev_file->event_list, in devx_async_event_destroy_uobj()
2652 list_for_each_entry_safe(entry, tmp, &ev_file->event_list, in devx_async_event_destroy_uobj()
2659 spin_unlock_irq(&ev_file->lock); in devx_async_event_destroy_uobj()
2660 wake_up_interruptible(&ev_file->poll_wait); in devx_async_event_destroy_uobj()
2665 &ev_file->subscribed_events_list, file_list) { in devx_async_event_destroy_uobj()