Lines Matching refs:equeue
299 struct events_queue equeue; member
544 pd = container_of(eq, struct scmi_registered_events_desc, equeue); in scmi_events_dispatcher()
598 if (kfifo_avail(&r_evt->proto->equeue.kfifo) < sizeof(eh) + len) { in scmi_notify()
613 kfifo_in(&r_evt->proto->equeue.kfifo, &eh, sizeof(eh)); in scmi_notify()
614 kfifo_in(&r_evt->proto->equeue.kfifo, buf, len); in scmi_notify()
627 queue_work(r_evt->proto->equeue.wq, in scmi_notify()
628 &r_evt->proto->equeue.notify_work); in scmi_notify()
653 struct events_queue *equeue, size_t sz) in scmi_initialize_events_queue() argument
657 if (kfifo_alloc(&equeue->kfifo, sz, GFP_KERNEL)) in scmi_initialize_events_queue()
660 equeue->sz = kfifo_size(&equeue->kfifo); in scmi_initialize_events_queue()
663 &equeue->kfifo); in scmi_initialize_events_queue()
667 INIT_WORK(&equeue->notify_work, scmi_events_dispatcher); in scmi_initialize_events_queue()
668 equeue->wq = ni->notify_wq; in scmi_initialize_events_queue()
712 ret = scmi_initialize_events_queue(ni, &pd->equeue, queue_sz); in scmi_allocate_registered_events_desc()
864 cancel_work_sync(&pd->equeue.notify_work); in scmi_deregister_protocol_events()