| /freebsd-13-stable/sys/dev/mlx5/mlx5_core/ |
| HD | 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()
|
| HD | wq.h | 96 static inline u16 mlx5_wq_cyc_ctr2ix(struct mlx5_wq_cyc *wq, u16 ctr) in mlx5_wq_cyc_ctr2ix() 101 static inline void *mlx5_wq_cyc_get_wqe(struct mlx5_wq_cyc *wq, u16 ix) in mlx5_wq_cyc_get_wqe() 114 static inline u32 mlx5_cqwq_get_ci(struct mlx5_cqwq *wq) in mlx5_cqwq_get_ci() 119 static inline void *mlx5_cqwq_get_wqe(struct mlx5_cqwq *wq, u32 ix) in mlx5_cqwq_get_wqe() 124 static inline u32 mlx5_cqwq_get_wrap_cnt(struct mlx5_cqwq *wq) in mlx5_cqwq_get_wrap_cnt() 129 static inline void mlx5_cqwq_pop(struct mlx5_cqwq *wq) in mlx5_cqwq_pop() 134 static inline void mlx5_cqwq_update_db_record(struct mlx5_cqwq *wq) in mlx5_cqwq_update_db_record() 139 static inline int mlx5_wq_ll_is_full(struct mlx5_wq_ll *wq) in mlx5_wq_ll_is_full() 144 static inline int mlx5_wq_ll_is_empty(struct mlx5_wq_ll *wq) in mlx5_wq_ll_is_empty() 149 static inline void mlx5_wq_ll_push(struct mlx5_wq_ll *wq, u16 head_next) in mlx5_wq_ll_push() [all …]
|
| HD | 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-13-stable/contrib/ofed/libcxgb4/ |
| HD | 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 …]
|
| HD | 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 …]
|
| HD | 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-13-stable/cddl/contrib/opensolaris/tools/ctf/cvt/ |
| HD | 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-13-stable/sys/compat/linuxkpi/common/include/linux/ |
| HD | 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 …]
|
| HD | 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-13-stable/sys/dev/cxgbe/iw_cxgbe/ |
| HD | cq.c | 202 static void insert_recv_cqe(struct t4_wq *wq, struct t4_cq *cq) in insert_recv_cqe() 219 int c4iw_flush_rq(struct t4_wq *wq, struct t4_cq *cq, int count) in c4iw_flush_rq() 234 static void insert_sq_cqe(struct t4_wq *wq, struct t4_cq *cq, in insert_sq_cqe() 258 struct t4_wq *wq = &qhp->wq; in c4iw_flush_sq() local 287 static void flush_completed_wrs(struct t4_wq *wq, struct t4_cq *cq) in flush_completed_wrs() 324 static void create_read_req_cqe(struct t4_wq *wq, struct t4_cqe *hw_cqe, in create_read_req_cqe() 336 static void advance_oldest_read(struct t4_wq *wq) in advance_oldest_read() 438 static int cqe_completes_wr(struct t4_cqe *cqe, struct t4_wq *wq) in cqe_completes_wr() 454 void c4iw_count_rcqes(struct t4_cq *cq, struct t4_wq *wq, int *count) in c4iw_count_rcqes() 489 static int poll_cq(struct t4_wq *wq, struct t4_cq *cq, struct t4_cqe *cqe, in poll_cq() [all …]
|
| HD | 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-13-stable/sys/compat/linuxkpi/common/src/ |
| HD | linux_schedule.c | 169 autoremove_wake_function(wait_queue_t *wq, unsigned int state, int flags, in autoremove_wake_function() 182 default_wake_function(wait_queue_t *wq, unsigned int state, int flags, in default_wake_function() 189 linux_init_wait_entry(wait_queue_t *wq, int flags) in linux_init_wait_entry() 220 linux_prepare_to_wait(wait_queue_head_t *wqh, wait_queue_t *wq, int state) in linux_prepare_to_wait() 231 linux_finish_wait(wait_queue_head_t *wqh, wait_queue_t *wq) in linux_finish_wait() 255 linux_wait_event_common(wait_queue_head_t *wqh, wait_queue_t *wq, int timeout, in linux_wait_event_common()
|
| HD | 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 622 struct workqueue_struct *wq; in linux_create_workqueue_common() local 642 linux_destroy_workqueue(struct workqueue_struct *wq) in linux_destroy_workqueue()
|
| /freebsd-13-stable/sys/dev/oce/ |
| HD | 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() 932 oce_start_wq(struct oce_wq *wq) in oce_start_wq() 1022 oce_drain_wq_cq(struct oce_wq *wq) in oce_drain_wq_cq()
|
| HD | oce_if.c | 644 struct oce_wq *wq = NULL; in oce_multiq_start() local 1035 struct oce_wq *wq = sc->wq[wq_index]; in oce_tx() local 1233 oce_process_tx_completion(struct oce_wq *wq) in oce_process_tx_completion() 1259 oce_tx_restart(POCE_SOFTC sc, struct oce_wq *wq) in oce_tx_restart() 1339 struct oce_wq *wq = arg; in oce_tx_task() local 1392 struct oce_wq *wq = (struct oce_wq *)arg; in oce_wq_handler() local 1428 oce_multiq_transmit(struct ifnet *ifp, struct mbuf *m, struct oce_wq *wq) in oce_multiq_transmit() 2314 struct oce_wq *wq; in oce_eqd_set_periodic() local 2476 struct oce_wq *wq; in oce_tx_compl_clean() local 2520 struct oce_wq *wq; in oce_if_deactivate() local [all …]
|
| /freebsd-13-stable/sys/dev/mlx5/mlx5_fpga/ |
| HD | conn.h | 55 struct mlx5_cqwq wq; member 65 struct mlx5_wq_qp wq; member
|
| /freebsd-13-stable/sys/dev/mlx5/mlx5_ib/ |
| HD | mlx5_ib_cq.c | 98 static enum ib_wc_opcode get_umr_comp(struct mlx5_ib_wq *wq, int idx) in get_umr_comp() 117 struct mlx5_ib_wq *wq, int idx) in handle_good_req() 169 struct mlx5_ib_wq *wq; in handle_responder() local 439 struct mlx5_ib_wq *wq; in sw_send_comp() local 469 struct mlx5_ib_wq *wq; in sw_recv_comp() local 521 struct mlx5_ib_wq *wq; in mlx5_poll_one() local
|
| /freebsd-13-stable/sys/kern/ |
| HD | uipc_ktls.c | 1681 struct ktls_wq *wq; in ktls_check_rx() local 2090 struct ktls_wq *wq; in ktls_enqueue_to_free() local 2125 struct ktls_wq *wq; in ktls_enqueue() local 2366 struct ktls_wq *wq = ctx; in ktls_work_thread() local
|
| /freebsd-13-stable/sys/dev/ocs_fc/ |
| HD | 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
|
| HD | ocs_ddump.c | 558 hw_wq_t *wq; in hw_queue_ddump() local
|
| /freebsd-13-stable/contrib/ofed/libibverbs/ |
| HD | device.c | 381 struct ibv_wq *wq = event->element.wq; in __ibv_ack_async_event() local
|
| /freebsd-13-stable/sys/dev/mlx5/mlx5_en/ |
| HD | en.h | 647 struct mlx5_wq_param wq; member 652 struct mlx5_wq_param wq; member 657 struct mlx5_wq_param wq; member 736 struct mlx5_cqwq wq; member 760 struct mlx5_wq_ll wq; member 816 struct mlx5_wq_cyc wq; member 874 struct mlx5_wq_cyc wq; member 1115 struct workqueue_struct *wq; member
|
| HD | en_hw_tls.h | 84 struct workqueue_struct *wq; member
|
| /freebsd-13-stable/sys/dev/mlx4/mlx4_ib/ |
| HD | mlx4_ib_cq.c | 610 struct mlx4_ib_wq *wq; in mlx4_ib_qp_sw_comp() local 662 struct mlx4_ib_wq *wq; in mlx4_ib_poll_one() local
|
| /freebsd-13-stable/contrib/ofed/libmlx5/ |
| HD | cq.c | 106 static inline void handle_good_req(struct ibv_wc *wc, struct mlx5_cqe64 *cqe, struct mlx5_wq *wq, i… in handle_good_req() 147 struct mlx5_wq *wq; in handle_responder_lazy() local 188 struct mlx5_wq *wq; in handle_responder() local 524 struct mlx5_wq *wq; in mlx5_parse_cqe() local
|