/drivers/media/dvb-core/ |
H A D | dvb_ringbuffer.h | 40 wait_queue_head_t queue; member in struct:dvb_ringbuffer 76 /* initialize ring buffer, lock and queue */
|
/drivers/media/usb/uvc/ |
H A D | uvc_isight.c | 39 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 D | octeon-ethernet.h | 43 /* 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 D | osdep_service.h | 51 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 D | isl_38xx.c | 57 /* 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 D | xmit_linux.c | 63 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 D | core.h | 21 * @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 D | vmwgfx_marker.c | 37 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 D | rt2x00mmio.c | 62 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 D | uvc_queue.h | 30 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 D | uvc_video.c | 36 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 D | aoenet.c | 113 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 D | ehca_uverbs.c | 135 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 D | ipz_pt_fn.c | 4 * 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 D | i2o_block.h | 26 * 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 D | qcu.c | 35 * 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 D | queue.h | 2 * 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 D | scan.c | 358 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 D | iwl-op-mode.h | 123 * @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 D | ptp_chardev.c | 274 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 D | ptp_sysfs.c | 99 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 D | queue.c | 2 * 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 D | xmit_linux.c | 114 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 D | osdep_service.h | 46 struct list_head queue; member in struct:__queue 56 INIT_LIST_HEAD(&((pqueue)->queue)); \
|
H A D | rtl871x_ioctl_set.c | 63 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
|