Home
last modified time | relevance | path

Searched refs:sq (Results 1 – 25 of 101) sorted by relevance

12345

/freebsd-12-stable/sys/dev/mlx5/mlx5_en/
Dmlx5_en_tx.c32 mlx5e_do_send_cqe(struct mlx5e_sq *sq) in mlx5e_do_send_cqe() argument
34 sq->cev_counter++; in mlx5e_do_send_cqe()
36 if (sq->cev_counter >= sq->cev_factor) { in mlx5e_do_send_cqe()
37 sq->cev_counter = 0; in mlx5e_do_send_cqe()
44 mlx5e_send_nop(struct mlx5e_sq *sq, u32 ds_cnt) in mlx5e_send_nop() argument
46 u16 pi = sq->pc & sq->wq.sz_m1; in mlx5e_send_nop()
47 struct mlx5e_tx_wqe *wqe = mlx5_wq_cyc_get_wqe(&sq->wq, pi); in mlx5e_send_nop()
51 wqe->ctrl.opmod_idx_opcode = cpu_to_be32((sq->pc << 8) | MLX5_OPCODE_NOP); in mlx5e_send_nop()
52 wqe->ctrl.qpn_ds = cpu_to_be32((sq->sqn << 8) | ds_cnt); in mlx5e_send_nop()
53 if (mlx5e_do_send_cqe(sq)) in mlx5e_send_nop()
[all …]
Dmlx5_en_rl.c89 mlx5e_rl_build_sq_param(rl, &cparam->sq); in mlx5e_rl_build_channel_param()
94 mlx5e_rl_create_sq(struct mlx5e_priv *priv, struct mlx5e_sq *sq, in mlx5e_rl_create_sq() argument
115 &sq->dma_tag))) in mlx5e_rl_create_sq()
119 sq->uar = priv->rl.sq_uar; in mlx5e_rl_create_sq()
121 err = mlx5_wq_cyc_create(mdev, &param->wq, sqc_wq, &sq->wq, in mlx5e_rl_create_sq()
122 &sq->wq_ctrl); in mlx5e_rl_create_sq()
126 sq->wq.db = &sq->wq.db[MLX5_SND_DBR]; in mlx5e_rl_create_sq()
133 err = mlx5e_alloc_sq_db(sq); in mlx5e_rl_create_sq()
137 sq->mkey_be = cpu_to_be32(priv->mr.key); in mlx5e_rl_create_sq()
138 sq->ifp = priv->ifp; in mlx5e_rl_create_sq()
[all …]
Dmlx5_en_main.c45 struct mlx5e_sq_param sq; member
896 sq_stats = &pch->sq[j].stats; in mlx5e_update_stats_locked()
914 struct mlx5e_sq *sq = channel->sq; in mlx5e_update_stats_locked() local
916 if (sq == NULL) in mlx5e_update_stats_locked()
919 sq_stats = &sq->stats; in mlx5e_update_stats_locked()
1536 mlx5e_free_sq_db(struct mlx5e_sq *sq) in mlx5e_free_sq_db() argument
1538 int wq_sz = mlx5_wq_cyc_get_size(&sq->wq); in mlx5e_free_sq_db()
1542 if (sq->mbuf[x].mbuf != NULL) { in mlx5e_free_sq_db()
1543 bus_dmamap_unload(sq->dma_tag, sq->mbuf[x].dma_map); in mlx5e_free_sq_db()
1544 m_freem(sq->mbuf[x].mbuf); in mlx5e_free_sq_db()
[all …]
/freebsd-12-stable/lib/libthr/thread/
Dthr_sleepq.c66 struct sleepqueue *sq; in _sleepq_alloc() local
68 sq = calloc(1, sizeof(struct sleepqueue)); in _sleepq_alloc()
69 TAILQ_INIT(&sq->sq_blocked); in _sleepq_alloc()
70 SLIST_INIT(&sq->sq_freeq); in _sleepq_alloc()
71 return (sq); in _sleepq_alloc()
75 _sleepq_free(struct sleepqueue *sq) in _sleepq_free() argument
77 free(sq); in _sleepq_free()
103 struct sleepqueue *sq; in lookup() local
105 LIST_FOREACH(sq, &sc->sc_queues, sq_hash) in lookup()
106 if (sq->sq_wchan == wchan) in lookup()
[all …]
/freebsd-12-stable/contrib/unbound/edns-subnet/
Dsubnetmod.c90 struct subnet_qstate *sq = (struct subnet_qstate*)regional_alloc( in subnet_new_qstate() local
92 if(!sq) in subnet_new_qstate()
94 qstate->minfo[id] = sq; in subnet_new_qstate()
95 memset(sq, 0, sizeof(*sq)); in subnet_new_qstate()
96 sq->started_no_cache_store = qstate->no_cache_store; in subnet_new_qstate()
97 sq->started_no_cache_lookup = qstate->no_cache_lookup; in subnet_new_qstate()
146 struct subnet_qstate *sq; in ecs_whitelist_check() local
149 if(!(sq=(struct subnet_qstate*)qstate->minfo[id])) in ecs_whitelist_check()
159 sq->subnet_sent_no_subnet = 0; in ecs_whitelist_check()
160 if(sq->ecs_server_out.subnet_validdata && ((sq->subnet_downstream && in ecs_whitelist_check()
[all …]
/freebsd-12-stable/contrib/unbound/services/
Doutside_network.c84 static void serviced_tcp_initiate(struct serviced_query* sq, sldns_buffer* buff);
94 static int serviced_udp_send(struct serviced_query* sq, sldns_buffer* buff);
97 static int serviced_tcp_send(struct serviced_query* sq, sldns_buffer* buff);
100 static void serviced_callbacks(struct serviced_query* sq, int error,
1006 if(outnet->dtenv && pend_tcp && w && w->sq &&
1011 dt_msg_send_outside_query(outnet->dtenv, &w->sq->addr,
1012 &pend_tcp->pi->addr, comm_tcp, w->sq->zone,
1013 w->sq->zonelen, &tmp);
1447 log_assert(!pend->sq->busy);
1448 pend->sq->busy = 1;
[all …]
/freebsd-12-stable/sys/kern/
Dsubr_sleepqueue.c170 static int sleepq_resume_thread(struct sleepqueue *sq, struct thread *td,
246 sleepq_free(struct sleepqueue *sq) in sleepq_free() argument
249 uma_zfree(sleepq_zone, sq); in sleepq_free()
273 struct sleepqueue *sq; in sleepq_lookup() local
278 LIST_FOREACH(sq, &sc->sc_queues, sq_hash) in sleepq_lookup()
279 if (sq->sq_wchan == wchan) in sleepq_lookup()
280 return (sq); in sleepq_lookup()
307 struct sleepqueue *sq; in sleepq_add() local
323 sq = sleepq_lookup(wchan); in sleepq_add()
330 if (sq == NULL) { in sleepq_add()
[all …]
/freebsd-12-stable/sys/dev/vnic/
Dnicvf_queues.c703 struct snd_queue *sq; in nicvf_snd_pkt_handler() local
707 sq = &nic->qs->sq[cqe_tx->sq_idx]; in nicvf_snd_pkt_handler()
709 hdr = (struct sq_hdr_subdesc *)GET_SQ_DESC(sq, cqe_tx->sqe_ptr); in nicvf_snd_pkt_handler()
718 dmap = (bus_dmamap_t)sq->snd_buff[cqe_tx->sqe_ptr].dmap; in nicvf_snd_pkt_handler()
719 bus_dmamap_unload(sq->snd_buff_dmat, dmap); in nicvf_snd_pkt_handler()
721 mbuf = (struct mbuf *)sq->snd_buff[cqe_tx->sqe_ptr].mbuf; in nicvf_snd_pkt_handler()
724 sq->snd_buff[cqe_tx->sqe_ptr].mbuf = NULL; in nicvf_snd_pkt_handler()
725 nicvf_put_sq_desc(sq, hdr->subdesc_cnt + 1); in nicvf_snd_pkt_handler()
740 struct snd_queue *sq = &qs->sq[cq_idx]; in nicvf_cq_intr_handler() local
811 taskqueue_enqueue(sq->snd_taskq, &sq->snd_task); in nicvf_cq_intr_handler()
[all …]
/freebsd-12-stable/contrib/ofed/libcxgb4/
Dcq.c53 V_CQE_QPID(wq->sq.qid)); in insert_recv_cqe()
86 V_CQE_QPID(wq->sq.qid)); in insert_sq_cqe()
104 if (wq->sq.flush_cidx == -1) in c4iw_flush_sq()
105 wq->sq.flush_cidx = wq->sq.cidx; in c4iw_flush_sq()
106 idx = wq->sq.flush_cidx; in c4iw_flush_sq()
107 BUG_ON(idx >= wq->sq.size); in c4iw_flush_sq()
108 while (idx != wq->sq.pidx) { in c4iw_flush_sq()
109 swsqe = &wq->sq.sw_sq[idx]; in c4iw_flush_sq()
113 if (wq->sq.oldest_read == swsqe) { in c4iw_flush_sq()
118 if (++idx == wq->sq.size) in c4iw_flush_sq()
[all …]
Dverbs.c332 qhp->wq.sq.qid = resp.sqid; in create_qp_v0()
333 qhp->wq.sq.size = resp.sq_size; in create_qp_v0()
334 qhp->wq.sq.memsize = resp.sq_memsize; in create_qp_v0()
335 qhp->wq.sq.flags = 0; in create_qp_v0()
347 qhp->wq.sq.udb = dbva; in create_qp_v0()
348 qhp->wq.sq.queue = mmap(NULL, qhp->wq.sq.memsize, in create_qp_v0()
351 if (qhp->wq.sq.queue == MAP_FAILED) in create_qp_v0()
365 qhp->wq.sq.sw_sq = calloc(qhp->wq.sq.size, sizeof (struct t4_swsqe)); in create_qp_v0()
366 if (!qhp->wq.sq.sw_sq) in create_qp_v0()
376 qhp->wq.sq.udb, qhp->wq.sq.queue, in create_qp_v0()
[all …]
Dt4.h354 struct t4_sq sq; member
408 return wq->sq.in_use == 0; in t4_sq_empty()
413 return wq->sq.in_use == (wq->sq.size - 1); in t4_sq_full()
418 return wq->sq.size - 1 - wq->sq.in_use; in t4_sq_avail()
423 return wq->sq.flags & T4_SQ_ONCHIP; in t4_sq_onchip()
428 wq->sq.in_use++; in t4_sq_produce()
429 if (++wq->sq.pidx == wq->sq.size) in t4_sq_produce()
430 wq->sq.pidx = 0; in t4_sq_produce()
431 wq->sq.wq_pidx += DIV_ROUND_UP(len16*16, T4_EQ_ENTRY_SIZE); in t4_sq_produce()
432 if (wq->sq.wq_pidx >= wq->sq.size * T4_SQ_NUM_SLOTS) in t4_sq_produce()
[all …]
Dqp.c52 dst = &wq->sq.queue->flits[wq->sq.wq_pidx * in copy_wr_to_sq()
67 end = (uintptr_t)&wq->sq.queue[wq->sq.size]; in copy_wr_to_sq()
74 memcpy(wq->sq.queue, src + len, total - len); in copy_wr_to_sq()
103 static int build_immd(struct t4_sq *sq, struct fw_ri_immd *immdp, in build_immd() argument
158 static int build_rdma_send(struct t4_sq *sq, union t4_wr *wqe, in build_rdma_send() argument
180 ret = build_immd(sq, wqe->send.u.immd_src, wr, in build_rdma_send()
207 static int build_rdma_write(struct t4_sq *sq, union t4_wr *wqe, in build_rdma_write() argument
221 ret = build_immd(sq, wqe->write.u.immd_src, wr, in build_rdma_write()
298 if (qid == qhp->wq.sq.qid) { in ring_kernel_db()
348 swsqe = &qhp->wq.sq.sw_sq[qhp->wq.sq.pidx]; in c4iw_post_send()
[all …]
/freebsd-12-stable/sys/dev/ice/
Dice_controlq.c37 (qinfo)->sq.head = prefix##_ATQH; \
38 (qinfo)->sq.tail = prefix##_ATQT; \
39 (qinfo)->sq.len = prefix##_ATQLEN; \
40 (qinfo)->sq.bah = prefix##_ATQBAH; \
41 (qinfo)->sq.bal = prefix##_ATQBAL; \
42 (qinfo)->sq.len_mask = prefix##_ATQLEN_ATQLEN_M; \
43 (qinfo)->sq.len_ena_mask = prefix##_ATQLEN_ATQENABLE_M; \
44 (qinfo)->sq.len_crit_mask = prefix##_ATQLEN_ATQCRIT_M; \
45 (qinfo)->sq.head_mask = prefix##_ATQH_ATQH_M; \
95 if (cq->sq.len && cq->sq.len_mask && cq->sq.len_ena_mask) in ice_check_sq_alive()
[all …]
/freebsd-12-stable/sys/contrib/ck/include/
Dck_sequence.h42 ck_sequence_init(struct ck_sequence *sq) in ck_sequence_init() argument
45 ck_pr_store_uint(&sq->sequence, 0); in ck_sequence_init()
50 ck_sequence_read_begin(const struct ck_sequence *sq) in ck_sequence_read_begin() argument
55 version = ck_pr_load_uint(&sq->sequence); in ck_sequence_read_begin()
77 ck_sequence_read_retry(const struct ck_sequence *sq, unsigned int version) in ck_sequence_read_retry() argument
85 return ck_pr_load_uint(&sq->sequence) != version; in ck_sequence_read_retry()
97 ck_sequence_write_begin(struct ck_sequence *sq) in ck_sequence_write_begin() argument
104 ck_pr_store_uint(&sq->sequence, sq->sequence + 1); in ck_sequence_write_begin()
113 ck_sequence_write_end(struct ck_sequence *sq) in ck_sequence_write_end() argument
121 ck_pr_store_uint(&sq->sequence, sq->sequence + 1); in ck_sequence_write_end()
/freebsd-12-stable/contrib/bearssl/src/symcipher/
Daes_ct_cbcdec.c53 uint32_t q[8], sq[8]; in br_aes_ct_cbcdec_run() local
70 memcpy(sq, q, sizeof q); in br_aes_ct_cbcdec_run()
79 iv0 = sq[0]; in br_aes_ct_cbcdec_run()
80 iv1 = sq[2]; in br_aes_ct_cbcdec_run()
81 iv2 = sq[4]; in br_aes_ct_cbcdec_run()
82 iv3 = sq[6]; in br_aes_ct_cbcdec_run()
85 br_enc32le(buf + 16, q[1] ^ sq[0]); in br_aes_ct_cbcdec_run()
86 br_enc32le(buf + 20, q[3] ^ sq[2]); in br_aes_ct_cbcdec_run()
87 br_enc32le(buf + 24, q[5] ^ sq[4]); in br_aes_ct_cbcdec_run()
88 br_enc32le(buf + 28, q[7] ^ sq[6]); in br_aes_ct_cbcdec_run()
[all …]
/freebsd-12-stable/sys/dev/cxgbe/iw_cxgbe/
Dcq.c215 V_CQE_QPID(wq->sq.qid)); in insert_recv_cqe()
248 V_CQE_QPID(wq->sq.qid)); in insert_sq_cqe()
266 if (wq->sq.flush_cidx == -1) in c4iw_flush_sq()
267 wq->sq.flush_cidx = wq->sq.cidx; in c4iw_flush_sq()
268 idx = wq->sq.flush_cidx; in c4iw_flush_sq()
269 BUG_ON(idx >= wq->sq.size); in c4iw_flush_sq()
270 while (idx != wq->sq.pidx) { in c4iw_flush_sq()
271 swsqe = &wq->sq.sw_sq[idx]; in c4iw_flush_sq()
275 if (wq->sq.oldest_read == swsqe) { in c4iw_flush_sq()
280 if (++idx == wq->sq.size) in c4iw_flush_sq()
[all …]
Dt4.h366 struct t4_sq sq; member
420 static inline int t4_sq_onchip(struct t4_sq *sq) in t4_sq_onchip() argument
422 return sq->flags & T4_SQ_ONCHIP; in t4_sq_onchip()
427 return wq->sq.in_use == 0; in t4_sq_empty()
432 return wq->sq.in_use == (wq->sq.size - 1); in t4_sq_full()
437 return wq->sq.size - 1 - wq->sq.in_use; in t4_sq_avail()
442 wq->sq.in_use++; in t4_sq_produce()
443 if (++wq->sq.pidx == wq->sq.size) in t4_sq_produce()
444 wq->sq.pidx = 0; in t4_sq_produce()
445 wq->sq.wq_pidx += DIV_ROUND_UP(len16*16, T4_EQ_ENTRY_SIZE); in t4_sq_produce()
[all …]
Dqp.c117 wq->sq.memsize, wq->sq.queue, in destroy_qp()
118 dma_unmap_addr(&wq->sq, mapping)); in destroy_qp()
121 kfree(wq->sq.sw_sq); in destroy_qp()
123 c4iw_put_qpid(rdev, wq->sq.qid, uctx); in destroy_qp()
143 wq->sq.qid = c4iw_get_qpid(rdev, uctx); in create_qp()
144 if (!wq->sq.qid) in create_qp()
154 wq->sq.sw_sq = kzalloc(wq->sq.size * sizeof *wq->sq.sw_sq, in create_qp()
156 if (!wq->sq.sw_sq) { in create_qp()
180 wq->sq.queue = dma_alloc_coherent(rhp->ibdev.dma_device, wq->sq.memsize, in create_qp()
181 &(wq->sq.dma_addr), GFP_KERNEL); in create_qp()
[all …]
/freebsd-12-stable/contrib/ofed/libmlx4/
Dqp.c66 return qp->buf.buf + qp->sq.offset + (n << qp->sq.wqe_shift); in get_send_wqe()
86 qp->sq.head = 0; in mlx4_init_qp_indices()
87 qp->sq.tail = 0; in mlx4_init_qp_indices()
97 for (i = 0; i < qp->sq.wqe_cnt; ++i) { in mlx4_qp_init_sq_ownership()
100 ctrl->fence_size = 1 << (qp->sq.wqe_shift - 4); in mlx4_qp_init_sq_ownership()
227 pthread_spin_lock(&qp->sq.lock); in mlx4_post_send()
231 ind = qp->sq.head; in mlx4_post_send()
234 if (wq_overflow(&qp->sq, nreq, to_mcq(ibqp->send_cq))) { in mlx4_post_send()
240 if (wr->num_sge > qp->sq.max_gs) { in mlx4_post_send()
252 ctrl = wqe = get_send_wqe(qp, ind & (qp->sq.wqe_cnt - 1)); in mlx4_post_send()
[all …]
/freebsd-12-stable/usr.bin/fortune/tools/
DTroff.mac24 \(sq\|\(sq\|\(sq\|\(sq\|\(sq\|\(sq\|\(sq\|\(sq\|\(sq
/freebsd-12-stable/bin/sh/tests/parser/
Dheredoc2.012 s='ast*que?non' sq=\' dq=\"
20 ${s+'$sq'x'$sq'}
22 )" = ${sq}x${sq}'
35 ${s##'$sq'ast'$sq'}
/freebsd-12-stable/sys/dev/mthca/
Dmthca_qp.c220 (n << qp->sq.wqe_shift); in get_send_wqe()
223 (n << qp->sq.wqe_shift)) >> in get_send_wqe()
225 ((qp->send_wqe_offset + (n << qp->sq.wqe_shift)) & in get_send_wqe()
498 qp_attr->cap.max_send_wr = qp->sq.max; in mthca_query_qp()
500 qp_attr->cap.max_send_sge = qp->sq.max_gs; in mthca_query_qp()
602 if (qp->sq.max) in __mthca_modify_qp()
603 qp_context->sq_size_stride = ilog2(qp->sq.max) << 3; in __mthca_modify_qp()
604 qp_context->sq_size_stride |= qp->sq.wqe_shift - 4; in __mthca_modify_qp()
723 qp_context->snd_db_index = cpu_to_be32(qp->sq.db_index); in __mthca_modify_qp()
824 mthca_wq_reset(&qp->sq); in __mthca_modify_qp()
[all …]
/freebsd-12-stable/sys/net80211/
Dieee80211_superg.c638 ieee80211_ff_age(struct ieee80211com *ic, struct ieee80211_stageq *sq, in ieee80211_ff_age() argument
645 if (sq->depth == 0) { in ieee80211_ff_age()
650 KASSERT(sq->head != NULL, ("stageq empty")); in ieee80211_ff_age()
652 head = sq->head; in ieee80211_ff_age()
653 while ((m = sq->head) != NULL && M_AGE_GET(m) < quanta) { in ieee80211_ff_age()
661 sq->head = m->m_nextpkt; in ieee80211_ff_age()
662 sq->depth--; in ieee80211_ff_age()
665 sq->tail = NULL; in ieee80211_ff_age()
676 stageq_add(struct ieee80211com *ic, struct ieee80211_stageq *sq, struct mbuf *m) in stageq_add() argument
682 if (sq->tail != NULL) { in stageq_add()
[all …]
/freebsd-12-stable/sys/dev/mlx5/mlx5_ib/
Dmlx5_ib_qp.c110 return get_wqe(qp, qp->sq.offset + (n << MLX5_IB_SQ_STRIDE)); in mlx5_get_send_wqe()
136 struct mlx5_ib_wq *wq = send ? &qp->sq : &qp->rq; in mlx5_ib_read_user_wqe()
400 qp->sq.wqe_cnt = wq_size / MLX5_SEND_WQE_BB; in calc_sq_size()
401 if (qp->sq.wqe_cnt > (1 << MLX5_CAP_GEN(dev->mdev, log_max_qp_sz))) { in calc_sq_size()
403 qp->sq.wqe_cnt, in calc_sq_size()
407 qp->sq.wqe_shift = ilog2(MLX5_SEND_WQE_BB); in calc_sq_size()
408 qp->sq.max_gs = get_send_sge(attr, wqe_size); in calc_sq_size()
409 if (qp->sq.max_gs < attr->cap.max_send_sge) in calc_sq_size()
412 attr->cap.max_send_sge = qp->sq.max_gs; in calc_sq_size()
413 qp->sq.max_post = wq_size / wqe_size; in calc_sq_size()
[all …]
/freebsd-12-stable/sys/dev/mlx5/mlx5_fpga/
Dmlx5fpga_conn.c135 *conn->qp.wq.sq.db = cpu_to_be32(conn->qp.sq.pc); in mlx5_fpga_conn_notify_hw()
149 ix = conn->qp.sq.pc & (conn->qp.sq.size - 1); in mlx5_fpga_conn_post_send()
151 ctrl = mlx5_wq_cyc_get_wqe(&conn->qp.wq.sq, ix); in mlx5_fpga_conn_post_send()
166 ctrl->opmod_idx_opcode = cpu_to_be32(((conn->qp.sq.pc & 0xffff) << 8) | in mlx5_fpga_conn_post_send()
170 conn->qp.sq.pc++; in mlx5_fpga_conn_post_send()
171 conn->qp.sq.bufs[ix] = buf; in mlx5_fpga_conn_post_send()
188 spin_lock_irqsave(&conn->qp.sq.lock, flags); in mlx5_fpga_conn_send()
190 if (conn->qp.sq.pc - conn->qp.sq.cc >= conn->qp.sq.size) { in mlx5_fpga_conn_send()
191 list_add_tail(&buf->list, &conn->qp.sq.backlog); in mlx5_fpga_conn_send()
198 spin_unlock_irqrestore(&conn->qp.sq.lock, flags); in mlx5_fpga_conn_send()
[all …]

12345