Searched refs:queue (Results 201 - 225 of 742) sorted by relevance

1234567891011>>

/drivers/ide/
H A Dide-ioctls.c128 rq = blk_get_request(drive->queue, READ, __GFP_WAIT);
130 err = blk_execute_rq(drive->queue, NULL, rq, 0);
224 rq = blk_get_request(drive->queue, READ, __GFP_WAIT);
228 if (blk_execute_rq(drive->queue, NULL, rq, 1))
/drivers/media/dvb-core/
H A Ddvb_ringbuffer.h40 wait_queue_head_t queue; member in struct:dvb_ringbuffer
76 /* initialize ring buffer, lock and queue */
/drivers/media/platform/
H A Dsh_vou.c73 struct list_head queue; member in struct:sh_vou_device
323 list_add_tail(&vb->queue, &vou_dev->queue);
335 } else if (vou_dev->active->queue.next == &vb->queue) {
347 /* Two buffers on the queue - activate the hardware */
375 list_del(&vb->queue);
1067 if (!vou_dev->active || list_empty(&vou_dev->queue)) {
1089 list_del(&vb->queue);
1096 if (list_empty(&vou_dev->queue)) {
[all...]
/drivers/net/wireless/rt2x00/
H A Drt61pci.c1134 static void rt61pci_start_queue(struct data_queue *queue) argument
1136 struct rt2x00_dev *rt2x00dev = queue->rt2x00dev;
1139 switch (queue->qid) {
1157 static void rt61pci_kick_queue(struct data_queue *queue) argument
1159 struct rt2x00_dev *rt2x00dev = queue->rt2x00dev;
1162 switch (queue->qid) {
1188 static void rt61pci_stop_queue(struct data_queue *queue) argument
1190 struct rt2x00_dev *rt2x00dev = queue->rt2x00dev;
1193 switch (queue->qid) {
1385 if (entry->queue
2155 struct data_queue *queue; local
2900 struct data_queue *queue; local
3026 rt61pci_queue_init(struct data_queue *queue) argument
[all...]
/drivers/staging/media/davinci_vpfe/
H A Dvpfe_video.h31 * @queue: Resume streaming when a buffer is queued. Called on VIDIOC_QBUF
35 int (*queue)(struct vpfe_device *vpfe_dev, unsigned long addr); member in struct:vpfe_video_operations
129 /* IRQ lock for DMA queue */
/drivers/block/
H A Dxsysace.c210 struct request_queue *queue; member in struct:ace_device
505 while ((req = blk_fetch_request(ace->queue)) != NULL)
520 if (ace->id_req_count || ace_get_next_request(ace->queue)) {
649 req = ace_get_next_request(ace->queue);
990 * Initialize the request queue
992 ace->queue = blk_init_queue(ace_request, &ace->lock);
993 if (ace->queue == NULL)
995 blk_queue_logical_block_size(ace->queue, 512);
1007 ace->gd->queue = ace->queue;
[all...]
/drivers/infiniband/hw/ehca/
H A Dehca_uverbs.c135 static int ehca_mmap_queue(struct vm_area_struct *vma, struct ipz_queue *queue, argument
144 for (ofs = 0; ofs < queue->queue_length; ofs += PAGE_SIZE) {
145 u64 virt_addr = (u64)ipz_qeit_calc(queue, ofs);
179 ehca_dbg(cq->ib_cq.device, "cq_num=%x queue", cq->cq_number);
304 ehca_gen_err("bad queue type %x", q_type);
/drivers/staging/rtl8712/
H A Drtl871x_mlme.c74 &(pmlmepriv->free_bss_pool.queue));
92 if (list_empty(&free_queue->queue))
95 plist = free_queue->queue.next;
121 list_add_tail(&pnetwork->list, &free_queue->queue);
136 list_add_tail(&pnetwork->list, &free_queue->queue);
156 phead = &scanned_queue->queue;
177 phead = &scanned_queue->queue;
318 phead = &scanned_queue->queue;
397 struct __queue *queue = &pmlmepriv->scanned_queue; local
401 phead = &queue
458 struct __queue *queue = &pmlmepriv->scanned_queue; local
1135 struct __queue *queue = NULL; local
[all...]
/drivers/usb/gadget/udc/
H A Dmv_udc_core.c223 /* Removed the req from fsl_ep->queue */
224 list_del_init(&req->queue);
273 if (!(list_empty(&ep->queue))) {
275 lastreq = list_entry(ep->queue.prev, struct mv_req, queue);
512 /* Get the endpoint queue head address */
579 /* Get the endpoint queue head address */
618 INIT_LIST_HEAD(&req->queue);
705 || !list_empty(&req->queue)) {
731 /* build dtds and push them to device queue */
[all...]
H A Ddummy_hcd.c84 struct list_head queue; member in struct:dummy_ep
97 struct list_head queue; /* ep's requests */ member in struct:dummy_request
253 while (!list_empty(&ep->queue)) {
256 req = list_entry(ep->queue.next, struct dummy_request, queue);
257 list_del_init(&req->queue);
593 INIT_LIST_HEAD(&req->queue);
607 WARN_ON(!list_empty(&req->queue));
625 if (!_req || !list_empty(&req->queue) || !_req->complete)
638 dev_dbg(udc_dev(dum), "ep %p queue re
[all...]
/drivers/net/ethernet/ti/
H A Dcpmac.c424 netdev_warn(priv->dev, "rx: polling, but no queue\n");
470 * of quota limits), check to see if the tail of the queue has EOQ set.
550 int queue, len; local
561 queue = skb_get_queue_mapping(skb);
562 netif_stop_subqueue(dev, queue);
564 desc = &priv->desc_ring[queue];
587 cpmac_write(priv->regs, CPMAC_TX_PTR(queue), (u32)desc->mapping);
592 static void cpmac_end_xmit(struct net_device *dev, int queue) argument
597 desc = &priv->desc_ring[queue];
598 cpmac_write(priv->regs, CPMAC_TX_ACK(queue), (u3
783 int queue; local
[all...]
/drivers/memstick/core/
H A Dmspro_block.c143 struct request_queue *queue; member in struct:mspro_block_data
732 msb->block_req = blk_fetch_request(msb->queue);
807 blk_stop_queue(msb->queue);
825 blk_start_queue(msb->queue);
1225 msb->queue = blk_init_queue(mspro_block_submit_req, &msb->q_lock);
1226 if (!msb->queue) {
1231 msb->queue->queuedata = card;
1232 blk_queue_prep_rq(msb->queue, mspro_block_prepare_req);
1234 blk_queue_bounce_limit(msb->queue, limit);
1235 blk_queue_max_hw_sectors(msb->queue, MSPRO_BLOCK_MAX_PAGE
[all...]
/drivers/soc/ti/
H A Dknav_qmss_queue.c72 * knav_queue_notify: qmss queue notfier call
74 * @inst: qmss queue instance like accumulator
107 unsigned queue = inst->id - range->queue_base; local
112 irq = range->irqs[queue].irq;
113 cpu_map = range->irqs[queue].cpu_map;
134 unsigned queue = inst->id - inst->range->queue_base; local
138 irq = range->irqs[queue].irq;
371 unsigned queue; local
374 queue = inst->id - range->queue_base;
376 enable_irq(range->irqs[queue]
[all...]
/drivers/atm/
H A Dnicstar.c232 while ((hb = skb_dequeue(&card->hbpool.queue)) != NULL) {
240 while ((iovb = skb_dequeue(&card->iovpool.queue)) != NULL) {
245 while ((lb = skb_dequeue(&card->lbpool.queue)) != NULL)
247 while ((sb = skb_dequeue(&card->sbpool.queue)) != NULL)
652 skb_queue_head_init(&card->hbpool.queue);
666 skb_queue_tail(&card->hbpool.queue, hb);
671 skb_queue_head_init(&card->lbpool.queue);
685 skb_queue_tail(&card->lbpool.queue, lb);
707 skb_queue_head_init(&card->sbpool.queue);
721 skb_queue_tail(&card->sbpool.queue, s
[all...]
/drivers/md/
H A Ddm-cache-policy-mq.c122 * This queue is divided up into different levels. Allowing us to push
124 * sorted queue.
128 struct queue { struct
132 static void queue_init(struct queue *q)
141 * Checks to see if the queue is empty.
144 static bool queue_empty(struct queue *q)
158 static void queue_push(struct queue *q, unsigned level, struct list_head *elt)
170 * the queue.
172 static void queue_shift_down(struct queue *q)
184 static struct list_head *queue_pop(struct queue *
[all...]
/drivers/net/wireless/b43/
H A Dpio.c165 p->queue = q;
222 #define destroy_queue_tx(pio, queue) do { \
223 b43_destroy_pioqueue_tx((pio)->queue, __stringify(queue)); \
224 (pio)->queue = NULL; \
227 #define destroy_queue_rx(pio, queue) do { \
228 b43_destroy_pioqueue_rx((pio)->queue, __stringify(queue)); \
229 (pio)->queue = NULL; \
365 struct b43_pio_txqueue *q = pack->queue;
[all...]
/drivers/net/wireless/ath/ath5k/
H A Dmac80211-ops.c586 ath5k_conf_tx(struct ieee80211_hw *hw, struct ieee80211_vif *vif, u16 queue, argument
593 if (queue >= ah->ah_capabilities.cap_queues.q_tx_num)
598 ath5k_hw_get_tx_queueprops(ah, queue, &qi);
606 "Configure tx [queue %d], "
608 queue, params->aifs, params->cw_min,
611 if (ath5k_hw_set_tx_queueprops(ah, queue, &qi)) {
613 "Unable to update hardware queue %u!\n", queue);
616 ath5k_hw_reset_tx_queue(ah, queue);
H A Dath5k.h138 /* Access QCU registers per queue */
534 * @AR5K_TX_QUEUE_DATA: A normal data queue
535 * @AR5K_TX_QUEUE_BEACON: The beacon queue
536 * @AR5K_TX_QUEUE_CAB: The after-beacon queue
537 * @AR5K_TX_QUEUE_UAPSD: Unscheduled Automatic Power Save Delivery queue
571 * @AR5K_TX_QUEUE_ID_NOQCU_DATA: Data queue on AR5210 (no QCU available)
572 * @AR5K_TX_QUEUE_ID_NOQCU_BEACON: Beacon queue on AR5210 (no QCU available)
573 * @AR5K_TX_QUEUE_ID_DATA_MIN: Data queue min index
574 * @AR5K_TX_QUEUE_ID_DATA_MAX: Data queue max index
575 * @AR5K_TX_QUEUE_ID_CAB: Content after beacon queue
[all...]
/drivers/virtio/
H A Dvirtio_pci.c77 /* the number of entries in the queue */
80 /* the virtual address of the ring queue */
81 void *queue; member in struct:virtio_pci_vq_info
196 /* the notify function used when creating a virt queue */
201 /* we write the queue's selector into the notification register to
396 /* Select the queue we're interested in */
399 /* Check if queue is either not available or already active. */
405 * queue */
414 info->queue = alloc_pages_exact(size, GFP_KERNEL|__GFP_ZERO);
415 if (info->queue
[all...]
/drivers/media/pci/cx25821/
H A Dcx25821-video.c92 vb.queue);
102 list_del(&buf->vb.queue);
151 vb.queue);
156 buf = list_entry(item, struct cx25821_buffer, vb.queue);
170 vb.queue);
173 list_move_tail(&buf->vb.queue, &q->active);
181 list_move_tail(&buf->vb.queue, &q->active);
208 vb.queue);
209 list_del(&buf->vb.queue);
425 list_add_tail(&buf->vb.queue,
[all...]
/drivers/scsi/
H A Dips.c62 /* - Send all of the commands on the queue at once rather than */
103 /* - Don't release HA Lock in ips_next() until SC taken off queue */
807 /* See if the command is on the copp queue */
817 /* See if the command is on the wait queue */
872 /* See if the command is on the copp queue */
883 /* See if the command is on the wait queue */
1199 /* Set queue depths on devices once scan is complete */
2536 /* Take the next command off the queue and send it to the controller */
2555 * Block access to the queue function so
2663 spin_unlock(host->host_lock); /* Unlock HA after command is taken off queue */
2774 ips_putq_scb_head(ips_scb_queue_t * queue, ips_scb_t * item) argument
2802 ips_removeq_scb_head(ips_scb_queue_t * queue) argument
2837 ips_removeq_scb(ips_scb_queue_t * queue, ips_scb_t * item) argument
2882 ips_putq_wait_tail(ips_wait_queue_t *queue, struct scsi_cmnd *item) argument
2913 ips_removeq_wait_head(ips_wait_queue_t *queue) argument
2947 ips_removeq_wait(ips_wait_queue_t *queue, struct scsi_cmnd *item) argument
2994 ips_putq_copp_tail(ips_copp_queue_t * queue, ips_copp_wait_item_t * item) argument
3026 ips_removeq_copp_head(ips_copp_queue_t * queue) argument
3061 ips_removeq_copp(ips_copp_queue_t * queue, ips_copp_wait_item_t * item) argument
[all...]
/drivers/scsi/bfa/
H A Dbfa_core.c704 * Callback only as long as there is room in request queue
770 int queue; local
777 * RME completion queue interrupt
781 for (queue = 0; queue < BFI_IOC_MAX_CQS; queue++)
782 bfa_isr_rspq(bfa, queue);
790 * CPE completion queue interrupt
794 for (queue = 0; queue < BFI_IOC_MAX_CQ
808 int queue; local
[all...]
/drivers/spi/
H A Dspi-topcliff-pch.c139 * @work: Reference to work queue handler
142 * @wait: Wait queue for waking up upon receiving an
147 * @queue: SPI Message queue
181 struct list_head queue; member in struct:pch_spi_data
518 /* add message to queue */
519 list_add_tail(&pmsg->queue, &data->queue);
524 /* schedule work queue to run */
526 dev_dbg(&pspi->dev, "%s - Invoked queue wor
[all...]
/drivers/infiniband/hw/cxgb3/
H A Dcxio_wr.h660 #define TPT_ERR_DDP_QUEUE_NUM 0x17 /* invalid ddp queue number */
692 union t3_wr *queue; /* DMA accessible memory */ member in struct:t3_wq
722 struct t3_cqe *queue; member in struct:t3_cq
738 &cq->queue[1 << cq->size_log2])->cq_err;
744 &cq->queue[1 << cq->size_log2])->cq_err = 1;
749 wq->queue->wq_in_err.err |= 1;
754 wq->queue->wq_in_err.err |= 2;
759 wq->queue->wq_in_err.err &= ~2;
764 return !(wq->queue->wq_in_err.err & 2);
771 cqe = cq->queue
[all...]
/drivers/media/pci/cx88/
H A Dcx88-mpeg.c217 dprintk(1, "cx8802_restart_queue: queue is empty\n" );
222 buf = list_entry(q->queued.next, struct cx88_buffer, vb.queue);
224 list_move_tail(&buf->vb.queue, &q->active);
235 list_move_tail(&buf->vb.queue, &q->active);
249 buf = list_entry(q->active.next, struct cx88_buffer, vb.queue);
253 list_for_each_entry(buf, &q->active, vb.queue)
303 dprintk( 1, "queue is empty - first active\n" );
304 list_add_tail(&buf->vb.queue,&cx88q->active);
313 dprintk( 1, "queue is not empty - append to active\n" );
314 prev = list_entry(cx88q->active.prev, struct cx88_buffer, vb.queue);
[all...]

Completed in 629 milliseconds

1234567891011>>