| /linux/drivers/media/usb/uvc/ |
| A D | uvc_queue.c | 219 queue->queue.type = type; in uvc_queue_init()
221 queue->queue.drv_priv = queue; in uvc_queue_init()
226 queue->queue.lock = &queue->mutex; in uvc_queue_init()
233 queue->queue.io_modes |= VB2_DMABUF; in uvc_queue_init()
234 queue->queue.ops = &uvc_queue_qops; in uvc_queue_init()
238 ret = vb2_queue_init(&queue->queue); in uvc_queue_init()
253 vb2_queue_release(&queue->queue); in uvc_queue_release()
267 ret = vb2_reqbufs(&queue->queue, rb); in uvc_request_buffers()
278 ret = vb2_querybuf(&queue->queue, buf); in uvc_query_buffer()
314 ret = vb2_expbuf(&queue->queue, exp); in uvc_export_buffer()
[all …]
|
| /linux/drivers/net/wireless/st/cw1200/ |
| A D | queue.c | 96 list_for_each_entry_safe(item, tmp, &queue->queue, head) { in __cw1200_queue_gc()
116 if (queue->num_queued <= (queue->capacity >> 1)) { in __cw1200_queue_gc()
169 memset(queue, 0, sizeof(*queue)); in cw1200_queue_init()
174 INIT_LIST_HEAD(&queue->queue); in cw1200_queue_init()
208 list_splice_tail_init(&queue->queue, &queue->pending); in cw1200_queue_clear()
265 ret = queue->num_queued - queue->num_pending; in cw1200_queue_get_num_queued()
293 list_move_tail(&item->head, &queue->queue); in cw1200_queue_put()
340 list_for_each_entry(item, &queue->queue, head) { in cw1200_queue_get()
405 list_move(&item->head, &queue->queue); in cw1200_queue_requeue()
431 list_move(&item->head, &queue->queue); in cw1200_queue_requeue_all()
[all …]
|
| /linux/drivers/usb/gadget/function/ |
| A D | uvc_queue.c | 132 queue->queue.type = type; in uvcg_queue_init()
134 queue->queue.drv_priv = queue; in uvcg_queue_init()
136 queue->queue.ops = &uvc_queue_qops; in uvcg_queue_init()
137 queue->queue.lock = lock; in uvcg_queue_init()
147 queue->queue.dev = dev; in uvcg_queue_init()
149 ret = vb2_queue_init(&queue->queue); in uvcg_queue_init()
165 vb2_queue_release(&queue->queue); in uvcg_free_buffers()
176 ret = vb2_reqbufs(&queue->queue, rb); in uvcg_alloc_buffers()
226 return vb2_mmap(&queue->queue, vma); in uvcg_queue_mmap()
301 ret = vb2_streamon(&queue->queue, queue->queue.type); in uvcg_queue_enable()
[all …]
|
| /linux/drivers/net/wireless/broadcom/b43legacy/ |
| 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/drivers/net/xen-netback/ |
| A D | rx.c | 91 if (queue->rx_queue_len >= queue->rx_queue_max) { in xenvif_rx_queue_tail()
117 xenvif_update_needed_slots(queue, skb_peek(&queue->rx_queue)); in xenvif_rx_dequeue()
120 if (queue->rx_queue_len < queue->rx_queue_max) { in xenvif_rx_dequeue()
123 txq = netdev_get_tx_queue(queue->vif->dev, queue->id); in xenvif_rx_dequeue()
162 gnttab_batch_copy(queue->rx_copy.op, queue->rx_copy.num); in xenvif_rx_copy_flush()
202 op = &queue->rx_copy.op[queue->rx_copy.num]; in xenvif_rx_copy_add()
224 queue->rx_copy.idx[queue->rx_copy.num] = queue->rx.req_cons; in xenvif_rx_copy_add()
330 queue->rx.rsp_prod_pvt = queue->rx.req_cons; in xenvif_rx_complete()
471 req = RING_GET_REQUEST(&queue->rx, queue->rx.req_cons); in xenvif_rx_skb()
472 rsp = RING_GET_RESPONSE(&queue->rx, queue->rx.req_cons); in xenvif_rx_skb()
[all …]
|
| A D | netback.c | 161 wake_up(&queue->wq); in xenvif_kick_thread()
189 max_credit = queue->remaining_credit + queue->credit_bytes; in tx_add_credit()
199 struct xenvif_queue *queue = from_timer(queue, t, credit_timeout); in xenvif_tx_credit_callback() local
344 queue->pages_to_map[mop-queue->tx_map_ops] = queue->mmap_pages[pending_idx]; in xenvif_tx_create_map_op()
820 if (queue->tx.sring->req_prod - queue->tx.req_cons > in xenvif_tx_build_gops()
825 queue->tx.sring->req_prod, queue->tx.req_cons, in xenvif_tx_build_gops()
993 queue->tx_copy_ops[*copy_ops].source.domid = queue->vif->domid; in xenvif_tx_build_gops()
1031 if (((gop-queue->tx_map_ops) >= ARRAY_SIZE(queue->tx_map_ops)) || in xenvif_tx_build_gops()
1245 BUG_ON(queue->dealloc_prod - queue->dealloc_cons >= in xenvif_zerocopy_callback()
1290 queue->pages_to_unmap[gop - queue->tx_unmap_ops] = in xenvif_tx_dealloc_action()
[all …]
|
| A D | interface.c | 326 if (queue->tx_irq != queue->rx_irq) in xenvif_up()
341 if (queue->tx_irq != queue->rx_irq) in xenvif_down()
579 queue->credit_bytes = queue->remaining_credit = ~0UL; in xenvif_init_queue()
704 unbind_from_irqhandler(queue->tx_irq, queue); in xenvif_disconnect_queue()
705 if (queue->tx_irq == queue->rx_irq) in xenvif_disconnect_queue()
711 unbind_from_irqhandler(queue->rx_irq, queue); in xenvif_disconnect_queue()
767 queue->name, queue); in xenvif_connect_data()
770 queue->tx_irq = queue->rx_irq = err; in xenvif_connect_data()
774 snprintf(queue->tx_irq_name, sizeof(queue->tx_irq_name), in xenvif_connect_data()
778 queue->tx_irq_name, queue); in xenvif_connect_data()
[all …]
|
| /linux/drivers/iio/buffer/ |
| A D | industrialio-buffer-dma.c | 183 block->queue = queue; in iio_dma_buffer_alloc_block()
194 struct iio_dma_buffer_queue *queue = block->queue; in _iio_dma_buffer_block_done() local
215 struct iio_dma_buffer_queue *queue = block->queue; in iio_dma_buffer_block_done() local
369 if (!queue->ops) in iio_dma_buffer_submit_block()
374 ret = queue->ops->submit(queue, block); in iio_dma_buffer_submit_block()
434 if (queue->ops && queue->ops->abort) in iio_dma_buffer_disable()
435 queue->ops->abort(queue); in iio_dma_buffer_disable()
615 queue->buffer.watermark = queue->buffer.length / 2; in iio_dma_buffer_init()
616 queue->dev = dev; in iio_dma_buffer_init()
617 queue->ops = ops; in iio_dma_buffer_init()
[all …]
|
| /linux/drivers/nvme/target/ |
| A D | tcp.c | 436 struct nvmet_tcp_queue *queue = cmd->queue; in nvmet_setup_c2h_data_pdu() local
469 struct nvmet_tcp_queue *queue = cmd->queue; in nvmet_setup_r2t_pdu() local
494 struct nvmet_tcp_queue *queue = cmd->queue; in nvmet_setup_response_pdu() local
553 struct nvmet_tcp_queue *queue = cmd->queue; in nvmet_tcp_queue_response() local
609 struct nvmet_tcp_queue *queue = cmd->queue; in nvmet_try_send_data() local
713 struct nvmet_tcp_queue *queue = cmd->queue; in nvmet_try_send_ddgst() local
1003 queue->cmd = nvmet_tcp_get_cmd(queue); in nvmet_tcp_done_recv_pdu()
1007 queue->idx, queue->nr_cmds, queue->send_list_len, in nvmet_tcp_done_recv_pdu()
1049 queue->cmd->req.execute(&queue->cmd->req); in nvmet_tcp_done_recv_pdu()
1138 struct nvmet_tcp_queue *queue = cmd->queue; in nvmet_tcp_prep_recv_ddgst() local
[all …]
|
| A D | rdma.c | 670 struct nvmet_rdma_queue *queue = rsp->queue; in nvmet_rdma_release_rsp() local
954 struct nvmet_rdma_queue *queue = rsp->queue; in nvmet_rdma_execute_command() local
1031 cmd->queue = queue; in nvmet_rdma_recv_done()
1042 rsp->queue = queue; in nvmet_rdma_recv_done()
1301 if (queue->port->pi_enable && queue->host_qid) in nvmet_rdma_create_queue_ib()
1309 queue->qp = queue->cm_id->qp; in nvmet_rdma_create_queue_ib()
1319 queue->cmds[i].queue = queue; in nvmet_rdma_create_queue_ib()
1354 nvmet_rdma_free_cmds(queue->dev, queue->cmds, in nvmet_rdma_free_queue()
1428 queue = kzalloc(sizeof(*queue), GFP_KERNEL); in nvmet_rdma_alloc_queue()
1472 queue->comp_vector = !queue->host_qid ? 0 : in nvmet_rdma_alloc_queue()
[all …]
|
| /linux/drivers/misc/genwqe/ |
| 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/drivers/net/ |
| A D | xen-netfront.c | 477 struct netfront_queue *queue = info->queue; in xennet_tx_setup_grant() local
614 .queue = queue, in xennet_xdp_xmit_one()
748 info.queue = queue; in xennet_start_xmit()
1752 if (queue->tx_irq && (queue->tx_irq == queue->rx_irq)) in xennet_disconnect_backend()
1754 if (queue->tx_irq && (queue->tx_irq != queue->rx_irq)) { in xennet_disconnect_backend()
1759 queue->tx_irq = queue->rx_irq = 0; in xennet_disconnect_backend()
1838 queue->rx_evtchn = queue->tx_evtchn; in setup_netfront_single()
1839 queue->rx_irq = queue->tx_irq = err; in setup_netfront_single()
1865 queue->tx_irq_name, queue); in setup_netfront_split()
1874 queue->rx_irq_name, queue); in setup_netfront_split()
[all …]
|
| /linux/drivers/nvme/host/ |
| A D | tcp.c | 149 return queue - queue->ctrl->queues; in nvme_tcp_queue_id()
286 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_queue_request() local
440 req->queue = queue; in nvme_tcp_init_request()
579 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_setup_h2c_data_pdu() local
797 if (queue->recv_ddgst != queue->exp_ddgst) { in nvme_tcp_recv_ddgst()
862 if (likely(queue && queue->rd_enabled) && in nvme_tcp_data_ready()
921 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_try_send_data() local
977 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_try_send_cmd_pdu() local
1016 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_try_send_data_pdu() local
1045 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_try_send_ddgst() local
[all …]
|
| A D | rdma.c | 162 return queue - queue->ctrl->queues; in nvme_rdma_queue_idx()
285 queue->qp = queue->cm_id->qp; in nvme_rdma_create_qp()
317 req->queue = queue; in nvme_rdma_init_request()
422 ib_cq_pool_put(queue->ib_cq, queue->cq_size); in nvme_rdma_free_cq()
481 queue->ib_cq = ib_alloc_cq(ibdev, queue, queue->cq_size, in nvme_rdma_create_cq()
513 queue->cq_size = cq_factor * queue->queue_size + 1; in nvme_rdma_create_queue_ib()
543 queue->queue_size, nvme_rdma_queue_idx(queue)); in nvme_rdma_create_queue_ib()
554 queue->queue_size, nvme_rdma_queue_idx(queue)); in nvme_rdma_create_queue_ib()
1992 struct nvme_rdma_queue *queue = req->queue; in nvme_rdma_complete_timed_out() local
2005 struct nvme_rdma_queue *queue = req->queue; in nvme_rdma_timeout() local
[all …]
|
| /linux/drivers/crypto/cavium/zip/ |
| 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/drivers/net/wireless/ralink/rt2x00/ |
| 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()
532 struct data_queue *queue = entry->queue; in rt2x00queue_write_tx_descriptor() local
557 queue->rt2x00dev->ops->lib->kick_queue(queue); in rt2x00queue_kick_tx_queue()
856 entry = &queue->entries[queue->index[index]]; in rt2x00queue_get_entry()
866 struct data_queue *queue = entry->queue; in rt2x00queue_index_inc() local
878 if (queue->index[index] >= queue->limit) in rt2x00queue_index_inc()
944 queue->rt2x00dev->ops->lib->kick_queue(queue); in rt2x00queue_unpause_queue()
964 queue->rt2x00dev->ops->lib->start_queue(queue); in rt2x00queue_start_queue()
983 queue->rt2x00dev->ops->lib->stop_queue(queue); in rt2x00queue_stop_queue()
[all …]
|
| /linux/drivers/net/wireguard/ |
| A D | queueing.c | 29 memset(queue, 0, sizeof(*queue)); in wg_packet_queue_init()
33 queue->worker = wg_packet_percpu_multicore_worker_alloc(function, queue); in wg_packet_queue_init()
34 if (!queue->worker) { in wg_packet_queue_init()
49 #define STUB(queue) ((struct sk_buff *)&queue->empty) argument
53 NEXT(STUB(queue)) = NULL; in wg_prev_queue_init()
54 queue->head = queue->tail = STUB(queue); in wg_prev_queue_init()
55 queue->peeked = NULL; in wg_prev_queue_init()
85 queue->tail = next; in wg_prev_queue_dequeue()
90 queue->tail = next; in wg_prev_queue_dequeue()
96 __wg_prev_queue_enqueue(queue, STUB(queue)); in wg_prev_queue_dequeue()
[all …]
|
| /linux/drivers/scsi/arm/ |
| A D | queue.c | 61 INIT_LIST_HEAD(&queue->head); in queue_initialise()
62 INIT_LIST_HEAD(&queue->free); in queue_initialise()
79 return queue->alloc != NULL; in queue_initialise()
91 kfree(queue->alloc); in queue_free()
111 if (list_empty(&queue->free)) in __queue_add()
114 l = queue->free.next; in __queue_add()
124 list_add(l, &queue->head); in __queue_add()
146 list_add(ent, &queue->free); in __queue_remove()
191 SCpnt = __queue_remove(queue, queue->head.next); in queue_remove()
243 __queue_remove(queue, l); in queue_remove_all_target()
[all …]
|
| /linux/drivers/crypto/hisilicon/sec/ |
| 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 …]
|
| /linux/drivers/net/ethernet/ibm/ehea/ |
| 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/net/sunrpc/ |
| A D | sched.c | 125 rpc_set_waitqueue_priority(queue, queue->maxpriority); in rpc_reset_waitqueue_priority()
207 queue->qlen++; in __rpc_add_wait_queue()
232 queue->qlen--; in __rpc_remove_wait_queue()
244 queue->qlen = 0; in __rpc_init_priority_wait_queue()
554 spin_lock(&queue->lock); in rpc_wake_up_queued_task()
614 q = &queue->tasks[queue->priority]; in __rpc_find_next_queued_priority()
616 queue->nr--; in __rpc_find_next_queued_priority()
626 q = &queue->tasks[queue->maxpriority]; in __rpc_find_next_queued_priority()
633 } while (q != &queue->tasks[queue->priority]); in __rpc_find_next_queued_priority()
639 rpc_set_waitqueue_priority(queue, (unsigned int)(q - &queue->tasks[0])); in __rpc_find_next_queued_priority()
[all …]
|
| /linux/drivers/soc/ixp4xx/ |
| A D | ixp4xx-qmgr.c | 35 qmgr_queue_descs[queue], queue, val); in qmgr_put_entry()
48 qmgr_queue_descs[queue], queue, val); in qmgr_get_entry()
86 if (queue >= HALF_QUEUES) in qmgr_stat_below_low_watermark()
100 if (queue >= HALF_QUEUES) in qmgr_stat_full()
136 irq_pdevs[queue] = pdev; in qmgr_set_irq()
208 int half = queue / 32; in qmgr_enable_irq()
220 int half = queue / 32; in qmgr_disable_irq()
252 BUG_ON(queue >= QUEUES); in qmgr_request_queue()
318 qmgr_queue_descs[queue], queue, addr); in qmgr_request_queue()
355 qmgr_queue_descs[queue], queue); in qmgr_release_queue()
[all …]
|
| /linux/drivers/net/wireless/ath/ath5k/ |
| A D | qcu.c | 161 qi = &ah->ah_txq[queue]; in ath5k_hw_set_tx_queueprops()
206 unsigned int queue; in ath5k_hw_setup_tx_queue() local
231 queue = AR5K_TX_QUEUE_ID_UAPSD; in ath5k_hw_setup_tx_queue()
237 queue = AR5K_TX_QUEUE_ID_CAB; in ath5k_hw_setup_tx_queue()
264 return queue; in ath5k_hw_setup_tx_queue()
282 unsigned int queue) in ath5k_hw_set_tx_retry_limits() argument
288 if (queue > 0) in ath5k_hw_set_tx_retry_limits()
371 AR5K_QUEUE_CBRCFG(queue)); in ath5k_hw_reset_tx_queue()
402 AR5K_QUEUE_DFS_MISC(queue)); in ath5k_hw_reset_tx_queue()
407 AR5K_QUEUE_DFS_MISC(queue)); in ath5k_hw_reset_tx_queue()
[all …]
|
| /linux/arch/mips/cavium-octeon/executive/ |
| A D | cvmx-pko.c | 70 int queue; in __cvmx_pko_iport_config() local
76 for (queue = 0; queue < num_queues; queue++) { in __cvmx_pko_iport_config()
101 num_queues, queue); in __cvmx_pko_iport_config()
284 int queue; in cvmx_pko_shutdown() local
288 for (queue = 0; queue < CVMX_PKO_MAX_OUTPUT_QUEUES; queue++) { in cvmx_pko_shutdown()
293 config.s.queue = queue & 0x7f; in cvmx_pko_shutdown()
331 uint64_t queue; in cvmx_pko_config_port() local
360 for (queue = 0; queue < num_queues; queue++) { in cvmx_pko_config_port()
370 && queue) in cvmx_pko_config_port()
422 for (queue = 0; queue < num_queues; queue++) { in cvmx_pko_config_port()
[all …]
|
| /linux/include/drm/ |
| A D | spsc_queue.h | 50 queue->head = NULL; in spsc_queue_init()
51 atomic_long_set(&queue->tail, (long)&queue->head); in spsc_queue_init()
52 atomic_set(&queue->job_count, 0); in spsc_queue_init()
57 return queue->head; in spsc_queue_peek()
62 return atomic_read(&queue->job_count); in spsc_queue_count()
75 atomic_inc(&queue->job_count); in spsc_queue_push()
85 return tail == &queue->head; in spsc_queue_push()
96 node = READ_ONCE(queue->head); in spsc_queue_pop()
102 WRITE_ONCE(queue->head, next); in spsc_queue_pop()
107 if (atomic_long_cmpxchg(&queue->tail, in spsc_queue_pop()
[all …]
|