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

12

/freebsd-9.3-release/lib/libthr/thread/
H A Dthr_sleepq.c62 struct sleepqueue *sq; local
64 sq = calloc(1, sizeof(struct sleepqueue));
65 TAILQ_INIT(&sq->sq_blocked);
66 SLIST_INIT(&sq->sq_freeq);
67 return (sq);
71 _sleepq_free(struct sleepqueue *sq) argument
73 free(sq);
100 struct sleepqueue *sq; local
103 LIST_FOREACH(sq, &sc->sc_queues, sq_hash)
104 if (sq
113 struct sleepqueue *sq; local
131 _sleepq_remove(struct sleepqueue *sq, struct pthread *td) argument
150 _sleepq_drop(struct sleepqueue *sq, void (*cb)(struct pthread *, void *arg), void *arg) argument
[all...]
H A Dthr_cond.c217 struct sleepqueue *sq; local
254 sq = _sleepq_lookup(cvp);
256 _sleepq_remove(sq, curthread);
265 sq = _sleepq_lookup(cvp);
267 _sleepq_remove(sq, curthread);
347 struct sleepqueue *sq; local
367 sq = _sleepq_lookup(cvp);
368 if (sq == NULL) {
373 td = _sleepq_first(sq);
375 cvp->__has_user_waiters = _sleepq_remove(sq, t
431 struct sleepqueue *sq; local
[all...]
/freebsd-9.3-release/sys/kern/
H A Dsubr_sleepqueue.c163 static int sleepq_resume_thread(struct sleepqueue *sq, struct thread *td,
224 sleepq_free(struct sleepqueue *sq) argument
227 uma_zfree(sleepq_zone, sq);
251 struct sleepqueue *sq; local
256 LIST_FOREACH(sq, &sc->sc_queues, sq_hash)
257 if (sq->sq_wchan == wchan)
258 return (sq);
285 struct sleepqueue *sq; local
300 sq = sleepq_lookup(wchan);
307 if (sq
380 struct sleepqueue *sq; local
400 struct sleepqueue *sq; local
493 struct sleepqueue *sq; local
686 struct sleepqueue *sq; local
707 sleepq_resume_thread(struct sleepqueue *sq, struct thread *td, int pri) argument
775 struct sleepqueue *sq; local
792 struct sleepqueue *sq; local
811 struct sleepqueue *sq; local
848 struct sleepqueue *sq; local
880 struct sleepqueue *sq; local
949 struct sleepqueue *sq; local
988 struct sleepqueue *sq; local
1173 struct sleepqueue *sq; local
[all...]
H A Dkern_sig.c287 sigqueue_get(sigqueue_t *sq, int signo, ksiginfo_t *si) argument
289 struct proc *p = sq->sq_proc;
293 KASSERT(sq->sq_flags & SQ_INIT, ("sigqueue not inited"));
295 if (!SIGISMEMBER(sq->sq_signals, signo))
298 if (SIGISMEMBER(sq->sq_kill, signo)) {
300 SIGDELSET(sq->sq_kill, signo);
303 TAILQ_FOREACH_SAFE(ksi, &sq->sq_list, ksi_link, next) {
306 TAILQ_REMOVE(&sq->sq_list, ksi, ksi_link);
318 SIGDELSET(sq->sq_signals, signo);
328 sigqueue_t *sq; local
349 sigqueue_add(sigqueue_t *sq, int signo, ksiginfo_t *si) argument
412 sigqueue_flush(sigqueue_t *sq) argument
482 sigqueue_delete_set(sigqueue_t *sq, const sigset_t *set) argument
503 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-9.3-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-9.3-release/contrib/bind9/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-9.3-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-9.3-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-9.3-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...]
H A Dmthca_provider.h275 struct mthca_wq sq; member in struct:mthca_qp
/freebsd-9.3-release/sys/net80211/
H A Dieee80211_superg.c552 ieee80211_ff_age(struct ieee80211com *ic, struct ieee80211_stageq *sq, argument
560 KASSERT(sq->head != NULL, ("stageq empty"));
563 head = sq->head;
564 while ((m = sq->head) != NULL && M_AGE_GET(m) < quanta) {
571 sq->head = m->m_nextpkt;
572 sq->depth--;
576 sq->tail = NULL;
585 stageq_add(struct ieee80211_stageq *sq, struct mbuf *m) argument
588 if (sq->tail != NULL) {
589 sq
601 stageq_remove(struct ieee80211_stageq *sq, struct mbuf *mstaged) argument
660 struct ieee80211_stageq *sq; local
[all...]
/freebsd-9.3-release/sys/sys/
H A Dsleepqueue.h102 void sleepq_free(struct sleepqueue *sq);
/freebsd-9.3-release/contrib/libucl/tests/
H A D3.in25 size: info -sq,
/freebsd-9.3-release/usr.sbin/gstat/
H A Dgstat.c79 void *sp, *sq; local
159 sq = NULL;
160 sq = geom_stats_snapshot_get();
161 if (sq == NULL)
193 geom_stats_snapshot_timestamp(sq, &tq);
204 geom_stats_snapshot_reset(sq);
235 gsq = geom_stats_snapshot_next(sq);
/freebsd-9.3-release/usr.sbin/sysinstall/
H A Dttys.c50 char sq, *line, *p, *q, *cp, *tptr; local
105 sq = *q;
108 *q = sq;
/freebsd-9.3-release/sys/ofed/drivers/infiniband/hw/mlx4/
H A Dqp.c147 return get_wqe(qp, qp->sq.offset + (n << qp->sq.wqe_shift));
170 s = roundup(size, 1U << qp->sq.wqe_shift);
172 ind = (i >> qp->sq.wqe_shift) + n;
173 stamp = ind & qp->sq.wqe_cnt ? cpu_to_be32(0x7fffffff) :
175 buf = get_send_wqe(qp, ind & (qp->sq.wqe_cnt - 1));
176 wqe = buf + (i & ((1 << qp->sq.wqe_shift) - 1));
180 ctrl = buf = get_send_wqe(qp, n & (qp->sq.wqe_cnt - 1));
196 ctrl = wqe = get_send_wqe(qp, n & (qp->sq.wqe_cnt - 1));
221 (n & qp->sq
[all...]
/freebsd-9.3-release/sbin/mdconfig/
H A Dmdconfig.c389 void *sq; local
401 sq = geom_stats_snapshot_get();
402 if (sq == NULL)
406 while ((gsp = geom_stats_snapshot_next(sq)) != NULL) {
460 geom_stats_snapshot_free(sq);
/freebsd-9.3-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:__anon4252
/freebsd-9.3-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...]
/freebsd-9.3-release/contrib/groff/font/devps/generate/
H A Dtextmap314 uni25A1 sq
/freebsd-9.3-release/contrib/groff/font/devps/
H A Dsymbolmap317 uni25A1 sq
/freebsd-9.3-release/sys/netinet/
H A Dsctp_pcb.c3307 struct sctp_queued_to_read *sq, *nsq; local
3619 TAILQ_FOREACH_SAFE(sq, &inp->read_queue, next, nsq) {
3621 if (sq->length)
3624 TAILQ_REMOVE(&inp->read_queue, sq, next);
3625 sctp_free_remote_addr(sq->whoFrom);
3627 so->so_rcv.sb_cc -= sq->length;
3628 if (sq->data) {
3629 sctp_m_freem(sq->data);
3630 sq->data = NULL;
3636 SCTP_ZONE_FREE(SCTP_BASE_INFO(ipi_zone_readq), sq); local
4645 struct sctp_queued_to_read *sq, *nsq; local
4961 SCTP_ZONE_FREE(SCTP_BASE_INFO(ipi_zone_readq), sq); local
[all...]

Completed in 401 milliseconds

12