| /freebsd/sys/dev/mlx5/mlx5_core/ |
| H A D | mlx5_wq.c | 33 u32 mlx5_wq_cyc_get_size(struct mlx5_wq_cyc *wq) in mlx5_wq_cyc_get_size()
38 u32 mlx5_cqwq_get_size(struct mlx5_cqwq *wq) in mlx5_cqwq_get_size()
43 u32 mlx5_wq_ll_get_size(struct mlx5_wq_ll *wq) in mlx5_wq_ll_get_size()
48 static u32 mlx5_wq_cyc_get_byte_size(struct mlx5_wq_cyc *wq) in mlx5_wq_cyc_get_byte_size()
53 static u32 mlx5_cqwq_get_byte_size(struct mlx5_cqwq *wq) in mlx5_cqwq_get_byte_size()
58 static u32 mlx5_wq_ll_get_byte_size(struct mlx5_wq_ll *wq) in mlx5_wq_ll_get_byte_size()
64 void *wqc, struct mlx5_wq_cyc *wq, in mlx5_wq_cyc_create()
100 void *cqc, struct mlx5_cqwq *wq, in mlx5_cqwq_create()
137 void *wqc, struct mlx5_wq_ll *wq, in mlx5_wq_ll_create()
|
| H A D | wq.h | 96 mlx5_wq_cyc_ctr2ix(struct mlx5_wq_cyc * wq,u16 ctr) mlx5_wq_cyc_ctr2ix() argument
101 mlx5_wq_cyc_get_wqe(struct mlx5_wq_cyc * wq,u16 ix) mlx5_wq_cyc_get_wqe() argument
114 mlx5_cqwq_get_ci(struct mlx5_cqwq * wq) mlx5_cqwq_get_ci() argument
119 mlx5_cqwq_get_wqe(struct mlx5_cqwq * wq,u32 ix) mlx5_cqwq_get_wqe() argument
124 mlx5_cqwq_get_wrap_cnt(struct mlx5_cqwq * wq) mlx5_cqwq_get_wrap_cnt() argument
129 mlx5_cqwq_pop(struct mlx5_cqwq * wq) mlx5_cqwq_pop() argument
134 mlx5_cqwq_update_db_record(struct mlx5_cqwq * wq) mlx5_cqwq_update_db_record() argument
139 mlx5_wq_ll_is_full(struct mlx5_wq_ll * wq) mlx5_wq_ll_is_full() argument
144 mlx5_wq_ll_is_empty(struct mlx5_wq_ll * wq) mlx5_wq_ll_is_empty() argument
149 mlx5_wq_ll_push(struct mlx5_wq_ll * wq,u16 head_next) mlx5_wq_ll_push() argument
156 mlx5_wq_ll_pop(struct mlx5_wq_ll * wq,__be16 ix,__be16 * next_tail_next) mlx5_wq_ll_pop() argument
163 mlx5_wq_ll_update_db_record(struct mlx5_wq_ll * wq) mlx5_wq_ll_update_db_record() argument
168 mlx5_wq_ll_get_wqe(struct mlx5_wq_ll * wq,u16 ix) mlx5_wq_ll_get_wqe() argument
[all...] |
| H A D | mlx5_srq.c | 61 static void set_wq(void *wq, struct mlx5_srq_attr *in) in set_wq()
87 static void get_wq(void *wq, struct mlx5_srq_attr *in) in get_wq()
151 void *wq; in create_rmp_cmd() local
|
| /freebsd/sys/dev/enic/ |
| H A D | vnic_wq.c | 62 void vnic_wq_free(struct vnic_wq *wq) { in vnic_wq_free()
67 int enic_wq_devcmd2_alloc(struct vnic_dev *vdev, struct vnic_wq *wq, in enic_wq_devcmd2_alloc()
106 void enic_wq_init_start(struct vnic_wq *wq, unsigned int cq_index, in enic_wq_init_start()
128 void vnic_wq_init(struct vnic_wq *wq, unsigned int cq_index, in vnic_wq_init()
139 unsigned int vnic_wq_error_status(struct vnic_wq *wq) in vnic_wq_error_status()
144 void vnic_wq_enable(struct vnic_wq *wq) in vnic_wq_enable()
149 int vnic_wq_disable(struct vnic_wq *wq) in vnic_wq_disable()
167 void vnic_wq_clean(struct vnic_wq *wq) in vnic_wq_clean()
|
| H A D | enic_txrx.c | 87 struct vnic_wq *wq; in enic_isc_txd_encap() local
154 struct vnic_wq *wq; in enic_isc_txd_flush() local
174 struct vnic_wq *wq; in enic_isc_txd_credits_update() local
331 vnic_wq_service(struct vnic_wq *wq, struct cq_desc *cq_desc, in vnic_wq_service()
452 struct vnic_wq *wq; in enic_prep_wq_for_simple_tx() local
|
| H A D | vnic_wq.h | 73 struct vnic_wq wq; member
78 static inline unsigned int vnic_wq_desc_avail(struct vnic_wq *wq) in vnic_wq_desc_avail()
84 static inline unsigned int vnic_wq_desc_used(struct vnic_wq *wq) in vnic_wq_desc_used()
|
| /freebsd/contrib/ofed/libcxgb4/ |
| H A D | cq.c | 42 static void insert_recv_cqe(struct t4_wq *wq, struct t4_cq *cq) in insert_recv_cqe()
59 int c4iw_flush_rq(struct t4_wq *wq, struct t4_cq *cq, int count) in c4iw_flush_rq()
74 static void insert_sq_cqe(struct t4_wq *wq, struct t4_cq *cq, in insert_sq_cqe()
98 struct t4_wq *wq = &qhp->wq; in c4iw_flush_sq() local
126 static void flush_completed_wrs(struct t4_wq *wq, struct t4_cq *cq) in flush_completed_wrs()
163 static void create_read_req_cqe(struct t4_wq *wq, struct t4_cqe *hw_cqe, in create_read_req_cqe()
175 static void advance_oldest_read(struct t4_wq *wq) in advance_oldest_read()
284 static int cqe_completes_wr(struct t4_cqe *cqe, struct t4_wq *wq) in cqe_completes_wr()
300 void c4iw_count_rcqes(struct t4_cq *cq, struct t4_wq *wq, int *count) in c4iw_count_rcqes()
345 static int poll_cq(struct t4_wq *wq, struct t4_cq *cq, struct t4_cqe *cqe, in poll_cq()
[all …]
|
| H A D | t4.h | 363 static inline int t4_rqes_posted(struct t4_wq *wq) in t4_rqes_posted()
368 static inline int t4_rq_empty(struct t4_wq *wq) in t4_rq_empty()
373 static inline int t4_rq_full(struct t4_wq *wq) in t4_rq_full()
378 static inline u32 t4_rq_avail(struct t4_wq *wq) in t4_rq_avail()
383 static inline void t4_rq_produce(struct t4_wq *wq, u8 len16) in t4_rq_produce()
395 static inline void t4_rq_consume(struct t4_wq *wq) in t4_rq_consume()
406 static inline int t4_sq_empty(struct t4_wq *wq) in t4_sq_empty()
411 static inline int t4_sq_full(struct t4_wq *wq) in t4_sq_full()
416 static inline u32 t4_sq_avail(struct t4_wq *wq) in t4_sq_avail()
421 static inline int t4_sq_onchip(struct t4_wq *wq) in t4_sq_onchip()
[all …]
|
| H A D | qp.c | 45 static void copy_wr_to_sq(struct t4_wq *wq, union t4_wr *wqe, u8 len16) in copy_wr_to_sq()
81 static void copy_wr_to_rq(struct t4_wq *wq, union t4_recv_wr *wqe, u8 len16) in copy_wr_to_rq()
|
| /freebsd/cddl/contrib/opensolaris/tools/ctf/cvt/ |
| H A D | ctfmerge.c | 286 finalize_phase_one(workqueue_t *wq) in finalize_phase_one()
334 init_phase_two(workqueue_t *wq) in init_phase_two()
362 wip_save_work(workqueue_t *wq, wip_t *slot, int slotnum) in wip_save_work()
400 worker_runphase1(workqueue_t *wq) in worker_runphase1()
447 worker_runphase2(workqueue_t *wq) in worker_runphase2()
518 worker_thread(workqueue_t *wq) in worker_thread()
552 workqueue_t *wq = arg; in merge_ctf_cb() local
633 wq_init(workqueue_t *wq, int nfiles) in wq_init()
695 start_threads(workqueue_t *wq) in start_threads()
724 join_threads(workqueue_t *wq) in join_threads()
[all …]
|
| /freebsd/sys/compat/linuxkpi/common/include/linux/ |
| H A D | workqueue.h | 63 #define WQ_EXEC_LOCK(wq) mtx_lock(&(wq)->exec_mtx) argument
64 #define WQ_EXEC_UNLOCK(wq) mtx_unlock(&(wq)->exec_mtx) argument
77 struct workqueue_struct *wq; member
138 #define queue_work(wq, work) \ argument
144 #define queue_delayed_work(wq, dwork, delay) \ argument
150 #define queue_work_on(cpu, wq, work) \ argument
156 #define queue_delayed_work_on(cpu, wq, dwork, delay) \ argument
171 #define flush_workqueue(wq) \ argument
174 #define drain_workqueue(wq) do { \ argument
180 #define mod_delayed_work(wq, dwork, delay) ({ \ argument
[all …]
|
| H A D | wait.h | 126 #define init_wait_entry(wq, flags) \ argument
235 __add_wait_queue(wait_queue_head_t *wqh, wait_queue_t *wq) in __add_wait_queue()
241 add_wait_queue(wait_queue_head_t *wqh, wait_queue_t *wq) in add_wait_queue()
250 __add_wait_queue_tail(wait_queue_head_t *wqh, wait_queue_t *wq) in __add_wait_queue_tail()
256 __add_wait_queue_entry_tail(wait_queue_head_t *wqh, wait_queue_entry_t *wq) in __add_wait_queue_entry_tail()
262 __remove_wait_queue(wait_queue_head_t *wqh, wait_queue_t *wq) in __remove_wait_queue()
268 remove_wait_queue(wait_queue_head_t *wqh, wait_queue_t *wq) in remove_wait_queue()
283 #define prepare_to_wait(wqh, wq, state) linux_prepare_to_wait(wqh, wq, state) argument
284 #define finish_wait(wqh, wq) linux_finish_wait(wqh, wq) argument
|
| /freebsd/sys/dev/cxgbe/iw_cxgbe/ |
| H A D | cq.c | 204 static void insert_recv_cqe(struct t4_wq *wq, struct t4_cq *cq) in insert_recv_cqe()
221 int c4iw_flush_rq(struct t4_wq *wq, struct t4_cq *cq, int count) in c4iw_flush_rq()
236 static void insert_sq_cqe(struct t4_wq *wq, struct t4_cq *cq, in insert_sq_cqe()
260 struct t4_wq *wq = &qhp->wq; in c4iw_flush_sq() local
289 static void flush_completed_wrs(struct t4_wq *wq, struct t4_cq *cq) in flush_completed_wrs()
326 static void create_read_req_cqe(struct t4_wq *wq, struct t4_cqe *hw_cqe, in create_read_req_cqe()
338 static void advance_oldest_read(struct t4_wq *wq) in advance_oldest_read()
440 static int cqe_completes_wr(struct t4_cqe *cqe, struct t4_wq *wq) in cqe_completes_wr()
456 void c4iw_count_rcqes(struct t4_cq *cq, struct t4_wq *wq, int *count) in c4iw_count_rcqes()
491 static int poll_cq(struct t4_wq *wq, struct t4_cq *cq, struct t4_cqe *cqe, in poll_cq()
[all …]
|
| H A D | t4.h | 367 static inline int t4_rqes_posted(struct t4_wq *wq) in t4_rqes_posted()
372 static inline int t4_rq_empty(struct t4_wq *wq) in t4_rq_empty()
377 static inline int t4_rq_full(struct t4_wq *wq) in t4_rq_full()
382 static inline u32 t4_rq_avail(struct t4_wq *wq) in t4_rq_avail()
387 static inline void t4_rq_produce(struct t4_wq *wq, u8 len16) in t4_rq_produce()
397 static inline void t4_rq_consume(struct t4_wq *wq) in t4_rq_consume()
405 static inline u16 t4_rq_host_wq_pidx(struct t4_wq *wq) in t4_rq_host_wq_pidx()
410 static inline u16 t4_rq_wq_size(struct t4_wq *wq) in t4_rq_wq_size()
420 static inline int t4_sq_empty(struct t4_wq *wq) in t4_sq_empty()
425 static inline int t4_sq_full(struct t4_wq *wq) in t4_sq_full()
[all …]
|
| /freebsd/sys/compat/linuxkpi/common/src/ |
| H A D | linux_schedule.c | 168 autoremove_wake_function(wait_queue_t * wq,unsigned int state,int flags,void * key __unused) autoremove_wake_function() argument
181 default_wake_function(wait_queue_t * wq,unsigned int state,int flags,void * key __unused) default_wake_function() argument
188 linux_init_wait_entry(wait_queue_t * wq,int flags) linux_init_wait_entry() argument
219 linux_prepare_to_wait(wait_queue_head_t * wqh,wait_queue_t * wq,int state) linux_prepare_to_wait() argument
230 linux_finish_wait(wait_queue_head_t * wqh,wait_queue_t * wq) linux_finish_wait() argument
254 linux_wait_event_common(wait_queue_head_t * wqh,wait_queue_t * wq,int timeout,unsigned int state,spinlock_t * lock) linux_wait_event_common() argument
[all...] |
| H A D | linux_work.c | 95 struct workqueue_struct *wq; in linux_work_exec_unblock() local
131 linux_queue_work_on(int cpu __unused, struct workqueue_struct *wq, in linux_queue_work_on()
178 linux_queue_rcu_work(struct workqueue_struct *wq, struct rcu_work *rwork) in linux_queue_rcu_work()
214 linux_queue_delayed_work_on(int cpu, struct workqueue_struct *wq, in linux_queue_delayed_work_on()
274 struct workqueue_struct *wq; in linux_work_fn() local
654 struct workqueue_struct *wq; in linux_create_workqueue_common() local
674 linux_destroy_workqueue(struct workqueue_struct *wq) in linux_destroy_workqueue()
|
| /freebsd/sys/dev/oce/ |
| H A D | oce_queue.c | 89 struct oce_wq *wq; in oce_queue_init_all() local
166 struct oce_wq *wq; in oce_queue_release_all() local
207 struct oce_wq *wq; in oce_wq_init() local
275 oce_wq_free(struct oce_wq *wq) in oce_wq_free()
311 oce_wq_create(struct oce_wq *wq, struct oce_eq *eq) in oce_wq_create()
354 oce_wq_del(struct oce_wq *wq) in oce_wq_del()
930 oce_start_wq(struct oce_wq *wq) in oce_start_wq()
1020 oce_drain_wq_cq(struct oce_wq *wq) in oce_drain_wq_cq()
|
| H A D | oce_if.c | 642 struct oce_wq *wq = NULL; oce_multiq_start() local
1033 struct oce_wq *wq = sc->wq[wq_index]; oce_tx() local
1231 oce_process_tx_completion(struct oce_wq * wq) oce_process_tx_completion() argument
1257 oce_tx_restart(POCE_SOFTC sc,struct oce_wq * wq) oce_tx_restart() argument
1337 struct oce_wq *wq = arg; oce_tx_task() local
1390 struct oce_wq *wq = (struct oce_wq *)arg; oce_wq_handler() local
1426 oce_multiq_transmit(if_t ifp,struct mbuf * m,struct oce_wq * wq) oce_multiq_transmit() argument
2309 struct oce_wq *wq; oce_eqd_set_periodic() local
2471 struct oce_wq *wq; oce_tx_compl_clean() local
2515 struct oce_wq *wq; oce_if_deactivate() local
2562 struct oce_wq *wq; oce_if_activate() local
[all...] |
| /freebsd/contrib/ofed/libibverbs/ |
| H A D | device.c | 420 struct ibv_wq *wq = event->element.wq; in __ibv_ack_async_event() local
436 int __ibv_init_wq(struct ibv_wq *wq) in __ibv_init_wq()
457 void __ibv_cleanup_wq(struct ibv_wq *wq) in __ibv_cleanup_wq()
|
| /freebsd/sys/dev/mlx5/mlx5_fpga/ |
| H A D | conn.h | 55 struct mlx5_cqwq wq; member
65 struct mlx5_wq_qp wq; member
|
| /freebsd/sys/kern/ |
| H A D | uipc_ktls.c | 2220 struct ktls_wq *wq; in ktls_check_rx() local
2756 struct ktls_wq *wq; in ktls_enqueue_to_free() local
2771 ktls_buffer_alloc(struct ktls_wq *wq, struct mbuf *m) in ktls_buffer_alloc()
2811 ktls_encrypt_record(struct ktls_wq *wq, struct mbuf *m, in ktls_encrypt_record()
2893 struct ktls_wq *wq; in ktls_enqueue() local
3023 ktls_encrypt(struct ktls_wq *wq, struct mbuf *top) in ktls_encrypt()
3152 ktls_encrypt_async(struct ktls_wq *wq, struct mbuf *top) in ktls_encrypt_async()
3276 struct ktls_wq *wq = ctx; in ktls_work_thread() local
|
| /freebsd/sys/dev/mlx5/mlx5_ib/ |
| H A D | mlx5_ib_cq.c | 99 static enum ib_wc_opcode get_umr_comp(struct mlx5_ib_wq *wq, int idx) in get_umr_comp() argument
118 struct mlx5_ib_wq *wq, int idx) in handle_good_req() argument
170 struct mlx5_ib_wq *wq; in handle_responder() local
440 struct mlx5_ib_wq *wq; sw_send_comp() local
470 struct mlx5_ib_wq *wq; sw_recv_comp() local
522 struct mlx5_ib_wq *wq; mlx5_poll_one() local
[all...] |
| /freebsd/sys/dev/ocs_fc/ |
| H A D | ocs_hw_queues.c | 70 hw_wq_t *wq = NULL; in ocs_hw_init_queues() local
548 hw_wq_t *wq = ocs_malloc(hw->os, sizeof(*wq), OCS_M_ZERO | OCS_M_NOWAIT); in hw_new_wq() local
845 hw_del_wq(hw_wq_t *wq) in hw_del_wq()
896 hw_wq_t *wq; in hw_queue_dump() local
979 hw_wq_t *wq = NULL; in ocs_hw_queue_next_wq() local
|
| /freebsd/sys/dev/mana/ |
| H A D | gdma_main.c | 1216 mana_gd_wq_avail_space(struct gdma_queue *wq) in mana_gd_wq_avail_space()
1230 mana_gd_get_wqe_ptr(const struct gdma_queue *wq, uint32_t wqe_offset) in mana_gd_get_wqe_ptr()
1292 mana_gd_write_sgl(struct gdma_queue *wq, uint8_t *wqe_ptr, in mana_gd_write_sgl()
1316 mana_gd_post_work_request(struct gdma_queue *wq, in mana_gd_post_work_request()
|
| /freebsd/sys/ofed/drivers/infiniband/core/ |
| H A D | ib_uverbs_std_types.c | 130 struct ib_wq *wq = uobject->object; in uverbs_free_wq() local
|