Searched refs:send_queue (Results 1 - 18 of 18) sorted by relevance

/freebsd-10.3-release/sys/cam/
H A Dcam_queue.c234 if (camq_init(&devq->send_queue, devices) != 0)
245 camq_fini(&devq->send_queue);
255 retval = camq_resize(&camq->send_queue, devices);
H A Dcam_queue.h74 struct camq send_queue; member in struct:cam_devq
H A Dcam_xpt.c333 xpt_schedule_dev(&devq->send_queue,
3210 devq->send_queue.qfrozen_cnt++;
3211 while ((devq->send_queue.entries > 0)
3213 && (devq->send_queue.qfrozen_cnt <= 1)) {
3218 device = (struct cam_ed *)camq_remove(&devq->send_queue,
3316 devq->send_queue.qfrozen_cnt--;
4319 camq_remove(&devq->send_queue, dev->devq_entry.index);
4346 freeze = (devq->send_queue.qfrozen_cnt += count);
4429 if (devq->send_queue.qfrozen_cnt <= 0) {
4432 devq->send_queue
[all...]
/freebsd-10.3-release/sys/ofed/drivers/infiniband/core/
H A Dmad.c1023 mad_send_wr->mad_list.mad_queue = &qp_info->send_queue;
1039 spin_lock_irqsave(&qp_info->send_queue.lock, flags);
1040 if (qp_info->send_queue.count < qp_info->send_queue.max_active) {
1043 list = &qp_info->send_queue.list;
1050 qp_info->send_queue.count++;
1053 spin_unlock_irqrestore(&qp_info->send_queue.lock, flags);
2110 struct ib_mad_queue *send_queue; local
2119 send_queue = mad_list->mad_queue;
2120 qp_info = send_queue
[all...]
H A Dmad_priv.h192 struct ib_mad_queue send_queue; member in struct:ib_mad_qp_info
/freebsd-10.3-release/usr.sbin/bsnmpd/modules/snmp_hast/
H A Dhast_snmp.c83 uint32_t send_queue; member in struct:hast_snmp_resource
355 res->send_queue =
525 value->v.uint32 = res->send_queue;
/freebsd-10.3-release/tools/tools/net80211/w00t/expand/
H A Dexpand.c304 void send_queue(struct params *p) function
364 send_queue(p);
388 send_queue(p);
/freebsd-10.3-release/tools/tools/net80211/w00t/redir/
H A Dredir.c321 void send_queue(struct params *p) function
420 send_queue(p);
557 send_queue(p);
/freebsd-10.3-release/sys/netinet/
H A Dsctp_timer.c693 if (TAILQ_EMPTY(&stcb->asoc.send_queue)) {
696 chk->rec.data.fast_retran_tsn = (TAILQ_FIRST(&stcb->asoc.send_queue))->rec.data.TSN_seq;
1372 if ((TAILQ_EMPTY(&stcb->asoc.send_queue)) &&
1422 (TAILQ_EMPTY(&stcb->asoc.send_queue)) &&
1547 if (TAILQ_EMPTY(&asoc->send_queue) &&
H A Dsctp_input.c316 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) {
318 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next);
949 if (!TAILQ_EMPTY(&asoc->send_queue) ||
1034 if (!TAILQ_EMPTY(&asoc->send_queue) ||
3035 lchk = TAILQ_LAST(&stcb->asoc.send_queue, sctpchunk_listhead);
3202 if (!TAILQ_EMPTY(&asoc->send_queue) ||
3324 if (TAILQ_EMPTY(&stcb->asoc.send_queue)) {
3327 tp1->rec.data.fast_retran_tsn = (TAILQ_FIRST(&stcb->asoc.send_queue))->rec.data.TSN_seq;
4996 if (TAILQ_EMPTY(&stcb->asoc.send_queue) &&
5083 if (TAILQ_EMPTY(&stcb->asoc.send_queue)
[all...]
H A Dsctp_output.c6198 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) {
6673 if (TAILQ_EMPTY(&asoc->send_queue) &&
6732 if (TAILQ_EMPTY(&asoc->send_queue) &&
6963 TAILQ_REMOVE(&asoc->send_queue, data_list[i], sctp_next);
7162 /* Move from the stream to the send_queue keeping track of the total */
7647 TAILQ_INSERT_TAIL(&asoc->send_queue, chk, sctp_next);
7777 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) {
7847 * stream queues into the general send_queue
7863 TAILQ_EMPTY(&asoc->send_queue) &&
7899 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_nex
[all...]
H A Dsctp_cc_functions.c203 lchk = TAILQ_FIRST(&asoc->send_queue);
1710 lchk = TAILQ_FIRST(&asoc->send_queue);
2243 lchk = TAILQ_FIRST(&asoc->send_queue);
H A Dsctp_indata.c2945 tp1 = TAILQ_FIRST(&stcb->asoc.send_queue);
3326 if (TAILQ_EMPTY(&asoc->send_queue)) {
3345 ttt = TAILQ_FIRST(&asoc->send_queue);
3956 if (TAILQ_EMPTY(&asoc->send_queue) && TAILQ_EMPTY(&asoc->sent_queue)) {
4223 TAILQ_EMPTY(&asoc->send_queue) &&
4667 if (TAILQ_EMPTY(&asoc->send_queue) && TAILQ_EMPTY(&asoc->sent_queue)) {
H A Dsctp_usrreq.c113 TAILQ_FOREACH(chk, &stcb->asoc.send_queue, sctp_next) {
754 if (TAILQ_EMPTY(&asoc->send_queue) &&
820 if (TAILQ_EMPTY(&asoc->send_queue) &&
979 TAILQ_EMPTY(&asoc->send_queue) &&
1013 if (TAILQ_EMPTY(&asoc->send_queue) &&
4789 if (!TAILQ_EMPTY(&stcb->asoc.send_queue) ||
5090 if (TAILQ_EMPTY(&stcb->asoc.send_queue) &&
6026 if (TAILQ_EMPTY(&stcb->asoc.send_queue) &&
H A Dsctp_structs.h810 struct sctpchunk_listhead send_queue; member in struct:sctp_association
H A Dsctputil.c1164 TAILQ_INIT(&asoc->send_queue);
2428 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) {
3861 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) {
3862 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next);
4896 TAILQ_FOREACH_SAFE(tp1, &stcb->asoc.send_queue, sctp_next, tp2) {
4925 TAILQ_REMOVE(&stcb->asoc.send_queue, tp1, sctp_next);
H A Dsctp_pcb.c3446 } else if (TAILQ_EMPTY(&asoc->asoc.send_queue) &&
3498 if (TAILQ_EMPTY(&asoc->asoc.send_queue) &&
5012 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) {
5020 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next);
/freebsd-10.3-release/sys/netinet6/
H A Dsctp6_usrreq.c235 TAILQ_FOREACH(chk, &stcb->asoc.send_queue, sctp_next) {

Completed in 308 milliseconds