Lines Matching refs:equeue

272  * @equeue: The embedded per-protocol events_queue
299 	struct events_queue		equeue;
548 	pd = container_of(eq, struct scmi_registered_events_desc, equeue);
602 	if (kfifo_avail(&r_evt->proto->equeue.kfifo) < sizeof(eh) + len) {
617 	kfifo_in(&r_evt->proto->equeue.kfifo, &eh, sizeof(eh));
618 	kfifo_in(&r_evt->proto->equeue.kfifo, buf, len);
631 	queue_work(r_evt->proto->equeue.wq,
632 		   &r_evt->proto->equeue.notify_work);
649  * @equeue: The events_queue to initialize
657 					struct events_queue *equeue, size_t sz)
661 	if (kfifo_alloc(&equeue->kfifo, sz, GFP_KERNEL))
664 	equeue->sz = kfifo_size(&equeue->kfifo);
667 				       &equeue->kfifo);
671 	INIT_WORK(&equeue->notify_work, scmi_events_dispatcher);
672 	equeue->wq = ni->notify_wq;
716 	ret = scmi_initialize_events_queue(ni, &pd->equeue, queue_sz);
877 	cancel_work_sync(&pd->equeue.notify_work);