Searched refs:send_queue (Results 1 - 14 of 14) sorted by relevance
/netbsd-current/usr.sbin/syslogd/ |
H A D | extern.h | 73 extern void send_queue(int __unused, short __unused, void *);
|
H A D | tls.h | 124 unsigned send_queue:1, /* currently sending buffer */ member in struct:tls_conn_settings
|
H A D | syslogd.h | 239 /* small optimization to call send_queue() only if queue has elements */ 242 send_queue(0, 0, f); \ 369 struct event *f_sq_event; /* timer for send_queue() */
|
H A D | tls.c | 969 send_queue(0, 0, get_f_by_conninfo(conn_info)); 1821 send_queue(0, 0, f); 1830 send_queue(0, 0, f);
|
H A D | syslogd.c | 2510 * they would be writeable and call send_queue() first. 2511 * So we call send_queue() after a successful write, 4357 send_queue(int fd, short event, void *arg) function 4366 /* use a flag to prevent recursive calls to send_queue() */ 4367 if (f->f_un.f_tls.tls_conn->send_queue) 4370 f->f_un.f_tls.tls_conn->send_queue = true; 4372 DPRINTF((D_DATA|D_CALL), "send_queue(f@%p with %zu msgs, " 4378 /* send_queue() might be called with an unconnected destination 4385 DPRINTF(D_TLS, "abort send_queue(cnt@%p = %zu) " 4404 event_set(f->f_sq_event, 0, 0, send_queue, [all...] |
/netbsd-current/sys/netinet/ |
H A D | sctp_timer.c | 674 chk = TAILQ_FIRST(&stcb->asoc.send_queue); 719 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) { 1226 if ((TAILQ_EMPTY(&stcb->asoc.send_queue)) && 1260 (TAILQ_EMPTY(&stcb->asoc.send_queue)) && 1388 if (TAILQ_EMPTY(&asoc->send_queue) &&
|
H A D | sctp_structs.h | 323 struct sctpchunk_listhead send_queue; member in struct:sctp_association
|
H A D | sctputil.c | 790 TAILQ_INIT(&asoc->send_queue); 1616 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) { 2606 if (!TAILQ_EMPTY(&asoc->send_queue)) { 2607 chk = TAILQ_FIRST(&asoc->send_queue); 2609 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next); 2624 chk = TAILQ_FIRST(&asoc->send_queue); 3402 if (queue == &stcb->asoc.send_queue) { 3403 TAILQ_REMOVE(&stcb->asoc.send_queue, tp1, sctp_next); 3429 tp1 = TAILQ_FIRST(&stcb->asoc.send_queue); 3431 * recurse throught the send_queue to [all...] |
H A D | sctp_indata.c | 2918 tp1 = TAILQ_FIRST(&asoc->send_queue); 2950 tp1 = TAILQ_FIRST(&stcb->asoc.send_queue); 3127 if (TAILQ_EMPTY(&asoc->send_queue)) { 3145 ttt = TAILQ_FIRST(&asoc->send_queue); 3551 if (TAILQ_EMPTY(&asoc->send_queue)) { 3554 tp1 = TAILQ_FIRST(&asoc->send_queue); 4053 if (TAILQ_EMPTY(&asoc->send_queue) && TAILQ_EMPTY(&asoc->sent_queue) && 4176 lchk = TAILQ_FIRST(&asoc->send_queue); 4220 lchk = TAILQ_FIRST(&asoc->send_queue);
|
H A D | sctp_input.c | 595 !TAILQ_EMPTY(&asoc->send_queue), 599 if (!TAILQ_EMPTY(&asoc->send_queue) || 643 if (!TAILQ_EMPTY(&asoc->send_queue) || 2234 lchk = TAILQ_FIRST(&stcb->asoc.send_queue); 2362 if (!TAILQ_EMPTY(&asoc->send_queue) || 2463 if (TAILQ_EMPTY(&stcb->asoc.send_queue) ) { 2466 tp1->rec.data.fast_retran_tsn = (TAILQ_FIRST(&stcb->asoc.send_queue))->rec.data.TSN_seq;
|
H A D | sctp_pcb.c | 2081 } else if (TAILQ_EMPTY(&asoc->asoc.send_queue) && 3174 if (!TAILQ_EMPTY(&asoc->send_queue)) { 3175 chk = TAILQ_FIRST(&asoc->send_queue); 3177 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next); 3188 chk = TAILQ_FIRST(&asoc->send_queue);
|
H A D | sctp_output.c | 3965 chk = TAILQ_FIRST(&asoc->send_queue); 3981 &asoc->send_queue); 4529 if (TAILQ_EMPTY(&asoc->send_queue) && 4909 TAILQ_REMOVE(&asoc->send_queue, 5001 /* Move from the stream to the send_queue keeping track of the total */ 5110 /* insert on send_queue */ 5112 TAILQ_INSERT_TAIL(&asoc->send_queue, chk, sctp_next); 5255 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) { 5304 * out of the stream queues into the general send_queue 5322 TAILQ_EMPTY(&asoc->send_queue) [all...] |
H A D | sctp_usrreq.c | 298 TAILQ_FOREACH(chk, &stcb->asoc.send_queue, sctp_next) { 762 if (TAILQ_EMPTY(&asoc->send_queue) && 860 if (TAILQ_EMPTY(&asoc->send_queue) && 2535 * nothing on the send_queue. For now we will
|
/netbsd-current/sys/netinet6/ |
H A D | sctp6_usrreq.c | 362 TAILQ_FOREACH(chk, &stcb->asoc.send_queue, sctp_next) { 741 if (TAILQ_EMPTY(&asoc->send_queue) &&
|
Completed in 492 milliseconds