Lines Matching refs:queue
185 struct rt2x00_dev *rt2x00dev = entry->queue->rt2x00dev; in rt2x00usb_interrupt_txdone()
213 struct rt2x00_dev *rt2x00dev = entry->queue->rt2x00dev; in rt2x00usb_write_tx_data()
222 skb_push(entry->skb, entry->queue->desc_size); in rt2x00usb_write_tx_data()
223 memset(entry->skb->data, 0, entry->queue->desc_size); in rt2x00usb_write_tx_data()
230 skbdesc->desc_len = entry->queue->desc_size; in rt2x00usb_write_tx_data()
240 usb_sndbulkpipe(usb_dev, entry->queue->usb_endpoint), in rt2x00usb_write_tx_data()
248 skb_pull(entry->skb, entry->queue->desc_size); in rt2x00usb_write_tx_data()
265 struct data_queue *queue = rt2x00queue_get_queue(rt2x00dev, qid); in rt2x00usb_kick_tx_queue() local
277 spin_lock_irqsave(&queue->lock, irqflags); in rt2x00usb_kick_tx_queue()
278 index = queue->index[Q_INDEX]; in rt2x00usb_kick_tx_queue()
279 index_done = queue->index[Q_INDEX_DONE]; in rt2x00usb_kick_tx_queue()
280 spin_unlock_irqrestore(&queue->lock, irqflags); in rt2x00usb_kick_tx_queue()
288 rt2x00usb_kick_tx_entry(&queue->entries[i]); in rt2x00usb_kick_tx_queue()
290 for (i = index_done; i < queue->limit; i++) in rt2x00usb_kick_tx_queue()
291 rt2x00usb_kick_tx_entry(&queue->entries[i]); in rt2x00usb_kick_tx_queue()
294 rt2x00usb_kick_tx_entry(&queue->entries[i]); in rt2x00usb_kick_tx_queue()
305 struct rt2x00_dev *rt2x00dev = entry->queue->rt2x00dev; in rt2x00usb_interrupt_rxdone()
318 if (urb->actual_length < entry->queue->desc_size || urb->status) { in rt2x00usb_interrupt_rxdone()
328 skbdesc->desc_len = entry->queue->desc_size; in rt2x00usb_interrupt_rxdone()
343 struct data_queue *queue; in rt2x00usb_disable_radio() local
352 queue_for_each(rt2x00dev, queue) { in rt2x00usb_disable_radio()
353 for (i = 0; i < queue->limit; i++) { in rt2x00usb_disable_radio()
354 entry_priv = queue->entries[i].priv_data; in rt2x00usb_disable_radio()
379 to_usb_device_intf(entry->queue->rt2x00dev->dev); in rt2x00usb_clear_entry()
383 if (entry->queue->qid == QID_RX) { in rt2x00usb_clear_entry()
384 pipe = usb_rcvbulkpipe(usb_dev, entry->queue->usb_endpoint); in rt2x00usb_clear_entry()
397 static void rt2x00usb_assign_endpoint(struct data_queue *queue, in rt2x00usb_assign_endpoint() argument
400 struct usb_device *usb_dev = to_usb_device_intf(queue->rt2x00dev->dev); in rt2x00usb_assign_endpoint()
403 queue->usb_endpoint = usb_endpoint_num(ep_desc); in rt2x00usb_assign_endpoint()
405 if (queue->qid == QID_RX) { in rt2x00usb_assign_endpoint()
406 pipe = usb_rcvbulkpipe(usb_dev, queue->usb_endpoint); in rt2x00usb_assign_endpoint()
407 queue->usb_maxpacket = usb_maxpacket(usb_dev, pipe, 0); in rt2x00usb_assign_endpoint()
409 pipe = usb_sndbulkpipe(usb_dev, queue->usb_endpoint); in rt2x00usb_assign_endpoint()
410 queue->usb_maxpacket = usb_maxpacket(usb_dev, pipe, 1); in rt2x00usb_assign_endpoint()
413 if (!queue->usb_maxpacket) in rt2x00usb_assign_endpoint()
414 queue->usb_maxpacket = 1; in rt2x00usb_assign_endpoint()
422 struct data_queue *queue = rt2x00dev->tx; in rt2x00usb_find_endpoints() local
438 (queue != queue_end(rt2x00dev))) { in rt2x00usb_find_endpoints()
439 rt2x00usb_assign_endpoint(queue, ep_desc); in rt2x00usb_find_endpoints()
440 queue = queue_next(queue); in rt2x00usb_find_endpoints()
459 txall_queue_for_each(rt2x00dev, queue) { in rt2x00usb_find_endpoints()
460 if (!queue->usb_endpoint) in rt2x00usb_find_endpoints()
461 rt2x00usb_assign_endpoint(queue, tx_ep_desc); in rt2x00usb_find_endpoints()
468 struct data_queue *queue) in rt2x00usb_alloc_urb() argument
474 for (i = 0; i < queue->limit; i++) { in rt2x00usb_alloc_urb()
475 entry_priv = queue->entries[i].priv_data; in rt2x00usb_alloc_urb()
486 if (rt2x00dev->bcn != queue || in rt2x00usb_alloc_urb()
490 for (i = 0; i < queue->limit; i++) { in rt2x00usb_alloc_urb()
491 bcn_priv = queue->entries[i].priv_data; in rt2x00usb_alloc_urb()
501 struct data_queue *queue) in rt2x00usb_free_urb() argument
507 if (!queue->entries) in rt2x00usb_free_urb()
510 for (i = 0; i < queue->limit; i++) { in rt2x00usb_free_urb()
511 entry_priv = queue->entries[i].priv_data; in rt2x00usb_free_urb()
521 if (rt2x00dev->bcn != queue || in rt2x00usb_free_urb()
525 for (i = 0; i < queue->limit; i++) { in rt2x00usb_free_urb()
526 bcn_priv = queue->entries[i].priv_data; in rt2x00usb_free_urb()
534 struct data_queue *queue; in rt2x00usb_initialize() local
547 queue_for_each(rt2x00dev, queue) { in rt2x00usb_initialize()
548 status = rt2x00usb_alloc_urb(rt2x00dev, queue); in rt2x00usb_initialize()
564 struct data_queue *queue; in rt2x00usb_uninitialize() local
566 queue_for_each(rt2x00dev, queue) in rt2x00usb_uninitialize()
567 rt2x00usb_free_urb(rt2x00dev, queue); in rt2x00usb_uninitialize()