Searched defs:queue (Results 1 - 25 of 395) sorted by relevance

1234567891011>>

/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/usb/uvc/
H A Duvc_isight.c39 static int isight_decode(struct uvc_video_queue *queue, struct uvc_buffer *buf, argument
123 ret = isight_decode(&stream->queue, buf,
133 buf = uvc_queue_next_buffer(&stream->queue,
/drivers/staging/octeon/
H A Docteon-ethernet.h43 /* PKO hardware queue for the port */
44 int queue; member in struct:octeon_ethernet
54 /* List of outstanding tx buffers per queue */
/drivers/staging/rtl8723au/include/
H A Dosdep_service.h51 struct list_head queue; member in struct:rtw_queue
55 static inline struct list_head *get_list_head(struct rtw_queue *queue) argument
57 return &queue->queue;
/drivers/net/wireless/prism54/
H A Disl_38xx.c57 /* data tx queue not empty */
61 /* management tx queue not empty */
66 /* data rx queue not empty */
70 /* management rx queue not empty */
102 /* either data or management transmit queue has a frame pending
223 isl38xx_in_queue(isl38xx_control_block *cb, int queue) argument
225 const s32 delta = (le32_to_cpu(cb->driver_curr_frag[queue]) -
226 le32_to_cpu(cb->device_curr_frag[queue]));
228 /* determine the amount of fragments in the queue depending on the type
229 * of the queue, eithe
[all...]
/drivers/staging/rtl8723au/os_dep/
H A Dxmit_linux.c63 u16 queue; local
65 queue = skb_get_queue_mapping(pkt);
67 if (__netif_subqueue_stopped(padapter->pnetdev, queue) &&
68 (pxmitpriv->hwxmits[queue].accnt < WMM_XMIT_THRESHOLD))
69 netif_wake_subqueue(padapter->pnetdev, queue);
71 if (__netif_subqueue_stopped(padapter->pnetdev, queue))
72 netif_wake_subqueue(padapter->pnetdev, queue);
105 u16 queue; local
107 queue = skb_get_queue_mapping(pkt);
110 if (pxmitpriv->hwxmits[queue]
[all...]
/drivers/crypto/qce/
H A Dcore.h21 * @queue: crypto request queue
22 * @lock: the lock protects queue and req
38 struct crypto_queue queue; member in struct:qce_device
/drivers/gpu/drm/vmwgfx/
H A Dvmwgfx_marker.c37 void vmw_marker_queue_init(struct vmw_marker_queue *queue) argument
39 INIT_LIST_HEAD(&queue->head);
40 queue->lag = 0;
41 queue->lag_time = ktime_get_raw_ns();
42 spin_lock_init(&queue->lock);
45 void vmw_marker_queue_takedown(struct vmw_marker_queue *queue) argument
49 spin_lock(&queue->lock);
50 list_for_each_entry_safe(marker, next, &queue->head, head) {
53 spin_unlock(&queue->lock);
56 int vmw_marker_push(struct vmw_marker_queue *queue, argument
73 vmw_marker_pull(struct vmw_marker_queue *queue, uint32_t signaled_seqno) argument
107 vmw_fifo_lag(struct vmw_marker_queue *queue) argument
120 vmw_lag_lt(struct vmw_marker_queue *queue, uint32_t us) argument
128 vmw_wait_lag(struct vmw_private *dev_priv, struct vmw_marker_queue *queue, uint32_t us) argument
[all...]
/drivers/net/wireless/rt2x00/
H A Drt2x00mmio.c62 struct data_queue *queue = rt2x00dev->rx; local
69 entry = rt2x00queue_get_entry(queue, Q_INDEX);
80 skbdesc->desc_len = entry->queue->desc_size;
99 void rt2x00mmio_flush_queue(struct data_queue *queue, bool drop) argument
103 for (i = 0; !rt2x00queue_empty(queue) && i < 10; i++)
112 struct data_queue *queue)
123 queue->limit * queue->desc_size, &dma,
129 * Initialize all queue entries to contain valid addresses.
131 for (i = 0; i < queue
111 rt2x00mmio_alloc_queue_dma(struct rt2x00_dev *rt2x00dev, struct data_queue *queue) argument
140 rt2x00mmio_free_queue_dma(struct rt2x00_dev *rt2x00dev, struct data_queue *queue) argument
155 struct data_queue *queue; local
191 struct data_queue *queue; local
[all...]
/drivers/usb/gadget/function/
H A Duvc_queue.h30 struct list_head queue; member in struct:uvc_buffer
43 struct vb2_queue queue; member in struct:uvc_video_queue
44 struct mutex mutex; /* Protects queue */
55 static inline int uvc_queue_streaming(struct uvc_video_queue *queue) argument
57 return vb2_is_streaming(&queue->queue);
60 int uvcg_queue_init(struct uvc_video_queue *queue, enum v4l2_buf_type type);
62 void uvcg_free_buffers(struct uvc_video_queue *queue);
64 int uvcg_alloc_buffers(struct uvc_video_queue *queue,
67 int uvcg_query_buffer(struct uvc_video_queue *queue, struc
[all...]
H A Duvc_video.c36 if (buf->bytesused - video->queue.buf_used <= len - 2)
46 struct uvc_video_queue *queue = &video->queue; local
51 mem = buf->mem + queue->buf_used;
52 nbytes = min((unsigned int)len, buf->bytesused - queue->buf_used);
55 queue->buf_used += nbytes;
86 if (buf->bytesused == video->queue.buf_used) {
87 video->queue.buf_used = 0;
89 uvcg_queue_next_buffer(&video->queue, buf);
96 buf->bytesused == video->queue
165 struct uvc_video_queue *queue = &video->queue; local
285 struct uvc_video_queue *queue = &video->queue; local
[all...]
/drivers/block/aoe/
H A Daoenet.c113 aoenet_xmit(struct sk_buff_head *queue) argument
118 skb_queue_walk_safe(queue, skb, tmp) {
119 __skb_unlink(skb, queue);
/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);
H A Dipz_pt_fn.c4 * internal queue handling
51 void *ipz_qpageit_get_inc(struct ipz_queue *queue) argument
53 void *ret = ipz_qeit_get(queue);
54 queue->current_q_offset += queue->pagesize;
55 if (queue->current_q_offset > queue->queue_length) {
56 queue->current_q_offset -= queue->pagesize;
59 if (((u64)ret) % queue
66 ipz_qeit_eq_get_inc(struct ipz_queue *queue) argument
80 ipz_queue_abs_to_offset(struct ipz_queue *queue, u64 addr, u64 *q_offset) argument
102 alloc_queue_pages(struct ipz_queue *queue, const u32 nr_of_pages) argument
127 alloc_small_queue_page(struct ipz_queue *queue, struct ehca_pd *pd) argument
172 free_small_queue_page(struct ipz_queue *queue, struct ehca_pd *pd) argument
204 ipz_queue_ctor(struct ehca_pd *pd, struct ipz_queue *queue, const u32 nr_of_pages, const u32 pagesize, const u32 qe_size, const u32 nr_of_sg, int is_small) argument
256 ipz_queue_dtor(struct ehca_pd *pd, struct ipz_queue *queue) argument
[all...]
/drivers/message/i2o/
H A Di2o_block.h26 * Added a queue depth.
29 * Removed queue walk, fixed for 64bitness.
34 * Heavily chop down the queue depths
59 /* request queue sizes */
75 spinlock_t lock; /* queue lock */
78 unsigned int open_queue_depth; /* number of requests in the queue */
89 struct list_head queue; member in struct:i2o_block_request
100 struct request_queue *queue; member in struct:i2o_block_delayed_request
/drivers/net/wireless/ath/ath5k/
H A Dqcu.c35 * basically we have 10 queues to play with. Each queue has a matching
36 * QCU that controls when the queue will get triggered and multiple QCUs
39 * and DCUs allowing us to have different DFS settings for each queue.
41 * When a frame goes into a TX queue, QCU decides when it'll trigger a
43 * it's buffer or -if it's a beacon queue- if it's time to fire up the queue
58 * ath5k_hw_num_tx_pending() - Get number of pending frames for a given queue
60 * @queue: One of enum ath5k_tx_queue_id
63 ath5k_hw_num_tx_pending(struct ath5k_hw *ah, unsigned int queue) argument
66 AR5K_ASSERT_ENTRY(queue, a
94 ath5k_hw_release_tx_queue(struct ath5k_hw *ah, unsigned int queue) argument
138 ath5k_hw_get_tx_queueprops(struct ath5k_hw *ah, int queue, struct ath5k_txq_info *queue_info) argument
154 ath5k_hw_set_tx_queueprops(struct ath5k_hw *ah, int queue, const struct ath5k_txq_info *qinfo) argument
206 unsigned int queue; local
287 ath5k_hw_set_tx_retry_limits(struct ath5k_hw *ah, unsigned int queue) argument
330 ath5k_hw_reset_tx_queue(struct ath5k_hw *ah, unsigned int queue) argument
[all...]
/drivers/net/wireless/cw1200/
H A Dqueue.h2 * O(1) TX queue with built-in allocator for ST-Ericsson CW1200 drivers
36 struct list_head queue; member in struct:cw1200_queue
42 spinlock_t lock; /* Protect queue entry */
71 int cw1200_queue_init(struct cw1200_queue *queue,
76 int cw1200_queue_clear(struct cw1200_queue *queue);
78 void cw1200_queue_deinit(struct cw1200_queue *queue);
80 size_t cw1200_queue_get_num_queued(struct cw1200_queue *queue,
82 int cw1200_queue_put(struct cw1200_queue *queue,
85 int cw1200_queue_get(struct cw1200_queue *queue,
90 int cw1200_queue_requeue(struct cw1200_queue *queue, u3
[all...]
H A Dscan.c358 struct cw1200_queue *queue = &priv->tx_queue[queue_id]; local
396 if (cw1200_queue_get_skb(queue, priv->pending_frame_id,
454 BUG_ON(cw1200_queue_remove(queue, priv->pending_frame_id));
/drivers/net/wireless/iwlwifi/
H A Diwl-op-mode.h123 * @queue_full: notifies that a HW queue is full.
125 * @queue_not_full: notifies that a HW queue is not full any more.
136 * @cmd_queue_full: Called when the command queue gets full. Must be atomic and
157 void (*queue_full)(struct iwl_op_mode *op_mode, int queue);
158 void (*queue_not_full)(struct iwl_op_mode *op_mode, int queue);
198 int queue)
200 op_mode->ops->queue_full(op_mode, queue);
204 int queue)
206 op_mode->ops->queue_not_full(op_mode, queue);
197 iwl_op_mode_queue_full(struct iwl_op_mode *op_mode, int queue) argument
203 iwl_op_mode_queue_not_full(struct iwl_op_mode *op_mode, int queue) argument
/drivers/ptp/
H A Dptp_chardev.c274 struct timestamp_event_queue *queue = &ptp->tsevq; local
292 ptp->defunct || queue_cnt(queue))) {
308 spin_lock_irqsave(&queue->lock, flags);
310 qcnt = queue_cnt(queue);
316 event[i] = queue->buf[queue->head];
317 queue->head = (queue->head + 1) % PTP_MAX_TIMESTAMPS;
320 spin_unlock_irqrestore(&queue->lock, flags);
H A Dptp_sysfs.c99 struct timestamp_event_queue *queue = &ptp->tsevq; local
110 spin_lock_irqsave(&queue->lock, flags);
111 qcnt = queue_cnt(queue);
113 event = queue->buf[queue->head];
114 queue->head = (queue->head + 1) % PTP_MAX_TIMESTAMPS;
116 spin_unlock_irqrestore(&queue->lock, flags);
/drivers/scsi/arm/
H A Dqueue.c2 * linux/drivers/acorn/scsi/queue.c: queue handling primitives
49 #include "queue.h"
54 * Function: void queue_initialise (Queue_t *queue)
55 * Purpose : initialise a queue
56 * Params : queue - queue to initialise
58 int queue_initialise (Queue_t *queue) argument
63 spin_lock_init(&queue->queue_lock);
64 INIT_LIST_HEAD(&queue
90 queue_free(Queue_t *queue) argument
106 __queue_add(Queue_t *queue, struct scsi_cmnd *SCpnt, int head) argument
137 __queue_remove(Queue_t *queue, struct list_head *ent) argument
161 queue_remove_exclude(Queue_t *queue, unsigned long *exclude) argument
187 queue_remove(Queue_t *queue) argument
209 queue_remove_tgtluntag(Queue_t *queue, int target, int lun, int tag) argument
237 queue_remove_all_target(Queue_t *queue, int target) argument
260 queue_probetgtlun(Queue_t *queue, int target, int lun) argument
286 queue_remove_cmd(Queue_t *queue, struct scsi_cmnd *SCpnt) argument
[all...]
/drivers/staging/rtl8188eu/os_dep/
H A Dxmit_linux.c114 u16 queue; local
117 queue = skb_get_queue_mapping(pkt);
119 if (__netif_subqueue_stopped(padapter->pnetdev, queue) &&
120 (pxmitpriv->hwxmits[queue].accnt < WMM_XMIT_THRESHOLD))
121 netif_wake_subqueue(padapter->pnetdev, queue);
123 if (__netif_subqueue_stopped(padapter->pnetdev, queue))
124 netif_wake_subqueue(padapter->pnetdev, queue);
157 u16 queue; local
159 queue = skb_get_queue_mapping(pkt);
162 if (pxmitpriv->hwxmits[queue]
[all...]
/drivers/staging/rtl8712/
H A Dosdep_service.h46 struct list_head queue; member in struct:__queue
56 INIT_LIST_HEAD(&((pqueue)->queue)); \
H A Drtl871x_ioctl_set.c63 struct __queue *queue = &(pmlmepriv->scanned_queue); local
65 phead = &queue->queue;
72 /* adhoc mode will start with an empty queue, but skip checking */
74 list_empty(&queue->queue)) {
77 /* when set_ssid/set_bssid for do_join(), but scanning queue
114 * there are no desired bss in scanning queue

Completed in 7696 milliseconds

1234567891011>>