Home
last modified time | relevance | path

Searched refs:ioloop (Results 26 – 50 of 1079) sorted by relevance

12345678910>>...44

/dports/mail/dovecot/dovecot-2.3.17/src/lib/
H A Diostream.c26 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 Dlib-signals.c29 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 Diostream-private.h17 struct ioloop *ioloop; member
48 struct ioloop *ioloop);
49 struct ioloop *io_stream_get_ioloop(struct iostream_private *stream);
H A Dioloop-notify-kqueue.c103 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 Dioloop-notify-none.c24 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 Dtest-ostream-multiplex.c116 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 Dgtornado.py16 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 Dtest_ioloop.py17 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 Dtest-program-client-local.c105 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 DDaemon.pm17 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 Ddict-memcached.c68 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 Ddict-redis.c110 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 Dmaildirlock.c19 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 Dtest-auth-client.c51 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 Dstats-client.c19 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 Duser_agent_tls.t22 …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 Dzmq.auth.ioloop.rst3 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 DUserAgent.pm24 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 Dfts-indexer.c25 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 Dfts-parser-tika.c27 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 Dfuzzer.h5 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 Dioloop.py768 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 Dhttp-server-private.h60 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 Dimapc-client.c177 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 Dreader_unit_test_helpers.py4 from tornado.ioloop import IOLoop
22 ioloop = create_autospec(IOLoop)
23 ioloop.time.return_value = 0
24 return ioloop

12345678910>>...44