| /src/usr.sbin/syslogd/ |
| extern.h | 73 extern void send_queue(int __unused, short __unused, void *);
|
| tls.h | 124 unsigned send_queue:1, /* currently sending buffer */ member in struct:tls_conn_settings
|
| syslogd.h | 239 /* small optimization to call send_queue() only if queue has elements */
240 #define SEND_QUEUE(f) do { \
242 send_queue(0, 0, f); \
369 struct event *f_sq_event; /* timer for send_queue() */
|
| 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);
|
| syslogd.c | 2441 SEND_QUEUE(f);
2542 * they would be writeable and call send_queue() first.
2543 * So we call send_queue() after a successful write,
2547 SEND_QUEUE(f);
2602 SEND_QUEUE(f);
3013 SEND_QUEUE(f);
3459 SEND_QUEUE(f);
4389 send_queue(int fd, short event, void *arg) function in typeref:typename:void
4398 /* use a flag to prevent recursive calls to send_queue() */
4399 if (f->f_un.f_tls.tls_conn->send_queue)
[all...] |
| /src/sys/netinet/ |
| 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) &&
|
| sctp_structs.h | 323 struct sctpchunk_listhead send_queue; member in struct:sctp_association
|
| sctputil.c | 790 TAILQ_INIT(&asoc->send_queue);
1616 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) {
2604 if (!TAILQ_EMPTY(&asoc->send_queue)) {
2605 chk = TAILQ_FIRST(&asoc->send_queue);
2607 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next);
2620 chk = TAILQ_FIRST(&asoc->send_queue);
3396 if (queue == &stcb->asoc.send_queue) {
3397 TAILQ_REMOVE(&stcb->asoc.send_queue, tp1, sctp_next);
3423 tp1 = TAILQ_FIRST(&stcb->asoc.send_queue);
3425 * recurse throught the send_queue too, starting at th
[all...] |
| sctp_indata.c | 2913 tp1 = TAILQ_FIRST(&asoc->send_queue);
2945 tp1 = TAILQ_FIRST(&stcb->asoc.send_queue);
3122 if (TAILQ_EMPTY(&asoc->send_queue)) {
3140 ttt = TAILQ_FIRST(&asoc->send_queue);
3546 if (TAILQ_EMPTY(&asoc->send_queue)) {
3549 tp1 = TAILQ_FIRST(&asoc->send_queue);
4048 if (TAILQ_EMPTY(&asoc->send_queue) && TAILQ_EMPTY(&asoc->sent_queue) &&
4171 lchk = TAILQ_FIRST(&asoc->send_queue);
4215 lchk = TAILQ_FIRST(&asoc->send_queue);
|
| sctp_input.c | 593 !TAILQ_EMPTY(&asoc->send_queue),
597 if (!TAILQ_EMPTY(&asoc->send_queue) ||
641 if (!TAILQ_EMPTY(&asoc->send_queue) ||
2232 lchk = TAILQ_FIRST(&stcb->asoc.send_queue);
2358 if (!TAILQ_EMPTY(&asoc->send_queue) ||
2459 if (TAILQ_EMPTY(&stcb->asoc.send_queue) ) {
2462 tp1->rec.data.fast_retran_tsn = (TAILQ_FIRST(&stcb->asoc.send_queue))->rec.data.TSN_seq;
|
| sctp_pcb.c | 2077 } else if (TAILQ_EMPTY(&asoc->asoc.send_queue) &&
3166 if (!TAILQ_EMPTY(&asoc->send_queue)) {
3167 chk = TAILQ_FIRST(&asoc->send_queue);
3169 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next);
3178 chk = TAILQ_FIRST(&asoc->send_queue);
|
| sctp_output.c | 3962 chk = TAILQ_FIRST(&asoc->send_queue);
3978 &asoc->send_queue);
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...] |
| sctp_usrreq.c | 298 TAILQ_FOREACH(chk, &stcb->asoc.send_queue, sctp_next) {
756 if (TAILQ_EMPTY(&asoc->send_queue) &&
854 if (TAILQ_EMPTY(&asoc->send_queue) &&
2529 * nothing on the send_queue. For now we will
|
| /src/sys/netinet6/ |
| sctp6_usrreq.c | 356 TAILQ_FOREACH(chk, &stcb->asoc.send_queue, sctp_next) {
735 if (TAILQ_EMPTY(&asoc->send_queue) &&
|
