Home
last modified time | relevance | path

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

/third_party/pulseaudio/src/pulsecore/
Dpstream.c130 pa_queue *send_queue; member
344 p->send_queue = pa_queue_new(); in pa_pstream_new()
416 pa_queue_free(p->send_queue, item_free); in pstream_free()
472 pa_queue_push(p->send_queue, i); in pa_pstream_send_packet()
514 pa_queue_push(p->send_queue, i); in pa_pstream_send_memblock()
541 pa_queue_push(p->send_queue, item); in pa_pstream_send_release()
578 pa_queue_push(p->send_queue, item); in pa_pstream_send_revoke()
599 p->write.current = pa_queue_pop(p->send_queue); in prepare_next_write_item()
1168 b = p->write.current || !pa_queue_isempty(p->send_queue); in pa_pstream_is_pending()
/third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/netinet/
Dsctp_timer.c703 if (TAILQ_EMPTY(&stcb->asoc.send_queue)) {
706 chk->rec.data.fast_retran_tsn = (TAILQ_FIRST(&stcb->asoc.send_queue))->rec.data.tsn;
1397 if ((TAILQ_EMPTY(&stcb->asoc.send_queue)) &&
1446 (TAILQ_EMPTY(&stcb->asoc.send_queue)) &&
1589 if (TAILQ_EMPTY(&asoc->send_queue) &&
Dsctp_input.c339 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) { in sctp_process_init()
341 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next); in sctp_process_init()
1052 if (!TAILQ_EMPTY(&asoc->send_queue) || in sctp_handle_shutdown()
1135 if (!TAILQ_EMPTY(&asoc->send_queue) || in sctp_handle_shutdown_ack()
3284 lchk = TAILQ_LAST(&stcb->asoc.send_queue, sctpchunk_listhead);
3443 if (!TAILQ_EMPTY(&stcb->asoc.send_queue) ||
3562 if (TAILQ_EMPTY(&stcb->asoc.send_queue)) {
3565 tp1->rec.data.fast_retran_tsn = (TAILQ_FIRST(&stcb->asoc.send_queue))->rec.data.tsn;
5236 if (TAILQ_EMPTY(&stcb->asoc.send_queue) &&
Dsctp_cc_functions.c208 lchk = TAILQ_FIRST(&asoc->send_queue); in sctp_cwnd_update_after_fr()
1802 lchk = TAILQ_FIRST(&asoc->send_queue); in sctp_hs_cwnd_update_after_fr()
2329 lchk = TAILQ_FIRST(&asoc->send_queue); in sctp_htcp_cwnd_update_after_fr()
Dsctp_indata.c3357 tp1 = TAILQ_FIRST(&stcb->asoc.send_queue);
3729 if (TAILQ_EMPTY(&asoc->send_queue)) {
3748 ttt = TAILQ_FIRST(&asoc->send_queue);
4365 if (TAILQ_EMPTY(&asoc->send_queue) && TAILQ_EMPTY(&asoc->sent_queue)) {
4612 TAILQ_EMPTY(&asoc->send_queue) &&
5078 if (TAILQ_EMPTY(&asoc->send_queue) && TAILQ_EMPTY(&asoc->sent_queue)) {
Dsctp_output.c6751 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) {
7222 if (TAILQ_EMPTY(&asoc->send_queue) &&
7264 if (TAILQ_EMPTY(&asoc->send_queue) &&
7530 TAILQ_REMOVE(&asoc->send_queue, data_list[i], sctp_next);
8224 TAILQ_INSERT_TAIL(&asoc->send_queue, chk, sctp_next);
8345 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) {
8434 TAILQ_EMPTY(&asoc->send_queue) &&
8470 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) {
8535 TAILQ_EMPTY(&asoc->send_queue)) {
9184 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) {
[all …]
Dsctp_structs.h887 struct sctpchunk_listhead send_queue; member
Dsctp_usrreq.c211 TAILQ_FOREACH(chk, &stcb->asoc.send_queue, sctp_next) { in sctp_pathmtu_adjustment()
1128 if (TAILQ_EMPTY(&asoc->send_queue) &&
1174 if (TAILQ_EMPTY(&asoc->send_queue) &&
1350 TAILQ_EMPTY(&asoc->send_queue) &&
1372 if (TAILQ_EMPTY(&asoc->send_queue) &&
5665 if (!TAILQ_EMPTY(&stcb->asoc.send_queue) ||
5960 if (TAILQ_EMPTY(&stcb->asoc.send_queue) &&
6986 if (TAILQ_EMPTY(&stcb->asoc.send_queue) &&
Dsctputil.c1381 TAILQ_INIT(&asoc->send_queue); in sctp_init_asoc()
3025 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) { in sctp_mtu_size_reset()
4506 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) {
4507 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next);
5615 TAILQ_FOREACH_SAFE(tp1, &stcb->asoc.send_queue, sctp_next, tp2) {
5643 TAILQ_REMOVE(&stcb->asoc.send_queue, tp1, sctp_next);
Dsctp_pcb.c4003 } else if (TAILQ_EMPTY(&asoc->asoc.send_queue) &&
4041 if (TAILQ_EMPTY(&asoc->asoc.send_queue) &&
5755 TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) {
5763 TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next);
/third_party/glib/gio/
Dgdbusprivate.c1368 GQueue *send_queue; in iostream_close_cb() local
1380 send_queue = worker->write_queue; in iostream_close_cb()
1413 g_queue_free_full (send_queue, (GDestroyNotify) message_to_write_data_free); in iostream_close_cb()