/linux/drivers/net/ethernet/mellanox/mlx5/core/ |
A D | wq.h | 105 static inline int mlx5_wq_cyc_is_full(struct mlx5_wq_cyc *wq) in mlx5_wq_cyc_is_full() 110 static inline int mlx5_wq_cyc_missing(struct mlx5_wq_cyc *wq) in mlx5_wq_cyc_missing() 120 static inline void mlx5_wq_cyc_push(struct mlx5_wq_cyc *wq) in mlx5_wq_cyc_push() 132 static inline void mlx5_wq_cyc_pop(struct mlx5_wq_cyc *wq) in mlx5_wq_cyc_pop() 180 static inline u32 mlx5_cqwq_get_size(struct mlx5_cqwq *wq) in mlx5_cqwq_get_size() 195 static inline u32 mlx5_cqwq_get_ci(struct mlx5_cqwq *wq) in mlx5_cqwq_get_ci() 220 static inline void mlx5_cqwq_pop(struct mlx5_cqwq *wq) in mlx5_cqwq_pop() 246 static inline u32 mlx5_wq_ll_get_size(struct mlx5_wq_ll *wq) in mlx5_wq_ll_get_size() 251 static inline int mlx5_wq_ll_is_full(struct mlx5_wq_ll *wq) in mlx5_wq_ll_is_full() 256 static inline int mlx5_wq_ll_is_empty(struct mlx5_wq_ll *wq) in mlx5_wq_ll_is_empty() [all …]
|
A D | wq.c | 38 void *wqc, struct mlx5_wq_cyc *wq, in mlx5_wq_cyc_create() 74 void mlx5_wq_cyc_wqe_dump(struct mlx5_wq_cyc *wq, u16 ix, u8 nstrides) in mlx5_wq_cyc_wqe_dump() 92 void mlx5_wq_cyc_reset(struct mlx5_wq_cyc *wq) in mlx5_wq_cyc_reset() 100 void *qpc, struct mlx5_wq_qp *wq, in mlx5_wq_qp_create() 160 void *cqc, struct mlx5_cqwq *wq, in mlx5_cqwq_create() 197 static void mlx5_wq_ll_init_list(struct mlx5_wq_ll *wq) in mlx5_wq_ll_init_list() 211 void *wqc, struct mlx5_wq_ll *wq, in mlx5_wq_ll_create() 247 void mlx5_wq_ll_reset(struct mlx5_wq_ll *wq) in mlx5_wq_ll_reset()
|
/linux/include/linux/ |
A D | swait.h | 121 static inline int swait_active(struct swait_queue_head *wq) in swait_active() 134 static inline bool swq_has_sleeper(struct swait_queue_head *wq) in swq_has_sleeper() 158 #define ___swait_event(wq, condition, state, ret, cmd) \ argument 182 #define __swait_event(wq, condition) \ argument 186 #define swait_event_exclusive(wq, condition) \ argument 193 #define __swait_event_timeout(wq, condition, timeout) \ argument 206 #define __swait_event_interruptible(wq, condition) \ argument 210 #define swait_event_interruptible_exclusive(wq, condition) \ argument 232 #define __swait_event_idle(wq, condition) \ argument 247 #define swait_event_idle_exclusive(wq, condition) \ argument [all …]
|
A D | wait.h | 174 struct wait_queue_entry *wq; in __add_wait_queue() local 616 #define __wait_event_interruptible_exclusive(wq, condition) \ argument 620 #define wait_event_interruptible_exclusive(wq, condition) \ argument 629 #define __wait_event_killable_exclusive(wq, condition) \ argument 633 #define wait_event_killable_exclusive(wq, condition) \ argument 643 #define __wait_event_freezable_exclusive(wq, condition) \ argument 647 #define wait_event_freezable_exclusive(wq, condition) \ argument 813 #define wait_event_interruptible_locked(wq, condition) \ argument 840 #define wait_event_interruptible_locked_irq(wq, condition) \ argument 871 #define wait_event_interruptible_exclusive_locked(wq, condition) \ argument [all …]
|
/linux/drivers/scsi/snic/ |
A D | vnic_wq.c | 43 static int vnic_wq_alloc_bufs(struct vnic_wq *wq) in vnic_wq_alloc_bufs() 81 void svnic_wq_free(struct vnic_wq *wq) in svnic_wq_free() 99 int vnic_wq_devcmd2_alloc(struct vnic_dev *vdev, struct vnic_wq *wq, in vnic_wq_devcmd2_alloc() 123 int svnic_wq_alloc(struct vnic_dev *vdev, struct vnic_wq *wq, in svnic_wq_alloc() 154 void vnic_wq_init_start(struct vnic_wq *wq, unsigned int cq_index, in vnic_wq_init_start() 177 void svnic_wq_init(struct vnic_wq *wq, unsigned int cq_index, in svnic_wq_init() 185 unsigned int svnic_wq_error_status(struct vnic_wq *wq) in svnic_wq_error_status() 190 void svnic_wq_enable(struct vnic_wq *wq) in svnic_wq_enable() 195 int svnic_wq_disable(struct vnic_wq *wq) in svnic_wq_disable() 213 void svnic_wq_clean(struct vnic_wq *wq, in svnic_wq_clean() [all …]
|
A D | vnic_wq.h | 85 static inline unsigned int svnic_wq_desc_avail(struct vnic_wq *wq) in svnic_wq_desc_avail() 91 static inline unsigned int svnic_wq_desc_used(struct vnic_wq *wq) in svnic_wq_desc_used() 97 static inline void *svnic_wq_next_desc(struct vnic_wq *wq) in svnic_wq_next_desc() 102 static inline void svnic_wq_post(struct vnic_wq *wq, in svnic_wq_post() 128 static inline void svnic_wq_service(struct vnic_wq *wq, in svnic_wq_service() 130 void (*buf_service)(struct vnic_wq *wq, in svnic_wq_service()
|
/linux/drivers/scsi/fnic/ |
A D | vnic_wq.c | 28 static int vnic_wq_get_ctrl(struct vnic_dev *vdev, struct vnic_wq *wq, in vnic_wq_get_ctrl() 47 static int vnic_wq_alloc_bufs(struct vnic_wq *wq) in vnic_wq_alloc_bufs() 84 void vnic_wq_free(struct vnic_wq *wq) in vnic_wq_free() 132 int vnic_wq_devcmd2_alloc(struct vnic_dev *vdev, struct vnic_wq *wq, in vnic_wq_devcmd2_alloc() 153 void vnic_wq_init_start(struct vnic_wq *wq, unsigned int cq_index, in vnic_wq_init_start() 177 void vnic_wq_init(struct vnic_wq *wq, unsigned int cq_index, in vnic_wq_init() 194 unsigned int vnic_wq_error_status(struct vnic_wq *wq) in vnic_wq_error_status() 199 void vnic_wq_enable(struct vnic_wq *wq) in vnic_wq_enable() 204 int vnic_wq_disable(struct vnic_wq *wq) in vnic_wq_disable() 222 void vnic_wq_clean(struct vnic_wq *wq, in vnic_wq_clean() [all …]
|
A D | vnic_wq_copy.c | 25 void vnic_wq_copy_enable(struct vnic_wq_copy *wq) in vnic_wq_copy_enable() 30 int vnic_wq_copy_disable(struct vnic_wq_copy *wq) in vnic_wq_copy_disable() 51 void vnic_wq_copy_clean(struct vnic_wq_copy *wq, in vnic_wq_copy_clean() 52 void (*q_clean)(struct vnic_wq_copy *wq, in vnic_wq_copy_clean() 69 void vnic_wq_copy_free(struct vnic_wq_copy *wq) in vnic_wq_copy_free() 78 int vnic_wq_copy_alloc(struct vnic_dev *vdev, struct vnic_wq_copy *wq, in vnic_wq_copy_alloc() 96 void vnic_wq_copy_init(struct vnic_wq_copy *wq, unsigned int cq_index, in vnic_wq_copy_init()
|
A D | vnic_wq_copy.h | 36 static inline unsigned int vnic_wq_copy_desc_avail(struct vnic_wq_copy *wq) in vnic_wq_copy_desc_avail() 41 static inline unsigned int vnic_wq_copy_desc_in_use(struct vnic_wq_copy *wq) in vnic_wq_copy_desc_in_use() 46 static inline void *vnic_wq_copy_next_desc(struct vnic_wq_copy *wq) in vnic_wq_copy_next_desc() 52 static inline void vnic_wq_copy_post(struct vnic_wq_copy *wq) in vnic_wq_copy_post() 69 static inline void vnic_wq_copy_desc_process(struct vnic_wq_copy *wq, u16 index) in vnic_wq_copy_desc_process() 83 static inline void vnic_wq_copy_service(struct vnic_wq_copy *wq, in vnic_wq_copy_service() 85 void (*q_service)(struct vnic_wq_copy *wq, in vnic_wq_copy_service()
|
A D | fnic_res.h | 30 static inline void fnic_queue_wq_desc(struct vnic_wq *wq, in fnic_queue_wq_desc() 54 static inline void fnic_queue_wq_eth_desc(struct vnic_wq *wq, in fnic_queue_wq_eth_desc() 79 static inline void fnic_queue_wq_copy_desc_icmnd_16(struct vnic_wq_copy *wq, in fnic_queue_wq_copy_desc_icmnd_16() 124 static inline void fnic_queue_wq_copy_desc_itmf(struct vnic_wq_copy *wq, in fnic_queue_wq_copy_desc_itmf() 150 static inline void fnic_queue_wq_copy_desc_flogi_reg(struct vnic_wq_copy *wq, in fnic_queue_wq_copy_desc_flogi_reg() 169 static inline void fnic_queue_wq_copy_desc_fip_reg(struct vnic_wq_copy *wq, in fnic_queue_wq_copy_desc_fip_reg() 193 static inline void fnic_queue_wq_copy_desc_fw_reset(struct vnic_wq_copy *wq, in fnic_queue_wq_copy_desc_fw_reset() 206 static inline void fnic_queue_wq_copy_desc_lunmap(struct vnic_wq_copy *wq, in fnic_queue_wq_copy_desc_lunmap()
|
A D | vnic_wq.h | 98 static inline unsigned int vnic_wq_desc_avail(struct vnic_wq *wq) in vnic_wq_desc_avail() 104 static inline unsigned int vnic_wq_desc_used(struct vnic_wq *wq) in vnic_wq_desc_used() 110 static inline void *vnic_wq_next_desc(struct vnic_wq *wq) in vnic_wq_next_desc() 115 static inline void vnic_wq_post(struct vnic_wq *wq, in vnic_wq_post() 141 static inline void vnic_wq_service(struct vnic_wq *wq, in vnic_wq_service() 143 void (*buf_service)(struct vnic_wq *wq, in vnic_wq_service()
|
/linux/drivers/net/ethernet/cisco/enic/ |
A D | vnic_wq.c | 31 static int vnic_wq_alloc_bufs(struct vnic_wq *wq) in vnic_wq_alloc_bufs() 69 void vnic_wq_free(struct vnic_wq *wq) in vnic_wq_free() 88 int vnic_wq_alloc(struct vnic_dev *vdev, struct vnic_wq *wq, unsigned int index, in vnic_wq_alloc() 117 int enic_wq_devcmd2_alloc(struct vnic_dev *vdev, struct vnic_wq *wq, in enic_wq_devcmd2_alloc() 134 void enic_wq_init_start(struct vnic_wq *wq, unsigned int cq_index, in enic_wq_init_start() 157 void vnic_wq_init(struct vnic_wq *wq, unsigned int cq_index, in vnic_wq_init() 166 unsigned int vnic_wq_error_status(struct vnic_wq *wq) in vnic_wq_error_status() 171 void vnic_wq_enable(struct vnic_wq *wq) in vnic_wq_enable() 176 int vnic_wq_disable(struct vnic_wq *wq) in vnic_wq_disable() 195 void vnic_wq_clean(struct vnic_wq *wq, in vnic_wq_clean() [all …]
|
A D | enic_res.h | 43 static inline void enic_queue_wq_desc_ex(struct vnic_wq *wq, in enic_queue_wq_desc_ex() 69 static inline void enic_queue_wq_desc_cont(struct vnic_wq *wq, in enic_queue_wq_desc_cont() 78 static inline void enic_queue_wq_desc(struct vnic_wq *wq, void *os_buf, in enic_queue_wq_desc() 88 static inline void enic_queue_wq_desc_csum(struct vnic_wq *wq, in enic_queue_wq_desc_csum() 100 static inline void enic_queue_wq_desc_csum_l4(struct vnic_wq *wq, in enic_queue_wq_desc_csum_l4() 111 static inline void enic_queue_wq_desc_tso(struct vnic_wq *wq, in enic_queue_wq_desc_tso()
|
A D | vnic_wq.h | 99 struct vnic_wq wq; member 103 static inline unsigned int vnic_wq_desc_avail(struct vnic_wq *wq) in vnic_wq_desc_avail() 109 static inline unsigned int vnic_wq_desc_used(struct vnic_wq *wq) in vnic_wq_desc_used() 115 static inline void *vnic_wq_next_desc(struct vnic_wq *wq) in vnic_wq_next_desc() 120 static inline void vnic_wq_doorbell(struct vnic_wq *wq) in vnic_wq_doorbell() 131 static inline void vnic_wq_post(struct vnic_wq *wq, in vnic_wq_post() 154 static inline void vnic_wq_service(struct vnic_wq *wq, in vnic_wq_service() 156 void (*buf_service)(struct vnic_wq *wq, in vnic_wq_service()
|
/linux/drivers/net/ethernet/huawei/hinic/ |
A D | hinic_hw_wq.c | 44 #define WQ_BASE_VADDR(wqs, wq) \ argument 48 #define WQ_BASE_PADDR(wqs, wq) \ argument 52 #define WQ_BASE_ADDR(wqs, wq) \ argument 56 #define CMDQ_BASE_VADDR(cmdq_pages, wq) \ argument 60 #define CMDQ_BASE_PADDR(cmdq_pages, wq) \ argument 64 #define CMDQ_BASE_ADDR(cmdq_pages, wq) \ argument 68 #define WQ_PAGE_ADDR(wq, idx) \ argument 77 #define WQE_SHADOW_PAGE(wq, wqe) \ argument 378 static int alloc_wqes_shadow(struct hinic_wq *wq) in alloc_wqes_shadow() 405 static void free_wqes_shadow(struct hinic_wq *wq) in free_wqes_shadow() [all …]
|
/linux/drivers/dma/idxd/ |
A D | device.c | 203 int idxd_wq_enable(struct idxd_wq *wq) in idxd_wq_enable() 255 void idxd_wq_drain(struct idxd_wq *wq) in idxd_wq_drain() 271 void idxd_wq_reset(struct idxd_wq *wq) in idxd_wq_reset() 319 struct idxd_wq *wq = idxd->wqs[i]; in idxd_wqs_unmap_portal() local 698 struct idxd_wq *wq = idxd->wqs[i]; in idxd_device_wqs_clear_state() local 901 struct idxd_wq *wq = idxd->wqs[i]; in idxd_wqs_config_write() local 967 struct idxd_wq *wq; in idxd_wqs_setup() local 1071 struct idxd_wq *wq; in idxd_group_load_config() local 1135 struct idxd_wq *wq = idxd->wqs[i]; in idxd_device_load_config() local 1233 int drv_enable_wq(struct idxd_wq *wq) in drv_enable_wq() [all …]
|
A D | cdev.c | 35 struct idxd_wq *wq; member 46 struct idxd_wq *wq = idxd_cdev->wq; in idxd_cdev_dev_release() local 76 struct idxd_wq *wq; in idxd_cdev_open() local 143 struct idxd_wq *wq = ctx->wq; in idxd_cdev_release() local 174 static int check_vma(struct idxd_wq *wq, struct vm_area_struct *vma, in check_vma() 193 struct idxd_wq *wq = ctx->wq; in idxd_cdev_mmap() local 219 struct idxd_wq *wq = ctx->wq; in idxd_cdev_poll() local 245 int idxd_wq_add_cdev(struct idxd_wq *wq) in idxd_wq_add_cdev() 296 void idxd_wq_del_cdev(struct idxd_wq *wq) in idxd_wq_del_cdev() 308 struct idxd_wq *wq = idxd_dev_to_wq(idxd_dev); in idxd_user_drv_probe() local [all …]
|
A D | submit.c | 11 static struct idxd_desc *__get_desc(struct idxd_wq *wq, int idx, int cpu) in __get_desc() 36 struct idxd_desc *idxd_alloc_desc(struct idxd_wq *wq, enum idxd_op_type optype) in idxd_alloc_desc() 74 void idxd_free_desc(struct idxd_wq *wq, struct idxd_desc *desc) in idxd_free_desc() 82 static struct idxd_desc *list_abort_desc(struct idxd_wq *wq, struct idxd_irq_entry *ie, in list_abort_desc() 104 static void llist_abort_desc(struct idxd_wq *wq, struct idxd_irq_entry *ie, in llist_abort_desc() 151 int idxd_submit_desc(struct idxd_wq *wq, struct idxd_desc *desc) in idxd_submit_desc()
|
A D | dma.c | 62 static inline void idxd_prep_desc_common(struct idxd_wq *wq, in idxd_prep_desc_common() 84 struct idxd_wq *wq = to_idxd_wq(c); in idxd_dma_submit_memcpy() local 111 struct idxd_wq *wq = to_idxd_wq(chan); in idxd_dma_alloc_chan_resources() local 122 struct idxd_wq *wq = to_idxd_wq(chan); in idxd_dma_free_chan_resources() local 148 struct idxd_wq *wq = to_idxd_wq(c); in idxd_dma_tx_submit() local 218 int idxd_register_dma_channel(struct idxd_wq *wq) in idxd_register_dma_channel() 255 void idxd_unregister_dma_channel(struct idxd_wq *wq) in idxd_unregister_dma_channel() 271 struct idxd_wq *wq = idxd_dev_to_wq(idxd_dev); in idxd_dmaengine_drv_probe() local 327 struct idxd_wq *wq = idxd_dev_to_wq(idxd_dev); in idxd_dmaengine_drv_remove() local
|
A D | sysfs.c | 282 struct idxd_wq *wq = idxd->wqs[i]; in group_work_queues_show() local 423 struct idxd_wq *wq = confdev_to_wq(dev); in wq_clients_show() local 434 struct idxd_wq *wq = confdev_to_wq(dev); in wq_state_show() local 452 struct idxd_wq *wq = confdev_to_wq(dev); in wq_group_id_show() local 464 struct idxd_wq *wq = confdev_to_wq(dev); in wq_group_id_store() local 507 struct idxd_wq *wq = confdev_to_wq(dev); in wq_mode_show() local 516 struct idxd_wq *wq = confdev_to_wq(dev); in wq_mode_store() local 554 struct idxd_wq *wq = idxd->wqs[i]; in total_claimed_wq_size() local 1106 struct idxd_wq *wq = idxd->wqs[i]; in clients_show() local 1347 struct idxd_wq *wq; in idxd_register_wq_devices() local [all …]
|
/linux/fs/btrfs/ |
A D | async-thread.c | 66 bool btrfs_workqueue_normal_congested(const struct btrfs_workqueue *wq) in btrfs_workqueue_normal_congested() 165 static inline void thresh_queue_hook(struct __btrfs_workqueue *wq) in thresh_queue_hook() 177 static inline void thresh_exec_hook(struct __btrfs_workqueue *wq) in thresh_exec_hook() 220 static void run_ordered_work(struct __btrfs_workqueue *wq, in run_ordered_work() 308 struct __btrfs_workqueue *wq; in btrfs_work_helper() local 353 static inline void __btrfs_queue_work(struct __btrfs_workqueue *wq, in __btrfs_queue_work() 369 void btrfs_queue_work(struct btrfs_workqueue *wq, in btrfs_queue_work() 382 __btrfs_destroy_workqueue(struct __btrfs_workqueue *wq) in __btrfs_destroy_workqueue() 389 void btrfs_destroy_workqueue(struct btrfs_workqueue *wq) in btrfs_destroy_workqueue() 399 void btrfs_workqueue_set_max(struct btrfs_workqueue *wq, int limit_active) in btrfs_workqueue_set_max() [all …]
|
/linux/kernel/ |
A D | workqueue.c | 3523 struct workqueue_struct *wq = in rcu_free_wq() local 4295 struct workqueue_struct *wq; in alloc_workqueue() local 4897 struct workqueue_struct *wq; in show_all_workqueues() local 5140 struct workqueue_struct *wq; in workqueue_online_cpu() local 5166 struct workqueue_struct *wq; in workqueue_offline_cpu() local 5258 struct workqueue_struct *wq; in freeze_workqueues_begin() local 5292 struct workqueue_struct *wq; in freeze_workqueues_busy() local 5333 struct workqueue_struct *wq; in thaw_workqueues() local 5360 struct workqueue_struct *wq; in workqueue_apply_unbound_cpumask() local 5460 struct workqueue_struct *wq; member [all …]
|
/linux/fs/ |
A D | io-wq.c | 102 struct io_wq *wq; member 184 struct io_wq *wq = wqe->wq; in io_worker_cancel_cb() local 208 struct io_wq *wq = wqe->wq; in io_worker_exit() local 314 struct io_wq *wq; in create_worker_cb() local 344 struct io_wq *wq = wqe->wq; in io_queue_worker_create() local 441 struct io_wq *wq = wqe->wq; in io_wait_on_hash() local 544 struct io_wq *wq = wqe->wq; in io_worker_handle_work() local 614 struct io_wq *wq = wqe->wq; in io_wqe_worker() local 872 struct io_wq *wq = wqe->wq; in io_run_cancel() local 1129 struct io_wq *wq; in io_wq_create() local [all …]
|
/linux/drivers/infiniband/hw/cxgb4/ |
A D | cq.c | 184 static void insert_recv_cqe(struct t4_wq *wq, struct t4_cq *cq, u32 srqidx) in insert_recv_cqe() 203 int c4iw_flush_rq(struct t4_wq *wq, struct t4_cq *cq, int count) in c4iw_flush_rq() 217 static void insert_sq_cqe(struct t4_wq *wq, struct t4_cq *cq, in insert_sq_cqe() 241 struct t4_wq *wq = &qhp->wq; in c4iw_flush_sq() local 267 static void flush_completed_wrs(struct t4_wq *wq, struct t4_cq *cq) in flush_completed_wrs() 300 static void create_read_req_cqe(struct t4_wq *wq, struct t4_cqe *hw_cqe, in create_read_req_cqe() 312 static void advance_oldest_read(struct t4_wq *wq) in advance_oldest_read() 422 static int cqe_completes_wr(struct t4_cqe *cqe, struct t4_wq *wq) in cqe_completes_wr() 443 void c4iw_count_rcqes(struct t4_cq *cq, struct t4_wq *wq, int *count) in c4iw_count_rcqes() 544 static int poll_cq(struct t4_wq *wq, struct t4_cq *cq, struct t4_cqe *cqe, in poll_cq() [all …]
|
/linux/fs/autofs/ |
A D | waitq.c | 17 struct autofs_wait_queue *wq, *nwq; in autofs_catatonic_mode() local 79 struct autofs_wait_queue *wq, in autofs_notify_daemon() 181 struct autofs_wait_queue *wq; in autofs_find_wait() local 207 struct autofs_wait_queue *wq; in validate_request() local 306 struct autofs_wait_queue *wq; in autofs_wait() local 489 struct autofs_wait_queue *wq, **wql; in autofs_wait_release() local
|