/freebsd-10.1-release/lib/libthr/thread/ |
H A D | thr_sleepq.c | 63 struct sleepqueue *sq; local 65 sq = calloc(1, sizeof(struct sleepqueue)); 66 TAILQ_INIT(&sq->sq_blocked); 67 SLIST_INIT(&sq->sq_freeq); 68 return (sq); 72 _sleepq_free(struct sleepqueue *sq) argument 74 free(sq); 100 struct sleepqueue *sq; local 102 LIST_FOREACH(sq, &sc->sc_queues, sq_hash) 103 if (sq 118 struct sleepqueue *sq; local 139 _sleepq_remove(struct sleepqueue *sq, struct pthread *td) argument 158 _sleepq_drop(struct sleepqueue *sq, void (*cb)(struct pthread *, void *arg), void *arg) argument [all...] |
H A D | thr_cond.c | 217 struct sleepqueue *sq; local 266 sq = _sleepq_lookup(cvp); 268 _sleepq_remove(sq, curthread); 277 sq = _sleepq_lookup(cvp); 279 _sleepq_remove(sq, curthread); 359 struct sleepqueue *sq; local 379 sq = _sleepq_lookup(cvp); 380 if (sq == NULL) { 385 td = _sleepq_first(sq); 387 cvp->__has_user_waiters = _sleepq_remove(sq, t 443 struct sleepqueue *sq; local [all...] |
/freebsd-10.1-release/contrib/unbound/services/ |
H A D | outside_network.c | 79 struct serviced_query* sq, sldns_buffer* buff); 730 struct serviced_query* sq = (struct serviced_query*)node; local 731 struct service_callback* p = sq->cblist, *np; 732 free(sq->qbuf); 733 free(sq->zone); 739 free(sq); 1212 struct serviced_query* sq = (struct serviced_query*)malloc(sizeof(*sq)); local 1216 if(!sq) 1218 sq 1277 serviced_delete(struct serviced_query* sq) argument 1349 serviced_encode(struct serviced_query* sq, sldns_buffer* buff, int with_edns) argument 1396 serviced_udp_send(struct serviced_query* sq, sldns_buffer* buff) argument 1479 serviced_callbacks(struct serviced_query* sq, int error, struct comm_point* c, struct comm_reply* rep) argument 1568 struct serviced_query* sq = (struct serviced_query*)arg; local 1635 serviced_tcp_initiate(struct outside_network* outnet, struct serviced_query* sq, sldns_buffer* buff) argument 1655 serviced_tcp_send(struct serviced_query* sq, sldns_buffer* buff) argument 1678 struct serviced_query* sq = (struct serviced_query*)arg; local 1835 struct serviced_query* sq; local 1884 callback_list_remove(struct serviced_query* sq, void* cb_arg) argument 1898 outnet_serviced_query_stop(struct serviced_query* sq, void* cb_arg) argument 1957 struct serviced_query* sq; local 1997 serviced_get_mem(struct serviced_query* sq) argument [all...] |
H A D | outside_network.h | 491 * @param sq: serviced query to adjust. 495 void outnet_serviced_query_stop(struct serviced_query* sq, void* cb_arg); 509 * @param sq: serviced query. 512 size_t serviced_get_mem(struct serviced_query* sq);
|
/freebsd-10.1-release/sys/kern/ |
H A D | subr_sleepqueue.c | 161 static int sleepq_resume_thread(struct sleepqueue *sq, struct thread *td, 222 sleepq_free(struct sleepqueue *sq) argument 225 uma_zfree(sleepq_zone, sq); 249 struct sleepqueue *sq; local 254 LIST_FOREACH(sq, &sc->sc_queues, sq_hash) 255 if (sq->sq_wchan == wchan) 256 return (sq); 283 struct sleepqueue *sq; local 299 sq = sleepq_lookup(wchan); 306 if (sq 381 struct sleepqueue *sq; local 401 struct sleepqueue *sq; local 492 struct sleepqueue *sq; local 685 struct sleepqueue *sq; local 706 sleepq_resume_thread(struct sleepqueue *sq, struct thread *td, int pri) argument 774 struct sleepqueue *sq; local 791 struct sleepqueue *sq; local 810 struct sleepqueue *sq; local 847 struct sleepqueue *sq; local 879 struct sleepqueue *sq; local 948 struct sleepqueue *sq; local 987 struct sleepqueue *sq; local 1172 struct sleepqueue *sq; local [all...] |
H A D | kern_sig.c | 292 sigqueue_get(sigqueue_t *sq, int signo, ksiginfo_t *si) argument 294 struct proc *p = sq->sq_proc; 298 KASSERT(sq->sq_flags & SQ_INIT, ("sigqueue not inited")); 300 if (!SIGISMEMBER(sq->sq_signals, signo)) 303 if (SIGISMEMBER(sq->sq_kill, signo)) { 305 SIGDELSET(sq->sq_kill, signo); 308 TAILQ_FOREACH_SAFE(ksi, &sq->sq_list, ksi_link, next) { 311 TAILQ_REMOVE(&sq->sq_list, ksi, ksi_link); 323 SIGDELSET(sq->sq_signals, signo); 333 sigqueue_t *sq; local 354 sigqueue_add(sigqueue_t *sq, int signo, ksiginfo_t *si) argument 417 sigqueue_flush(sigqueue_t *sq) argument 487 sigqueue_delete_set(sigqueue_t *sq, const sigset_t *set) argument 508 sigqueue_delete(sigqueue_t *sq, int signo) argument [all...] |
H A D | kern_condvar.c | 78 struct sleepqueue *sq; local 81 sq = sleepq_lookup(cvp); 83 KASSERT(sq == NULL, ("%s: associated sleep queue non-empty", __func__));
|
/freebsd-10.1-release/contrib/ofed/libmlx4/src/ |
H A D | qp.c | 65 return qp->buf.buf + qp->sq.offset + (n << qp->sq.wqe_shift); 85 qp->sq.head = 0; 86 qp->sq.tail = 0; 96 for (i = 0; i < qp->sq.wqe_cnt; ++i) { 99 ctrl->fence_size = 1 << (qp->sq.wqe_shift - 4); 203 pthread_spin_lock(&qp->sq.lock); 207 ind = qp->sq.head; 210 if (wq_overflow(&qp->sq, nreq, to_mcq(qp->ibv_qp.send_cq))) { 216 if (wr->num_sge > qp->sq [all...] |
H A D | verbs.c | 466 qp->sq_spare_wqes = (2048 >> qp->sq.wqe_shift) + 1; 467 qp->sq.wqe_cnt = align_queue_size(attr->cap.max_send_wr + qp->sq_spare_wqes); 484 if (pthread_spin_init(&qp->sq.lock, PTHREAD_PROCESS_PRIVATE) || 501 cmd.log_sq_stride = qp->sq.wqe_shift; 503 qp->sq.wqe_cnt > 1 << cmd.log_sq_bb_count; 548 free(qp->sq.wrid); 571 init_attr->cap.max_send_wr = qp->sq.max_post; 572 init_attr->cap.max_send_sge = qp->sq.max_gs; 668 free(qp->sq.wrid);
|
/freebsd-10.1-release/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-10.1-release/contrib/ofed/libmthca/src/ |
H A D | qp.c | 68 return qp->buf.buf + qp->send_wqe_offset + (n << qp->sq.wqe_shift); 73 qp->sq.next_ind = 0; 74 qp->sq.last_comp = qp->sq.max - 1; 75 qp->sq.head = 0; 76 qp->sq.tail = 0; 77 qp->sq.last = get_send_wqe(qp, qp->sq.max - 1); 122 pthread_spin_lock(&qp->sq.lock); 124 ind = qp->sq [all...] |
H A D | verbs.c | 526 qp->sq.max = align_queue_size(pd->context, attr->cap.max_send_wr, 0); 534 if (pthread_spin_init(&qp->sq.lock, PTHREAD_PROCESS_PRIVATE) || 548 qp->sq.db_index = mthca_alloc_db(to_mctx(pd->context)->db_tab, 550 &qp->sq.db); 551 if (qp->sq.db_index < 0) 560 cmd.sq_db_page = db_align(qp->sq.db); 562 cmd.sq_db_index = qp->sq.db_index; 576 mthca_set_db_qn(qp->sq.db, MTHCA_DB_TYPE_SQ, qp->ibv_qp.qp_num); 585 qp->sq.max = attr->cap.max_send_wr; 587 qp->sq [all...] |
/freebsd-10.1-release/sys/dev/cxgbe/iw_cxgbe/ |
H A D | qp.c | 79 static void dealloc_host_sq(struct c4iw_rdev *rdev, struct t4_sq *sq) argument 82 contigfree(sq->queue, sq->memsize, M_DEVBUF); 85 static void dealloc_sq(struct c4iw_rdev *rdev, struct t4_sq *sq) argument 88 dealloc_host_sq(rdev, sq); 91 static int alloc_host_sq(struct c4iw_rdev *rdev, struct t4_sq *sq) argument 93 sq->queue = contigmalloc(sq->memsize, M_DEVBUF, M_NOWAIT, 0ul, ~0ul, 96 if (sq->queue) 97 sq 287 build_immd(struct t4_sq *sq, struct fw_ri_immd *immdp, struct ib_send_wr *wr, int max, u32 *plenp) argument 357 build_rdma_send(struct t4_sq *sq, union t4_wr *wqe, struct ib_send_wr *wr, u8 *len16) argument 422 build_rdma_write(struct t4_sq *sq, union t4_wr *wqe, struct ib_send_wr *wr, u8 *len16) argument 509 build_fastreg(struct t4_sq *sq, union t4_wr *wqe, struct ib_send_wr *wr, u8 *len16) argument [all...] |
H A D | t4.h | 338 struct t4_sq sq; member in struct:t4_wq 395 return wq->sq.in_use == 0; 400 return wq->sq.in_use == (wq->sq.size - 1); 405 return wq->sq.size - 1 - wq->sq.in_use; 410 wq->sq.in_use++; 411 if (++wq->sq.pidx == wq->sq.size) 412 wq->sq [all...] |
H A D | cq.c | 208 V_CQE_QPID(wq->sq.qid)); 241 V_CQE_QPID(wq->sq.qid)); 251 struct t4_swsqe *swsqe = &wq->sq.sw_sq[wq->sq.cidx + count]; 252 int in_use = wq->sq.in_use - count; 259 if (swsqe == (wq->sq.sw_sq + wq->sq.size)) 260 swsqe = wq->sq.sw_sq; 314 wq->sq.oldest_read)) && 315 (CQE_QPID(cqe) == wq->sq [all...] |
H A D | ev.c | 55 qhp->attr.state, qhp->wq.sq.qid, CQE_STATUS(err_cqe)); 178 CQE_STATUS(err_cqe), qhp->wq.sq.qid);
|
/freebsd-10.1-release/sys/ofed/drivers/infiniband/hw/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)) & 505 qp_attr->cap.max_send_wr = qp->sq.max; 507 qp_attr->cap.max_send_sge = qp->sq.max_gs; 609 if (qp->sq.max) 610 qp_context->sq_size_stride = ilog2(qp->sq.max) << 3; 611 qp_context->sq_size_stride |= qp->sq.wqe_shift - 4; 730 qp_context->snd_db_index = cpu_to_be32(qp->sq.db_index); 834 mthca_wq_reset(&qp->sq); [all...] |
/freebsd-10.1-release/sys/net80211/ |
H A D | ieee80211_superg.c | 527 ieee80211_ff_age(struct ieee80211com *ic, struct ieee80211_stageq *sq, argument 535 KASSERT(sq->head != NULL, ("stageq empty")); 539 head = sq->head; 540 while ((m = sq->head) != NULL && M_AGE_GET(m) < quanta) { 549 sq->head = m->m_nextpkt; 550 sq->depth--; 553 sq->tail = NULL; 564 stageq_add(struct ieee80211com *ic, struct ieee80211_stageq *sq, struct mbuf *m) argument 570 if (sq->tail != NULL) { 571 sq 583 stageq_remove(struct ieee80211com *ic, struct ieee80211_stageq *sq, struct mbuf *mstaged) argument 644 struct ieee80211_stageq *sq; local [all...] |
/freebsd-10.1-release/contrib/libucl/tests/basic/ |
H A D | 3.in | 25 size: info -sq,
|
/freebsd-10.1-release/usr.sbin/gstat/ |
H A D | gstat.c | 79 void *sp, *sq; local 165 sq = NULL; 166 sq = geom_stats_snapshot_get(); 167 if (sq == NULL) 199 geom_stats_snapshot_timestamp(sq, &tq); 210 geom_stats_snapshot_reset(sq); 243 gsq = geom_stats_snapshot_next(sq);
|
/freebsd-10.1-release/sys/ofed/drivers/infiniband/hw/mlx4/ |
H A D | qp.c | 203 return get_wqe(qp, qp->sq.offset + (n << qp->sq.wqe_shift)); 226 s = roundup(size, 1U << qp->sq.wqe_shift); 228 ind = (i >> qp->sq.wqe_shift) + n; 229 stamp = ind & qp->sq.wqe_cnt ? cpu_to_be32(0x7fffffff) : 231 buf = get_send_wqe(qp, ind & (qp->sq.wqe_cnt - 1)); 232 wqe = buf + (i & ((1 << qp->sq.wqe_shift) - 1)); 236 ctrl = buf = get_send_wqe(qp, n & (qp->sq.wqe_cnt - 1)); 252 ctrl = wqe = get_send_wqe(qp, n & (qp->sq.wqe_cnt - 1)); 277 (n & qp->sq [all...] |
/freebsd-10.1-release/sys/sys/ |
H A D | sleepqueue.h | 100 void sleepq_free(struct sleepqueue *sq);
|
/freebsd-10.1-release/sbin/mdconfig/ |
H A D | mdconfig.c | 412 void *sq; local 424 sq = geom_stats_snapshot_get(); 425 if (sq == NULL) 429 while ((gsp = geom_stats_snapshot_next(sq)) != NULL) { 483 geom_stats_snapshot_free(sq);
|
/freebsd-10.1-release/contrib/texinfo/makeinfo/ |
H A D | lang.h | 49 sa, sd, sg, sh, si, sk, sl, sm, sn, so, sq, sr, ss, st, su, sv, sw, enumerator in enum:__anon4602
|
/freebsd-10.1-release/sys/dev/cxgb/ulp/iw_cxgb/ |
H A D | iw_cxgb_hal.c | 312 wq->sq = malloc(depth * sizeof(struct t3_swsq), M_DEVBUF, M_NOWAIT|M_ZERO); 313 if (!wq->sq) 332 free(wq->sq, M_DEVBUF); 375 free(wq->sq, M_DEVBUF); 447 struct t3_swsq *sqp = wq->sq + Q_PTR2IDX(wq->sq_rptr, wq->sq_size_log2); 450 sqp = wq->sq + Q_PTR2IDX(ptr, wq->sq_size_log2); 454 sqp = wq->sq + Q_PTR2IDX(ptr, wq->sq_size_log2); 1083 sqp = wq->sq + Q_PTR2IDX(ptr, wq->sq_size_log2); 1087 sqp = wq->sq + Q_PTR2IDX(ptr, wq->sq_size_log2); 1093 CTR3(KTR_IW_CXGB, "%s moving cqe into swcq sq id [all...] |