/freebsd-11-stable/sys/contrib/ck/include/ |
H A D | ck_sequence.h | 42 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 D | thr_sleepq.c | 64 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 D | thr_cond.c | 267 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 D | mlx5_en_tx.c | 32 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 D | mlx5_en_main.c | 45 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 D | subr_sleepqueue.c | 165 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 D | subnetmod.c | 89 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 D | outside_network.c | 84 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 D | cq.c | 53 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 D | verbs.c | 323 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 D | t4.h | 354 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 D | qp.c | 52 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 D | dev.c | 288 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 D | nicvf_queues.c | 703 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 D | nicvf_queues.h | 353 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 D | entropy.c | 194 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 D | cq.c | 213 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 D | qp.c | 115 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 D | t4.h | 364 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 D | qp.c | 66 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 D | sleepqueue.h | 94 void sleepq_free(struct sleepqueue *sq); 99 int sleepq_remove_matching(struct sleepqueue *sq, int queue,
|
/freebsd-11-stable/sys/dev/mthca/ |
H A D | mthca_qp.c | 220 (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 D | mlx5fpga_conn.c | 135 *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 D | mlx5_ib_qp.c | 110 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 D | ieee80211_superg.c | 624 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...] |