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

/netbsd-current/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 in struct:tls_conn_settings
H A Dsyslogd.h239 /* 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 Dtls.c969 send_queue(0, 0, get_f_by_conninfo(conn_info));
1821 send_queue(0, 0, f);
1830 send_queue(0, 0, f);
H A Dsyslogd.c2510 * 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 Dsctp_timer.c674 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 Dsctp_structs.h323 struct sctpchunk_listhead send_queue; member in struct:sctp_association
H A Dsctputil.c790 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 Dsctp_indata.c2918 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 Dsctp_input.c595 !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 Dsctp_pcb.c2081 } 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 Dsctp_output.c3965 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 Dsctp_usrreq.c298 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 Dsctp6_usrreq.c362 TAILQ_FOREACH(chk, &stcb->asoc.send_queue, sctp_next) {
741 if (TAILQ_EMPTY(&asoc->send_queue) &&

Completed in 492 milliseconds