/dports/devel/py-pika/pika-1.1.0/examples/ |
H A D | asynchronous_publisher_example.py | 86 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 D | test-iostream-ssl.c | 246 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 D | Subprocess.pm | 12 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 D | test-iostream-proxy.c | 42 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 D | ostream-wrapper.c | 12 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 D | Makefile.am | 115 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 D | http-server-ostream.c | 179 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 D | test-http-server.c | 16 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 D | http-server-request.c | 134 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 D | test-http-server-errors.c | 46 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 D | test-http-client-errors.c | 52 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 D | ForkCall.pm | 28 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 D | dict-memcached-ascii.c | 82 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 D | test-dict-client.c | 37 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.py | 39 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 D | test-penalty.c | 11 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 D | terminal.py | 28 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 D | mailbox-watch.c | 111 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 D | Client.pm | 52 $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 D | auth-master.c | 36 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 D | test_minion.py | 278 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 D | dns-lookup.c | 48 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 D | tornado_tests.py | 27 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 D | echo.py | 8 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 D | eventloop.rst | 77 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 …]
|