Searched refs:queue (Results 126 - 150 of 575) sorted by relevance

1234567891011>>

/drivers/usb/gadget/
H A Dat91_udc.c135 if (list_empty (&ep->queue))
136 seq_printf(s, "\t(queue empty)\n");
138 else list_for_each_entry (req, &ep->queue, queue) {
261 list_del_init(&req->queue);
275 /* ep0 is always ready; other endpoints need a non-empty queue */
276 if (list_empty(&ep->queue) && ep->int_mask != (1 << 0))
397 * If ep_queue() calls us, the queue is empty and possibly in
454 /* terminate any request in the queue */
456 if (list_empty(&ep->queue))
[all...]
H A Dpxa25x_udc.c312 INIT_LIST_HEAD (&req->queue);
326 WARN_ON(!list_empty (&req->queue));
339 list_del_init(&req->queue);
351 /* don't modify queue heads during completion callback */
429 if (list_empty(&ep->queue))
576 if (list_empty(&ep->queue))
641 || !list_empty(&req->queue))) {
666 DBG(DBG_NOISY, "%s queue req %p, len %d buf %p\n",
674 /* kickstart this i/o queue? */
675 if (list_empty(&ep->queue)
[all...]
H A Dfsl_udc_core.c168 /* Removed the req from fsl_ep->queue */
169 list_del_init(&req->queue);
231 while (!list_empty(&ep->queue)) {
234 req = list_entry(ep->queue.next, struct fsl_req, queue);
671 * the main operation is to insert the req->queue to the eq->queue
684 INIT_LIST_HEAD(&req->queue);
733 if (!(list_empty(&ep->queue)) && !(ep_index(ep) == 0)) {
736 lastreq = list_entry(ep->queue
[all...]
H A Dfusb300_udc.c261 while (!list_empty(&ep->queue)) {
262 req = list_entry(ep->queue.next, struct fusb300_request, queue);
279 INIT_LIST_HEAD(&req->queue);
438 if (list_empty(&ep->queue))
441 list_add_tail(&req->queue, &ep->queue);
466 if (!list_empty(&ep->queue))
486 if (!list_empty(&ep->queue)) {
528 .queue
[all...]
H A Ds3c2410_udc.c264 list_del_init(&req->queue);
280 if (&ep->queue == NULL)
283 while (!list_empty (&ep->queue)) {
285 req = list_entry (ep->queue.next, struct s3c2410_request,
286 queue);
437 * return: 0 = still running, 1 = queue empty, negative = errno
766 if (list_empty(&ep->queue))
769 req = list_entry(ep->queue.next, struct s3c2410_request, queue);
839 if (likely (!list_empty(&ep->queue)))
[all...]
/drivers/block/
H A Dps3vram.c69 struct request_queue *queue; member in struct:ps3vram_priv
625 struct request_queue *queue; local
744 queue = blk_alloc_queue(GFP_KERNEL);
745 if (!queue) {
751 priv->queue = queue;
752 queue->queuedata = dev;
753 blk_queue_make_request(queue, ps3vram_make_request);
754 blk_queue_max_segments(queue, BLK_MAX_SEGMENTS);
755 blk_queue_max_segment_size(queue, BLK_MAX_SEGMENT_SIZ
[all...]
/drivers/atm/
H A Dfirestream.c138 You could queue up a bunch of outgoing packets without telling the
150 /* The strings that define what the RX queue entry is all about. */
588 static inline struct FS_QENTRY *get_qentry (struct fs_dev *dev, struct queue *q)
594 static void submit_qentry (struct fs_dev *dev, struct queue *q, struct FS_QENTRY *qe)
603 fs_dprintk (FS_DEBUG_TXQ, "Found queue at %x full. Waiting.\n",
638 static void submit_queue (struct fs_dev *dev, struct queue *q,
665 static void submit_command (struct fs_dev *dev, struct queue *q,
677 static void process_return_queue (struct fs_dev *dev, struct queue *q)
684 fs_dprintk (FS_DEBUG_QUEUE, "reaping return queue entry at %lx\n", rq);
687 fs_dprintk (FS_DEBUG_QUEUE, "queue entr
1401 init_q(struct fs_dev *dev, struct queue *txq, int queue, int nentries, int is_rq) argument
1437 init_fp(struct fs_dev *dev, struct freepool *fp, int queue, int bufsize, int nr_buffers) argument
[all...]
H A Didt77252.c95 struct sk_buff *, int queue);
100 static void add_rx_skb(struct idt77252_dev *, int queue,
582 sb_pool_add(struct idt77252_dev *card, struct sk_buff *skb, int queue) argument
584 struct sb_pool *pool = &card->sbpool[queue];
595 IDT77252_PRV_POOL(skb) = POOL_HANDLE(queue, index);
604 unsigned int queue, index; local
609 queue = POOL_QUEUE(handle);
610 if (queue > 3)
617 card->sbpool[queue].skb[index] = NULL;
623 unsigned int queue, inde local
1242 struct sk_buff *queue; local
1792 idt77252_fbq_level(struct idt77252_dev *card, int queue) argument
1798 idt77252_fbq_full(struct idt77252_dev *card, int queue) argument
1804 push_rx_skb(struct idt77252_dev *card, struct sk_buff *skb, int queue) argument
1850 add_rx_skb(struct idt77252_dev *card, int queue, unsigned int size, unsigned int count) argument
[all...]
/drivers/md/
H A Dmultipath.c263 q = rdev->bdev->bd_disk->queue;
274 blk_queue_max_segments(mddev->queue, 1);
275 blk_queue_segment_boundary(mddev->queue,
445 if (rdev->bdev->bd_disk->queue->merge_bvec_fn) {
446 blk_queue_max_segments(mddev->queue, 1);
447 blk_queue_segment_boundary(mddev->queue,
494 mddev->queue->backing_dev_info.congested_fn = multipath_congested;
495 mddev->queue->backing_dev_info.congested_data = mddev;
518 blk_sync_queue(mddev->queue); /* the unplug fn references 'conf'*/
/drivers/net/wireless/rtl818x/rtl8187/
H A Ddev.c203 skb_queue_tail(&priv->b_tx_status.queue, skb);
205 /* queue is "full", discard last items */
206 while (skb_queue_len(&priv->b_tx_status.queue) > 5) {
210 "transmit status queue full\n");
212 old_skb = skb_dequeue(&priv->b_tx_status.queue);
225 * here, thus queue the skb and finish on a work queue. */
226 skb_queue_tail(&priv->b_tx_status.queue, skb);
389 /* TODO check rx queue length and refill *somewhere* */
502 spin_lock_irqsave(&priv->b_tx_status.queue
1185 int queue; local
1327 rtl8187_conf_tx(struct ieee80211_hw *dev, struct ieee80211_vif *vif, u16 queue, const struct ieee80211_tx_queue_params *params) argument
[all...]
/drivers/usb/host/
H A Duhci-q.c43 * We turn on FSBR whenever a queue that wants it is advancing,
261 INIT_LIST_HEAD(&qh->queue);
296 if (!list_empty(&qh->queue))
309 * When a queue is stopped and a dequeued URB is given back, adjust
310 * the previous TD link (if the URB isn't first on the queue) or
332 /* If the URB isn't first on its queue, adjust the link pointer
335 if (qh->queue.next != &urbp->node) {
370 * Fix up the data toggles for URBs in a queue, when one of them
382 * queue (the short URB is the first). */
384 urbp = list_entry(qh->queue
[all...]
/drivers/block/aoe/
H A Daoecmd.c293 aoecmd_cfg_pkts(ushort aoemajor, unsigned char aoeminor, struct sk_buff_head *queue) argument
313 __skb_queue_tail(queue, skb);
479 struct sk_buff_head queue; local
570 __skb_queue_head_init(&queue);
571 skb_queue_splice_init(&d->sendq, &queue);
578 aoenet_xmit(&queue);
742 struct sk_buff_head queue; local
872 __skb_queue_head_init(&queue);
873 skb_queue_splice_init(&d->sendq, &queue);
876 aoenet_xmit(&queue);
882 struct sk_buff_head queue; local
1056 struct sk_buff_head queue; local
[all...]
/drivers/media/video/
H A Dfsl-viu.c200 spinlock_t vbq_lock; /* spinlock for the videobuf queue */
333 buf = list_entry(vidq->active.next, struct viu_buf, vb.queue);
340 list_for_each_entry_safe(buf, prev, &vidq->active, vb.queue) {
341 list_del(&buf->vb.queue);
353 buf = list_entry(vidq->queued.next, struct viu_buf, vb.queue);
355 list_del(&buf->vb.queue);
356 list_add_tail(&buf->vb.queue, &vidq->active);
370 list_del(&buf->vb.queue);
371 list_add_tail(&buf->vb.queue, &vidq->active);
389 buf = list_entry(vidq->active.next, struct viu_buf, vb.queue);
[all...]
/drivers/infiniband/hw/cxgb4/
H A Dqp.c56 dma_free_coherent(&(rdev->lldi.pdev->dev), sq->memsize, sq->queue,
77 sq->queue = (__force union t4_wr *)(rdev->oc_mw_kva + sq->dma_addr -
85 sq->queue = dma_alloc_coherent(&(rdev->lldi.pdev->dev), sq->memsize,
87 if (!sq->queue)
89 sq->phys_addr = virt_to_phys(sq->queue);
102 wq->rq.memsize, wq->rq.queue,
160 memset(wq->sq.queue, 0, wq->sq.memsize);
163 wq->rq.queue = dma_alloc_coherent(&(rdev->lldi.pdev->dev),
166 if (!wq->rq.queue)
169 __func__, wq->sq.queue,
[all...]
/drivers/net/wireless/rt2x00/
H A Drt2x00debug.c73 * - queue folder
75 * - queue stats file
105 * We queue each frame before dumping it to the user,
107 * so we should be prepared to queue multiple sk buffers
173 DEBUG(rt2x00dev, "txrx dump queue length exceeded.\n");
197 dump_hdr->queue_index = skbdesc->entry->queue->qid;
329 struct data_queue *queue; local
346 queue_for_each(intf->rt2x00dev, queue) {
347 spin_lock_irqsave(&queue->index_lock, irqflags);
350 queue
[all...]
H A Drt2x00usb.h392 * rt2x00usb_kick_queue - Kick data queue
393 * @queue: Data queue to kick
395 * This will walk through all entries of the queue and push all pending
398 void rt2x00usb_kick_queue(struct data_queue *queue);
401 * rt2x00usb_flush_queue - Flush data queue
402 * @queue: Data queue to stop
405 * This will walk through all entries of the queue and will optionally
409 void rt2x00usb_flush_queue(struct data_queue *queue, boo
[all...]
/drivers/ide/
H A Dide-lib.c31 if (drive->queue)
32 blk_queue_bounce_limit(drive->queue, addr);
/drivers/net/ethernet/sfc/
H A Dselftest.c138 * Interrupt and event queue testing
232 "channel %d event queue passed (with%s NAPI)\n",
241 "channel %d timed out waiting for event queue\n",
246 "during event queue test\n",
446 "TX queue %d could not transmit packet %d of "
447 "%d in %s loopback test\n", tx_queue->queue,
486 * skbs not already completed will be free'd when the queue is flushed */
504 "TX queue %d saw only %d out of an expected %d "
506 tx_queue->queue, tx_done, state->packet_count,
515 "TX queue
[all...]
/drivers/pps/
H A Dkapi.c117 init_waitqueue_head(&pps->queue);
229 wake_up_interruptible_all(&pps->queue);
/drivers/spi/
H A Dspi-mpc512x-psc.c49 struct list_head queue; member in struct:mpc512x_psc_spi
50 spinlock_t lock; /* Message queue lock */
225 while (!list_empty(&mps->queue)) {
232 m = container_of(mps->queue.next, struct spi_message, queue);
233 list_del_init(&m->queue);
313 list_add_tail(&m->queue, &mps->queue);
397 /* clear interrupt and wake up the work queue */
468 INIT_LIST_HEAD(&mps->queue);
[all...]
H A Dspi-mpc52xx-psc.c49 struct list_head queue; member in struct:mpc52xx_psc_spi
213 while (!list_empty(&mps->queue)) {
220 m = container_of(mps->queue.next, struct spi_message, queue);
221 list_del_init(&m->queue);
301 list_add_tail(&m->queue, &mps->queue);
356 /* disable interrupt and wake up the work queue */
426 INIT_LIST_HEAD(&mps->queue);
H A Dspi-mpc52xx.c77 struct list_head queue; /* queue of pending messages */ member in struct:mpc52xx_spi
156 if (list_empty(&ms->queue))
159 /* get the head of the queue */
160 ms->message = list_first_entry(&ms->queue, struct spi_message, queue);
161 list_del_init(&ms->message->queue);
383 list_add_tail(&m->queue, &ms->queue);
487 INIT_LIST_HEAD(&ms->queue);
[all...]
H A Dspi-sh.c89 struct list_head queue; member in struct:spi_sh_data
305 while (!list_empty(&ss->queue)) {
306 mesg = list_entry(ss->queue.next, struct spi_message, queue);
307 list_del_init(&mesg->queue);
394 list_add_tail(&mesg->queue, &ss->queue);
496 INIT_LIST_HEAD(&ss->queue);
H A Dspi-stmp.c62 /* lock protects queue access */
64 struct list_head queue; member in struct:stmp_spi
386 * stmp_spi_handle - handle messages from the queue
395 while (!list_empty(&ss->queue)) {
396 m = list_entry(ss->queue.next, struct spi_message, queue);
397 list_del_init(&m->queue);
424 list_add_tail(&m->queue, &ss->queue);
486 INIT_LIST_HEAD(&ss->queue);
[all...]
/drivers/staging/octeon/
H A Dethernet-mdio.c132 if (priv->queue != -1)
134 "port %2d, queue %2d\n",
138 priv->port, priv->queue);

Completed in 435 milliseconds

1234567891011>>