| /linux-6.15/drivers/media/usb/uvc/ |
| H A D | uvc_queue.c | 215 queue->queue.type = type; in uvc_queue_init()
217 queue->queue.drv_priv = queue; in uvc_queue_init()
222 queue->queue.lock = &queue->mutex; in uvc_queue_init()
229 queue->queue.io_modes |= VB2_DMABUF; in uvc_queue_init()
230 queue->queue.ops = &uvc_queue_qops; in uvc_queue_init()
234 ret = vb2_queue_init(&queue->queue); in uvc_queue_init()
248 vb2_queue_release(&queue->queue); in uvc_queue_release()
262 ret = vb2_reqbufs(&queue->queue, rb); in uvc_request_buffers()
273 ret = vb2_querybuf(&queue->queue, buf); in uvc_query_buffer()
309 ret = vb2_expbuf(&queue->queue, exp); in uvc_export_buffer()
[all …]
|
| /linux-6.15/drivers/usb/gadget/function/ |
| H A D | uvc_queue.c | 134 queue->queue.type = type; in uvcg_queue_init()
136 queue->queue.drv_priv = queue; in uvcg_queue_init()
138 queue->queue.ops = &uvc_queue_qops; in uvcg_queue_init()
139 queue->queue.lock = lock; in uvcg_queue_init()
149 queue->queue.dev = dev; in uvcg_queue_init()
151 ret = vb2_queue_init(&queue->queue); in uvcg_queue_init()
167 vb2_queue_release(&queue->queue); in uvcg_free_buffers()
178 ret = vb2_reqbufs(&queue->queue, rb); in uvcg_alloc_buffers()
217 return vb2_mmap(&queue->queue, vma); in uvcg_queue_mmap()
295 ret = vb2_streamon(&queue->queue, queue->queue.type); in uvcg_queue_enable()
[all …]
|
| /linux-6.15/drivers/md/dm-vdo/ |
| H A D | funnel-workqueue.c | 156 queue->common.type->start(queue->private); in run_start_hook()
162 queue->common.type->finish(queue->private); in run_finish_hook()
280 vdo_free(queue); in free_simple_work_queue()
295 vdo_free(queue); in free_round_robin_work_queue()
300 if (queue == NULL) in vdo_free_work_queue()
338 vdo_free(queue); in make_simple_work_queue()
403 &queue); in vdo_make_work_queue()
410 vdo_free(queue); in vdo_make_work_queue()
421 vdo_free(queue); in vdo_make_work_queue()
614 return (queue == NULL) ? NULL : &queue->common; in vdo_get_current_work_queue()
[all …]
|
| H A D | funnel-queue.c | 15 struct funnel_queue *queue; in vdo_make_funnel_queue() local
25 queue->stub.next = NULL; in vdo_make_funnel_queue()
26 queue->newest = &queue->stub; in vdo_make_funnel_queue()
27 queue->oldest = &queue->stub; in vdo_make_funnel_queue()
29 *queue_ptr = queue; in vdo_make_funnel_queue()
35 vdo_free(queue); in vdo_free_funnel_queue()
48 if (oldest == &queue->stub) { in get_oldest()
60 queue->oldest = oldest; in get_oldest()
83 vdo_funnel_queue_put(queue, &queue->stub); in get_oldest()
154 if (queue->oldest != &queue->stub) in vdo_is_funnel_queue_idle()
[all …]
|
| /linux-6.15/drivers/net/wireless/st/cw1200/ |
| H A D | queue.c | 97 list_for_each_entry_safe(iter, tmp, &queue->queue, head) { in __cw1200_queue_gc()
119 if (queue->num_queued <= (queue->capacity >> 1)) { in __cw1200_queue_gc()
172 memset(queue, 0, sizeof(*queue)); in cw1200_queue_init()
177 INIT_LIST_HEAD(&queue->queue); in cw1200_queue_init()
197 list_add_tail(&queue->pool[i].head, &queue->free_pool); in cw1200_queue_init()
211 list_splice_tail_init(&queue->queue, &queue->pending); in cw1200_queue_clear()
268 ret = queue->num_queued - queue->num_pending; in cw1200_queue_get_num_queued()
296 list_move_tail(&item->head, &queue->queue); in cw1200_queue_put()
343 list_for_each_entry(item, &queue->queue, head) { in cw1200_queue_get()
408 list_move(&item->head, &queue->queue); in cw1200_queue_requeue()
[all …]
|
| /linux-6.15/drivers/nvme/target/ |
| H A D | tcp.c | 455 struct nvmet_tcp_queue *queue = cmd->queue; in nvmet_setup_c2h_data_pdu() local
488 struct nvmet_tcp_queue *queue = cmd->queue; in nvmet_setup_r2t_pdu() local
513 struct nvmet_tcp_queue *queue = cmd->queue; in nvmet_setup_response_pdu() local
572 struct nvmet_tcp_queue *queue = cmd->queue; in nvmet_tcp_queue_response() local
638 struct nvmet_tcp_queue *queue = cmd->queue; in nvmet_try_send_data() local
750 struct nvmet_tcp_queue *queue = cmd->queue; in nvmet_try_send_ddgst() local
1055 queue->idx, queue->state); in nvmet_tcp_done_recv_pdu()
1067 queue->cmd = nvmet_tcp_get_cmd(queue); in nvmet_tcp_done_recv_pdu()
1071 queue->idx, queue->nr_cmds, queue->send_list_len, in nvmet_tcp_done_recv_pdu()
1114 queue->cmd->req.execute(&queue->cmd->req); in nvmet_tcp_done_recv_pdu()
[all …]
|
| H A D | rdma.c | 663 struct nvmet_rdma_queue *queue = rsp->queue; in nvmet_rdma_release_rsp() local
945 struct nvmet_rdma_queue *queue = rsp->queue; in nvmet_rdma_execute_command() local
1043 cmd->queue = queue; in nvmet_rdma_recv_done()
1054 rsp->queue = queue; in nvmet_rdma_recv_done()
1306 if (queue->port->pi_enable && queue->host_qid) in nvmet_rdma_create_queue_ib()
1314 queue->qp = queue->cm_id->qp; in nvmet_rdma_create_queue_ib()
1324 queue->cmds[i].queue = queue; in nvmet_rdma_create_queue_ib()
1359 nvmet_rdma_free_cmds(queue->dev, queue->cmds, in nvmet_rdma_free_queue()
1433 queue = kzalloc(sizeof(*queue), GFP_KERNEL); in nvmet_rdma_alloc_queue()
1475 queue->comp_vector = !queue->host_qid ? 0 : in nvmet_rdma_alloc_queue()
[all …]
|
| /linux-6.15/drivers/net/wireless/broadcom/b43legacy/ |
| H A D | pio.c | 205 struct b43legacy_pioqueue *queue = packet->queue; in free_txpacket() local
219 struct b43legacy_pioqueue *queue = packet->queue; in pio_tx_packet() local
241 if (queue->tx_devq_used + octets > queue->tx_devq_size) in pio_tx_packet()
308 packet->queue = queue; in setup_txqueues()
323 queue = kzalloc(sizeof(*queue), GFP_KERNEL); in b43legacy_setup_pioqueue()
324 if (!queue) in b43legacy_setup_pioqueue()
381 if (!queue) in b43legacy_destroy_pioqueue()
413 if (!queue) in b43legacy_pio_init()
418 if (!queue) in b43legacy_pio_init()
423 if (!queue) in b43legacy_pio_init()
[all …]
|
| /linux-6.15/drivers/iio/buffer/ |
| H A D | industrialio-buffer-dma.c | 101 struct iio_dma_buffer_queue *queue = block->queue; in iio_buffer_block_release() local
195 block->queue = queue; in iio_dma_buffer_alloc_block()
234 struct iio_dma_buffer_queue *queue = block->queue; in iio_dma_buffer_block_done() local
315 return queue->fileio.enabled || !atomic_read(&queue->num_dmabufs); in iio_dma_buffer_can_use_fileio()
344 queue->fileio.enabled = iio_dma_buffer_can_use_fileio(queue); in iio_dma_buffer_request_update()
458 if (!queue->ops) in iio_dma_buffer_submit_block()
464 ret = queue->ops->submit(queue, block); in iio_dma_buffer_submit_block()
527 if (queue->ops && queue->ops->abort) in iio_dma_buffer_disable()
528 queue->ops->abort(queue); in iio_dma_buffer_disable()
738 struct iio_dma_buffer_queue *queue = block->queue; in iio_dma_can_enqueue_block() local
[all …]
|
| /linux-6.15/drivers/net/xen-netback/ |
| H A D | rx.c | 92 if (queue->rx_queue_len >= queue->rx_queue_max) { in xenvif_rx_queue_tail()
119 xenvif_update_needed_slots(queue, skb_peek(&queue->rx_queue)); in xenvif_rx_dequeue()
122 if (queue->rx_queue_len < queue->rx_queue_max) { in xenvif_rx_dequeue()
125 txq = netdev_get_tx_queue(queue->vif->dev, queue->id); in xenvif_rx_dequeue()
164 gnttab_batch_copy(queue->rx_copy.op, queue->rx_copy.num); in xenvif_rx_copy_flush()
204 op = &queue->rx_copy.op[queue->rx_copy.num]; in xenvif_rx_copy_add()
226 queue->rx_copy.idx[queue->rx_copy.num] = queue->rx.req_cons; in xenvif_rx_copy_add()
332 queue->rx.rsp_prod_pvt = queue->rx.req_cons; in xenvif_rx_complete()
473 req = RING_GET_REQUEST(&queue->rx, queue->rx.req_cons); in xenvif_rx_skb()
474 rsp = RING_GET_RESPONSE(&queue->rx, queue->rx.req_cons); in xenvif_rx_skb()
[all …]
|
| H A D | netback.c | 163 wake_up(&queue->wq); in xenvif_kick_thread()
191 max_credit = queue->remaining_credit + queue->credit_bytes; in tx_add_credit()
201 struct xenvif_queue *queue = from_timer(queue, t, credit_timeout); in xenvif_tx_credit_callback() local
202 tx_add_credit(queue); in xenvif_tx_credit_callback()
346 queue->pages_to_map[mop-queue->tx_map_ops] = queue->mmap_pages[pending_idx]; in xenvif_tx_create_map_op()
933 if (queue->tx.sring->req_prod - queue->tx.req_cons > in xenvif_tx_build_gops()
938 queue->tx.sring->req_prod, queue->tx.req_cons, in xenvif_tx_build_gops()
1298 BUG_ON(queue->dealloc_prod - queue->dealloc_cons >= in xenvif_zerocopy_callback()
1347 queue->pages_to_unmap[gop - queue->tx_unmap_ops] = in xenvif_tx_dealloc_action()
1527 return queue->dealloc_cons != queue->dealloc_prod; in tx_dealloc_work_todo()
[all …]
|
| H A D | interface.c | 314 if (queue->tx_irq != queue->rx_irq) in xenvif_up()
329 if (queue->tx_irq != queue->rx_irq) in xenvif_down()
565 queue->credit_bytes = queue->remaining_credit = ~0UL; in xenvif_init_queue()
689 unbind_from_irqhandler(queue->tx_irq, queue); in xenvif_disconnect_queue()
690 if (queue->tx_irq == queue->rx_irq) in xenvif_disconnect_queue()
696 unbind_from_irqhandler(queue->rx_irq, queue); in xenvif_disconnect_queue()
751 queue->name, queue); in xenvif_connect_data()
754 queue->tx_irq = queue->rx_irq = err; in xenvif_connect_data()
758 snprintf(queue->tx_irq_name, sizeof(queue->tx_irq_name), in xenvif_connect_data()
762 queue->tx_irq_name, queue); in xenvif_connect_data()
[all …]
|
| /linux-6.15/drivers/md/dm-vdo/indexer/ |
| H A D | funnel-requestqueue.c | 191 queue->processor(request); in request_queue_worker()
206 queue->running = true; in uds_make_request_queue()
223 &queue->thread); in uds_make_request_queue()
229 queue->started = true; in uds_make_request_queue()
230 *queue_ptr = queue; in uds_make_request_queue()
246 sub_queue = request->requeued ? queue->retry_queue : queue->main_queue; in uds_request_queue_enqueue()
254 wake_up_worker(queue); in uds_request_queue_enqueue()
259 if (queue == NULL) in uds_request_queue_finish()
271 if (queue->started) { in uds_request_queue_finish()
272 wake_up_worker(queue); in uds_request_queue_finish()
[all …]
|
| /linux-6.15/drivers/misc/genwqe/ |
| H A D | card_ddcb.c | 84 return queue->ddcb_next == queue->ddcb_act; in queue_empty()
89 if (queue->ddcb_next >= queue->ddcb_act) in queue_enqueued_ddcbs()
90 return queue->ddcb_next - queue->ddcb_act; in queue_enqueued_ddcbs()
92 return queue->ddcb_max - (queue->ddcb_act - queue->ddcb_next); in queue_enqueued_ddcbs()
332 struct ddcb_queue *queue = req->queue; in copy_ddcb_results() local
451 queue->ddcb_act = (queue->ddcb_act + 1) % queue->ddcb_max; in genwqe_check_ddcb_queue()
487 queue = req->queue; in __genwqe_wait_ddcb()
586 queue->ddcb_next = (queue->ddcb_next + 1) % queue->ddcb_max; in get_next_ddcb()
625 struct ddcb_queue *queue = req->queue; in __genwqe_purge_ddcb() local
772 queue = req->queue = &cd->queue; in __genwqe_enqueue_ddcb()
[all …]
|
| /linux-6.15/drivers/infiniband/hw/mana/ |
| H A D | shadow_queue.h | 44 if (!queue->buffer) in create_shadow_queue()
60 return (queue->prod_idx - queue->cons_idx) >= queue->length; in shadow_queue_full()
65 return queue->prod_idx == queue->cons_idx; in shadow_queue_empty()
73 return ((u8 *)queue->buffer + index * queue->stride); in shadow_queue_get_element()
79 return shadow_queue_get_element(queue, queue->prod_idx); in shadow_queue_producer_entry()
85 if (queue->cons_idx == queue->next_to_complete_idx) in shadow_queue_get_next_to_consume()
88 return shadow_queue_get_element(queue, queue->cons_idx); in shadow_queue_get_next_to_consume()
94 if (queue->next_to_complete_idx == queue->prod_idx) in shadow_queue_get_next_to_complete()
97 return shadow_queue_get_element(queue, queue->next_to_complete_idx); in shadow_queue_get_next_to_complete()
102 queue->prod_idx++; in shadow_queue_advance_producer()
[all …]
|
| /linux-6.15/drivers/crypto/cavium/zip/ |
| H A D | zip_device.c | 59 return ((zip_dev->iq[queue].sw_head - zip_dev->iq[queue].sw_tail) * in zip_cmd_queue_consumed()
81 u32 queue = 0; in zip_load_instr() local
91 queue = 0; in zip_load_instr()
93 queue = 1; in zip_load_instr()
128 zip_dev->iq[queue].sw_head = zip_dev->iq[queue].sw_tail; in zip_load_instr()
151 zip_dev->iq[queue].sw_head, zip_dev->iq[queue].sw_tail, in zip_load_instr()
152 zip_dev->iq[queue].hw_tail); in zip_load_instr()
166 return queue; in zip_load_instr()
187 zip_dev->iq[queue].hw_tail = zip_dev->iq[queue].sw_head; in zip_update_cmd_bufs()
197 zip_dev->iq[queue].sw_head, zip_dev->iq[queue].sw_tail, in zip_update_cmd_bufs()
[all …]
|
| /linux-6.15/drivers/net/ |
| H A D | xen-netfront.c | 482 struct netfront_queue *queue = info->queue; in xennet_tx_setup_grant() local
619 .queue = queue, in xennet_xdp_xmit_one()
784 info.queue = queue; in xennet_start_xmit()
1831 if (queue->tx_irq && (queue->tx_irq == queue->rx_irq)) in xennet_disconnect_backend()
1833 if (queue->tx_irq && (queue->tx_irq != queue->rx_irq)) { in xennet_disconnect_backend()
1838 queue->tx_irq = queue->rx_irq = 0; in xennet_disconnect_backend()
1923 queue->rx_evtchn = queue->tx_evtchn; in setup_netfront_single()
1924 queue->rx_irq = queue->tx_irq = err; in setup_netfront_single()
1950 queue->tx_irq_name, queue); in setup_netfront_split()
1959 queue->rx_irq_name, queue); in setup_netfront_split()
[all …]
|
| /linux-6.15/drivers/nvme/host/ |
| H A D | tcp.c | 216 return queue - queue->ctrl->queues; in nvme_tcp_queue_id()
408 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_queue_request() local
560 req->queue = queue; in nvme_tcp_init_request()
698 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_setup_h2c_data_pdu() local
982 if (queue->recv_ddgst != queue->exp_ddgst) { in nvme_tcp_recv_ddgst()
1052 if (likely(queue && queue->rd_enabled) && in nvme_tcp_data_ready()
1119 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_try_send_data() local
1182 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_try_send_cmd_pdu() local
1223 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_try_send_data_pdu() local
1257 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_try_send_ddgst() local
[all …]
|
| /linux-6.15/fs/fuse/ |
| H A D | dev_uring.c | 81 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_req_end() local
315 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_entry_teardown() local
493 queue = ent->queue; in fuse_uring_cancel()
649 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_copy_to_ring() local
705 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_send_next_to_ring() local
739 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_add_to_pq() local
754 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_add_req_to_ring_ent() local
776 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_ent_assign_req() local
844 struct fuse_ring_queue *queue = ent->queue; in fuse_ring_ent_set_commit() local
964 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_do_register() local
[all …]
|
| /linux-6.15/drivers/net/wireguard/ |
| H A D | queueing.c | 30 memset(queue, 0, sizeof(*queue)); in wg_packet_queue_init()
31 queue->last_cpu = -1; in wg_packet_queue_init()
35 queue->worker = wg_packet_percpu_multicore_worker_alloc(function, queue); in wg_packet_queue_init()
36 if (!queue->worker) { in wg_packet_queue_init()
51 #define STUB(queue) ((struct sk_buff *)&queue->empty) argument
56 queue->head = queue->tail = STUB(queue); in wg_prev_queue_init()
57 queue->peeked = NULL; in wg_prev_queue_init()
87 queue->tail = next; in wg_prev_queue_dequeue()
92 queue->tail = next; in wg_prev_queue_dequeue()
98 __wg_prev_queue_enqueue(queue, STUB(queue)); in wg_prev_queue_dequeue()
[all …]
|
| /linux-6.15/drivers/net/wireless/ralink/rt2x00/ |
| H A D | rt2x00queue.c | 25 struct data_queue *queue = entry->queue; in rt2x00queue_alloc_rxskb() local
37 frame_size = queue->data_size + queue->desc_size + queue->winfo_size; in rt2x00queue_alloc_rxskb()
529 struct data_queue *queue = entry->queue; in rt2x00queue_write_tx_descriptor() local
554 queue->rt2x00dev->ops->lib->kick_queue(queue); in rt2x00queue_kick_tx_queue()
853 entry = &queue->entries[queue->index[index]]; in rt2x00queue_get_entry()
863 struct data_queue *queue = entry->queue; in rt2x00queue_index_inc() local
875 if (queue->index[index] >= queue->limit) in rt2x00queue_index_inc()
941 queue->rt2x00dev->ops->lib->kick_queue(queue); in rt2x00queue_unpause_queue()
961 queue->rt2x00dev->ops->lib->start_queue(queue); in rt2x00queue_start_queue()
980 queue->rt2x00dev->ops->lib->stop_queue(queue); in rt2x00queue_stop_queue()
[all …]
|
| /linux-6.15/drivers/gpu/drm/imagination/ |
| H A D | pvr_queue.c | 278 fence->queue = queue; in pvr_queue_fence_init()
1070 queue->ctx->fw_obj, queue->ctx_offset); in pvr_queue_cleanup_fw_context()
1096 if (!queue) in pvr_queue_job_init()
1268 queue = kzalloc(sizeof(*queue), GFP_KERNEL); in pvr_queue_create()
1269 if (!queue) in pvr_queue_create()
1274 queue->ctx = ctx; in pvr_queue_create()
1288 reg_state_init, queue, &queue->reg_state_obj); in pvr_queue_create()
1324 return queue; in pvr_queue_create()
1340 kfree(queue); in pvr_queue_create()
1394 if (!queue) in pvr_queue_destroy()
[all …]
|
| /linux-6.15/drivers/scsi/arm/ |
| H A D | queue.c | 65 INIT_LIST_HEAD(&queue->head); in queue_initialise()
66 INIT_LIST_HEAD(&queue->free); in queue_initialise()
83 return queue->alloc != NULL; in queue_initialise()
95 kfree(queue->alloc); in queue_free()
115 if (list_empty(&queue->free)) in __queue_add()
118 l = queue->free.next; in __queue_add()
128 list_add(l, &queue->head); in __queue_add()
150 list_add(ent, &queue->free); in __queue_remove()
195 SCpnt = __queue_remove(queue, queue->head.next); in queue_remove()
247 __queue_remove(queue, l); in queue_remove_all_target()
[all …]
|
| /linux-6.15/drivers/net/ethernet/ibm/ehea/ |
| H A D | ehea_qmr.h | 208 return hw_qeit_calc(queue, queue->current_q_offset); in hw_qeit_get()
213 queue->current_q_offset += queue->qe_size; in hw_qeit_inc()
214 if (queue->current_q_offset >= queue->queue_length) { in hw_qeit_inc()
217 queue->toggle_state = (~queue->toggle_state) & 1; in hw_qeit_inc()
224 hw_qeit_inc(queue); in hw_qeit_get_inc()
236 hw_qeit_inc(queue); in hw_qeit_get_inc_valid()
237 pref = hw_qeit_calc(queue, queue->current_q_offset); in hw_qeit_get_inc_valid()
251 pref = hw_qeit_calc(queue, queue->current_q_offset); in hw_qeit_get_valid()
269 u64 last_entry_in_q = queue->queue_length - queue->qe_size; in hw_qeit_eq_get_inc()
273 queue->current_q_offset += queue->qe_size; in hw_qeit_eq_get_inc()
[all …]
|
| /linux-6.15/drivers/crypto/hisilicon/sec/ |
| H A D | sec_drv.c | 703 while (test_bit(queue->expected, queue->unprocessed)) { in sec_isr_handle()
704 clear_bit(queue->expected, queue->unprocessed); in sec_isr_handle()
708 queue->shadow[queue->expected]); in sec_isr_handle()
709 queue->shadow[queue->expected] = NULL; in sec_isr_handle()
710 queue->expected = (queue->expected + 1) % in sec_isr_handle()
735 IRQF_TRIGGER_RISING, queue->name, queue); in sec_queue_irq_init()
747 free_irq(queue->task_irq, queue); in sec_queue_irq_uninit()
907 sec_queue_cmdbase_addr(queue, queue->ring_cmd.paddr); in sec_queue_hw_init()
909 sec_queue_outorder_addr(queue, queue->ring_cq.paddr); in sec_queue_hw_init()
911 sec_queue_errbase_addr(queue, queue->ring_db.paddr); in sec_queue_hw_init()
[all …]
|