| /dports/www/py-notebook/notebook-6.4.5/notebook/services/ |
| H A D | shutdown.py | 3 from tornado import web, ioloop
10 ioloop.IOLoop.current().stop()
|
| /dports/devel/py-jupyter-server/jupyter_server-1.12.1/jupyter_server/services/ |
| H A D | shutdown.py | 3 from tornado import ioloop
16 ioloop.IOLoop.current().stop()
|
| /dports/www/py-notebook/notebook-6.4.5/notebook/base/ |
| H A D | zmqhandlers.py | 12 from tornado import gen, ioloop, web
163 loop = ioloop.IOLoop.current()
166 self.ping_callback = ioloop.PeriodicCallback(
180 now = ioloop.IOLoop.current().time()
197 self.last_pong = ioloop.IOLoop.current().time()
|
| /dports/devel/py-jupyter-server/jupyter_server-1.12.1/jupyter_server/base/ |
| H A D | zmqhandlers.py | 20 from tornado import ioloop
164 loop = ioloop.IOLoop.current()
167 self.ping_callback = ioloop.PeriodicCallback(
186 now = ioloop.IOLoop.current().time()
198 self.last_pong = ioloop.IOLoop.current().time()
|
| /dports/net/py-pynsq/pynsq-0.9.0b1/nsq/ |
| H A D | client.py | 6 import tornado.ioloop
13 self.io_loop = tornado.ioloop.IOLoop.current()
14 tornado.ioloop.PeriodicCallback(self._check_last_recv_timestamps, 60 * 1000).start()
|
| /dports/net/py-pyzmq/pyzmq-22.3.0/examples/heartbeat/ |
| H A D | heartbeater.py | 18 from zmq.eventloop import ioloop, zmqstream
39 self.caller = ioloop.PeriodicCallback(self.beat, period, self.loop)
78 loop = ioloop.IOLoop()
|
| /dports/net/py-pyzmq/pyzmq-22.3.0/zmq/tests/ |
| H A D | test_zmqstream.py | 17 from zmq.eventloop import ioloop, zmqstream
29 self.loop = ioloop.IOLoop()
40 ioloop.IOLoop.clear_current()
|
| /dports/mail/dovecot/dovecot-2.3.17/src/director/ |
| H A D | test-user-directory.c | 105 struct ioloop *ioloop = io_loop_create(); in main() local
107 io_loop_destroy(&ioloop); in main()
|
| /dports/mail/dovecot/dovecot-2.3.17/src/lib-dict/ |
| H A D | dict-private.h | 7 struct ioloop;
69 struct ioloop *ioloop, *prev_ioloop; member
|
| /dports/databases/powa-web/powa-web-4.0.2/ |
| H A D | run_powa.py | 3 import tornado.ioloop
13 tornado.ioloop.IOLoop.instance().start()
|
| /dports/mail/dovecot/dovecot-2.3.17/src/lib-storage/ |
| H A D | test-mail-storage-common.h | 11 struct ioloop *ioloop; member
|
| /dports/mail/dovecot/dovecot-2.3.17/src/lib-http/ |
| H A D | test-http-client.c | 25 static struct ioloop *ioloop; variable
61 io_loop_stop(ioloop); in got_request_response()
366 ioloop = io_loop_create(); in main()
367 io_loop_set_running(ioloop); in main()
454 io_loop_run(ioloop); in main()
466 io_loop_destroy(&ioloop); in main()
|
| /dports/www/py-tornado4/tornado-4.5.3/tornado/ |
| H A D | autoreload.py | 93 from tornado import ioloop
120 io_loop = io_loop or ioloop.IOLoop.current()
128 scheduler = ioloop.PeriodicCallback(callback, check_time, io_loop=io_loop)
139 io_loop = ioloop.IOLoop()
|
| H A D | curl_httpclient.py | 30 from tornado import ioloop
55 self._force_timeout_callback = ioloop.PeriodicCallback(
87 pycurl.POLL_NONE: ioloop.IOLoop.NONE,
88 pycurl.POLL_IN: ioloop.IOLoop.READ,
89 pycurl.POLL_OUT: ioloop.IOLoop.WRITE,
90 pycurl.POLL_INOUT: ioloop.IOLoop.READ | ioloop.IOLoop.WRITE
124 if events & ioloop.IOLoop.READ:
126 if events & ioloop.IOLoop.WRITE:
|
| /dports/sysutils/py-salt/salt-3004.1/salt/ext/tornado/ |
| H A D | autoreload.py | 94 from salt.ext.tornado import ioloop
121 io_loop = io_loop or ioloop.IOLoop.current()
129 scheduler = ioloop.PeriodicCallback(callback, check_time, io_loop=io_loop)
140 io_loop = ioloop.IOLoop()
|
| H A D | curl_httpclient.py | 31 from salt.ext.tornado import ioloop
56 self._force_timeout_callback = ioloop.PeriodicCallback(
88 pycurl.POLL_NONE: ioloop.IOLoop.NONE,
89 pycurl.POLL_IN: ioloop.IOLoop.READ,
90 pycurl.POLL_OUT: ioloop.IOLoop.WRITE,
91 pycurl.POLL_INOUT: ioloop.IOLoop.READ | ioloop.IOLoop.WRITE
125 if events & ioloop.IOLoop.READ:
127 if events & ioloop.IOLoop.WRITE:
|
| /dports/databases/py-queries/queries-2.1.1/queries/ |
| H A D | tornado_session.py | 29 from tornado import concurrent, ioloop
158 self._ioloop = io_loop or ioloop.IOLoop.current()
263 ioloop.IOLoop.WRITE)
336 ioloop.IOLoop.WRITE)
503 self._ioloop.update_handler(fd, ioloop.IOLoop.WRITE)
505 self._ioloop.update_handler(fd, ioloop.IOLoop.READ)
|
| /dports/net/py-pyzmq/pyzmq-22.3.0/examples/eventloop/ |
| H A D | echostream.py | 6 from zmq.eventloop import ioloop, zmqstream
8 loop = ioloop.IOLoop.instance()
|
| H A D | echofuture.py | 5 from tornado import ioloop
19 loop = ioloop.IOLoop.current()
|
| /dports/devel/py-opentracing/opentracing-2.4.0/tests/scope_managers/ |
| H A D | test_tornado.py | 25 from tornado import ioloop, version_info
44 ioloop.IOLoop.current().run_sync(test_fn)
|
| /dports/devel/py-jupyter-client/jupyter_client-6.1.12/jupyter_client/ioloop/ |
| H A D | manager.py | 6 from tornado import ioloop
30 return ioloop.IOLoop.current()
70 return ioloop.IOLoop.current()
|
| /dports/mail/dovecot/dovecot-2.3.17/src/lib-smtp/ |
| H A D | test-smtp-submit.c | 72 static struct ioloop *ioloop; variable
1467 struct ioloop *ioloop; in test_client_parallel_delivery() local
1515 io_loop_run(ioloop); in test_client_parallel_delivery()
1519 io_loop_destroy(&ioloop); in test_client_parallel_delivery()
1709 struct ioloop *ioloop; in test_client_parallel_sendmail() local
1763 io_loop_run(ioloop); in test_client_parallel_sendmail()
1767 io_loop_destroy(&ioloop); in test_client_parallel_sendmail()
1971 io_loop_run(ioloop); in test_server_run()
2075 io_loop_destroy(&ioloop); in test_run_server()
2100 io_loop_run(ioloop); in test_run_client()
[all …]
|
| /dports/www/py-tornado/tornado-6.1/tornado/ |
| H A D | curl_httpclient.py | 27 from tornado import ioloop
69 self._force_timeout_callback = ioloop.PeriodicCallback(
110 pycurl.POLL_NONE: ioloop.IOLoop.NONE,
111 pycurl.POLL_IN: ioloop.IOLoop.READ,
112 pycurl.POLL_OUT: ioloop.IOLoop.WRITE,
113 pycurl.POLL_INOUT: ioloop.IOLoop.READ | ioloop.IOLoop.WRITE,
147 if events & ioloop.IOLoop.READ:
149 if events & ioloop.IOLoop.WRITE:
|
| /dports/www/py-tornado5/tornado-5.1.1/tornado/ |
| H A D | curl_httpclient.py | 29 from tornado import ioloop
54 self._force_timeout_callback = ioloop.PeriodicCallback(
92 pycurl.POLL_NONE: ioloop.IOLoop.NONE,
93 pycurl.POLL_IN: ioloop.IOLoop.READ,
94 pycurl.POLL_OUT: ioloop.IOLoop.WRITE,
95 pycurl.POLL_INOUT: ioloop.IOLoop.READ | ioloop.IOLoop.WRITE
129 if events & ioloop.IOLoop.READ:
131 if events & ioloop.IOLoop.WRITE:
|
| /dports/mail/dovecot/dovecot-2.3.17/src/lib-master/ |
| H A D | test-event-stats.c | 86 static struct ioloop *ioloop; variable
115 ioloop = io_loop_create(); in stats_proc()
120 io_loop_run(ioloop); in stats_proc()
123 io_loop_destroy(&ioloop); in stats_proc()
194 io_loop_stop(ioloop); in stats_conn_input()
688 struct ioloop *ioloop = io_loop_create(); in run_tests() local
699 io_loop_destroy(&ioloop); in run_tests()
|