Home
last modified time | relevance | path

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

/external/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.c452 TAILQ_EMPTY(&asoc->strmout[chk->rec.data.sid].outqueue)) {
1386 if (!TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) {
1387 TAILQ_FOREACH(sp, &stcb->asoc.strmout[i].outqueue, next) {
Dsctp_output.c3757 TAILQ_INIT(&stcb->asoc.strmout[i].outqueue);
6994 TAILQ_INSERT_TAIL(&strm->outqueue, sp, next);
7776 sp = TAILQ_FIRST(&strq->outqueue);
7782 sp = TAILQ_FIRST(&strq->outqueue);
7821 TAILQ_REMOVE(&strq->outqueue, sp, next);
7825 TAILQ_EMPTY(&strq->outqueue)) {
8249 TAILQ_REMOVE(&strq->outqueue, sp, next);
8253 TAILQ_EMPTY(&strq->outqueue)) {
8386 TAILQ_FOREACH(sp, &stcb->asoc.strmout[i].outqueue, next) {
12556 TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) {
[all …]
Dsctp_structs.h667 struct sctp_streamhead outqueue; member
Dsctp_input.c267 sp = TAILQ_FIRST(&stcb->asoc.strmout[i].outqueue); in sctp_is_there_unsent_data()
287 TAILQ_REMOVE(&stcb->asoc.strmout[i].outqueue, sp, next); in sctp_is_there_unsent_data()
298 if (!TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) { in sctp_is_there_unsent_data()
375 TAILQ_FOREACH_SAFE(sp, &outs->outqueue, next, nsp) { in sctp_process_init()
377 TAILQ_REMOVE(&outs->outqueue, sp, next); in sctp_process_init()
Dsctp_indata.c3166 TAILQ_EMPTY(&stcb->asoc.strmout[tp1->rec.data.sid].outqueue)) { in sctp_process_segment_range()
4125 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.sid].outqueue)) {
4842 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.sid].outqueue)) {
Dsctputil.c1347 TAILQ_INIT(&asoc->strmout[i].outqueue); in sctp_init_asoc()
4542 TAILQ_FOREACH_SAFE(sp, &outs->outqueue, next, nsp) {
4544 TAILQ_REMOVE(&outs->outqueue, sp, next);
5696 sp = TAILQ_FIRST(&strq->outqueue);
Dsctp_pcb.c5736 TAILQ_FOREACH_SAFE(sp, &outs->outqueue, next, nsp) {
5738 TAILQ_REMOVE(&outs->outqueue, sp, next);
Dsctp_usrreq.c5763 if (!TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) {
/external/python/cpython3/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 …]
/external/python/cpython2/Lib/multiprocessing/
Dpool.py88 def worker(inqueue, outqueue, initializer=None, initargs=(), maxtasks=None): argument
90 put = outqueue.put
94 outqueue._reader.close()
335 def _handle_tasks(taskqueue, put, outqueue, pool, cache): argument
375 outqueue.put(None)
387 def _handle_results(outqueue, get, cache): argument
430 if hasattr(outqueue, '_reader'):
437 if not outqueue._reader.poll():
491 def _terminate_pool(cls, taskqueue, inqueue, outqueue, pool, argument
505 outqueue.put(None) # sentinel