| /linux/drivers/usb/gadget/function/ |
| H A D | uvc_queue.c | 46 struct uvc_video_queue *queue = vb2_get_drv_priv(vq); in uvc_queue_setup() local
63 struct uvc_video_queue *queue = vb2_get_drv_priv(vb->vb2_queue); in uvc_buffer_prepare() local
107 struct uvc_video_queue *queue = vb2_get_drv_priv(vb->vb2_queue); in uvc_buffer_queue() local
134 int uvcg_queue_init(struct uvc_video_queue *queue, struct device *dev, enum v4l2_buf_type type, in uvcg_queue_init()
172 void uvcg_free_buffers(struct uvc_video_queue *queue) in uvcg_free_buffers()
180 int uvcg_alloc_buffers(struct uvc_video_queue *queue, in uvcg_alloc_buffers()
198 int uvcg_query_buffer(struct uvc_video_queue *queue, struct v4l2_buffer *buf) in uvcg_query_buffer()
203 int uvcg_queue_buffer(struct uvc_video_queue *queue, struct v4l2_buffer *buf) in uvcg_queue_buffer()
212 int uvcg_dequeue_buffer(struct uvc_video_queue *queue, struct v4l2_buffer *buf, in uvcg_dequeue_buffer()
224 __poll_t uvcg_queue_poll(struct uvc_video_queue *queue, struct file *file, in uvcg_queue_poll()
[all …]
|
| /linux/drivers/net/xen-netback/ |
| H A D | rx.c | 42 static void xenvif_update_needed_slots(struct xenvif_queue *queue, in xenvif_update_needed_slots()
58 static bool xenvif_rx_ring_slots_available(struct xenvif_queue *queue) in xenvif_rx_ring_slots_available()
85 bool xenvif_rx_queue_tail(struct xenvif_queue *queue, struct sk_buff *skb) in xenvif_rx_queue_tail()
111 static struct sk_buff *xenvif_rx_dequeue(struct xenvif_queue *queue) in xenvif_rx_dequeue()
135 static void xenvif_rx_queue_purge(struct xenvif_queue *queue) in xenvif_rx_queue_purge()
143 static void xenvif_rx_queue_drop_expired(struct xenvif_queue *queue) in xenvif_rx_queue_drop_expired()
159 static void xenvif_rx_copy_flush(struct xenvif_queue *queue) in xenvif_rx_copy_flush()
193 static void xenvif_rx_copy_add(struct xenvif_queue *queue, in xenvif_rx_copy_add()
252 static void xenvif_rx_next_skb(struct xenvif_queue *queue, in xenvif_rx_next_skb()
328 static void xenvif_rx_complete(struct xenvif_queue *queue, in xenvif_rx_complete()
[all …]
|
| H A D | netback.c | 119 static inline unsigned long idx_to_pfn(struct xenvif_queue *queue, in idx_to_pfn()
125 static inline unsigned long idx_to_kaddr(struct xenvif_queue *queue, in idx_to_kaddr()
161 void xenvif_kick_thread(struct xenvif_queue *queue) in xenvif_kick_thread()
166 void xenvif_napi_schedule_or_enable_events(struct xenvif_queue *queue) in xenvif_napi_schedule_or_enable_events()
180 static void tx_add_credit(struct xenvif_queue *queue) in tx_add_credit()
201 struct xenvif_queue *queue = timer_container_of(queue, t, in xenvif_tx_credit_callback() local
207 static void xenvif_tx_err(struct xenvif_queue *queue, in xenvif_tx_err()
232 static int xenvif_count_requests(struct xenvif_queue *queue, in xenvif_count_requests()
341 static inline void xenvif_tx_create_map_op(struct xenvif_queue *queue, in xenvif_tx_create_map_op()
376 static void xenvif_get_requests(struct xenvif_queue *queue, in xenvif_get_requests()
[all …]
|
| H A D | interface.c | 52 void xenvif_skb_zerocopy_prepare(struct xenvif_queue *queue, in xenvif_skb_zerocopy_prepare()
59 void xenvif_skb_zerocopy_complete(struct xenvif_queue *queue) in xenvif_skb_zerocopy_complete()
77 static bool xenvif_handle_tx_interrupt(struct xenvif_queue *queue) in xenvif_handle_tx_interrupt()
89 struct xenvif_queue *queue = dev_id; in xenvif_tx_interrupt() local
105 struct xenvif_queue *queue = in xenvif_poll() local
132 static bool xenvif_handle_rx_interrupt(struct xenvif_queue *queue) in xenvif_handle_rx_interrupt()
144 struct xenvif_queue *queue = dev_id; in xenvif_rx_interrupt() local
160 struct xenvif_queue *queue = dev_id; in xenvif_interrupt() local
208 struct xenvif_queue *queue = NULL; in xenvif_start_xmit() local
274 struct xenvif_queue *queue = NULL; in xenvif_get_stats() local
[all …]
|
| /linux/drivers/iio/buffer/ |
| H A D | industrialio-buffer-dma.c | 102 struct iio_dma_buffer_queue *queue = block->queue; in iio_buffer_block_release() local
173 iio_dma_buffer_alloc_block(struct iio_dma_buffer_queue *queue, size_t size, in iio_dma_buffer_alloc_block()
209 static void iio_dma_buffer_queue_wake(struct iio_dma_buffer_queue *queue) in iio_dma_buffer_queue_wake()
230 struct iio_dma_buffer_queue *queue = block->queue; in iio_dma_buffer_block_done() local
257 void iio_dma_buffer_block_list_abort(struct iio_dma_buffer_queue *queue, in iio_dma_buffer_block_list_abort()
302 static bool iio_dma_buffer_can_use_fileio(struct iio_dma_buffer_queue *queue) in iio_dma_buffer_can_use_fileio()
321 struct iio_dma_buffer_queue *queue = iio_buffer_to_queue(buffer); in iio_dma_buffer_request_update() local
414 static void iio_dma_buffer_fileio_free(struct iio_dma_buffer_queue *queue) in iio_dma_buffer_fileio_free()
437 static void iio_dma_buffer_submit_block(struct iio_dma_buffer_queue *queue, in iio_dma_buffer_submit_block()
484 struct iio_dma_buffer_queue *queue = iio_buffer_to_queue(buffer); in iio_dma_buffer_enable() local
[all …]
|
| /linux/drivers/net/wireless/broadcom/b43legacy/ |
| H A D | pio.c | 22 static void tx_start(struct b43legacy_pioqueue *queue) in tx_start()
28 static void tx_octet(struct b43legacy_pioqueue *queue, in tx_octet()
63 static void tx_data(struct b43legacy_pioqueue *queue, in tx_data()
89 static void tx_complete(struct b43legacy_pioqueue *queue, in tx_complete()
103 static u16 generate_cookie(struct b43legacy_pioqueue *queue, in generate_cookie()
141 struct b43legacy_pioqueue *queue = NULL; in parse_cookie() local
172 static int pio_tx_write_fragment(struct b43legacy_pioqueue *queue, in pio_tx_write_fragment()
205 struct b43legacy_pioqueue *queue = packet->queue; in free_txpacket() local
219 struct b43legacy_pioqueue *queue = packet->queue; in pio_tx_packet() local
269 struct b43legacy_pioqueue *queue = from_tasklet(queue, t, txtask); in tx_tasklet() local
[all …]
|
| H A D | pio.h | 43 struct b43legacy_pioqueue *queue; member
84 u16 b43legacy_pio_read(struct b43legacy_pioqueue *queue, in b43legacy_pio_read()
91 void b43legacy_pio_write(struct b43legacy_pioqueue *queue, in b43legacy_pio_write()
137 void b43legacy_pio_rx(struct b43legacy_pioqueue *queue) in b43legacy_pio_rx()
141 void b43legacy_pio_tx_suspend(struct b43legacy_pioqueue *queue) in b43legacy_pio_tx_suspend()
145 void b43legacy_pio_tx_resume(struct b43legacy_pioqueue *queue) in b43legacy_pio_tx_resume()
|
| /linux/drivers/net/wireless/ralink/rt2x00/ |
| H A D | rt2x00queue.c | 25 struct data_queue *queue = entry->queue; in rt2x00queue_alloc_rxskb() local
529 struct data_queue *queue = entry->queue; in rt2x00queue_write_tx_descriptor() local
540 static void rt2x00queue_kick_tx_queue(struct data_queue *queue, in rt2x00queue_kick_tx_queue()
599 int rt2x00queue_write_tx_frame(struct data_queue *queue, struct sk_buff *skb, in rt2x00queue_write_tx_frame()
784 bool rt2x00queue_for_each_entry(struct data_queue *queue, in rt2x00queue_for_each_entry()
839 struct queue_entry *rt2x00queue_get_entry(struct data_queue *queue, in rt2x00queue_get_entry()
863 struct data_queue *queue = entry->queue; in rt2x00queue_index_inc() local
890 static void rt2x00queue_pause_queue_nocheck(struct data_queue *queue) in rt2x00queue_pause_queue_nocheck()
907 void rt2x00queue_pause_queue(struct data_queue *queue) in rt2x00queue_pause_queue()
918 void rt2x00queue_unpause_queue(struct data_queue *queue) in rt2x00queue_unpause_queue()
[all …]
|
| H A D | rt2x00mmio.c | 51 struct data_queue *queue = rt2x00dev->rx; in rt2x00mmio_rxdone() local
88 void rt2x00mmio_flush_queue(struct data_queue *queue, bool drop) in rt2x00mmio_flush_queue()
101 struct data_queue *queue) in rt2x00mmio_alloc_queue_dma()
130 struct data_queue *queue) in rt2x00mmio_free_queue_dma()
144 struct data_queue *queue; in rt2x00mmio_initialize() local
180 struct data_queue *queue; in rt2x00mmio_uninitialize() local
|
| /linux/drivers/nvme/target/ |
| H A D | tcp.c | 109 struct nvmet_tcp_queue *queue; member
218 static inline u16 nvmet_tcp_cmd_tag(struct nvmet_tcp_queue *queue, in nvmet_tcp_cmd_tag()
254 nvmet_tcp_get_cmd(struct nvmet_tcp_queue *queue) in nvmet_tcp_get_cmd()
280 static inline int queue_cpu(struct nvmet_tcp_queue *queue) in queue_cpu()
285 static inline u8 nvmet_tcp_hdgst_len(struct nvmet_tcp_queue *queue) in nvmet_tcp_hdgst_len()
290 static inline u8 nvmet_tcp_ddgst_len(struct nvmet_tcp_queue *queue) in nvmet_tcp_ddgst_len()
300 static int nvmet_tcp_verify_hdgst(struct nvmet_tcp_queue *queue, in nvmet_tcp_verify_hdgst()
326 static int nvmet_tcp_check_ddgst(struct nvmet_tcp_queue *queue, void *pdu) in nvmet_tcp_check_ddgst()
395 static void nvmet_tcp_socket_error(struct nvmet_tcp_queue *queue, int status) in nvmet_tcp_socket_error()
491 struct nvmet_tcp_queue *queue = cmd->queue; in nvmet_setup_c2h_data_pdu() local
[all …]
|
| /linux/drivers/gpu/drm/imagination/ |
| H A D | pvr_queue.c | 297 struct pvr_queue *queue, in pvr_queue_fence_init()
322 pvr_queue_cccb_fence_init(struct dma_fence *fence, struct pvr_queue *queue) in pvr_queue_cccb_fence_init()
340 pvr_queue_job_fence_init(struct dma_fence *fence, struct pvr_queue *queue) in pvr_queue_job_fence_init()
447 pvr_queue_get_job_cccb_fence(struct pvr_queue *queue, struct pvr_job *job) in pvr_queue_get_job_cccb_fence()
500 pvr_queue_get_job_kccb_fence(struct pvr_queue *queue, struct pvr_job *job) in pvr_queue_get_job_kccb_fence()
566 struct pvr_queue *queue = container_of(s_entity, struct pvr_queue, entity); in pvr_queue_prepare_job() local
620 static void pvr_queue_update_active_state_locked(struct pvr_queue *queue) in pvr_queue_update_active_state_locked()
652 static void pvr_queue_update_active_state(struct pvr_queue *queue) in pvr_queue_update_active_state()
663 struct pvr_queue *queue = container_of(job->base.sched, struct pvr_queue, scheduler); in pvr_queue_submit_job_to_cccb() local
807 struct pvr_queue *queue = container_of(job->base.sched, in pvr_queue_run_job() local
[all …]
|
| /linux/net/sunrpc/ |
| H A D | sched.c | 95 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_disable_timer()
106 rpc_set_queue_timer(struct rpc_wait_queue *queue, unsigned long expires) in rpc_set_queue_timer()
121 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task, in __rpc_add_timer()
130 static void rpc_set_waitqueue_priority(struct rpc_wait_queue *queue, int priority) in rpc_set_waitqueue_priority()
138 static void rpc_reset_waitqueue_priority(struct rpc_wait_queue *queue) in rpc_reset_waitqueue_priority()
193 static void __rpc_add_wait_queue_priority(struct rpc_wait_queue *queue, in __rpc_add_wait_queue_priority()
205 static void __rpc_add_wait_queue(struct rpc_wait_queue *queue, in __rpc_add_wait_queue()
233 static void __rpc_remove_wait_queue(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_remove_wait_queue()
243 static void __rpc_init_priority_wait_queue(struct rpc_wait_queue *queue, const char *qname, unsigne… in __rpc_init_priority_wait_queue()
259 void rpc_init_priority_wait_queue(struct rpc_wait_queue *queue, const char *qname) in rpc_init_priority_wait_queue()
[all …]
|
| /linux/drivers/nvme/host/ |
| H A D | tcp.c | 69 struct nvme_tcp_queue *queue; member
188 static void nvme_tcp_reclassify_socket(struct nvme_tcp_queue *queue) in nvme_tcp_reclassify_socket()
219 static inline int nvme_tcp_queue_id(struct nvme_tcp_queue *queue) in nvme_tcp_queue_id()
240 static inline bool nvme_tcp_queue_tls(struct nvme_tcp_queue *queue) in nvme_tcp_queue_tls()
259 static inline struct blk_mq_tags *nvme_tcp_tagset(struct nvme_tcp_queue *queue) in nvme_tcp_tagset()
268 static inline u8 nvme_tcp_hdgst_len(struct nvme_tcp_queue *queue) in nvme_tcp_hdgst_len()
273 static inline u8 nvme_tcp_ddgst_len(struct nvme_tcp_queue *queue) in nvme_tcp_ddgst_len()
381 static inline void nvme_tcp_send_all(struct nvme_tcp_queue *queue) in nvme_tcp_send_all()
391 static inline bool nvme_tcp_queue_has_pending(struct nvme_tcp_queue *queue) in nvme_tcp_queue_has_pending()
397 static inline bool nvme_tcp_queue_more(struct nvme_tcp_queue *queue) in nvme_tcp_queue_more()
[all …]
|
| /linux/drivers/net/ethernet/mellanox/mlx5/core/steering/hws/ |
| H A D | send.c | 10 mlx5hws_send_add_new_dep_wqe(struct mlx5hws_send_engine *queue) in mlx5hws_send_add_new_dep_wqe()
20 void mlx5hws_send_abort_new_dep_wqe(struct mlx5hws_send_engine *queue) in mlx5hws_send_abort_new_dep_wqe()
25 void mlx5hws_send_all_dep_wqe(struct mlx5hws_send_engine *queue) in mlx5hws_send_all_dep_wqe()
65 mlx5hws_send_engine_post_start(struct mlx5hws_send_engine *queue) in mlx5hws_send_engine_post_start()
180 static void hws_send_wqe(struct mlx5hws_send_engine *queue, in hws_send_wqe()
210 void mlx5hws_send_ste(struct mlx5hws_send_engine *queue, in mlx5hws_send_ste()
252 static void hws_send_engine_retry_post_send(struct mlx5hws_send_engine *queue, in hws_send_engine_retry_post_send()
296 void mlx5hws_send_engine_flush_queue(struct mlx5hws_send_engine *queue) in mlx5hws_send_engine_flush_queue()
308 hws_send_engine_update_rule_resize(struct mlx5hws_send_engine *queue, in hws_send_engine_update_rule_resize()
377 static void hws_send_engine_dump_error_cqe(struct mlx5hws_send_engine *queue, in hws_send_engine_dump_error_cqe()
[all …]
|
| /linux/drivers/misc/genwqe/ |
| H A D | card_ddcb.c | 82 static int queue_empty(struct ddcb_queue *queue) in queue_empty()
87 static int queue_enqueued_ddcbs(struct ddcb_queue *queue) in queue_enqueued_ddcbs()
95 static int queue_free_ddcbs(struct ddcb_queue *queue) in queue_free_ddcbs()
163 static void print_ddcb_info(struct genwqe_dev *cd, struct ddcb_queue *queue) in print_ddcb_info()
265 static int enqueue_ddcb(struct genwqe_dev *cd, struct ddcb_queue *queue, in enqueue_ddcb()
332 struct ddcb_queue *queue = req->queue; in copy_ddcb_results() local
366 struct ddcb_queue *queue) in genwqe_check_ddcb_queue()
481 struct ddcb_queue *queue; in __genwqe_wait_ddcb() local
506 struct ddcb_queue *queue = req->queue; in __genwqe_wait_ddcb() local
568 struct ddcb_queue *queue, in get_next_ddcb()
[all …]
|
| /linux/drivers/net/wireguard/ |
| H A D | queueing.c | 25 int wg_packet_queue_init(struct crypt_queue *queue, work_func_t function, in wg_packet_queue_init()
43 void wg_packet_queue_free(struct crypt_queue *queue, bool purge) in wg_packet_queue_free()
51 #define STUB(queue) ((struct sk_buff *)&queue->empty) argument
53 void wg_prev_queue_init(struct prev_queue *queue) in wg_prev_queue_init()
66 static void __wg_prev_queue_enqueue(struct prev_queue *queue, struct sk_buff *skb) in __wg_prev_queue_enqueue()
72 bool wg_prev_queue_enqueue(struct prev_queue *queue, struct sk_buff *skb) in wg_prev_queue_enqueue()
80 struct sk_buff *wg_prev_queue_dequeue(struct prev_queue *queue) in wg_prev_queue_dequeue()
|
| /linux/drivers/net/wireless/st/cw1200/ |
| H A D | queue.c | 27 static inline void __cw1200_queue_lock(struct cw1200_queue *queue) in __cw1200_queue_lock()
37 static inline void __cw1200_queue_unlock(struct cw1200_queue *queue) in __cw1200_queue_unlock()
89 static void __cw1200_queue_gc(struct cw1200_queue *queue, in __cw1200_queue_gc()
135 struct cw1200_queue *queue = in cw1200_queue_gc() local
163 int cw1200_queue_init(struct cw1200_queue *queue, in cw1200_queue_init()
199 int cw1200_queue_clear(struct cw1200_queue *queue) in cw1200_queue_clear()
241 void cw1200_queue_deinit(struct cw1200_queue *queue) in cw1200_queue_deinit()
253 size_t cw1200_queue_get_num_queued(struct cw1200_queue *queue, in cw1200_queue_get_num_queued()
277 int cw1200_queue_put(struct cw1200_queue *queue, in cw1200_queue_put()
328 int cw1200_queue_get(struct cw1200_queue *queue, in cw1200_queue_get()
[all …]
|
| /linux/drivers/scsi/arm/ |
| H A D | queue.c | 59 int queue_initialise (Queue_t *queue) in queue_initialise()
91 void queue_free (Queue_t *queue) in queue_free()
107 int __queue_add(Queue_t *queue, struct scsi_cmnd *SCpnt, int head) in __queue_add()
138 static struct scsi_cmnd *__queue_remove(Queue_t *queue, struct list_head *ent) in __queue_remove()
162 struct scsi_cmnd *queue_remove_exclude(Queue_t *queue, unsigned long *exclude) in queue_remove_exclude()
188 struct scsi_cmnd *queue_remove(Queue_t *queue) in queue_remove()
210 struct scsi_cmnd *queue_remove_tgtluntag(Queue_t *queue, int target, int lun, in queue_remove_tgtluntag()
238 void queue_remove_all_target(Queue_t *queue, int target) in queue_remove_all_target()
261 int queue_probetgtlun (Queue_t *queue, int target, int lun) in queue_probetgtlun()
287 int queue_remove_cmd(Queue_t *queue, struct scsi_cmnd *SCpnt) in queue_remove_cmd()
|
| /linux/drivers/net/wireless/ath/ath5k/ |
| H A D | qcu.c | 63 ath5k_hw_num_tx_pending(struct ath5k_hw *ah, unsigned int queue) in ath5k_hw_num_tx_pending()
94 ath5k_hw_release_tx_queue(struct ath5k_hw *ah, unsigned int queue) in ath5k_hw_release_tx_queue()
138 ath5k_hw_get_tx_queueprops(struct ath5k_hw *ah, int queue, in ath5k_hw_get_tx_queueprops()
154 ath5k_hw_set_tx_queueprops(struct ath5k_hw *ah, int queue, in ath5k_hw_set_tx_queueprops()
206 unsigned int queue; in ath5k_hw_setup_tx_queue() local
282 unsigned int queue) in ath5k_hw_set_tx_retry_limits()
324 ath5k_hw_reset_tx_queue(struct ath5k_hw *ah, unsigned int queue) in ath5k_hw_reset_tx_queue()
|
| /linux/include/drm/ |
| H A D | spsc_queue.h | 48 static inline void spsc_queue_init(struct spsc_queue *queue) in spsc_queue_init()
55 static inline struct spsc_node *spsc_queue_peek(struct spsc_queue *queue) in spsc_queue_peek()
60 static inline int spsc_queue_count(struct spsc_queue *queue) in spsc_queue_count()
65 static inline bool spsc_queue_push(struct spsc_queue *queue, struct spsc_node *node) in spsc_queue_push()
91 static inline struct spsc_node *spsc_queue_pop(struct spsc_queue *queue) in spsc_queue_pop()
|
| /linux/drivers/net/ |
| H A D | xen-netfront.c | 218 static struct sk_buff *xennet_get_rx_skb(struct netfront_queue *queue, in xennet_get_rx_skb()
227 static grant_ref_t xennet_get_rx_ref(struct netfront_queue *queue, in xennet_get_rx_ref()
248 struct netfront_queue *queue = timer_container_of(queue, t, in rx_refill_timeout() local
253 static int netfront_tx_slot_available(struct netfront_queue *queue) in netfront_tx_slot_available()
259 static void xennet_maybe_wake_tx(struct netfront_queue *queue) in xennet_maybe_wake_tx()
271 static struct sk_buff *xennet_alloc_one_rx_buffer(struct netfront_queue *queue) in xennet_alloc_one_rx_buffer()
299 static void xennet_alloc_rx_buffers(struct netfront_queue *queue) in xennet_alloc_rx_buffers()
366 struct netfront_queue *queue = NULL; in xennet_open() local
390 static bool xennet_tx_buf_gc(struct netfront_queue *queue) in xennet_tx_buf_gc()
466 struct netfront_queue *queue; member
[all …]
|
| /linux/net/core/ |
| H A D | net-sysfs.c | 927 struct netdev_rx_queue *queue = to_rx_queue(kobj); in rx_queue_attr_show() local
939 struct netdev_rx_queue *queue = to_rx_queue(kobj); in rx_queue_attr_store() local
953 static ssize_t show_rps_map(struct netdev_rx_queue *queue, char *buf) in show_rps_map()
975 static int netdev_rx_queue_set_rps_mask(struct netdev_rx_queue *queue, in netdev_rx_queue_set_rps_mask()
1027 static ssize_t store_rps_map(struct netdev_rx_queue *queue, in store_rps_map()
1054 static ssize_t show_rps_dev_flow_table_cnt(struct netdev_rx_queue *queue, in show_rps_dev_flow_table_cnt()
1067 static ssize_t store_rps_dev_flow_table_cnt(struct netdev_rx_queue *queue, in store_rps_dev_flow_table_cnt()
1143 struct netdev_rx_queue *queue = to_rx_queue(kobj); in rx_queue_release() local
1165 struct netdev_rx_queue *queue = to_rx_queue(kobj); in rx_queue_namespace() local
1191 struct netdev_rx_queue *queue) in rx_queue_default_mask()
[all …]
|
| /linux/drivers/net/wwan/t7xx/ |
| H A D | t7xx_hif_cldma.c | 60 static void md_cd_queue_struct_reset(struct cldma_queue *queue, struct cldma_ctrl *md_ctrl, in md_cd_queue_struct_reset()
71 static void md_cd_queue_struct_init(struct cldma_queue *queue, struct cldma_ctrl *md_ctrl, in md_cd_queue_struct_init()
110 static int t7xx_cldma_gpd_rx_from_q(struct cldma_queue *queue, int budget, bool *over_budget) in t7xx_cldma_gpd_rx_from_q()
196 static int t7xx_cldma_gpd_rx_collect(struct cldma_queue *queue, int budget) in t7xx_cldma_gpd_rx_collect()
240 struct cldma_queue *queue = container_of(work, struct cldma_queue, cldma_work); in t7xx_cldma_rx_done() local
256 static int t7xx_cldma_gpd_tx_collect(struct cldma_queue *queue) in t7xx_cldma_gpd_tx_collect()
297 static void t7xx_cldma_txq_empty_hndl(struct cldma_queue *queue) in t7xx_cldma_txq_empty_hndl()
335 struct cldma_queue *queue = container_of(work, struct cldma_queue, cldma_work); in t7xx_cldma_tx_done() local
504 static void t7xx_cldma_q_reset(struct cldma_queue *queue) in t7xx_cldma_q_reset()
518 static void t7xx_cldma_rxq_init(struct cldma_queue *queue) in t7xx_cldma_rxq_init()
[all …]
|
| /linux/net/sctp/ |
| H A D | inqueue.c | 32 void sctp_inq_init(struct sctp_inq *queue) in sctp_inq_init() argument
50 void sctp_inq_free(struct sctp_inq *queue) in sctp_inq_free() argument
92 sctp_inq_peek(struct sctp_inq * queue) sctp_inq_peek() argument
115 sctp_inq_pop(struct sctp_inq * queue) sctp_inq_pop() argument
[all...] |
| /linux/drivers/net/wireless/silabs/wfx/ |
| H A D | queue.c | 76 bool wfx_tx_queue_empty(struct wfx_vif *wvif, struct wfx_queue *queue) in wfx_tx_queue_empty()
106 void wfx_tx_queue_drop(struct wfx_vif *wvif, struct wfx_queue *queue, in wfx_tx_queue_drop()
117 struct wfx_queue *queue = &wvif->tx_queue[skb_get_queue_mapping(skb)]; in wfx_tx_queues_put() local
130 struct wfx_queue *queue; in wfx_pending_drop() local
149 struct wfx_queue *queue; in wfx_pending_get() local
226 static int wfx_tx_queue_get_weight(struct wfx_queue *queue) in wfx_tx_queue_get_weight()
|