| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/ |
| pool.py | 88 def worker(inqueue, outqueue, initializer=None, initargs=(), maxtasks=None):
91 get = inqueue.get
92 if hasattr(inqueue, '_writer'):
93 inqueue._writer.close()
464 def _help_stuff_finish(inqueue, task_handler, size):
465 # task_handler may be blocked trying to put items on inqueue
466 debug('removing tasks from inqueue until task handler finished')
467 inqueue._rlock.acquire()
468 while task_handler.is_alive() and inqueue._reader.poll():
469 inqueue._reader.recv(
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/ |
| pool.py | 88 def worker(inqueue, outqueue, initializer=None, initargs=(), maxtasks=None):
91 get = inqueue.get
92 if hasattr(inqueue, '_writer'):
93 inqueue._writer.close()
464 def _help_stuff_finish(inqueue, task_handler, size):
465 # task_handler may be blocked trying to put items on inqueue
466 debug('removing tasks from inqueue until task handler finished')
467 inqueue._rlock.acquire()
468 while task_handler.is_alive() and inqueue._reader.poll():
469 inqueue._reader.recv(
[all...] |
| /external/chromium_org/third_party/usrsctp/usrsctplib/netinet/ |
| sctp_indata.c | 533 TAILQ_FOREACH_SAFE(ctl, &strm->inqueue, next, nctl) {
536 TAILQ_REMOVE(&strm->inqueue, ctl, next);
612 TAILQ_INSERT_HEAD(&strm->inqueue, control, next);
639 TAILQ_FOREACH_SAFE(control, &strm->inqueue, next, at) {
643 TAILQ_REMOVE(&strm->inqueue, control, next);
676 if (TAILQ_EMPTY(&strm->inqueue)) {
681 TAILQ_INSERT_HEAD(&strm->inqueue, control, next);
683 TAILQ_FOREACH(at, &strm->inqueue, next) {
731 TAILQ_INSERT_AFTER(&strm->inqueue,
[all...] |
| sctp_input.c | 410 TAILQ_FOREACH_SAFE(ctl, &asoc->strmin[i].inqueue, next, nctl) {
411 TAILQ_REMOVE(&asoc->strmin[i].inqueue, ctl, next);
436 TAILQ_INIT(&asoc->strmin[i].inqueue);
[all...] |
| sctp_structs.h | 584 struct sctp_readhead inqueue; member in struct:sctp_stream_in
[all...] |
| sctp_pcb.c | [all...] |
