Home
last modified time | relevance | path

Searched refs:ioloop (Results 1 – 25 of 1079) sorted by relevance

12345678910>>...44

/dports/mail/dovecot/dovecot-2.3.17/src/lib/
H A Dioloop.c58 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 Dioloop.h9 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 Dioloop-private.h12 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 Dtest-ioloop.c60 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 Dioloop-select.c20 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 Dtest-log-throttle.c10 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 Dioloop-poll.c21 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 Dioloop-epoll.c22 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 Dioloop-kqueue.c38 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 Dioloop-notify-inotify.c34 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 Dostream-wrapper.h64 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 Dtest-lib-signals.c45 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 Dtest_ioloop.py15 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 Dioloop.m45 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 Dselect_connection_ioloop_tests.py134 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 Dthreaded.py12 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 Dservers.py45 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 Dweaken.t11 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 Dioloop.py23 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 Dtest-dict-lua.c18 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 Dutil.py15 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 Dtornado.c7 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 Dtest-master-login-auth.c50 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 Dzmq.eventloop.ioloop.rst2 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 Dtornado_notifier.py2 from tornado.ioloop import IOLoop
15 ioloop = IOLoop.instance() variable
16 notifier = pyinotify.TornadoAsyncNotifier(wm, ioloop,
19 ioloop.start()
20 ioloop.close()

12345678910>>...44