Home
last modified time | relevance | path

Searched refs:ioloop (Results 76 – 100 of 1079) sorted by relevance

12345678910>>...44

/dports/mail/dovecot/dovecot-2.3.17/src/lib-http/
H A Dhttp-client.c119 client->ioloop = current_ioloop; in http_client_init_shared()
313 struct ioloop *prev_ioloop = client->ioloop; in http_client_switch_ioloop()
315 client->ioloop = current_ioloop; in http_client_switch_ioloop()
408 timeout_add_short_to(client->ioloop, 0, in http_client_delay_request_error()
445 cctx->ioloop = current_ioloop; in http_client_context_create()
627 if (cctx->ioloop != current_ioloop && in http_client_context_remove_client()
628 cctx->ioloop == client->ioloop && in http_client_context_remove_client()
630 struct ioloop *prev_ioloop = current_ioloop; in http_client_context_remove_client()
632 io_loop_set_current(cctx->clients_list->ioloop); in http_client_context_remove_client()
697 cctx->ioloop = current_ioloop; in http_client_context_switch_ioloop()
[all …]
H A Dhttp-server-connection.c983 conn->ioloop = current_ioloop; in http_server_connection_create()
1146 struct ioloop *
1148 struct ioloop *ioloop) in http_server_connection_switch_ioloop_to() argument
1150 struct ioloop *prev_ioloop = conn->ioloop; in http_server_connection_switch_ioloop_to()
1155 conn->ioloop = ioloop; in http_server_connection_switch_ioloop_to()
1157 connection_switch_ioloop_to(&conn->conn, ioloop); in http_server_connection_switch_ioloop_to()
1160 io_loop_move_timeout_to(ioloop, &conn->to_input); in http_server_connection_switch_ioloop_to()
1164 io_loop_move_timeout_to(ioloop, &conn->to_idle); in http_server_connection_switch_ioloop_to()
1168 io_loop_move_io_to(ioloop, &conn->io_resp_payload); in http_server_connection_switch_ioloop_to()
1172 conn->payload_handler, ioloop); in http_server_connection_switch_ioloop_to()
[all …]
/dports/net/py-pynsq/pynsq-0.9.0b1/nsq/
H A D__init__.py4 import tornado.ioloop
39 tornado.ioloop.IOLoop.instance().stop()
48 tornado.ioloop.IOLoop.instance().start()
/dports/mail/dovecot/dovecot-2.3.17/src/lib/
H A Dconnection.h6 struct ioloop;
127 struct ioloop *ioloop; member
241 struct ioloop *ioloop);
H A Diostream-pump.h19 struct ioloop;
66 struct ioloop *ioloop);
H A Dconnection.c213 conn->io = io_add_istream_to(conn->ioloop, conn->input, in connection_input_resume_full()
224 conn->to = timeout_add_to(conn->ioloop, in connection_input_resume_full()
448 i_stream_switch_ioloop_to(conn->input, conn->ioloop); in connection_init_streams()
459 o_stream_switch_ioloop_to(conn->output, conn->ioloop); in connection_init_streams()
522 conn->ioloop = current_ioloop; in connection_init_full()
731 conn->to = timeout_add_to(conn->ioloop, in connection_client_connect()
898 struct ioloop *ioloop) in connection_switch_ioloop_to() argument
900 conn->ioloop = ioloop; in connection_switch_ioloop_to()
902 conn->io = io_loop_move_io_to(ioloop, &conn->io); in connection_switch_ioloop_to()
906 i_stream_switch_ioloop_to(conn->input, ioloop); in connection_switch_ioloop_to()
[all …]
/dports/www/p5-Mojolicious/Mojolicious-9.22/lib/Mojo/
H A DPromise.pm11 has ioloop => sub { Mojo::IOLoop->singleton }, weak => 1;
63 sub clone { $_[0]->new->ioloop($_[0]->ioloop) }
117 return if (my $loop = $self->ioloop)->is_running;
194 $self->ioloop->next_tick(sub { $_->(@$results) for @$cbs });
249 $self->ioloop->timer($after => sub { $self->$method(@results) });
/dports/mail/dovecot/dovecot-2.3.17/src/lib-sql/
H A Ddriver-pgsql.c31 struct ioloop *ioloop, *orig_ioloop; member
102 if (db->ioloop != NULL) in driver_pgsql_set_state()
105 if (db->ioloop != NULL) in driver_pgsql_set_state()
144 if (db->ioloop != NULL) { in driver_pgsql_close()
146 io_loop_stop(db->ioloop); in driver_pgsql_close()
207 if (db->ioloop != NULL) { in connect_callback()
210 io_loop_stop(db->ioloop); in connect_callback()
476 if (db->ioloop != NULL) in result_finish()
477 io_loop_stop(db->ioloop); in result_finish()
667 io_loop_run(db->ioloop); in driver_pgsql_sync_init()
[all …]
/dports/devel/py-pika/pika-1.1.0/pika/adapters/
H A Dtornado_connection.py6 from tornado import ioloop
53 custom_ioloop or ioloop.IOLoop.instance()))
73 custom_ioloop or ioloop.IOLoop.instance())
/dports/math/py-matplotlib2/matplotlib-2.2.4/lib/matplotlib/backends/
H A Dbackend_webagg.py34 import tornado.ioloop
46 tornado.ioloop.IOLoop.instance().start()
277 ioloop = tornado.ioloop.IOLoop.instance()
280 ioloop.stop()
289 lambda sig, frame: ioloop.add_callback_from_signal(shutdown))
301 ioloop.start()
/dports/math/py-matplotlib/matplotlib-3.4.3/lib/matplotlib/backends/
H A Dbackend_webagg.py32 import tornado.ioloop
44 tornado.ioloop.IOLoop.instance().start()
253 ioloop = tornado.ioloop.IOLoop.instance()
256 ioloop.stop()
265 lambda sig, frame: ioloop.add_callback_from_signal(shutdown))
277 ioloop.start()
/dports/www/p5-Mojo-IOLoop-ForkCall/Mojo-IOLoop-ForkCall-0.21/t/
H A Dbad_deserialize.t15 $fc->on(finish => sub { my $fc = shift; $err = shift; $res = shift; $fc->ioloop->stop });
17 $fc->ioloop->start;
30 $fc->ioloop->start;
/dports/net/py-pyzmq/pyzmq-22.3.0/examples/security/
H A Dioloop-ironhouse.py22 from zmq.auth.ioloop import IOLoopAuthenticator
23 from zmq.eventloop import ioloop, zmqstream
53 ioloop.IOLoop.instance().stop()
113 ioloop.IOLoop.instance().start()
/dports/lang/spidermonkey78/firefox-78.9.0/third_party/python/urllib3/dummyserver/
H A Dproxy.py33 import tornado.ioloop
128 ioloop = tornado.ioloop.IOLoop.instance()
130 ioloop.start()
/dports/multimedia/quodlibet/quodlibet-4.3.0/quodlibet/packages/raven/transport/
H A Dtornado.py16 from tornado import ioloop
40 if ioloop.IOLoop.initialized():
45 … ioloop.IOLoop.current().add_future(future, partial(self.handler, success_cb, failure_cb))
/dports/devel/py-raven/raven-python-6.10.0/raven/transport/
H A Dtornado.py16 from tornado import ioloop
40 if ioloop.IOLoop.initialized():
45 … ioloop.IOLoop.current().add_future(future, partial(self.handler, success_cb, failure_cb))
/dports/mail/dovecot/dovecot-2.3.17/src/lib-smtp/
H A Dtest-smtp-server-errors.c52 static struct ioloop *ioloop; variable
130 io_loop_stop(ioloop); in test_server_slow_server_destroyed()
231 io_loop_stop(ioloop); in test_server_slow_client_disconnect_timeout()
245 io_loop_stop(ioloop); in test_server_slow_client_disconnect()
365 io_loop_stop(ioloop); in test_server_hanging_command_payload_trans_free()
499 io_loop_stop(ioloop); in test_server_bad_command_disconnect()
665 io_loop_stop(ioloop); in test_server_many_bad_commands_disconnect()
762 io_loop_stop(ioloop); in test_server_long_command_disconnect()
868 io_loop_stop(ioloop); in test_server_big_data_trans_free()
3280 io_loop_run(ioloop); in test_client_run()
[all …]
/dports/www/py-tornado4/tornado-4.5.3/tornado/platform/
H A Dtwisted.py48 import tornado.ioloop
52 from tornado.ioloop import IOLoop
130 io_loop = tornado.ioloop.IOLoop.current()
354 io_loop = tornado.ioloop.IOLoop.current()
376 self.handler(self.fileobj, tornado.ioloop.IOLoop.READ)
380 self.handler(self.fileobj, tornado.ioloop.IOLoop.WRITE)
391 class TwistedIOLoop(tornado.ioloop.IOLoop):
436 if events & tornado.ioloop.IOLoop.READ:
439 if events & tornado.ioloop.IOLoop.WRITE:
445 if events & tornado.ioloop.IOLoop.READ:
[all …]
/dports/sysutils/py-salt/salt-3004.1/salt/ext/tornado/platform/
H A Dtwisted.py49 import salt.ext.tornado.ioloop
53 from salt.ext.tornado.ioloop import IOLoop
131 io_loop = salt.ext.tornado.ioloop.IOLoop.current()
355 io_loop = salt.ext.tornado.ioloop.IOLoop.current()
377 self.handler(self.fileobj, salt.ext.tornado.ioloop.IOLoop.READ)
381 self.handler(self.fileobj, salt.ext.tornado.ioloop.IOLoop.WRITE)
392 class TwistedIOLoop(salt.ext.tornado.ioloop.IOLoop):
437 if events & salt.ext.tornado.ioloop.IOLoop.READ:
440 if events & salt.ext.tornado.ioloop.IOLoop.WRITE:
446 if events & salt.ext.tornado.ioloop.IOLoop.READ:
[all …]
/dports/net/py-pyzmq/pyzmq-22.3.0/examples/eventloop/
H A Dasyncweb.py21 from tornado import ioloop
67 beat = ioloop.PeriodicCallback(dot, 100)
71 ioloop.IOLoop.instance().start()
/dports/www/p5-Mojolicious/Mojolicious-9.22/lib/Mojo/UserAgent/
H A DServer.pm8 has ioloop => sub { Mojo::IOLoop->singleton };
36 my $server = $self->{server} = Mojo::Server::Daemon->new(ioloop => $self->ioloop, silent => 1);
/dports/net/py-urllib3/urllib3-1.26.7/dummyserver/
H A Dproxy.py35 import tornado.ioloop
136 ioloop = tornado.ioloop.IOLoop.instance()
138 ioloop.start()
/dports/mail/mailutils/mailutils-3.13/examples/
H A Dmusocio.c33 ioloop (char *id, mu_stream_t in, mu_stream_t out) in ioloop() function
102 ioloop ("reader", sock, out); in main()
106 ioloop ("writer", in, sock); in main()
/dports/www/p5-Mojo-IOLoop-Delay/Mojo-IOLoop-Delay-8.76/lib/Mojo/IOLoop/
H A DDelay.pm14 my $delay = Mojo::IOLoop::Delay->new->ioloop($loop);
31 $self->ioloop->next_tick($self->begin);
53 $self->ioloop->next_tick($self->begin) unless $self->{pending};
/dports/devel/py-jupyter-client/jupyter_client-6.1.12/jupyter_client/ioloop/
H A Drestarter.py12 from zmq.eventloop import ioloop
29 return ioloop.IOLoop.current()
36 self._pcallback = ioloop.PeriodicCallback(

12345678910>>...44