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

12

/freebsd-10.1-release/lib/libthr/thread/
H A Dthr_sleepq.c63 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 Dthr_cond.c217 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 Doutside_network.c79 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 Doutside_network.h491 * @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 Dsubr_sleepqueue.c161 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 Dkern_sig.c292 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 Dkern_condvar.c78 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 Dqp.c65 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 Dverbs.c466 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 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-10.1-release/contrib/ofed/libmthca/src/
H A Dqp.c68 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 Dverbs.c526 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 Dqp.c79 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 Dt4.h338 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 Dcq.c208 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 Dev.c55 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 Dmthca_qp.c220 (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 Dieee80211_superg.c527 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 D3.in25 size: info -sq,
/freebsd-10.1-release/usr.sbin/gstat/
H A Dgstat.c79 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 Dqp.c203 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 Dsleepqueue.h100 void sleepq_free(struct sleepqueue *sq);
/freebsd-10.1-release/sbin/mdconfig/
H A Dmdconfig.c412 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 Dlang.h49 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 Diw_cxgb_hal.c312 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...]

Completed in 319 milliseconds

12