Searched refs:sq (Results 1 - 25 of 77) sorted by relevance

1234

/freebsd-11-stable/sys/contrib/ck/include/
H A Dck_sequence.h42 ck_sequence_init(struct ck_sequence *sq) argument
45 ck_pr_store_uint(&sq->sequence, 0);
50 ck_sequence_read_begin(const struct ck_sequence *sq) argument
55 version = ck_pr_load_uint(&sq->sequence);
77 ck_sequence_read_retry(const struct ck_sequence *sq, unsigned int version) argument
85 return ck_pr_load_uint(&sq->sequence) != version;
97 ck_sequence_write_begin(struct ck_sequence *sq) argument
104 ck_pr_store_uint(&sq->sequence, sq->sequence + 1);
113 ck_sequence_write_end(struct ck_sequence *sq) argument
[all...]
/freebsd-11-stable/lib/libthr/thread/
H A Dthr_sleepq.c64 struct sleepqueue *sq; local
66 sq = calloc(1, sizeof(struct sleepqueue));
67 TAILQ_INIT(&sq->sq_blocked);
68 SLIST_INIT(&sq->sq_freeq);
69 return (sq);
73 _sleepq_free(struct sleepqueue *sq) argument
75 free(sq);
101 struct sleepqueue *sq; local
103 LIST_FOREACH(sq, &sc->sc_queues, sq_hash)
104 if (sq
119 struct sleepqueue *sq; local
140 _sleepq_remove(struct sleepqueue *sq, struct pthread *td) argument
159 _sleepq_drop(struct sleepqueue *sq, void (*cb)(struct pthread *, void *arg), void *arg) argument
[all...]
H A Dthr_cond.c267 struct sleepqueue *sq; local
314 sq = _sleepq_lookup(cvp);
315 cvp->__has_user_waiters = _sleepq_remove(sq, curthread);
324 sq = _sleepq_lookup(cvp);
326 _sleepq_remove(sq, curthread);
415 struct sleepqueue *sq; local
435 sq = _sleepq_lookup(cvp);
436 if (sq == NULL) {
441 td = _sleepq_first(sq);
443 cvp->__has_user_waiters = _sleepq_remove(sq, t
499 struct sleepqueue *sq; local
[all...]
/freebsd-11-stable/sys/dev/mlx5/mlx5_en/
H A Dmlx5_en_tx.c32 mlx5e_do_send_cqe(struct mlx5e_sq *sq) argument
34 sq->cev_counter++;
36 if (sq->cev_counter >= sq->cev_factor) {
37 sq->cev_counter = 0;
44 mlx5e_send_nop(struct mlx5e_sq *sq, u32 ds_cnt) argument
46 u16 pi = sq->pc & sq->wq.sz_m1;
47 struct mlx5e_tx_wqe *wqe = mlx5_wq_cyc_get_wqe(&sq->wq, pi);
51 wqe->ctrl.opmod_idx_opcode = cpu_to_be32((sq
84 struct mlx5e_sq *sq; local
131 mlx5e_get_l2_header_size(struct mlx5e_sq *sq, struct mbuf *mb) argument
266 mlx5e_sq_xmit(struct mlx5e_sq *sq, struct mbuf **mbp) argument
497 mlx5e_poll_tx_cq(struct mlx5e_sq *sq, int budget) argument
553 mlx5e_xmit_locked(struct ifnet *ifp, struct mlx5e_sq *sq, struct mbuf *mb) argument
594 struct mlx5e_sq *sq; local
614 struct mlx5e_sq *sq = container_of(mcq, struct mlx5e_sq, cq.mcq); local
[all...]
H A Dmlx5_en_main.c45 struct mlx5e_sq_param sq; member in struct:mlx5e_channel_param
888 sq_stats = &pch->sq[j].stats;
1397 mlx5e_free_sq_db(struct mlx5e_sq *sq) argument
1399 int wq_sz = mlx5_wq_cyc_get_size(&sq->wq);
1403 if (sq->mbuf[x].mbuf != NULL) {
1404 bus_dmamap_unload(sq->dma_tag, sq->mbuf[x].dma_map);
1405 m_freem(sq->mbuf[x].mbuf);
1407 bus_dmamap_destroy(sq->dma_tag, sq
1413 mlx5e_alloc_sq_db(struct mlx5e_sq *sq) argument
1439 mlx5e_update_sq_inline(struct mlx5e_sq *sq) argument
1485 mlx5e_create_sq(struct mlx5e_channel *c, int tc, struct mlx5e_sq_param *param, struct mlx5e_sq *sq) argument
1556 mlx5e_destroy_sq(struct mlx5e_sq *sq) argument
1568 mlx5e_enable_sq(struct mlx5e_sq *sq, struct mlx5e_sq_param *param, int tis_num) argument
1611 mlx5e_modify_sq(struct mlx5e_sq *sq, int curr_state, int next_state) argument
1637 mlx5e_disable_sq(struct mlx5e_sq *sq) argument
1644 mlx5e_open_sq(struct mlx5e_channel *c, int tc, struct mlx5e_sq_param *param, struct mlx5e_sq *sq) argument
1682 mlx5e_sq_send_nops_locked(struct mlx5e_sq *sq, int can_sleep) argument
1710 struct mlx5e_sq *sq = arg; local
1737 mlx5e_drain_sq(struct mlx5e_sq *sq) argument
1800 mlx5e_close_sq_wait(struct mlx5e_sq *sq) argument
2024 struct mlx5e_sq *sq = c->sq + tc; local
2350 mlx5e_refresh_sq_params(struct mlx5e_priv *priv, struct mlx5e_sq *sq) argument
3602 mlx5e_reset_sq_doorbell_record(struct mlx5e_sq *sq) argument
3612 mlx5e_resume_sq(struct mlx5e_sq *sq) argument
[all...]
/freebsd-11-stable/sys/kern/
H A Dsubr_sleepqueue.c165 static int sleepq_resume_thread(struct sleepqueue *sq, struct thread *td,
241 sleepq_free(struct sleepqueue *sq) argument
244 uma_zfree(sleepq_zone, sq);
268 struct sleepqueue *sq; local
273 LIST_FOREACH(sq, &sc->sc_queues, sq_hash)
274 if (sq->sq_wchan == wchan)
275 return (sq);
302 struct sleepqueue *sq; local
318 sq = sleepq_lookup(wchan);
325 if (sq
409 struct sleepqueue *sq; local
429 struct sleepqueue *sq; local
555 struct sleepqueue *sq; local
767 struct sleepqueue *sq; local
788 sleepq_resume_thread(struct sleepqueue *sq, struct thread *td, int pri) argument
856 struct sleepqueue *sq; local
873 struct sleepqueue *sq; local
893 struct sleepqueue *sq; local
955 struct sleepqueue *sq; local
973 sleepq_remove_matching(struct sleepqueue *sq, int queue, bool (*matches)(struct thread *), int pri) argument
1004 struct sleepqueue *sq; local
1054 struct sleepqueue *sq; local
1093 struct sleepqueue *sq; local
1132 struct sleepqueue *sq, *sq1; local
1166 struct sleepqueue *sq; local
1420 struct sleepqueue *sq; local
[all...]
/freebsd-11-stable/contrib/unbound/edns-subnet/
H A Dsubnetmod.c89 struct subnet_qstate *sq = (struct subnet_qstate*)regional_alloc( local
91 if(!sq)
93 qstate->minfo[id] = sq;
94 memset(sq, 0, sizeof(*sq));
95 sq->started_no_cache_store = qstate->no_cache_store;
144 struct subnet_qstate *sq; local
147 if(!(sq=(struct subnet_qstate*)qstate->minfo[id]))
157 if(sq->ecs_server_out.subnet_validdata && ((sq
325 struct subnet_qstate *sq = (struct subnet_qstate*)qstate->minfo[id]; local
401 lookup_and_reply(struct module_qstate *qstate, int id, struct subnet_qstate *sq) argument
469 eval_response(struct module_qstate *qstate, int id, struct subnet_qstate *sq) argument
638 struct subnet_qstate *sq; local
671 struct subnet_qstate *sq; local
701 struct subnet_qstate *sq = (struct subnet_qstate*)qstate->minfo[id]; local
[all...]
/freebsd-11-stable/contrib/unbound/services/
H A Doutside_network.c84 static void serviced_tcp_initiate(struct serviced_query* sq, sldns_buffer* buff);
960 * the callbacks remove references in sq->pending to the waiting_tcp
1525 struct serviced_query* sq = (struct serviced_query*)node; local
1526 struct service_callback* p = sq->cblist, *np;
1527 free(sq->qbuf);
1528 free(sq->zone);
1529 free(sq->tls_auth_name);
1530 edns_opt_list_free(sq->opt_list);
1536 free(sq);
1899 struct outside_network* outnet = pend->sq
1944 pending_udp_query(struct serviced_query* sq, struct sldns_buffer* packet, int timeout, comm_point_callback_type* cb, void* cb_arg) argument
2105 pending_tcp_query(struct serviced_query* sq, sldns_buffer* packet, int timeout, comm_point_callback_type* callback, void* callback_arg) argument
2265 struct serviced_query* sq = (struct serviced_query*)malloc(sizeof(*sq)); local
2356 reuse_tcp_remove_serviced_keep(struct waiting_tcp* w, struct serviced_query* sq) argument
2397 serviced_delete(struct serviced_query* sq) argument
2489 serviced_encode(struct serviced_query* sq, sldns_buffer* buff, int with_edns) argument
2546 serviced_udp_send(struct serviced_query* sq, sldns_buffer* buff) argument
2628 serviced_callbacks(struct serviced_query* sq, int error, struct comm_point* c, struct comm_reply* rep) argument
2721 struct serviced_query* sq = (struct serviced_query*)arg; local
2801 serviced_tcp_initiate(struct serviced_query* sq, sldns_buffer* buff) argument
2819 serviced_tcp_send(struct serviced_query* sq, sldns_buffer* buff) argument
2887 struct serviced_query* sq = (struct serviced_query*)arg; local
3027 struct serviced_query* sq; local
3091 callback_list_remove(struct serviced_query* sq, void* cb_arg) argument
3105 outnet_serviced_query_stop(struct serviced_query* sq, void* cb_arg) argument
3424 struct serviced_query* sq; local
3464 serviced_get_mem(struct serviced_query* sq) argument
[all...]
/freebsd-11-stable/contrib/ofed/libcxgb4/
H A Dcq.c53 V_CQE_QPID(wq->sq.qid));
86 V_CQE_QPID(wq->sq.qid));
104 if (wq->sq.flush_cidx == -1)
105 wq->sq.flush_cidx = wq->sq.cidx;
106 idx = wq->sq.flush_cidx;
107 BUG_ON(idx >= wq->sq.size);
108 while (idx != wq->sq.pidx) {
109 swsqe = &wq->sq.sw_sq[idx];
113 if (wq->sq
[all...]
H A Dverbs.c323 PDBG("%s sqid 0x%x sq key %" PRIx64 " sq db/gts key %" PRIx64
332 qhp->wq.sq.qid = resp.sqid;
333 qhp->wq.sq.size = resp.sq_size;
334 qhp->wq.sq.memsize = resp.sq_memsize;
335 qhp->wq.sq.flags = 0;
347 qhp->wq.sq.udb = dbva;
348 qhp->wq.sq.queue = mmap(NULL, qhp->wq.sq.memsize,
351 if (qhp->wq.sq
[all...]
H A Dt4.h354 struct t4_sq sq; member in struct:t4_wq
408 return wq->sq.in_use == 0;
413 return wq->sq.in_use == (wq->sq.size - 1);
418 return wq->sq.size - 1 - wq->sq.in_use;
423 return wq->sq.flags & T4_SQ_ONCHIP;
428 wq->sq.in_use++;
429 if (++wq->sq.pidx == wq->sq
[all...]
H A Dqp.c52 dst = &wq->sq.queue->flits[wq->sq.wq_pidx *
65 same sq.queue memory twice in this loop */
67 end = (uintptr_t)&wq->sq.queue[wq->sq.size];
74 memcpy(wq->sq.queue, src + len, total - len);
103 static int build_immd(struct t4_sq *sq, struct fw_ri_immd *immdp, argument
158 static int build_rdma_send(struct t4_sq *sq, union t4_wr *wqe, argument
180 ret = build_immd(sq, wqe->send.u.immd_src, wr,
207 static int build_rdma_write(struct t4_sq *sq, unio argument
[all...]
H A Ddev.c288 qhp->wq.sq.qid,
292 qhp->wq.sq.qid,
293 qhp->wq.sq.queue,
294 qhp->wq.sq.sw_sq,
295 qhp->wq.sq.cidx,
296 qhp->wq.sq.pidx,
297 qhp->wq.sq.in_use,
298 qhp->wq.sq.wq_pidx,
299 qhp->wq.sq.size,
300 qhp->wq.sq
[all...]
/freebsd-11-stable/sys/dev/vnic/
H A Dnicvf_queues.c703 struct snd_queue *sq; local
707 sq = &nic->qs->sq[cqe_tx->sq_idx];
709 hdr = (struct sq_hdr_subdesc *)GET_SQ_DESC(sq, cqe_tx->sqe_ptr);
718 dmap = (bus_dmamap_t)sq->snd_buff[cqe_tx->sqe_ptr].dmap;
719 bus_dmamap_unload(sq->snd_buff_dmat, dmap);
721 mbuf = (struct mbuf *)sq->snd_buff[cqe_tx->sqe_ptr].mbuf;
724 sq->snd_buff[cqe_tx->sqe_ptr].mbuf = NULL;
725 nicvf_put_sq_desc(sq, hdr->subdesc_cnt + 1);
740 struct snd_queue *sq local
983 nicvf_xmit_locked(struct snd_queue *sq) argument
1017 struct snd_queue *sq = (struct snd_queue *)arg; local
1043 nicvf_init_snd_queue(struct nicvf *nic, struct snd_queue *sq, int q_len, int qidx) argument
1142 nicvf_free_snd_queue(struct nicvf *nic, struct snd_queue *sq) argument
1411 struct snd_queue *sq; local
1662 nicvf_get_sq_desc(struct snd_queue *sq, int desc_cnt) argument
1676 nicvf_put_sq_desc(struct snd_queue *sq, int desc_cnt) argument
1685 nicvf_get_nxt_sqentry(struct snd_queue *sq, int qentry) argument
1693 nicvf_sq_enable(struct nicvf *nic, struct snd_queue *sq, int qidx) argument
1715 nicvf_sq_free_used_descs(struct nicvf *nic, struct snd_queue *sq, int qidx) argument
1746 nicvf_sq_add_hdr_subdesc(struct snd_queue *sq, int qentry, int subdesc_cnt, struct mbuf *mbuf, int len) argument
1880 nicvf_sq_add_gather_subdesc(struct snd_queue *sq, int qentry, int size, uint64_t data) argument
1897 nicvf_tx_mbuf_locked(struct snd_queue *sq, struct mbuf **mbufp) argument
2212 struct snd_queue *sq; local
[all...]
H A Dnicvf_queues.h353 struct snd_queue sq[MAX_SND_QUEUES_PER_QS]; member in struct:queue_set
375 #define NICVF_TX_LOCK(sq) mtx_lock(&(sq)->mtx)
376 #define NICVF_TX_TRYLOCK(sq) mtx_trylock(&(sq)->mtx)
377 #define NICVF_TX_UNLOCK(sq) mtx_unlock(&(sq)->mtx)
378 #define NICVF_TX_LOCK_ASSERT(sq) mtx_assert(&(sq)->mtx, MA_OWNED)
392 int nicvf_xmit_locked(struct snd_queue *sq);
[all...]
/freebsd-11-stable/contrib/ntp/lib/isc/
H A Dentropy.c194 samplequeue_release(isc_entropy_t *ent, sample_queue_t *sq) { argument
195 REQUIRE(sq->samples != NULL);
196 REQUIRE(sq->extra != NULL);
198 isc_mem_put(ent->mctx, sq->samples, RND_EVENTQSIZE * 4);
199 isc_mem_put(ent->mctx, sq->extra, RND_EVENTQSIZE * 4);
200 sq->samples = NULL;
201 sq->extra = NULL;
205 samplesource_allocate(isc_entropy_t *ent, sample_queue_t *sq) { argument
206 sq->samples = isc_mem_get(ent->mctx, RND_EVENTQSIZE * 4);
207 if (sq
391 estimate_entropy(sample_queue_t *sq, isc_uint32_t t) argument
438 crunchsamples(isc_entropy_t *ent, sample_queue_t *sq) argument
954 sample_queue_t *sq; local
1008 addsample(sample_queue_t *sq, isc_uint32_t sample, isc_uint32_t extra) argument
1027 sample_queue_t *sq; local
1053 sample_queue_t *sq; local
[all...]
/freebsd-11-stable/sys/dev/cxgbe/iw_cxgbe/
H A Dcq.c213 V_CQE_QPID(wq->sq.qid));
246 V_CQE_QPID(wq->sq.qid));
264 if (wq->sq.flush_cidx == -1)
265 wq->sq.flush_cidx = wq->sq.cidx;
266 idx = wq->sq.flush_cidx;
267 BUG_ON(idx >= wq->sq.size);
268 while (idx != wq->sq.pidx) {
269 swsqe = &wq->sq.sw_sq[idx];
273 if (wq->sq
[all...]
H A Dqp.c115 wq->sq.memsize, wq->sq.queue,
116 dma_unmap_addr(&wq->sq, mapping));
119 kfree(wq->sq.sw_sq);
121 c4iw_put_qpid(rdev, wq->sq.qid, uctx);
141 wq->sq.qid = c4iw_get_qpid(rdev, uctx);
142 if (!wq->sq.qid)
152 wq->sq.sw_sq = kzalloc(wq->sq.size * sizeof *wq->sq
335 build_immd(struct t4_sq *sq, struct fw_ri_immd *immdp, struct ib_send_wr *wr, int max, u32 *plenp) argument
405 build_rdma_send(struct t4_sq *sq, union t4_wr *wqe, struct ib_send_wr *wr, u8 *len16) argument
472 build_rdma_write(struct t4_sq *sq, union t4_wr *wqe, struct ib_send_wr *wr, u8 *len16) argument
701 build_memreg(struct t4_sq *sq, union t4_wr *wqe, struct ib_reg_wr *wr, struct c4iw_mr *mhp, u8 *len16, bool dsgl_supported) argument
[all...]
H A Dt4.h364 struct t4_sq sq; member in struct:t4_wq
418 static inline int t4_sq_onchip(struct t4_sq *sq) argument
420 return sq->flags & T4_SQ_ONCHIP;
425 return wq->sq.in_use == 0;
430 return wq->sq.in_use == (wq->sq.size - 1);
435 return wq->sq.size - 1 - wq->sq.in_use;
440 wq->sq.in_use++;
441 if (++wq->sq
[all...]
/freebsd-11-stable/contrib/ofed/libmlx4/
H A Dqp.c66 return qp->buf.buf + qp->sq.offset + (n << qp->sq.wqe_shift);
86 qp->sq.head = 0;
87 qp->sq.tail = 0;
97 for (i = 0; i < qp->sq.wqe_cnt; ++i) {
100 ctrl->fence_size = 1 << (qp->sq.wqe_shift - 4);
227 pthread_spin_lock(&qp->sq.lock);
231 ind = qp->sq.head;
234 if (wq_overflow(&qp->sq, nreq, to_mcq(ibqp->send_cq))) {
240 if (wr->num_sge > qp->sq
[all...]
/freebsd-11-stable/sys/sys/
H A Dsleepqueue.h94 void sleepq_free(struct sleepqueue *sq);
99 int sleepq_remove_matching(struct sleepqueue *sq, int queue,
/freebsd-11-stable/sys/dev/mthca/
H A Dmthca_qp.c220 (n << qp->sq.wqe_shift);
223 (n << qp->sq.wqe_shift)) >>
225 ((qp->send_wqe_offset + (n << qp->sq.wqe_shift)) &
498 qp_attr->cap.max_send_wr = qp->sq.max;
500 qp_attr->cap.max_send_sge = qp->sq.max_gs;
602 if (qp->sq.max)
603 qp_context->sq_size_stride = ilog2(qp->sq.max) << 3;
604 qp_context->sq_size_stride |= qp->sq.wqe_shift - 4;
723 qp_context->snd_db_index = cpu_to_be32(qp->sq.db_index);
824 mthca_wq_reset(&qp->sq);
[all...]
/freebsd-11-stable/sys/dev/mlx5/mlx5_fpga/
H A Dmlx5fpga_conn.c135 *conn->qp.wq.sq.db = cpu_to_be32(conn->qp.sq.pc);
149 ix = conn->qp.sq.pc & (conn->qp.sq.size - 1);
151 ctrl = mlx5_wq_cyc_get_wqe(&conn->qp.wq.sq, ix);
166 ctrl->opmod_idx_opcode = cpu_to_be32(((conn->qp.sq.pc & 0xffff) << 8) |
170 conn->qp.sq.pc++;
171 conn->qp.sq.bufs[ix] = buf;
188 spin_lock_irqsave(&conn->qp.sq.lock, flags);
190 if (conn->qp.sq
[all...]
/freebsd-11-stable/sys/dev/mlx5/mlx5_ib/
H A Dmlx5_ib_qp.c110 return get_wqe(qp, qp->sq.offset + (n << MLX5_IB_SQ_STRIDE));
136 struct mlx5_ib_wq *wq = send ? &qp->sq : &qp->rq;
400 qp->sq.wqe_cnt = wq_size / MLX5_SEND_WQE_BB;
401 if (qp->sq.wqe_cnt > (1 << MLX5_CAP_GEN(dev->mdev, log_max_qp_sz))) {
403 qp->sq.wqe_cnt,
407 qp->sq.wqe_shift = ilog2(MLX5_SEND_WQE_BB);
408 qp->sq.max_gs = get_send_sge(attr, wqe_size);
409 if (qp->sq.max_gs < attr->cap.max_send_sge)
412 attr->cap.max_send_sge = qp->sq.max_gs;
413 qp->sq
1039 create_raw_packet_qp_tis(struct mlx5_ib_dev *dev, struct mlx5_ib_sq *sq, u32 tdn) argument
1049 destroy_raw_packet_qp_tis(struct mlx5_ib_dev *dev, struct mlx5_ib_sq *sq) argument
1055 create_raw_packet_qp_sq(struct mlx5_ib_dev *dev, struct mlx5_ib_sq *sq, void *qpin, struct ib_pd *pd) argument
1122 destroy_raw_packet_qp_sq(struct mlx5_ib_dev *dev, struct mlx5_ib_sq *sq) argument
1238 struct mlx5_ib_sq *sq = &raw_packet_qp->sq; local
1292 struct mlx5_ib_sq *sq = &raw_packet_qp->sq; local
1309 struct mlx5_ib_sq *sq = &raw_packet_qp->sq; local
2167 modify_raw_packet_eth_prio(struct mlx5_core_dev *dev, struct mlx5_ib_sq *sq, u8 sl) argument
2192 modify_raw_packet_tx_affinity(struct mlx5_core_dev *dev, struct mlx5_ib_sq *sq, u8 tx_affinity) argument
2475 modify_raw_packet_qp_sq(struct mlx5_core_dev *dev, struct mlx5_ib_sq *sq, int new_state) argument
2511 struct mlx5_ib_sq *sq = &raw_packet_qp->sq; local
4290 query_raw_packet_qp_sq_state(struct mlx5_ib_dev *dev, struct mlx5_ib_sq *sq, u8 *sq_state) argument
4394 struct mlx5_ib_sq *sq = &raw_packet_qp->sq; local
[all...]
/freebsd-11-stable/sys/net80211/
H A Dieee80211_superg.c624 ieee80211_ff_age(struct ieee80211com *ic, struct ieee80211_stageq *sq, argument
631 if (sq->depth == 0) {
636 KASSERT(sq->head != NULL, ("stageq empty"));
638 head = sq->head;
639 while ((m = sq->head) != NULL && M_AGE_GET(m) < quanta) {
647 sq->head = m->m_nextpkt;
648 sq->depth--;
651 sq->tail = NULL;
662 stageq_add(struct ieee80211com *ic, struct ieee80211_stageq *sq, struct mbuf *m) argument
668 if (sq
681 stageq_remove(struct ieee80211com *ic, struct ieee80211_stageq *sq, struct mbuf *mstaged) argument
757 struct ieee80211_stageq *sq; local
[all...]

Completed in 215 milliseconds

1234