Lines Matching refs:poll_ctx

483 	struct sync_kloop_poll_ctx *poll_ctx =  in sync_kloop_poll_table_queue_proc()  local
485 struct sync_kloop_poll_entry *entry = poll_ctx->entries + in sync_kloop_poll_table_queue_proc()
486 poll_ctx->next_entry; in sync_kloop_poll_table_queue_proc()
488 BUG_ON(poll_ctx->next_entry >= poll_ctx->num_entries); in sync_kloop_poll_table_queue_proc()
492 if (poll_ctx->next_wake_fun == NULL) { in sync_kloop_poll_table_queue_proc()
496 poll_ctx->next_wake_fun); in sync_kloop_poll_table_queue_proc()
519 struct sync_kloop_poll_ctx *poll_ctx = entry->parent; in sync_kloop_tx_irq_wake_fun() local
522 for (i = 0; i < poll_ctx->num_tx_rings; i++) { in sync_kloop_tx_irq_wake_fun()
523 struct eventfd_ctx *irq_ctx = poll_ctx->entries[i].irq_ctx; in sync_kloop_tx_irq_wake_fun()
551 struct sync_kloop_poll_ctx *poll_ctx = entry->parent; in sync_kloop_rx_irq_wake_fun() local
554 for (i = poll_ctx->num_tx_rings; i < poll_ctx->num_rings; i++) { in sync_kloop_rx_irq_wake_fun()
555 struct eventfd_ctx *irq_ctx = poll_ctx->entries[i].irq_ctx; in sync_kloop_rx_irq_wake_fun()
573 struct sync_kloop_poll_ctx *poll_ctx = NULL; in netmap_sync_kloop() local
705 poll_ctx = nm_os_malloc(sizeof(*poll_ctx) + in netmap_sync_kloop()
706 (num_rings + 2) * sizeof(poll_ctx->entries[0])); in netmap_sync_kloop()
707 init_poll_funcptr(&poll_ctx->wait_table, in netmap_sync_kloop()
709 poll_ctx->num_entries = 2 + num_rings; in netmap_sync_kloop()
710 poll_ctx->num_tx_rings = num_tx_rings; in netmap_sync_kloop()
711 poll_ctx->num_rings = num_rings; in netmap_sync_kloop()
712 poll_ctx->next_entry = 0; in netmap_sync_kloop()
713 poll_ctx->next_wake_fun = NULL; in netmap_sync_kloop()
725 poll_ctx->entries[i].args = args + i; in netmap_sync_kloop()
726 poll_ctx->entries[i].parent = poll_ctx; in netmap_sync_kloop()
731 for (i = 0; i < num_rings; i++, poll_ctx->next_entry++) { in netmap_sync_kloop()
750 poll_ctx->entries[i].irq_filp = filp; in netmap_sync_kloop()
751 poll_ctx->entries[i].irq_ctx = irq; in netmap_sync_kloop()
752 poll_ctx->entries[i].args->busy_wait = busy_wait; in netmap_sync_kloop()
755 poll_ctx->entries[i].args->irq_ctx = in netmap_sync_kloop()
758 poll_ctx->entries[i].irq_ctx; in netmap_sync_kloop()
759 poll_ctx->entries[i].args->direct = in netmap_sync_kloop()
774 poll_ctx->next_wake_fun = in netmap_sync_kloop()
778 poll_ctx->next_wake_fun = in netmap_sync_kloop()
781 poll_ctx->next_wake_fun = NULL; in netmap_sync_kloop()
784 &poll_ctx->wait_table); in netmap_sync_kloop()
799 poll_ctx->next_wake_fun = direct_tx ? in netmap_sync_kloop()
802 &poll_ctx->wait_table); in netmap_sync_kloop()
803 poll_ctx->next_entry++; in netmap_sync_kloop()
805 poll_ctx->next_wake_fun = direct_rx ? in netmap_sync_kloop()
808 &poll_ctx->wait_table); in netmap_sync_kloop()
809 poll_ctx->next_entry++; in netmap_sync_kloop()
869 if (poll_ctx) { in netmap_sync_kloop()
875 for (i = 0; i < poll_ctx->next_entry; i++) { in netmap_sync_kloop()
877 poll_ctx->entries + i; in netmap_sync_kloop()
891 nm_os_free(poll_ctx); in netmap_sync_kloop()
892 poll_ctx = NULL; in netmap_sync_kloop()