Home
last modified time | relevance | path

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

/netbsd-src/usr.sbin/syslogd/
H A Dextern.h73 extern void send_queue(int __unused, short __unused, void *);
H A Dtls.h124 unsigned send_queue:1, /* currently sending buffer */ member
H A Dsyslogd.h242 send_queue(0, 0, f); \
H A Dtls.c969 send_queue(0, 0, get_f_by_conninfo(conn_info)); in dispatch_SSL_connect()
1821 send_queue(0, 0, f); in dispatch_tls_send()
1830 send_queue(0, 0, f); in dispatch_tls_send()
H A Dsyslogd.c2542 * they would be writeable and call send_queue() first. in fprintlog()
2543 * So we call send_queue() after a successful write, in fprintlog()
4389 send_queue(int fd, short event, void *arg) in send_queue()
4398 /* use a flag to prevent recursive calls to send_queue() */ in send_queue()
4399 if (f->f_un.f_tls.tls_conn->send_queue) in send_queue()
4402 f->f_un.f_tls.tls_conn->send_queue = true; in send_queue()
4404 DPRINTF((D_DATA|D_CALL), "send_queue(f@%p with %zu msgs, " in send_queue()
4410 /* send_queue() might be called with an unconnected destination in send_queue()
4417 DPRINTF(D_TLS, "abort send_queue(cnt@%p = %zu) " in send_queue()
4436 event_set(f->f_sq_event, 0, 0, send_queue, in find_qentry_to_delete()
4357 send_queue(int fd, short event, void *arg) send_queue() function
[all...]
/netbsd-src/sys/netinet/
H A Dsctp_timer.c674 chk = TAILQ_FIRST(&stcb->asoc.send_queue); in sctp_mark_all_for_resend()
719 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) { in sctp_move_all_chunks_to_alt()
1226 if ((TAILQ_EMPTY(&stcb->asoc.send_queue)) && in sctp_audit_stream_queues_for_size()
1260 (TAILQ_EMPTY(&stcb->asoc.send_queue)) && in sctp_heartbeat_timer()
1388 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp_autoclose_timer()
H A Dsctputil.c790 TAILQ_INIT(&asoc->send_queue); in sctp_init_asoc()
1616 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) { in sctp_mtu_size_reset()
2604 if (!TAILQ_EMPTY(&asoc->send_queue)) { in sctp_report_all_outbound()
2605 chk = TAILQ_FIRST(&asoc->send_queue); in sctp_report_all_outbound()
2607 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next); in sctp_report_all_outbound()
2620 chk = TAILQ_FIRST(&asoc->send_queue); in sctp_report_all_outbound()
3396 if (queue == &stcb->asoc.send_queue) { in sctp_release_pr_sctp_chunk()
3397 TAILQ_REMOVE(&stcb->asoc.send_queue, tp1, sctp_next); in sctp_release_pr_sctp_chunk()
3423 tp1 = TAILQ_FIRST(&stcb->asoc.send_queue); in sctp_release_pr_sctp_chunk()
3430 &stcb->asoc.send_queue); in sctp_release_pr_sctp_chunk()
H A Dsctp_indata.c2913 tp1 = TAILQ_FIRST(&asoc->send_queue); in sctp_check_for_revoked()
2945 tp1 = TAILQ_FIRST(&stcb->asoc.send_queue); in sctp_strike_gap_ack_chunks()
3122 if (TAILQ_EMPTY(&asoc->send_queue)) { in sctp_strike_gap_ack_chunks()
3140 ttt = TAILQ_FIRST(&asoc->send_queue); in sctp_strike_gap_ack_chunks()
3546 if (TAILQ_EMPTY(&asoc->send_queue)) { in sctp_handle_sack()
3549 tp1 = TAILQ_FIRST(&asoc->send_queue); in sctp_handle_sack()
4048 if (TAILQ_EMPTY(&asoc->send_queue) && TAILQ_EMPTY(&asoc->sent_queue) && in sctp_handle_sack()
4171 lchk = TAILQ_FIRST(&asoc->send_queue); in sctp_handle_sack()
4215 lchk = TAILQ_FIRST(&asoc->send_queue); in sctp_handle_sack()
H A Dsctp_structs.h323 struct sctpchunk_listhead send_queue; member
H A Dsctp_input.c593 !TAILQ_EMPTY(&asoc->send_queue), in sctp_handle_shutdown()
597 if (!TAILQ_EMPTY(&asoc->send_queue) || in sctp_handle_shutdown()
641 if (!TAILQ_EMPTY(&asoc->send_queue) || in sctp_handle_shutdown_ack()
2232 lchk = TAILQ_FIRST(&stcb->asoc.send_queue); in sctp_handle_ecn_echo()
2358 if (!TAILQ_EMPTY(&asoc->send_queue) || in sctp_handle_shutdown_complete()
2459 if (TAILQ_EMPTY(&stcb->asoc.send_queue) ) { in process_chunk_drop()
2462 tp1->rec.data.fast_retran_tsn = (TAILQ_FIRST(&stcb->asoc.send_queue))->rec.data.TSN_seq; in process_chunk_drop()
H A Dsctp_pcb.c2077 } else if (TAILQ_EMPTY(&asoc->asoc.send_queue) && in sctp_inpcb_free()
3166 if (!TAILQ_EMPTY(&asoc->send_queue)) { in sctp_free_assoc()
3167 chk = TAILQ_FIRST(&asoc->send_queue); in sctp_free_assoc()
3169 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next); in sctp_free_assoc()
3178 chk = TAILQ_FIRST(&asoc->send_queue); in sctp_free_assoc()
H A Dsctp_output.c3962 chk = TAILQ_FIRST(&asoc->send_queue); in sctp_prune_prsctp()
3978 &asoc->send_queue); in sctp_prune_prsctp()
4525 if (TAILQ_EMPTY(&asoc->send_queue) &&
4901 TAILQ_REMOVE(&asoc->send_queue,
4991 /* Move from the stream to the send_queue keeping track of the total */
5098 /* insert on send_queue */
5100 TAILQ_INSERT_TAIL(&asoc->send_queue, chk, sctp_next);
5243 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) {
5292 * out of the stream queues into the general send_queue
5310 TAILQ_EMPTY(&asoc->send_queue)
[all...]
H A Dsctp_usrreq.c298 TAILQ_FOREACH(chk, &stcb->asoc.send_queue, sctp_next) { in sctp_notify_mbuf()
756 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp_disconnect()
854 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp_shutdown()
2529 * nothing on the send_queue. For now we will in sctp_optsset()
/netbsd-src/sys/netinet6/
H A Dsctp6_usrreq.c356 TAILQ_FOREACH(chk, &stcb->asoc.send_queue, sctp_next) { in sctp6_notify_mbuf()
735 if (TAILQ_EMPTY(&asoc->send_queue) && in sctp6_disconnect()