Home
last modified time | relevance | path

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

/third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/netinet/
Dsctp_ss_functions.c132 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_add()
163 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_remove()
223 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_default_select()
224 TAILQ_FIRST(&strq->outqueue)->net != NULL && in sctp_ss_default_select()
225 TAILQ_FIRST(&strq->outqueue)->net != net) { in sctp_ss_default_select()
248 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_scheduled()
297 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_is_user_msgs_incomplete()
318 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_rr_add()
384 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_rrp_packet_done()
385 TAILQ_FIRST(&strq->outqueue)->net != NULL && in sctp_ss_rrp_packet_done()
[all …]
Dsctp_timer.c448 TAILQ_EMPTY(&asoc->strmout[chk->rec.data.sid].outqueue)) {
1382 if (!TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) {
1383 TAILQ_FOREACH(sp, &stcb->asoc.strmout[i].outqueue, next) {
Dsctp_output.c3751 TAILQ_INIT(&stcb->asoc.strmout[i].outqueue);
6967 TAILQ_INSERT_TAIL(&strm->outqueue, sp, next);
7732 sp = TAILQ_FIRST(&strq->outqueue);
7738 sp = TAILQ_FIRST(&strq->outqueue);
7777 TAILQ_REMOVE(&strq->outqueue, sp, next);
7781 TAILQ_EMPTY(&strq->outqueue)) {
8205 TAILQ_REMOVE(&strq->outqueue, sp, next);
8209 TAILQ_EMPTY(&strq->outqueue)) {
8338 TAILQ_FOREACH(sp, &stcb->asoc.strmout[i].outqueue, next) {
12459 TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) {
[all …]
Dsctp_structs.h664 struct sctp_streamhead outqueue; member
Dsctp_input.c258 sp = TAILQ_FIRST(&stcb->asoc.strmout[i].outqueue); in sctp_is_there_unsent_data()
278 TAILQ_REMOVE(&stcb->asoc.strmout[i].outqueue, sp, next); in sctp_is_there_unsent_data()
289 if (!TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) { in sctp_is_there_unsent_data()
366 TAILQ_FOREACH_SAFE(sp, &outs->outqueue, next, nsp) { in sctp_process_init()
368 TAILQ_REMOVE(&outs->outqueue, sp, next); in sctp_process_init()
Dsctp_indata.c3185 TAILQ_EMPTY(&stcb->asoc.strmout[tp1->rec.data.sid].outqueue)) { in sctp_process_segment_range()
4144 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.sid].outqueue)) {
4861 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.sid].outqueue)) {
Dsctputil.c1339 TAILQ_INIT(&asoc->strmout[i].outqueue); in sctp_init_asoc()
4532 TAILQ_FOREACH_SAFE(sp, &outs->outqueue, next, nsp) {
4534 TAILQ_REMOVE(&outs->outqueue, sp, next);
5658 sp = TAILQ_FIRST(&strq->outqueue);
Dsctp_pcb.c5696 TAILQ_FOREACH_SAFE(sp, &outs->outqueue, next, nsp) {
5698 TAILQ_REMOVE(&outs->outqueue, sp, next);
Dsctp_usrreq.c5675 if (!TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) {
/third_party/python/Lib/multiprocessing/
Dpool.py97 def worker(inqueue, outqueue, initializer=None, initargs=(), maxtasks=None, argument
102 put = outqueue.put
106 outqueue._reader.close()
313 outqueue, initializer, initargs, argument
320 args=(inqueue, outqueue,
331 def _maintain_pool(ctx, Process, processes, pool, inqueue, outqueue, argument
338 inqueue, outqueue, initializer,
505 pool, inqueue, outqueue, initializer, initargs, argument
514 outqueue, initializer, initargs,
525 def _handle_tasks(taskqueue, put, outqueue, pool, cache): argument
[all …]
/third_party/gstreamer/gstplugins_base/gst/encoding/
Dgstencodebasebin.c159 GstElement *outqueue; /* Queue just before the muxer */ member
1515 last = sgroup->outqueue = gst_element_factory_make ("queue", NULL); in _create_stream_group()
1516 g_object_set (sgroup->outqueue, "max-size-buffers", (guint) 0, in _create_stream_group()
1520 gst_bin_add (GST_BIN (ebin), sgroup->outqueue); in _create_stream_group()
1521 tosync = g_list_append (tosync, sgroup->outqueue); in _create_stream_group()
1522 srcpad = gst_element_get_static_pad (sgroup->outqueue, "src"); in _create_stream_group()
2327 if (sgroup->outqueue) { in stream_group_free()
2330 tmppad = gst_element_get_static_pad (sgroup->outqueue, "src"); in stream_group_free()
2343 gst_element_set_state (sgroup->outqueue, GST_STATE_NULL); in stream_group_free()
2350 gst_element_unlink (sgroup->formatter, sgroup->outqueue); in stream_group_free()
[all …]