/dports/mail/dovecot/dovecot-2.3.17/src/lib/ |
H A D | ioloop.c | 58 io->io.ioloop = ioloop; in io_add_file() 268 timeout->ioloop = ioloop; in timeout_add_common() 400 struct ioloop *ioloop; in timeout_remove() local 405 ioloop = timeout->ioloop; in timeout_remove() 614 struct ioloop *ioloop; in io_loops_timeouts_update() local 616 for (ioloop = current_ioloop; ioloop != NULL; ioloop = ioloop->prev) in io_loops_timeouts_update() 724 struct ioloop *ioloop = io->ioloop; in io_loop_call_io() local 831 struct ioloop *ioloop; in io_loop_create() local 990 ioloop = ioloop->prev; in io_loop_get_root() 1048 ctx->ioloop = ioloop; in io_loop_context_new() [all …]
|
H A D | ioloop.h | 9 struct ioloop; 166 timeout_add_absolute_to(struct ioloop *ioloop, 184 void io_loop_run(struct ioloop *ioloop); 187 void io_loop_stop(struct ioloop *ioloop); 191 bool io_loop_is_running(struct ioloop *ioloop); 194 void io_loop_set_running(struct ioloop *ioloop); 195 void io_loop_handler_run(struct ioloop *ioloop); 201 void io_loop_destroy(struct ioloop **ioloop); 298 struct ioloop *ioloop); 311 bool io_loop_have_ios(struct ioloop *ioloop); [all …]
|
H A D | ioloop-private.h | 12 struct ioloop { struct 13 struct ioloop *prev; argument 53 struct ioloop *ioloop; member 81 struct ioloop *ioloop; member 92 struct ioloop *ioloop; member 105 struct ioloop *ioloop; member 109 int io_loop_run_get_wait_time(struct ioloop *ioloop, struct timeval *tv_r); 110 void io_loop_handle_timeouts(struct ioloop *ioloop); 113 void io_loop_handler_run_internal(struct ioloop *ioloop); 120 void io_loop_handler_deinit(struct ioloop *ioloop); [all …]
|
H A D | test-ioloop.c | 60 struct ioloop *ioloop = io_loop_create(); in test_ioloop_fd() local 75 io_loop_run(ioloop); in test_ioloop_fd() 94 struct ioloop *ioloop, *ioloop2; in test_ioloop_timeout() local 125 io_loop_run(ioloop); in test_ioloop_timeout() 142 struct ioloop *ioloop; in test_ioloop_zero_timeout() local 169 io_loop_run(ioloop); in test_ioloop_zero_timeout() 193 struct ioloop *ioloop; in test_ioloop_zero_timeout_recreate() local 219 io_loop_run(ioloop); in test_ioloop_zero_timeout_recreate() 245 struct ioloop *ioloop; in test_ioloop_find_fd_conditions() local 285 struct ioloop *ioloop = io_loop_create(); in test_ioloop_pending_io() local [all …]
|
H A D | ioloop-select.c | 20 static void update_highest_fd(struct ioloop *ioloop) in update_highest_fd() argument 40 void io_loop_handler_init(struct ioloop *ioloop, in io_loop_handler_init() argument 52 void io_loop_handler_deinit(struct ioloop *ioloop) in io_loop_handler_deinit() argument 54 i_free(ioloop->handler_context); in io_loop_handler_deinit() 96 update_highest_fd(io->io.ioloop); in io_loop_handle_remove() 106 void io_loop_handler_run_internal(struct ioloop *ioloop) in io_loop_handler_run_internal() argument 114 io_loop_run_get_wait_time(ioloop, &tv); in io_loop_handler_run_internal() 126 io_loop_handle_timeouts(ioloop); in io_loop_handler_run_internal() 128 if (ret <= 0 || !ioloop->running) { in io_loop_handler_run_internal() 133 io = ioloop->io_files; in io_loop_handler_run_internal() [all …]
|
H A D | test-log-throttle.c | 10 struct ioloop *ioloop) in test_log_throttle_callback() argument 13 io_loop_stop(ioloop); in test_log_throttle_callback() 24 struct ioloop *ioloop; in test_log_throttle() local 29 ioloop = io_loop_create(); in test_log_throttle() 30 throttle = log_throttle_init(&set, test_log_throttle_callback, ioloop); in test_log_throttle() 38 io_loop_run(ioloop); in test_log_throttle() 47 io_loop_run(ioloop); in test_log_throttle() 54 io_loop_destroy(&ioloop); in test_log_throttle()
|
H A D | ioloop-poll.c | 21 void io_loop_handler_init(struct ioloop *ioloop, unsigned int initial_fd_count) in io_loop_handler_init() argument 34 void io_loop_handler_deinit(struct ioloop *ioloop) in io_loop_handler_deinit() argument 36 i_free(ioloop->handler_context->fds); in io_loop_handler_deinit() 37 i_free(ioloop->handler_context->fd_index); in io_loop_handler_deinit() 38 i_free(ioloop->handler_context); in io_loop_handler_deinit() 144 void io_loop_handler_run_internal(struct ioloop *ioloop) in io_loop_handler_run_internal() argument 169 io_loop_handle_timeouts(ioloop); in io_loop_handler_run_internal() 171 if (ret <= 0 || !ioloop->running) { in io_loop_handler_run_internal() 176 io = ioloop->io_files; in io_loop_handler_run_internal() 178 ioloop->next_io_file = io->next; in io_loop_handler_run_internal() [all …]
|
H A D | ioloop-epoll.c | 22 void io_loop_handler_init(struct ioloop *ioloop, unsigned int initial_fd_count) in io_loop_handler_init() argument 43 void io_loop_handler_deinit(struct ioloop *ioloop) in io_loop_handler_deinit() argument 45 struct ioloop_handler_context *ctx = ioloop->handler_context; in io_loop_handler_deinit() 55 array_free(&ioloop->handler_context->fd_index); in io_loop_handler_deinit() 56 array_free(&ioloop->handler_context->events); in io_loop_handler_deinit() 57 i_free(ioloop->handler_context); in io_loop_handler_deinit() 164 void io_loop_handler_run_internal(struct ioloop *ioloop) in io_loop_handler_run_internal() argument 179 msecs = io_loop_run_get_wait_time(ioloop, &tv); in io_loop_handler_run_internal() 195 io_loop_handle_timeouts(ioloop); in io_loop_handler_run_internal() 197 if (!ioloop->running) in io_loop_handler_run_internal() [all …]
|
H A D | ioloop-kqueue.c | 38 void io_loop_handler_init(struct ioloop *ioloop, unsigned int initial_fd_count) in io_loop_handler_init() argument 51 void io_loop_handler_deinit(struct ioloop *ioloop) in io_loop_handler_deinit() argument 53 if (close(ioloop->handler_context->kq) < 0) in io_loop_handler_deinit() 55 array_free(&ioloop->handler_context->events); in io_loop_handler_deinit() 56 i_free(ioloop->handler_context); in io_loop_handler_deinit() 111 void io_loop_handler_run_internal(struct ioloop *ioloop) in io_loop_handler_run_internal() argument 113 struct ioloop_handler_context *ctx = ioloop->handler_context; in io_loop_handler_run_internal() 123 msecs = io_loop_run_get_wait_time(ioloop, &tv); in io_loop_handler_run_internal() 151 io_loop_handle_timeouts(ioloop); in io_loop_handler_run_internal() 153 if (!ioloop->running) in io_loop_handler_run_internal() [all …]
|
H A D | ioloop-notify-inotify.c | 34 static bool inotify_input_more(struct ioloop *ioloop) in inotify_input_more() argument 37 ioloop->notify_handler_context; in inotify_input_more() 80 static void inotify_input(struct ioloop *ioloop) in inotify_input() argument 82 while (inotify_input_more(ioloop)) ; in inotify_input() 136 _io->ioloop->notify_handler_context; in io_loop_notify_remove() 171 struct ioloop *ioloop = current_ioloop; in io_loop_notify_handler_init() local 174 ctx = ioloop->notify_handler_context = in io_loop_notify_handler_init() 191 void io_loop_notify_handler_deinit(struct ioloop *ioloop) in io_loop_notify_handler_deinit() argument 194 ioloop->notify_handler_context; in io_loop_notify_handler_deinit() 211 int io_loop_extract_notify_fd(struct ioloop *ioloop) in io_loop_extract_notify_fd() argument [all …]
|
H A D | ostream-wrapper.h | 64 struct ioloop *(*wait_begin)(struct wrapper_ostream *wostream, 65 struct ioloop *ioloop); 67 struct ioloop *prev_ioloop); 76 struct ioloop *ioloop); 91 struct ioloop *flush_ioloop;
|
H A D | test-lib-signals.c | 45 struct ioloop *ioloop; in test_lib_signals_delayed() local 56 ioloop = io_loop_create(); in test_lib_signals_delayed() 59 io_loop_run(ioloop); in test_lib_signals_delayed() 63 io_loop_destroy(&ioloop); in test_lib_signals_delayed() 76 ioloop = io_loop_create(); in test_lib_signals_delayed() 85 io_loop_run(ioloop); in test_lib_signals_delayed() 92 io_loop_destroy(&ioloop); in test_lib_signals_delayed() 106 struct ioloop *ioloop1, *ioloop2; in test_lib_signals_delayed_nested_ioloop() 151 struct ioloop *ioloop1, *ioloop2; in test_lib_signals_delayed_no_ioloop_automove()
|
/dports/ftp/py-pyftpdlib/pyftpdlib-1.5.6/pyftpdlib/test/ |
H A D | test_ioloop.py | 15 from pyftpdlib.ioloop import Acceptor 16 from pyftpdlib.ioloop import AsyncChat 17 from pyftpdlib.ioloop import IOLoop 18 from pyftpdlib.ioloop import RetryError 23 import pyftpdlib.ioloop 292 self.ioloop.sched.poll() 352 self.ioloop.call_later( 384 self.ioloop.sched.poll() 406 self.ioloop.sched.poll() 418 self.ioloop.sched.poll() [all …]
|
/dports/mail/dovecot/dovecot-2.3.17/m4/ |
H A D | ioloop.m4 | 5 if test "$ioloop" = "best" || test "$ioloop" = "epoll"; then 23 ioloop=epoll 25 if test "$ioloop" = "epoll" ; then 26 AC_MSG_ERROR([epoll ioloop requested but epoll_create() is not available]) 31 if test "$ioloop" = "best" || test "$ioloop" = "kqueue"; then 34 ioloop=kqueue 36 elif test "$ioloop" = "kqueue"; then 37 AC_MSG_ERROR([kqueue ioloop requested but kqueue() is not available]) 41 if test "$ioloop" = "best" || test "$ioloop" = "poll"; then 44 ioloop=poll [all …]
|
/dports/devel/py-pika/pika-1.1.0/tests/unit/ |
H A D | select_connection_ioloop_tests.py | 134 self.ioloop.start() 167 self.ioloop.close() 221 lambda: self.ioloop.add_callback_threadsafe(self.ioloop.stop)) 253 self.ioloop.close() 322 self.ioloop.stop() 444 self.ioloop.add_handler(fd_, self.do_accept, self.ioloop.READ) 454 self.ioloop.add_handler(fd_, on_connected, self.ioloop.WRITE) 463 self.ioloop.add_handler(fd_, self.do_read, self.ioloop.READ) 484 self.ioloop.stop() 747 return ioloop [all …]
|
/dports/devel/py-jupyter-client/jupyter_client-6.1.12/jupyter_client/ |
H A D | threaded.py | 12 from zmq.eventloop import ioloop, zmqstream 23 ioloop = None variable in ThreadedZMQSocketChannel 43 self.ioloop = loop 151 ioloop = None variable in IOLoopThread 182 self.ioloop = ioloop.IOLoop() 187 self.ioloop.start() 208 if self.ioloop is not None: 209 self.ioloop.add_callback(self.ioloop.stop) 212 self.ioloop = None 215 if self.ioloop is not None: [all …]
|
/dports/ftp/py-pyftpdlib/pyftpdlib-1.5.6/pyftpdlib/ |
H A D | servers.py | 45 from .ioloop import Acceptor 46 from .ioloop import IOLoop 105 Acceptor.__init__(self, ioloop=ioloop) 133 return len(self.ioloop.socket_map) 262 handler = self.handler(sock, self, ioloop=self.ioloop) 318 return self.ioloop.close() 340 ioloop=ioloop, backlog=backlog) 378 with IOLoop() as ioloop: 379 handler.ioloop = ioloop 393 poll = ioloop.poll [all …]
|
/dports/www/p5-Mojo-IOLoop-ForkCall/Mojo-IOLoop-ForkCall-0.21/t/ |
H A D | weaken.t | 11 my $ioloop = $fc->ioloop; 15 $ioloop->stop; 17 return $ioloop; 22 my $ioloop = generate(0, sub { 27 $ioloop->start; 34 my $ioloop = generate(1, sub { $fc = shift; shift; $res = shift; }); 36 $ioloop->reactor->unsubscribe('error'); 37 $ioloop->reactor->on( error => sub { $loop_err++ } ); 38 $ioloop->start; 40 ok ! $loop_err, 'No error thrown by ioloop (at emit)';
|
/dports/net/py-pyzmq/pyzmq-22.3.0/zmq/eventloop/ |
H A D | ioloop.py | 23 from tornado import ioloop 25 if not hasattr(ioloop.IOLoop, 'configurable_default'): 30 from .minitornado import ioloop # type: ignore 33 PeriodicCallback = ioloop.PeriodicCallback # type: ignore 89 if '.minitornado.' in ioloop.__name__: 92 _IOLoop = ioloop.IOLoop 118 ioloop.IOLoop.configure(cls) 128 ioloop.IOLoop.configure(cls) 130 loop = ioloop.IOLoop.current(*args, **kwargs) 144 ioloop.IOLoop.configure(ZMQIOLoop) [all …]
|
/dports/mail/dovecot/dovecot-2.3.17/src/lib-lua/ |
H A D | test-dict-lua.c | 18 static void test_dict_finished(lua_State *L, struct ioloop *ioloop, int res) in test_dict_finished() argument 22 io_loop_stop(ioloop); in test_dict_finished() 62 struct ioloop *ioloop = io_loop_create(); in test_dict_lua() local 77 ioloop, &error) < 0) in test_dict_lua() 79 io_loop_run(ioloop); in test_dict_lua() 85 io_loop_destroy(&ioloop); in test_dict_lua()
|
/dports/devel/py-nbclient/nbclient-0.5.9/nbclient/tests/ |
H A D | util.py | 15 ioloop = asyncio.new_event_loop() 17 asyncio.set_event_loop(ioloop) 19 assert asyncio.get_event_loop() is ioloop 37 ioloop = tornado.ioloop.IOLoop.current() 43 ioloop.add_future(future, lambda f: f.result()) 57 ioloop.run_sync(run)
|
/dports/www/uwsgi/uwsgi-2.0.20/plugins/tornado/ |
H A D | tornado.c | 7 PyObject *ioloop; member 75 if (PyObject_CallMethod(utornado.ioloop, "add_handler", "iOO", fd, cb_fd, utornado.read) == NULL) { in uwsgi_tornado_wait_read_hook() 92 if (PyObject_CallMethod(utornado.ioloop, "remove_handler", "i", fd) == NULL) PyErr_Print(); in uwsgi_tornado_wait_read_hook() 93 if (PyObject_CallMethod(utornado.ioloop, "remove_timeout", "O", ob_timeout) == NULL) PyErr_Print(); in uwsgi_tornado_wait_read_hook() 170 if (PyObject_CallMethod(utornado.ioloop, "remove_handler", "i", fd) == NULL) { in py_uwsgi_tornado_request() 307 if (PyObject_CallMethod(utornado.ioloop, "add_callback", "O", cb_fix) == NULL) { in uwsgi_tornado_schedule_fix() 360 utornado.ioloop = PyObject_CallMethod(tornado_IOLoop, "instance", NULL); in tornado_loop() 361 if (!utornado.ioloop) uwsgi_pyexit; in tornado_loop() 377 utornado.read = PyObject_GetAttrString(utornado.ioloop, "READ"); in tornado_loop() 379 utornado.write = PyObject_GetAttrString(utornado.ioloop, "WRITE"); in tornado_loop() [all …]
|
/dports/mail/dovecot/dovecot-2.3.17/src/master/ |
H A D | test-master-login-auth.c | 50 static struct ioloop *ioloop; variable 678 struct ioloop *ioloop; member 697 test_client_request_run(struct master_login_auth *auth, struct ioloop *ioloop, in test_client_request_run() argument 707 login_test.ioloop = ioloop; in test_client_request_run() 719 io_loop_run(ioloop); in test_client_request_run() 733 struct ioloop *ioloop; in test_client_request_parallel() local 759 io_loop_destroy(&ioloop); in test_client_request_parallel() 859 io_loop_run(ioloop); in test_server_run() 895 io_loop_destroy(&ioloop); in test_run_server() 915 io_loop_run(ioloop); in test_run_client() [all …]
|
/dports/net/py-pyzmq/pyzmq-22.3.0/docs/source/api/ |
H A D | zmq.eventloop.ioloop.rst | 2 eventloop.ioloop 5 Module: :mod:`eventloop.ioloop` 7 .. automodule:: zmq.eventloop.ioloop 9 .. currentmodule:: zmq.eventloop.ioloop 26 .. autofunction:: zmq.eventloop.ioloop.install
|
/dports/devel/py-pyinotify/pyinotify-0.9.6/python2/examples/ |
H A D | tornado_notifier.py | 2 from tornado.ioloop import IOLoop 15 ioloop = IOLoop.instance() variable 16 notifier = pyinotify.TornadoAsyncNotifier(wm, ioloop, 19 ioloop.start() 20 ioloop.close()
|