Home
last modified time | relevance | path

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

/freebsd-9-stable/sys/cam/
Dcam_queue.c233 if (camq_init(&devq->send_queue, devices) != 0) in cam_devq_init()
243 camq_fini(&devq->send_queue); in cam_devq_free()
252 retval = camq_resize(&camq->send_queue, devices); in cam_devq_resize()
Dcam_queue.h72 struct camq send_queue; member
Dcam_xpt.c316 xpt_schedule_dev(&devq->send_queue, in xpt_schedule_devq()
3268 devq->send_queue.qfrozen_cnt++; in xpt_run_devq()
3269 while ((devq->send_queue.entries > 0) in xpt_run_devq()
3271 && (devq->send_queue.qfrozen_cnt <= 1)) { in xpt_run_devq()
3277 qinfo = (struct cam_ed_qinfo *)camq_remove(&devq->send_queue, in xpt_run_devq()
3373 devq->send_queue.qfrozen_cnt--; in xpt_run_devq()
4244 camq_remove(&dev->sim->devq->send_queue, in xpt_freeze_devq()
4255 sim->devq->send_queue.qfrozen_cnt += count; in xpt_freeze_simq()
4256 return (sim->devq->send_queue.qfrozen_cnt); in xpt_freeze_simq()
4327 sendq = &(sim->devq->send_queue); in xpt_release_simq()
[all …]
/freebsd-9-stable/sys/ofed/drivers/infiniband/core/
Dmad.c1023 mad_send_wr->mad_list.mad_queue = &qp_info->send_queue; in ib_send_mad()
1039 spin_lock_irqsave(&qp_info->send_queue.lock, flags); in ib_send_mad()
1040 if (qp_info->send_queue.count < qp_info->send_queue.max_active) { in ib_send_mad()
1043 list = &qp_info->send_queue.list; in ib_send_mad()
1050 qp_info->send_queue.count++; in ib_send_mad()
1053 spin_unlock_irqrestore(&qp_info->send_queue.lock, flags); in ib_send_mad()
2110 struct ib_mad_queue *send_queue; in ib_mad_send_done_handler() local
2119 send_queue = mad_list->mad_queue; in ib_mad_send_done_handler()
2120 qp_info = send_queue->qp_info; in ib_mad_send_done_handler()
2130 spin_lock_irqsave(&send_queue->lock, flags); in ib_mad_send_done_handler()
[all …]
Dmad_priv.h192 struct ib_mad_queue send_queue; member
/freebsd-9-stable/tools/tools/net80211/w00t/expand/
Dexpand.c304 void send_queue(struct params *p) in send_queue() function
364 send_queue(p); in read_wifi()
388 send_queue(p); in own()
/freebsd-9-stable/usr.sbin/bsnmpd/modules/snmp_hast/
Dhast_snmp.c83 uint32_t send_queue; member
355 res->send_queue = in update_resources()
525 value->v.uint32 = res->send_queue; in op_hastResourceTable()
/freebsd-9-stable/tools/tools/net80211/w00t/redir/
Dredir.c321 void send_queue(struct params *p) in send_queue() function
420 send_queue(p); in read_wifi()
557 send_queue(p); in read_buddy_data()
/freebsd-9-stable/sys/netinet/
Dsctp_timer.c679 if (TAILQ_EMPTY(&stcb->asoc.send_queue)) { in sctp_mark_all_for_resend()
682 chk->rec.data.fast_retran_tsn = (TAILQ_FIRST(&stcb->asoc.send_queue))->rec.data.TSN_seq; in sctp_mark_all_for_resend()
1358 if ((TAILQ_EMPTY(&stcb->asoc.send_queue)) && in sctp_audit_stream_queues_for_size()
1408 (TAILQ_EMPTY(&stcb->asoc.send_queue)) && in sctp_heartbeat_timer()
1529 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp_autoclose_timer()
Dsctp_input.c314 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) { in sctp_process_init()
316 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next); in sctp_process_init()
950 if (!TAILQ_EMPTY(&asoc->send_queue) || in sctp_handle_shutdown()
1031 if (!TAILQ_EMPTY(&asoc->send_queue) || in sctp_handle_shutdown_ack()
3013 lchk = TAILQ_LAST(&stcb->asoc.send_queue, sctpchunk_listhead); in sctp_handle_ecn_echo()
3183 if (!TAILQ_EMPTY(&asoc->send_queue) || in sctp_handle_shutdown_complete()
3303 if (TAILQ_EMPTY(&stcb->asoc.send_queue)) { in process_chunk_drop()
3306 tp1->rec.data.fast_retran_tsn = (TAILQ_FIRST(&stcb->asoc.send_queue))->rec.data.TSN_seq; in process_chunk_drop()
4911 if (TAILQ_EMPTY(&stcb->asoc.send_queue) && in sctp_process_control()
4999 if (TAILQ_EMPTY(&stcb->asoc.send_queue) && in sctp_process_control()
Dsctp_indata.c2947 tp1 = TAILQ_FIRST(&stcb->asoc.send_queue); in sctp_strike_gap_ack_chunks()
3328 if (TAILQ_EMPTY(&asoc->send_queue)) { in sctp_strike_gap_ack_chunks()
3347 ttt = TAILQ_FIRST(&asoc->send_queue); in sctp_strike_gap_ack_chunks()
3952 if (TAILQ_EMPTY(&asoc->send_queue) && TAILQ_EMPTY(&asoc->sent_queue)) { in sctp_express_handle_sack()
4218 TAILQ_EMPTY(&asoc->send_queue) && in sctp_handle_sack()
4654 if (TAILQ_EMPTY(&asoc->send_queue) && TAILQ_EMPTY(&asoc->sent_queue)) { in sctp_handle_sack()
Dsctp_output.c6170 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) { in sctp_prune_prsctp()
6657 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp_sendall_iterator()
6716 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp_sendall_iterator()
6947 TAILQ_REMOVE(&asoc->send_queue, data_list[i], sctp_next); in sctp_clean_up_datalist()
7632 TAILQ_INSERT_TAIL(&asoc->send_queue, chk, sctp_next); in sctp_move_to_outqueue()
7762 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) { in sctp_move_chunks_from_net()
7848 TAILQ_EMPTY(&asoc->send_queue) && in sctp_med_chunk_output()
7884 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) { in sctp_med_chunk_output()
7949 TAILQ_EMPTY(&asoc->send_queue)) { in sctp_med_chunk_output()
8599 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) { in sctp_med_chunk_output()
[all …]
Dsctp_cc_functions.c188 lchk = TAILQ_FIRST(&asoc->send_queue); in sctp_cwnd_update_after_fr()
1693 lchk = TAILQ_FIRST(&asoc->send_queue); in sctp_hs_cwnd_update_after_fr()
2222 lchk = TAILQ_FIRST(&asoc->send_queue); in sctp_htcp_cwnd_update_after_fr()
Dsctp_structs.h793 struct sctpchunk_listhead send_queue; member
Dsctp_usrreq.c112 TAILQ_FOREACH(chk, &stcb->asoc.send_queue, sctp_next) { in sctp_pathmtu_adjustment()
785 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp_disconnect()
851 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp_disconnect()
986 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp_shutdown()
1047 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp_shutdown()
4613 if (TAILQ_EMPTY(&stcb->asoc.send_queue) && in sctp_setopt()
5458 if (TAILQ_EMPTY(&stcb->asoc.send_queue) && in sctp_setopt()
Dsctputil.c1085 TAILQ_INIT(&asoc->send_queue); in sctp_init_asoc()
2325 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) { in sctp_mtu_size_reset()
3755 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) { in sctp_report_all_outbound()
3756 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next); in sctp_report_all_outbound()
4773 TAILQ_FOREACH_SAFE(tp1, &stcb->asoc.send_queue, sctp_next, tp2) { in sctp_release_pr_sctp_chunk()
4802 TAILQ_REMOVE(&stcb->asoc.send_queue, tp1, sctp_next); in sctp_release_pr_sctp_chunk()
Dsctp_pcb.c3416 } else if (TAILQ_EMPTY(&asoc->asoc.send_queue) && in sctp_inpcb_free()
3468 if (TAILQ_EMPTY(&asoc->asoc.send_queue) && in sctp_inpcb_free()
4980 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) { in sctp_free_assoc()
4988 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next); in sctp_free_assoc()
/freebsd-9-stable/sys/netinet6/
Dsctp6_usrreq.c246 TAILQ_FOREACH(chk, &stcb->asoc.send_queue, sctp_next) { in sctp6_notify_mbuf()