| /dports/games/openage/openage-0.3.0-1262-ga554ab49/openage/convert/ |
| H A D | slp_converter_pool.py | 58 inqueue = multiprocessing.Queue()
63 args=(inqueue, outqueue)
70 inqueue.put(get_loglevel())
71 inqueue.put(palette)
83 inqueue.put(StopIteration)
105 inqueue, outqueue = self.idle.get()
114 self.idle.put((inqueue, outqueue))
130 def converter_process(inqueue, outqueue): argument
142 loglevel = inqueue.get()
143 palette = inqueue.get()
[all …]
|
| /dports/net-mgmt/xymon-server/xymon-4.3.30/xymond/rrd/ |
| H A D | do_mailq.c | 19 char *inqueue, *outqueue; in do_mailq_rrd() local
31 inqueue = strstr(msg, "\nMail queue in:"); in do_mailq_rrd()
32 if (inqueue && outqueue) { in do_mailq_rrd()
37 inqueue = strchr(inqueue+1, '\n'); in do_mailq_rrd()
38 if ((outqueue == NULL) || (inqueue == NULL)) return 0; in do_mailq_rrd()
39 outqueue++; inqueue++; in do_mailq_rrd()
43 p = strchr(inqueue, '\n'); if (p) *p = '\0'; in do_mailq_rrd()
47 p = inqueue + strcspn(inqueue, "0123456789"); inq = atoi(p); in do_mailq_rrd()
|
| /dports/net-mgmt/xymon-client/xymon-4.3.30/xymond/rrd/ |
| H A D | do_mailq.c | 19 char *inqueue, *outqueue; in do_mailq_rrd() local
31 inqueue = strstr(msg, "\nMail queue in:"); in do_mailq_rrd()
32 if (inqueue && outqueue) { in do_mailq_rrd()
37 inqueue = strchr(inqueue+1, '\n'); in do_mailq_rrd()
38 if ((outqueue == NULL) || (inqueue == NULL)) return 0; in do_mailq_rrd()
39 outqueue++; inqueue++; in do_mailq_rrd()
43 p = strchr(inqueue, '\n'); if (p) *p = '\0'; in do_mailq_rrd()
47 p = inqueue + strcspn(inqueue, "0123456789"); inq = atoi(p); in do_mailq_rrd()
|
| /dports/devel/py-celery/celery-4.4.7/examples/eventlet/ |
| H A D | bulk_task_producer.py | 40 self.inqueue = LightQueue()
48 self.inqueue.put((task, args, kwargs, options, receipt))
57 inqueue = self.inqueue
61 task, args, kwargs, options, receipt = inqueue.get()
|
| /dports/devel/py-tables/tables-3.6.1/examples/ |
| H A D | simple_threading.py | 43 def run(filename, path, inqueue, outqueue): argument
45 yslice = inqueue.get()
64 inqueue = queue.Queue()
70 args=(FILENAME, H5PATH, inqueue, outqueue))
76 inqueue.put(yslice)
|
| H A D | threading_monkeypatch.py | 81 def run(filename, path, inqueue, outqueue): argument
83 yslice = inqueue.get()
100 inqueue = queue.Queue()
106 args=(FILENAME, H5PATH, inqueue, outqueue))
112 inqueue.put(yslice)
|
| /dports/devel/py-multiprocess/multiprocess-0.70.12.2/py2.6/multiprocess/ |
| H A D | pool.py | 45 def worker(inqueue, outqueue, initializer=None, initargs=()): argument
47 get = inqueue.get
48 if hasattr(inqueue, '_writer'):
49 inqueue._writer.close()
348 inqueue._rlock.acquire()
350 inqueue._reader.recv()
590 inqueue.not_empty.acquire()
592 inqueue.queue.clear()
593 inqueue.queue.extend([None] * size)
594 inqueue.not_empty.notify_all()
[all …]
|
| /dports/devel/py-multiprocess/multiprocess-0.70.12.2/py3.1/multiprocess/ |
| H A D | pool.py | 73 get = inqueue.get
74 if hasattr(inqueue, '_writer'):
75 inqueue._writer.close()
377 def _help_stuff_finish(inqueue, task_handler, size): argument
380 inqueue._rlock.acquire()
382 inqueue._reader.recv()
625 inqueue.not_empty.acquire()
627 inqueue.queue.clear()
628 inqueue.queue.extend([None] * size)
629 inqueue.not_empty.notify_all()
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/net/sctp/ |
| H A D | endpointola.c | 72 sctp_inq_init(&ep->base.inqueue); in sctp_endpoint_init()
75 sctp_inq_set_th_handler(&ep->base.inqueue, sctp_endpoint_bh_rcv); in sctp_endpoint_init()
206 sctp_inq_free(&ep->base.inqueue); in sctp_endpoint_destroy()
317 base.inqueue.immediate); in sctp_endpoint_bh_rcv()
323 struct sctp_inq *inqueue; in sctp_endpoint_bh_rcv() local
333 inqueue = &ep->base.inqueue; in sctp_endpoint_bh_rcv()
337 while (NULL != (chunk = sctp_inq_pop(inqueue))) { in sctp_endpoint_bh_rcv()
346 next_hdr = sctp_inq_peek(inqueue); in sctp_endpoint_bh_rcv()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/net/sctp/ |
| H A D | endpointola.c | 72 sctp_inq_init(&ep->base.inqueue); in sctp_endpoint_init()
75 sctp_inq_set_th_handler(&ep->base.inqueue, sctp_endpoint_bh_rcv); in sctp_endpoint_init()
206 sctp_inq_free(&ep->base.inqueue); in sctp_endpoint_destroy()
317 base.inqueue.immediate); in sctp_endpoint_bh_rcv()
323 struct sctp_inq *inqueue; in sctp_endpoint_bh_rcv() local
333 inqueue = &ep->base.inqueue; in sctp_endpoint_bh_rcv()
337 while (NULL != (chunk = sctp_inq_pop(inqueue))) { in sctp_endpoint_bh_rcv()
346 next_hdr = sctp_inq_peek(inqueue); in sctp_endpoint_bh_rcv()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/net/sctp/ |
| H A D | endpointola.c | 72 sctp_inq_init(&ep->base.inqueue); in sctp_endpoint_init()
75 sctp_inq_set_th_handler(&ep->base.inqueue, sctp_endpoint_bh_rcv); in sctp_endpoint_init()
206 sctp_inq_free(&ep->base.inqueue); in sctp_endpoint_destroy()
317 base.inqueue.immediate); in sctp_endpoint_bh_rcv()
323 struct sctp_inq *inqueue; in sctp_endpoint_bh_rcv() local
333 inqueue = &ep->base.inqueue; in sctp_endpoint_bh_rcv()
337 while (NULL != (chunk = sctp_inq_pop(inqueue))) { in sctp_endpoint_bh_rcv()
346 next_hdr = sctp_inq_peek(inqueue); in sctp_endpoint_bh_rcv()
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/libs/freetdm/src/ |
| H A D | ftdm_queue.c | 42 static ftdm_status_t ftdm_std_queue_destroy(ftdm_queue_t **inqueue);
210 static ftdm_status_t ftdm_std_queue_destroy(ftdm_queue_t **inqueue) in ftdm_std_queue_destroy() argument
213 ftdm_assert_return(inqueue != NULL, FTDM_FAIL, "Queue is null!\n"); in ftdm_std_queue_destroy()
214 ftdm_assert_return(*inqueue != NULL, FTDM_FAIL, "Queue is null!\n"); in ftdm_std_queue_destroy()
216 queue = *inqueue; in ftdm_std_queue_destroy()
221 *inqueue = NULL; in ftdm_std_queue_destroy()
|
| /dports/devel/libcii/libcii-1.1/src/ |
| H A D | thread.c | 18 T *inqueue; member
39 assert(t->inqueue == NULL && t->link == NULL); in put()
46 t->inqueue = q; in put()
56 assert(t->inqueue == q); in get()
58 t->inqueue = NULL; in get()
63 assert(t->link && t->inqueue == q); in delete()
75 t->inqueue = NULL; in delete()
208 if (t->inqueue) { in Thread_alert()
209 delete(t, t->inqueue); in Thread_alert()
|
| /dports/lang/eisl/eisl-2.35/cii/src/ |
| H A D | thread.c | 18 T *inqueue; member
39 assert(t->inqueue == NULL && t->link == NULL); in put()
46 t->inqueue = q; in put()
56 assert(t->inqueue == q); in get()
58 t->inqueue = NULL; in get()
63 assert(t->link && t->inqueue == q); in delete()
75 t->inqueue = NULL; in delete()
213 if (t->inqueue) { in Thread_alert()
214 delete(t, t->inqueue); in Thread_alert()
|
| /dports/lang/python-legacy/Python-2.7.18/Lib/multiprocessing/ |
| H A D | pool.py | 91 get = inqueue.get
92 if hasattr(inqueue, '_writer'):
93 inqueue._writer.close()
482 def _help_stuff_finish(inqueue, task_handler, size): argument
485 inqueue._rlock.acquire()
487 inqueue._reader.recv()
743 inqueue.not_empty.acquire()
745 inqueue.queue.clear()
746 inqueue.queue.extend([None] * size)
747 inqueue.not_empty.notify_all()
[all …]
|
| /dports/lang/python27/Python-2.7.18/Lib/multiprocessing/ |
| H A D | pool.py | 91 get = inqueue.get
92 if hasattr(inqueue, '_writer'):
93 inqueue._writer.close()
482 def _help_stuff_finish(inqueue, task_handler, size): argument
485 inqueue._rlock.acquire()
487 inqueue._reader.recv()
743 inqueue.not_empty.acquire()
745 inqueue.queue.clear()
746 inqueue.queue.extend([None] * size)
747 inqueue.not_empty.notify_all()
[all …]
|
| /dports/devel/py-multiprocess/multiprocess-0.70.12.2/pypy2.7/multiprocess/ |
| H A D | pool.py | 91 get = inqueue.get
92 if hasattr(inqueue, '_writer'):
93 inqueue._writer.close()
482 def _help_stuff_finish(inqueue, task_handler, size): argument
485 inqueue._rlock.acquire()
487 inqueue._reader.recv()
743 inqueue.not_empty.acquire()
745 inqueue.queue.clear()
746 inqueue.queue.extend([None] * size)
747 inqueue.not_empty.notify_all()
[all …]
|
| /dports/devel/py-multiprocess/multiprocess-0.70.12.2/py2.7/multiprocess/ |
| H A D | pool.py | 91 get = inqueue.get
92 if hasattr(inqueue, '_writer'):
93 inqueue._writer.close()
482 def _help_stuff_finish(inqueue, task_handler, size): argument
485 inqueue._rlock.acquire()
487 inqueue._reader.recv()
743 inqueue.not_empty.acquire()
745 inqueue.queue.clear()
746 inqueue.queue.extend([None] * size)
747 inqueue.not_empty.notify_all()
[all …]
|
| /dports/devel/py-multiprocess/multiprocess-0.70.12.2/py3.2/multiprocess/ |
| H A D | pool.py | 91 get = inqueue.get
92 if hasattr(inqueue, '_writer'):
93 inqueue._writer.close()
468 def _help_stuff_finish(inqueue, task_handler, size): argument
471 inqueue._rlock.acquire()
473 inqueue._reader.recv()
732 inqueue.not_empty.acquire()
734 inqueue.queue.clear()
735 inqueue.queue.extend([None] * size)
736 inqueue.not_empty.notify_all()
[all …]
|
| /dports/devel/py-multiprocess/multiprocess-0.70.12.2/py3.3/multiprocess/ |
| H A D | pool.py | 69 get = inqueue.get
70 if hasattr(inqueue, '_writer'):
71 inqueue._writer.close()
477 def _help_stuff_finish(inqueue, task_handler, size): argument
480 inqueue._rlock.acquire()
482 inqueue._reader.recv()
728 inqueue.not_empty.acquire()
730 inqueue.queue.clear()
731 inqueue.queue.extend([None] * size)
732 inqueue.not_empty.notify_all()
[all …]
|
| /dports/databases/py-gdbm/Python-3.8.12/Lib/multiprocessing/ |
| H A D | pool.py | 103 get = inqueue.get
104 if hasattr(inqueue, '_writer'):
105 inqueue._writer.close()
320 args=(inqueue, outqueue,
669 def _help_stuff_finish(inqueue, task_handler, size): argument
672 inqueue._rlock.acquire()
674 inqueue._reader.recv()
692 cls._help_stuff_finish(inqueue, task_handler, len(pool))
941 def _help_stuff_finish(inqueue, task_handler, size): argument
945 inqueue.get(block=False)
[all …]
|
| /dports/databases/py-sqlite3/Python-3.8.12/Lib/multiprocessing/ |
| H A D | pool.py | 103 get = inqueue.get
104 if hasattr(inqueue, '_writer'):
105 inqueue._writer.close()
320 args=(inqueue, outqueue,
669 def _help_stuff_finish(inqueue, task_handler, size): argument
672 inqueue._rlock.acquire()
674 inqueue._reader.recv()
692 cls._help_stuff_finish(inqueue, task_handler, len(pool))
941 def _help_stuff_finish(inqueue, task_handler, size): argument
945 inqueue.get(block=False)
[all …]
|
| /dports/lang/python310/Python-3.10.1/Lib/multiprocessing/ |
| H A D | pool.py | 103 get = inqueue.get
104 if hasattr(inqueue, '_writer'):
105 inqueue._writer.close()
320 args=(inqueue, outqueue,
669 def _help_stuff_finish(inqueue, task_handler, size): argument
672 inqueue._rlock.acquire()
674 inqueue._reader.recv()
692 cls._help_stuff_finish(inqueue, task_handler, len(pool))
943 def _help_stuff_finish(inqueue, task_handler, size): argument
947 inqueue.get(block=False)
[all …]
|
| /dports/lang/python-tools/Python-3.8.12/Lib/multiprocessing/ |
| H A D | pool.py | 103 get = inqueue.get
104 if hasattr(inqueue, '_writer'):
105 inqueue._writer.close()
320 args=(inqueue, outqueue,
669 def _help_stuff_finish(inqueue, task_handler, size): argument
672 inqueue._rlock.acquire()
674 inqueue._reader.recv()
692 cls._help_stuff_finish(inqueue, task_handler, len(pool))
941 def _help_stuff_finish(inqueue, task_handler, size): argument
945 inqueue.get(block=False)
[all …]
|
| /dports/lang/python39/Python-3.9.9/Lib/multiprocessing/ |
| H A D | pool.py | 103 get = inqueue.get
104 if hasattr(inqueue, '_writer'):
105 inqueue._writer.close()
320 args=(inqueue, outqueue,
669 def _help_stuff_finish(inqueue, task_handler, size): argument
672 inqueue._rlock.acquire()
674 inqueue._reader.recv()
692 cls._help_stuff_finish(inqueue, task_handler, len(pool))
943 def _help_stuff_finish(inqueue, task_handler, size): argument
947 inqueue.get(block=False)
[all …]
|