Home
last modified time | relevance | path

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

/freebsd/sys/cam/
H A Dcam_queue.c201 if (camq_init(&devq->send_queue, devices) != 0) in cam_devq_init()
212 camq_fini(&devq->send_queue); in cam_devq_free()
222 retval = camq_resize(&camq->send_queue, devices); in cam_devq_resize()
H A Dcam_queue.h74 struct camq send_queue; member
H A Dcam_xpt.c334 xpt_schedule_dev(&devq->send_queue, in xpt_schedule_devq()
3289 devq->send_queue.qfrozen_cnt++; in xpt_run_devq()
3290 while ((devq->send_queue.entries > 0) in xpt_run_devq()
3292 && (devq->send_queue.qfrozen_cnt <= 1)) { in xpt_run_devq()
3298 device = (struct cam_ed *)camq_remove(&devq->send_queue, in xpt_run_devq()
3385 devq->send_queue.qfrozen_cnt--; in xpt_run_devq()
4349 camq_remove(&devq->send_queue, dev->devq_entry.index); in xpt_freeze_devq_device()
4376 freeze = (devq->send_queue.qfrozen_cnt += count); in xpt_freeze_simq()
4459 if (devq->send_queue.qfrozen_cnt <= 0) { in xpt_release_simq()
4462 devq->send_queue.qfrozen_cnt); in xpt_release_simq()
[all …]
/freebsd/tools/tools/net80211/w00t/expand/
H A Dexpand.c302 void send_queue(struct params *p) in send_queue() function
362 send_queue(p); in read_wifi()
386 send_queue(p); in own()
/freebsd/sys/ofed/drivers/infiniband/core/
H A Dib_mad.c1158 mad_send_wr->mad_list.mad_queue = &qp_info->send_queue; in ib_send_mad()
1185 spin_lock_irqsave(&qp_info->send_queue.lock, flags); in ib_send_mad()
1186 if (qp_info->send_queue.count < qp_info->send_queue.max_active) { in ib_send_mad()
1189 list = &qp_info->send_queue.list; in ib_send_mad()
1196 qp_info->send_queue.count++; in ib_send_mad()
1199 spin_unlock_irqrestore(&qp_info->send_queue.lock, flags); in ib_send_mad()
2427 struct ib_mad_queue *send_queue; in ib_mad_send_done() local
2443 send_queue = mad_list->mad_queue; in ib_mad_send_done()
2444 qp_info = send_queue->qp_info; in ib_mad_send_done()
2454 spin_lock_irqsave(&send_queue->lock, flags); in ib_mad_send_done()
[all …]
H A Dmad_priv.h190 struct ib_mad_queue send_queue; member
/freebsd/usr.sbin/bsnmpd/modules/snmp_hast/
H A Dhast_snmp.c82 uint32_t send_queue; member
354 res->send_queue = in update_resources()
524 value->v.uint32 = res->send_queue; in op_hastResourceTable()
/freebsd/tools/tools/net80211/w00t/redir/
H A Dredir.c319 void send_queue(struct params *p) in send_queue() function
418 send_queue(p); in read_wifi()
555 send_queue(p); in read_buddy_data()
/freebsd/sys/netinet/
H A Dsctp_timer.c700 if (TAILQ_EMPTY(&stcb->asoc.send_queue)) { in sctp_mark_all_for_resend()
703 chk->rec.data.fast_retran_tsn = (TAILQ_FIRST(&stcb->asoc.send_queue))->rec.data.tsn; in sctp_mark_all_for_resend()
1352 KASSERT(TAILQ_EMPTY(&stcb->asoc.send_queue), ("send_queue not empty")); in sctp_audit_stream_queues_for_size()
1388 if ((TAILQ_EMPTY(&stcb->asoc.send_queue)) && in sctp_audit_stream_queues_for_size()
1434 (TAILQ_EMPTY(&stcb->asoc.send_queue)) && in sctp_heartbeat_timer()
1558 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp_autoclose_timer()
H A Dsctp_input.c273 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) { in sctp_process_init()
275 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next); in sctp_process_init()
917 if (!TAILQ_EMPTY(&stcb->asoc.send_queue) || in sctp_handle_shutdown()
974 if (!TAILQ_EMPTY(&stcb->asoc.send_queue) || in sctp_handle_shutdown_ack()
2791 TAILQ_EMPTY(&asoc->send_queue) && in sctp_handle_cookie_ack()
2873 lchk = TAILQ_LAST(&stcb->asoc.send_queue, sctpchunk_listhead); in sctp_handle_ecn_echo()
3033 if (!TAILQ_EMPTY(&stcb->asoc.send_queue) || in sctp_handle_shutdown_complete()
3141 if (TAILQ_EMPTY(&stcb->asoc.send_queue)) { in process_chunk_drop()
3144 tp1->rec.data.fast_retran_tsn = (TAILQ_FIRST(&stcb->asoc.send_queue))->rec.data.tsn; in process_chunk_drop()
4768 if (TAILQ_EMPTY(&stcb->asoc.send_queue) && in sctp_process_control()
H A Dsctp_indata.c3304 tp1 = TAILQ_FIRST(&stcb->asoc.send_queue); in sctp_strike_gap_ack_chunks()
3688 if (TAILQ_EMPTY(&asoc->send_queue)) { in sctp_strike_gap_ack_chunks()
3707 ttt = TAILQ_FIRST(&asoc->send_queue); in sctp_strike_gap_ack_chunks()
4278 if (TAILQ_EMPTY(&asoc->send_queue) && TAILQ_EMPTY(&asoc->sent_queue)) { in sctp_express_handle_sack()
4526 TAILQ_EMPTY(&asoc->send_queue) && in sctp_handle_sack()
4946 if (TAILQ_EMPTY(&asoc->send_queue) && TAILQ_EMPTY(&asoc->sent_queue)) { in sctp_handle_sack()
H A Dsctp_cc_functions.c208 lchk = TAILQ_FIRST(&asoc->send_queue); in sctp_cwnd_update_after_fr()
1706 lchk = TAILQ_FIRST(&asoc->send_queue); in sctp_hs_cwnd_update_after_fr()
2239 lchk = TAILQ_FIRST(&asoc->send_queue); in sctp_htcp_cwnd_update_after_fr()
H A Dsctp_structs.h830 struct sctpchunk_listhead send_queue; member
H A Dsctp_output.c6262 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) { in sctp_prune_prsctp()
6744 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp_sendall_iterator()
6792 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp_sendall_iterator()
7047 TAILQ_REMOVE(&asoc->send_queue, data_list[i], sctp_next); in sctp_clean_up_datalist()
7690 TAILQ_INSERT_TAIL(&asoc->send_queue, chk, sctp_next); in sctp_move_to_outqueue()
7803 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) { in sctp_move_chunks_from_net()
7890 TAILQ_EMPTY(&asoc->send_queue) && in sctp_med_chunk_output()
7926 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) { in sctp_med_chunk_output()
7990 TAILQ_EMPTY(&asoc->send_queue)) { in sctp_med_chunk_output()
8641 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) { in sctp_med_chunk_output()
[all …]
H A Dsctp_usrreq.c133 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) { in sctp_pathmtu_adjustment()
704 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp_disconnect()
748 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp_disconnect()
920 TAILQ_EMPTY(&asoc->send_queue) && in sctp_shutdown()
944 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp_shutdown()
4843 if (!TAILQ_EMPTY(&stcb->asoc.send_queue) ||
5127 if (TAILQ_EMPTY(&stcb->asoc.send_queue) &&
6094 if (TAILQ_EMPTY(&stcb->asoc.send_queue) &&
H A Dsctputil.c1345 TAILQ_INIT(&asoc->send_queue); in sctp_init_asoc()
4308 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) { in sctp_report_all_outbound()
4309 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next); in sctp_report_all_outbound()
5146 TAILQ_FOREACH_SAFE(tp1, &stcb->asoc.send_queue, sctp_next, tp2) { in sctp_release_pr_sctp_chunk()
5175 TAILQ_REMOVE(&stcb->asoc.send_queue, tp1, sctp_next); in sctp_release_pr_sctp_chunk()
H A Dsctp_pcb.c3299 } else if (TAILQ_EMPTY(&stcb->asoc.send_queue) && in sctp_inpcb_free()
3336 if (TAILQ_EMPTY(&stcb->asoc.send_queue) && in sctp_inpcb_free()
4848 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) { in sctp_free_assoc()
4856 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next); in sctp_free_assoc()