Lines Matching refs:poll_ctx

477 	struct sync_kloop_poll_ctx *poll_ctx =  in sync_kloop_poll_table_queue_proc()  local
479 struct sync_kloop_poll_entry *entry = poll_ctx->entries + in sync_kloop_poll_table_queue_proc()
480 poll_ctx->next_entry; in sync_kloop_poll_table_queue_proc()
482 BUG_ON(poll_ctx->next_entry >= poll_ctx->num_entries); in sync_kloop_poll_table_queue_proc()
486 if (poll_ctx->next_wake_fun == NULL) { in sync_kloop_poll_table_queue_proc()
490 poll_ctx->next_wake_fun); in sync_kloop_poll_table_queue_proc()
513 struct sync_kloop_poll_ctx *poll_ctx = entry->parent; in sync_kloop_tx_irq_wake_fun() local
516 for (i = 0; i < poll_ctx->num_tx_rings; i++) { in sync_kloop_tx_irq_wake_fun()
517 struct eventfd_ctx *irq_ctx = poll_ctx->entries[i].irq_ctx; in sync_kloop_tx_irq_wake_fun()
545 struct sync_kloop_poll_ctx *poll_ctx = entry->parent; in sync_kloop_rx_irq_wake_fun() local
548 for (i = poll_ctx->num_tx_rings; i < poll_ctx->num_rings; i++) { in sync_kloop_rx_irq_wake_fun()
549 struct eventfd_ctx *irq_ctx = poll_ctx->entries[i].irq_ctx; in sync_kloop_rx_irq_wake_fun()
567 struct sync_kloop_poll_ctx *poll_ctx = NULL; in netmap_sync_kloop() local
699 poll_ctx = nm_os_malloc(sizeof(*poll_ctx) + in netmap_sync_kloop()
700 (num_rings + 2) * sizeof(poll_ctx->entries[0])); in netmap_sync_kloop()
701 init_poll_funcptr(&poll_ctx->wait_table, in netmap_sync_kloop()
703 poll_ctx->num_entries = 2 + num_rings; in netmap_sync_kloop()
704 poll_ctx->num_tx_rings = num_tx_rings; in netmap_sync_kloop()
705 poll_ctx->num_rings = num_rings; in netmap_sync_kloop()
706 poll_ctx->next_entry = 0; in netmap_sync_kloop()
707 poll_ctx->next_wake_fun = NULL; in netmap_sync_kloop()
719 poll_ctx->entries[i].args = args + i; in netmap_sync_kloop()
720 poll_ctx->entries[i].parent = poll_ctx; in netmap_sync_kloop()
725 for (i = 0; i < num_rings; i++, poll_ctx->next_entry++) { in netmap_sync_kloop()
744 poll_ctx->entries[i].irq_filp = filp; in netmap_sync_kloop()
745 poll_ctx->entries[i].irq_ctx = irq; in netmap_sync_kloop()
746 poll_ctx->entries[i].args->busy_wait = busy_wait; in netmap_sync_kloop()
749 poll_ctx->entries[i].args->irq_ctx = in netmap_sync_kloop()
752 poll_ctx->entries[i].irq_ctx; in netmap_sync_kloop()
753 poll_ctx->entries[i].args->direct = in netmap_sync_kloop()
768 poll_ctx->next_wake_fun = in netmap_sync_kloop()
772 poll_ctx->next_wake_fun = in netmap_sync_kloop()
775 poll_ctx->next_wake_fun = NULL; in netmap_sync_kloop()
778 &poll_ctx->wait_table); in netmap_sync_kloop()
793 poll_ctx->next_wake_fun = direct_tx ? in netmap_sync_kloop()
796 &poll_ctx->wait_table); in netmap_sync_kloop()
797 poll_ctx->next_entry++; in netmap_sync_kloop()
799 poll_ctx->next_wake_fun = direct_rx ? in netmap_sync_kloop()
802 &poll_ctx->wait_table); in netmap_sync_kloop()
803 poll_ctx->next_entry++; in netmap_sync_kloop()
863 if (poll_ctx) { in netmap_sync_kloop()
869 for (i = 0; i < poll_ctx->next_entry; i++) { in netmap_sync_kloop()
871 poll_ctx->entries + i; in netmap_sync_kloop()
885 nm_os_free(poll_ctx); in netmap_sync_kloop()
886 poll_ctx = NULL; in netmap_sync_kloop()