Home
last modified time | relevance | path

Searched refs:ioloop (Results 51 – 75 of 1079) sorted by relevance

12345678910>>...44

/dports/devel/py-pika/pika-1.1.0/examples/
H A Dasynchronous_publisher_example.py86 self._connection.ioloop.call_later(5, self._connection.ioloop.stop)
100 self._connection.ioloop.stop()
104 self._connection.ioloop.call_later(5, self._connection.ioloop.stop)
276 self._connection.ioloop.call_later(self.PUBLISH_INTERVAL,
323 self._connection.ioloop.start()
329 self._connection.ioloop.start()
/dports/mail/dovecot/dovecot-2.3.17/src/lib-ssl-iostream/
H A Dtest-iostream-ssl.c246 struct ioloop *ioloop; in test_iostream_ssl_handshake() local
251 ioloop = io_loop_create(); in test_iostream_ssl_handshake()
348 io_loop_destroy(&ioloop); in test_iostream_ssl_handshake()
357 struct ioloop *ioloop; in test_iostream_ssl_get_buffer_avail_size() local
368 ioloop = io_loop_create(); in test_iostream_ssl_get_buffer_avail_size()
417 io_loop_run(ioloop); in test_iostream_ssl_get_buffer_avail_size()
431 io_loop_destroy(&ioloop); in test_iostream_ssl_get_buffer_avail_size()
440 struct ioloop *ioloop; in test_iostream_ssl_small_packets() local
451 ioloop = io_loop_create(); in test_iostream_ssl_small_packets()
489 io_loop_run(ioloop); in test_iostream_ssl_small_packets()
[all …]
/dports/www/p5-Mojolicious/Mojolicious-9.22/lib/Mojo/IOLoop/
H A DSubprocess.pm12 has ioloop => sub { Mojo::IOLoop->singleton }, weak => 1;
21 $self->ioloop->next_tick(sub { $self->_start(@args) });
33 $self->ioloop->next_tick(sub { $self->_start($child, $parent) });
52 $self->ioloop->reset({freeze => 1});
64 $self->emit('spawn')->ioloop->stream($stream);
/dports/mail/dovecot/dovecot-2.3.17/src/lib/
H A Dtest-iostream-proxy.c42 struct ioloop *ioloop = io_loop_create(); in test_iostream_proxy_simple() local
74 io_loop_run(ioloop); in test_iostream_proxy_simple()
86 io_loop_run(ioloop); in test_iostream_proxy_simple()
94 io_loop_destroy(&ioloop); in test_iostream_proxy_simple()
H A Dostream-wrapper.c12 struct ioloop *ioloop);
262 struct ioloop *ioloop, *prev_ioloop; in wrapper_ostream_flush_wait() local
290 i_assert(io_loop_have_ios(ioloop) || in wrapper_ostream_flush_wait()
296 io_loop_run(ioloop); in wrapper_ostream_flush_wait()
303 io_loop_destroy(&ioloop); in wrapper_ostream_flush_wait()
1037 struct ioloop *ioloop) in wrapper_ostream_switch_ioloop_to() argument
1042 if (wostream->flush_ioloop != ioloop && in wrapper_ostream_switch_ioloop_to()
1088 struct ioloop *ioloop = NULL; in wrapper_ostream_continue() local
1094 ioloop = wostream->flush_ioloop; in wrapper_ostream_continue()
1106 i_assert(ioloop != NULL); in wrapper_ostream_continue()
[all …]
H A DMakefile.am115 ioloop.c \
116 ioloop-iolist.c \
118 ioloop-notify-fd.c \
121 ioloop-poll.c \
122 ioloop-select.c \
123 ioloop-epoll.c \
124 ioloop-kqueue.c \
279 ioloop.h \
280 ioloop-iolist.h \
281 ioloop-private.h \
[all …]
/dports/mail/dovecot/dovecot-2.3.17/src/lib-http/
H A Dhttp-server-ostream.c179 static struct ioloop *
181 struct ioloop *ioloop) in http_server_ostream_wait_begin() argument
186 struct ioloop *prev_ioloop; in http_server_ostream_wait_begin()
208 prev_ioloop = http_server_connection_switch_ioloop_to(conn, ioloop); in http_server_ostream_wait_begin()
214 struct ioloop *prev_ioloop) in http_server_ostream_wait_end()
245 struct ioloop *ioloop) in http_server_ostream_switch_ioloop_to() argument
255 http_server_connection_switch_ioloop_to(conn, ioloop); in http_server_ostream_switch_ioloop_to()
H A Dtest-http-server.c16 static struct ioloop *ioloop; variable
45 io_loop_stop(ioloop); in client_destroy()
182 io_loop_stop(ioloop); in sig_die()
219 ioloop = io_loop_create(); in main()
234 io_loop_run(ioloop); in main()
243 io_loop_destroy(&ioloop); in main()
H A Dhttp-server-request.c134 if (server->ioloop != NULL) in http_server_request_destroy()
135 io_loop_stop(server->ioloop); in http_server_request_destroy()
568 struct ioloop *ioloop) in http_server_istream_switch_ioloop_to() argument
576 i_assert(ioloop == current_ioloop); in http_server_istream_switch_ioloop_to()
589 io_loop_stop(server->ioloop); in http_server_istream_read_any()
624 i_assert(server->ioloop == NULL); in http_server_istream_read()
637 io_loop_run(server->ioloop); in http_server_istream_read()
644 io_loop_destroy(&server->ioloop); in http_server_istream_read()
739 struct http_server_payload_handler *handler, struct ioloop *ioloop) in http_server_payload_handler_switch_ioloop() argument
767 struct ioloop *ioloop) in payload_handler_pump_switch_ioloop() argument
[all …]
H A Dtest-http-server-errors.c46 static struct ioloop *ioloop; variable
120 io_loop_stop(ioloop); in test_server_slow_request_destroyed()
218 io_loop_stop(ioloop); in test_server_hanging_request_payload_destroyed()
351 io_loop_stop(ioloop); in test_server_hanging_response_payload_destroyed()
496 io_loop_stop(ioloop); in test_server_excessive_payload_length_destroyed()
580 io_loop_stop(ioloop); in test_response_ostream_disconnect_connected()
608 io_loop_stop(ioloop); in test_server_response_ostream_disconnect_destroyed()
827 io_loop_run(ioloop); in test_client_run()
895 io_loop_run(ioloop); in test_server_run()
939 io_loop_destroy(&ioloop); in test_run_client()
[all …]
H A Dtest-http-client-errors.c52 static struct ioloop *ioloop; variable
126 io_loop_stop(ioloop); in test_client_unconfigured_ssl_response()
199 io_loop_stop(ioloop); in test_client_unconfigured_ssl_abort_response2()
264 io_loop_stop(ioloop); in test_client_invalid_url_response()
326 io_loop_stop(ioloop); in test_client_host_lookup_failed_response()
403 io_loop_stop(ioloop); in test_client_connection_refused_response()
515 io_loop_stop(ioloop); in test_client_connection_lost_prematurely_response()
717 io_loop_stop(ioloop); in test_client_invalid_redirect_response()
802 io_loop_stop(ioloop); in test_client_unseekable_redirect_response()
870 io_loop_stop(ioloop); in test_client_unseekable_retry_response()
[all …]
/dports/www/p5-Mojo-IOLoop-ForkCall/Mojo-IOLoop-ForkCall-0.21/lib/Mojo/IOLoop/
H A DForkCall.pm28 my $delay = Mojo::IOLoop::Delay->new->ioloop($self->ioloop);
49 $self->ioloop->reset;
50 delete $self->{ioloop}; # not sure this is needed
78 $self->ioloop->stream($stream);
/dports/mail/dovecot/dovecot-2.3.17/src/lib-dict/
H A Ddict-memcached-ascii.c82 current_ioloop = dict->dict.ioloop; in memcached_ascii_callback()
96 if (conn->dict->dict.ioloop != NULL) in memcached_ascii_disconnected()
97 io_loop_stop(conn->dict->dict.ioloop); in memcached_ascii_disconnected()
248 io_loop_stop(conn->dict->dict.ioloop); in memcached_ascii_conn_input()
256 io_loop_set_current(dict->dict.ioloop); in memcached_ascii_input_wait()
260 io_loop_run(dict->dict.ioloop); in memcached_ascii_input_wait()
340 if (conn->dict->dict.ioloop != NULL) in memcached_ascii_conn_connected()
341 io_loop_stop(conn->dict->dict.ioloop); in memcached_ascii_conn_connected()
445 dict->dict.ioloop = io_loop_create(); in memcached_ascii_dict_init()
464 io_loop_set_current(dict->dict.ioloop); in memcached_ascii_dict_deinit()
[all …]
H A Dtest-dict-client.c37 struct ioloop *ioloop; in main() local
43 ioloop = io_loop_create(); in main()
104 io_loop_destroy(&ioloop); in main()
/dports/net/py-pyzmq/pyzmq-22.3.0/zmq/eventloop/
H A D_deprecated.py39 from .minitornado.ioloop import PollIOLoop, PeriodicCallback
208 from tornado import ioloop
213 not ioloop.IOLoop.initialized()
214 ) or ioloop.IOLoop.instance() is IOLoop.instance(), (
220 ioloop.IOLoop.configure(ZMQIOLoop)
223 ioloop.IOLoop._instance = IOLoop.instance()
/dports/mail/dovecot/dovecot-2.3.17/src/anvil/
H A Dtest-penalty.c11 struct ioloop *ioloop; in test_penalty_checksum() local
17 ioloop = io_loop_create(); in test_penalty_checksum()
53 io_loop_destroy(&ioloop); in test_penalty_checksum()
/dports/www/butterfly/butterfly-2.0.1/butterfly/
H A Dterminal.py28 import tornado.ioloop
37 ioloop = tornado.ioloop.IOLoop.instance() variable
267 ioloop.add_handler(
268 self.fd, self.shell_handler, ioloop.READ | ioloop.ERROR)
287 if events & ioloop.READ:
297 events = ioloop.ERROR
299 if events & ioloop.ERROR:
319 ioloop.remove_handler(self.fd)
/dports/mail/dovecot/dovecot-2.3.17/src/lib-storage/
H A Dmailbox-watch.c111 struct ioloop *ioloop; in mailbox_watch_extract_notify_fd() local
119 ioloop = io_loop_create(); in mailbox_watch_extract_notify_fd()
144 ret = io_loop_extract_notify_fd(ioloop); in mailbox_watch_extract_notify_fd()
150 io_loop_destroy(&ioloop); in mailbox_watch_extract_notify_fd()
/dports/www/p5-Mojo-Weixin/Mojo-Weixin-1.4.6/lib/Mojo/Weixin/
H A DClient.pm52 $self->ioloop->remove($self->_synccheck_connection_id);
96 Mojo::IOLoop::Delay->new(ioloop=>$self->ioloop)->steps(@_)->catch(sub {
150 $self->ioloop->start unless $self->ioloop->is_running;
167 return $self->ioloop->timer(@_);
171 return $self->ioloop->recurring(@_);
196 …my $run = Mojo::Weixin::Run->new(ioloop=>($is_blocking?Mojo::IOLoop->new:$self->ioloop),log=>$self…
/dports/mail/dovecot/dovecot-2.3.17/src/lib-auth/
H A Dauth-master.c36 struct ioloop *ioloop, *prev_ioloop; member
160 io_loop_stop(conn->ioloop); in auth_request_lookup_abort()
284 io_loop_stop(ctx->conn->ioloop); in auth_lookup_reply_callback()
370 if (conn->ioloop != NULL) in auth_master_connect()
404 if (conn->ioloop != NULL) in auth_master_set_io()
410 conn->ioloop = io_loop_create(); in auth_master_set_io()
424 if (conn->ioloop != NULL) { in auth_master_unset_io()
429 io_loop_destroy(&conn->ioloop); in auth_master_unset_io()
510 io_loop_run(conn->ioloop); in auth_master_run_cmd()
830 io_loop_stop(ctx->conn->ioloop); in auth_cache_flush_reply_callback()
[all …]
/dports/sysutils/py-salt/salt-3004.1/tests/pytests/unit/
H A Dtest_minion.py278 io_loop=salt.ext.tornado.ioloop.IOLoop(),
387 io_loop = salt.ext.tornado.ioloop.IOLoop()
446 io_loop = salt.ext.tornado.ioloop.IOLoop()
480 io_loop = salt.ext.tornado.ioloop.IOLoop()
566 io_loop = salt.ext.tornado.ioloop.IOLoop()
589 io_loop = salt.ext.tornado.ioloop.IOLoop()
609 io_loop = salt.ext.tornado.ioloop.IOLoop()
627 io_loop = salt.ext.tornado.ioloop.IOLoop()
667 io_loop = salt.ext.tornado.ioloop.IOLoop()
693 io_loop = salt.ext.tornado.ioloop.IOLoop()
[all …]
/dports/mail/dovecot/dovecot-2.3.17/src/lib-dns/
H A Ddns-lookup.c48 struct ioloop *ioloop; member
243 client->to_idle = timeout_add_to(client->ioloop, in dns_lookup_free()
303 client->ioloop = set->ioloop == NULL ? current_ioloop : set->ioloop; in dns_client_init()
328 if (client->ioloop != NULL) in dns_client_connect()
329 connection_switch_ioloop_to(&client->conn, client->ioloop); in dns_client_connect()
402 lookup->to = timeout_add_to(client->ioloop, in dns_client_lookup_common()
434 client->ioloop = current_ioloop; in dns_client_switch_ioloop()
/dports/devel/py-pika/pika-1.1.0/tests/unit/
H A Dtornado_tests.py27 def construct_io_services_adapter(ioloop): argument
28 adapter = _SelectorIOServicesAdapter(ioloop)
41 tornado_connection.ioloop.IOLoop.instance())
/dports/net/py-pyzmq/pyzmq-22.3.0/examples/eventloop/
H A Decho.py8 from tornado import ioloop
22 ioloop.IOLoop.current().add_callback(echo, sock, events)
29 loop = ioloop.IOLoop.current()
/dports/net/py-pyzmq/pyzmq-22.3.0/docs/source/
H A Deventloop.rst77 from tornado import gen, ioloop
125 ioloop.IOLoop.instance().start()
163 ioloop.IOLoop.instance().start()
185 :func:`.ioloop.install` is no longer needed for pyzmq ≥ 17.
187 …th PyZMQ's ioloop, you can use zmq sockets in any tornado application. You can tell tornado to us…
191 from zmq.eventloop import ioloop
192 ioloop.install()
198 from zmq.eventloop.ioloop import IOLoop
211 from zmq.eventloop.ioloop import ZMQIOLoop
223 from zmq.eventloop.ioloop import ZMQIOLoop
[all …]

12345678910>>...44