/dports/mail/dovecot/dovecot-2.3.17/src/lib/ |
H A D | iostream.c | 26 stream->ioloop = current_ioloop; in io_stream_init() 146 struct ioloop *ioloop) in io_stream_switch_ioloop_to() argument 148 stream->ioloop = ioloop; in io_stream_switch_ioloop_to() 151 struct ioloop *io_stream_get_ioloop(struct iostream_private *stream) in io_stream_get_ioloop() 153 return (stream->ioloop == NULL ? current_ioloop : stream->ioloop); in io_stream_get_ioloop()
|
H A D | lib-signals.c | 29 struct ioloop *ioloop; member 177 lib_signals_ioloop_find(struct ioloop *ioloop) in lib_signals_ioloop_find() argument 182 if (l->ioloop == ioloop) in lib_signals_ioloop_find() 197 lib_signals_ioloop_ref(struct ioloop *ioloop) in lib_signals_ioloop_ref() argument 201 l = lib_signals_ioloop_find(ioloop); in lib_signals_ioloop_ref() 204 l->ioloop = ioloop; in lib_signals_ioloop_ref() 265 h->sig_ioloop->ioloop != current_ioloop) { in signal_handle_shadowed() 368 h->sig_ioloop->ioloop != current_ioloop) { in signal_read() 437 static void lib_signals_ioloop_destroyed(struct ioloop *ioloop) in lib_signals_ioloop_destroyed() argument 441 sig_ioloop = lib_signals_ioloop_find(ioloop); in lib_signals_ioloop_destroyed() [all …]
|
H A D | iostream-private.h | 17 struct ioloop *ioloop; member 48 struct ioloop *ioloop); 49 struct ioloop *io_stream_get_ioloop(struct iostream_private *stream);
|
H A D | ioloop-notify-kqueue.c | 103 void io_loop_notify_handler_deinit(struct ioloop *ioloop) in io_loop_notify_handler_deinit() argument 106 ioloop->notify_handler_context; in io_loop_notify_handler_deinit() 156 io->io.ioloop = current_ioloop; in io_add_notify() 175 io->io.ioloop->notify_handler_context); in io_add_notify() 185 _io->ioloop->notify_handler_context; in io_loop_notify_remove() 200 int io_loop_extract_notify_fd(struct ioloop *ioloop) in io_loop_extract_notify_fd() argument 203 ioloop->notify_handler_context; in io_loop_extract_notify_fd()
|
H A D | ioloop-notify-none.c | 24 void io_loop_notify_handler_deinit(struct ioloop *ioloop ATTR_UNUSED) in io_loop_notify_handler_deinit() 28 int io_loop_extract_notify_fd(struct ioloop *ioloop ATTR_UNUSED) in io_loop_extract_notify_fd()
|
H A D | test-ostream-multiplex.c | 116 struct ioloop *ioloop = io_loop_create(); in test_ostream_multiplex_stream() local 117 io_loop_set_current(ioloop); in test_ostream_multiplex_stream() 147 io_loop_destroy(&ioloop); in test_ostream_multiplex_stream() 225 struct ioloop *ioloop = io_loop_create(); in test_ostream_multiplex_hang() local 269 io_loop_run(ioloop); in test_ostream_multiplex_hang() 287 io_loop_destroy(&ioloop); in test_ostream_multiplex_hang() 353 struct ioloop *ioloop = io_loop_create(); in test_ostream_multiplex_flush_callback() local 376 io_loop_run(ioloop); in test_ostream_multiplex_flush_callback() 394 io_loop_destroy(&ioloop); in test_ostream_multiplex_flush_callback()
|
/dports/www/py-gunicorn/gunicorn-19.9.0/gunicorn/workers/ |
H A D | gtornado.py | 16 from tornado.ioloop import IOLoop, PeriodicCallback 69 if not self.ioloop._callbacks: 70 self.ioloop.stop() 73 self.ioloop = IOLoop.instance() 80 PeriodicCallback(self.watchdog, 1000, io_loop=self.ioloop).start() 81 PeriodicCallback(self.heartbeat, 1000, io_loop=self.ioloop).start() 125 server = server_class(app, io_loop=self.ioloop, 131 server = server_class(app, io_loop=self.ioloop) 146 self.ioloop.start()
|
/dports/net/py-pyzmq/pyzmq-22.3.0/zmq/tests/ |
H A D | test_ioloop.py | 17 from tornado.ioloop import IOLoop as BaseIOLoop 18 from zmq.eventloop import ioloop 63 IOLoop = ioloop.IOLoop 81 dc = ioloop.PeriodicCallback(loop.stop, 200) 82 pc = ioloop.PeriodicCallback(lambda: None, 10) 103 loop = ioloop.IOLoop.current() 113 loop.add_handler(req, lambda msg: msg, ioloop.IOLoop.READ) 114 loop.add_handler(rep, lambda msg: msg, ioloop.IOLoop.READ) 123 import zmq.green.eventloop.ioloop as green_ioloop
|
/dports/mail/dovecot/dovecot-2.3.17/src/lib-program-client/ |
H A D | test-program-client-local.c | 105 struct ioloop *prev_ioloop, *ioloop; in test_program_io_async() local 116 ioloop = io_loop_create(); in test_program_io_async() 130 io_loop_run(ioloop); in test_program_io_async() 140 io_loop_set_current(ioloop); in test_program_io_async() 141 io_loop_destroy(&ioloop); in test_program_io_async() 256 struct ioloop *ioloop; in main() local 281 ioloop = io_loop_create(); in main() 285 io_loop_destroy(&ioloop); in main()
|
/dports/www/p5-Mojolicious/Mojolicious-9.22/lib/Mojo/Server/ |
H A D | Daemon.pm | 17 has ioloop => sub { Mojo::IOLoop->singleton }; 25 my $loop = $self->ioloop; 29 sub ports { [map { $_[0]->ioloop->acceptor($_)->port } @{$_[0]->acceptors}] } 35 my $loop = $self->ioloop; 38 $self->start->ioloop->start; 45 my $loop = $self->ioloop; 66 my $loop = $self->ioloop; 192 push @{$self->acceptors}, $self->ioloop->server( 227 $self->ioloop->remove($id); 243 return $self->ioloop->stream($id)->write($chunk) unless $next; [all …]
|
/dports/mail/dovecot/dovecot-2.3.17/src/lib-dict/ |
H A D | dict-memcached.c | 68 if (conn->dict->dict.ioloop != NULL) in memcached_conn_destroy() 69 io_loop_stop(conn->dict->dict.ioloop); in memcached_conn_destroy() 119 if (conn->dict->dict.ioloop != NULL) in memcached_input_get() 120 io_loop_stop(conn->dict->dict.ioloop); in memcached_input_get() 152 if (conn->dict->dict.ioloop != NULL) in memcached_conn_connected() 254 io_loop_stop(dict->dict.ioloop); in memcached_dict_lookup_timeout() 300 i_assert(dict->dict.ioloop == NULL); in memcached_dict_lookup() 302 dict->dict.ioloop = io_loop_create(); in memcached_dict_lookup() 313 io_loop_run(dict->dict.ioloop); in memcached_dict_lookup() 326 io_loop_run(dict->dict.ioloop); in memcached_dict_lookup() [all …]
|
H A D | dict-redis.c | 110 if (conn->dict->dict.ioloop != NULL) in redis_disconnected() 111 io_loop_stop(conn->dict->dict.ioloop); in redis_disconnected() 133 i_assert(dict->dict.ioloop == NULL); in redis_wait() 136 dict->dict.ioloop = io_loop_create(); in redis_wait() 141 io_loop_run(dict->dict.ioloop); in redis_wait() 148 io_loop_destroy(&dict->dict.ioloop); in redis_wait() 166 if (conn->dict->dict.ioloop != NULL) in redis_input_get() 194 if (conn->dict->dict.ioloop != NULL) in redis_input_get() 309 if (conn->dict->dict.ioloop != NULL) in redis_conn_connected() 566 io_loop_run(dict->dict.ioloop); in redis_dict_lookup() [all …]
|
/dports/mail/dovecot/dovecot-2.3.17/src/util/ |
H A D | maildirlock.c | 19 static struct ioloop *ioloop; variable 23 io_loop_stop(ioloop); in sig_die() 64 ioloop = io_loop_create(); in main() 98 io_loop_run(ioloop); in main() 103 io_loop_destroy(&ioloop); in main()
|
/dports/mail/dovecot/dovecot-2.3.17/src/master/ |
H A D | test-auth-client.c | 51 static struct ioloop *ioloop; variable 859 struct ioloop *ioloop; member 938 test_client_auth_run(struct auth_client *auth_client, struct ioloop *ioloop, in test_client_auth_run() argument 949 login_test.ioloop = ioloop; in test_client_auth_run() 961 io_loop_run(ioloop); in test_client_auth_run() 975 io_loop_run(ioloop); in test_client_auth_run() 994 struct ioloop *ioloop; in test_client_auth_parallel() local 1047 io_loop_destroy(&ioloop); in test_client_auth_parallel() 1146 io_loop_run(ioloop); in test_server_run() 1182 io_loop_destroy(&ioloop); in test_run_server() [all …]
|
/dports/mail/dovecot/dovecot-2.3.17/src/lib-master/ |
H A D | stats-client.c | 19 struct ioloop *ioloop; member 64 if (client->ioloop != NULL) in stats_client_handshake() 65 io_loop_stop(client->ioloop); in stats_client_handshake() 103 if (client->ioloop != NULL) { in stats_client_destroy() 105 io_loop_stop(client->ioloop); in stats_client_destroy() 274 io_loop_stop(client->ioloop); in stats_client_timeout() 279 struct ioloop *prev_ioloop = current_ioloop; in stats_client_wait_handshake() 284 client->ioloop = io_loop_create(); in stats_client_wait_handshake() 287 io_loop_run(client->ioloop); in stats_client_wait_handshake() 292 io_loop_set_current(client->ioloop); in stats_client_wait_handshake() [all …]
|
/dports/www/p5-Mojolicious/Mojolicious-9.22/t/mojo/ |
H A D | user_agent_tls.t | 22 …my $daemon = Mojo::Server::Daemon->new(app => app, ioloop => Mojo::IOLoop->singleton, silent => 1); 31 my $ua = Mojo::UserAgent->new(ioloop => Mojo::IOLoop->singleton); 43 my $ua = Mojo::UserAgent->new(ioloop => Mojo::IOLoop->singleton); 52 my $ua = Mojo::UserAgent->new(ioloop => Mojo::IOLoop->singleton); 68 my $ua = Mojo::UserAgent->new(ioloop => Mojo::IOLoop->singleton); 77 …my $daemon = Mojo::Server::Daemon->new(app => app, ioloop => Mojo::IOLoop->singleton, silent => 1); 89 my $ua = Mojo::UserAgent->new(ioloop => Mojo::IOLoop->singleton); 93 $ua = Mojo::UserAgent->new(ioloop => $ua->ioloop, insecure => 1); 97 …is $ua->ioloop->stream($tx->connection)->handle->get_cipher, 'AES256-SHA', 'AES256-SHA has bee… 98 …is $ua->ioloop->stream($tx->connection)->handle->get_sslversion, 'TLSv1', 'TLSv1 has been neg…
|
/dports/net/py-pyzmq/pyzmq-22.3.0/docs/source/api/ |
H A D | zmq.auth.ioloop.rst | 3 auth.ioloop 6 Module: :mod:`auth.ioloop` 8 .. automodule:: zmq.auth.ioloop 11 .. currentmodule:: zmq.auth.ioloop
|
/dports/www/p5-Mojolicious/Mojolicious-9.22/lib/Mojo/ |
H A D | UserAgent.pm | 24 has ioloop => sub { Mojo::IOLoop->new }; 30 has server => sub { Mojo::UserAgent::Server->new(ioloop => shift->ioloop) }; 66 $self->_start($self->ioloop, $tx => sub { shift->ioloop->stop; $tx = shift }); 67 $self->ioloop->start; 193 $self->{connections}{$id} = {cb => $cb, ioloop => $loop, tx => $tx}; 227 $c->{ioloop}->remove(delete $c->{timeout}) if $c->{timeout}; 283 return $self->_start($c->{ioloop}, $new, delete $c->{cb}); 289 $self->_dequeue($c->{ioloop}, $id); 290 $c->{ioloop}->remove($id); 303 my $queue = $self->{queue}{$c->{ioloop}} //= []; [all …]
|
/dports/mail/dovecot/dovecot-2.3.17/src/plugins/fts/ |
H A D | fts-indexer.c | 25 struct ioloop *ioloop; member 69 struct ioloop *prev_ioloop = current_ioloop; in fts_indexer_more_int() 79 io_loop_set_current(ctx->ioloop); in fts_indexer_more_int() 80 to = timeout_add_short(INDEXER_WAIT_MSECS, io_loop_stop, ctx->ioloop); in fts_indexer_more_int() 81 io_loop_run(ctx->ioloop); in fts_indexer_more_int() 133 io_loop_set_current(ctx->ioloop); in fts_indexer_deinit() 134 io_loop_destroy(&ctx->ioloop); in fts_indexer_deinit() 221 struct ioloop *prev_ioloop = current_ioloop; in fts_indexer_init() 261 ctx->ioloop = io_loop_create(); in fts_indexer_init()
|
H A D | fts-parser-tika.c | 27 struct ioloop *ioloop; member 180 struct ioloop *prev_ioloop = current_ioloop; in fts_parser_tika_more() 213 if (parser->ioloop == NULL) { in fts_parser_tika_more() 214 parser->ioloop = io_loop_create(); in fts_parser_tika_more() 218 io_loop_set_current(parser->ioloop); in fts_parser_tika_more() 259 if (parser->ioloop != NULL) { in fts_parser_tika_deinit() 260 io_loop_set_current(parser->ioloop); in fts_parser_tika_deinit() 261 io_loop_destroy(&parser->ioloop); in fts_parser_tika_deinit()
|
/dports/mail/dovecot/dovecot-2.3.17/src/lib-test/ |
H A D | fuzzer.h | 5 struct ioloop; 10 struct ioloop *ioloop; member 25 fuzz_ctx.ioloop = io_loop_create(); \
|
/dports/ftp/py-pyftpdlib/pyftpdlib-1.5.6/pyftpdlib/ |
H A D | ioloop.py | 768 def __init__(self, sock=None, ioloop=None): argument 769 self.ioloop = ioloop or IOLoop.instance() 770 self._wanted_io_events = self.ioloop.READ 771 self._current_io_events = self.ioloop.READ 789 self.ioloop.unregister(self._fileno) 806 elif events == self.ioloop.READ | self.ioloop.WRITE: 834 self.modify_ioloop_events(self.ioloop.WRITE) 931 wanted = self.ioloop.READ 936 wanted = self.ioloop.READ | self.ioloop.WRITE 1026 if isinstance(self.ioloop, Kqueue): [all …]
|
/dports/mail/dovecot/dovecot-2.3.17/src/lib-http/ |
H A D | http-server-private.h | 60 struct ioloop *ioloop); 128 struct ioloop *ioloop, *ioloop_switching; member 185 struct ioloop *ioloop; member 283 struct http_server_payload_handler *handler, struct ioloop *ioloop);
|
/dports/mail/dovecot/dovecot-2.3.17/src/lib-imap-client/ |
H A D | imapc-client.c | 177 i_assert(client->ioloop == NULL); in imapc_client_run_pre() 179 client->ioloop = io_loop_create(); in imapc_client_run_pre() 180 io_loop_set_running(client->ioloop); in imapc_client_run_pre() 189 io_loop_run(client->ioloop); in imapc_client_run_pre() 196 struct ioloop *ioloop = client->ioloop; in imapc_client_run_post() local 198 client->ioloop = NULL; in imapc_client_run_post() 202 io_loop_set_current(ioloop); in imapc_client_run_post() 203 io_loop_destroy(&ioloop); in imapc_client_run_post() 214 if (client->ioloop != NULL) in imapc_client_stop() 215 io_loop_stop(client->ioloop); in imapc_client_stop() [all …]
|
/dports/net/py-pynsq/pynsq-0.9.0b1/tests/ |
H A D | reader_unit_test_helpers.py | 4 from tornado.ioloop import IOLoop 22 ioloop = create_autospec(IOLoop) 23 ioloop.time.return_value = 0 24 return ioloop
|