Home
last modified time | relevance | path

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

/netbsd/src/usr.sbin/syslogd/
Dextern.h73 extern void send_queue(int __unused, short __unused, void *);
Dtls.h124 unsigned send_queue:1, /* currently sending buffer */ member
Dsyslogd.h242 send_queue(0, 0, f); \
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()
Dsyslogd.c4389 send_queue(int fd, short event, void *arg) in send_queue() function
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()
4436 event_set(f->f_sq_event, 0, 0, send_queue, f); in send_queue()
4446 f->f_un.f_tls.tls_conn->send_queue = false; in send_queue()
/netbsd/src/sys/netinet/
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()
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()
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()
Dsctp_structs.h323 struct sctpchunk_listhead send_queue; member
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()
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()
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,
5100 TAILQ_INSERT_TAIL(&asoc->send_queue, chk, sctp_next);
5243 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) {
5310 TAILQ_EMPTY(&asoc->send_queue) &&
5367 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) {
5388 if ((TAILQ_FIRST(&asoc->send_queue) != NULL) &&
5401 (TAILQ_FIRST(&asoc->send_queue) == NULL)) {
[all …]
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()
/netbsd/src/sys/netinet6/
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()