| /dports/mail/dovecot/dovecot-2.3.17/src/lib-http/ |
| H A D | http-client-connection.c | 173 io_loop_stop(client->ioloop); in http_client_connection_server_close()
468 conn->conn.ioloop, timeout, in http_client_connection_start_idle_timeout()
531 io_loop_stop(client->ioloop); in http_client_connection_check_idle()
603 conn->conn.ioloop, timeout_msecs, in http_client_connection_start_request_timeout()
818 conn->conn.ioloop, 0, in http_client_payload_destroyed()
1631 conn->conn.ioloop, 0, in http_client_connection_connect()
1640 cctx->ioloop, timeout_msecs, in http_client_connection_connect()
1712 cctx->ioloop, timeout_msecs, in http_client_connection_connect_tunnel()
1915 struct ioloop *ioloop = cctx->ioloop; in http_client_connection_switch_ioloop() local
1917 connection_switch_ioloop_to(&conn->conn, ioloop); in http_client_connection_switch_ioloop()
[all …]
|
| /dports/devel/py-nbdime/nbdime-3.1.1/nbdime/tests/ |
| H A D | test_web.py | 10 from tornado import ioloop
33 loop = ioloop.IOLoop.current()
42 loop = ioloop.IOLoop.current()
59 loop = ioloop.IOLoop.current()
69 loop = ioloop.IOLoop.current()
|
| /dports/mail/dovecot/dovecot-2.3.17/src/lib/ |
| H A D | iostream-pump.c | 239 struct ioloop *ioloop) in iostream_pump_switch_ioloop_to() argument
243 pump->io = io_loop_move_io_to(ioloop, &pump->io); in iostream_pump_switch_ioloop_to()
244 o_stream_switch_ioloop_to(pump->output, ioloop); in iostream_pump_switch_ioloop_to()
245 i_stream_switch_ioloop_to(pump->input, ioloop); in iostream_pump_switch_ioloop_to()
|
| H A D | file-dotlock.c | 425 static void dotlock_wait_end(struct ioloop *ioloop) in dotlock_wait_end() argument
427 io_loop_stop(ioloop); in dotlock_wait_end()
432 struct ioloop *ioloop; in dotlock_wait() local
441 ioloop = io_loop_create(); in dotlock_wait()
443 ioloop, &io)) { in dotlock_wait()
448 io_loop_destroy(&ioloop); in dotlock_wait()
452 io_loop_destroy(&ioloop); in dotlock_wait()
460 dotlock_wait_end, ioloop); in dotlock_wait()
461 io_loop_run(ioloop); in dotlock_wait()
464 io_loop_destroy(&ioloop); in dotlock_wait()
|
| H A D | test-multiplex.c | 122 struct ioloop *ioloop = io_loop_create(); in test_multiplex_stream() local
123 io_loop_set_current(ioloop); in test_multiplex_stream()
155 io_loop_destroy(&ioloop); in test_multiplex_stream()
|
| /dports/mail/dovecot/dovecot-2.3.17/src/lib-smtp/ |
| H A D | fuzz-smtp-server.c | 64 io_loop_stop(ctx->ioloop); in server_connection_free()
70 io_loop_stop_delayed(ctx->ioloop); in test_server_continue()
97 io_loop_run(fuzz_ctx.ioloop);
|
| /dports/www/py-tornado4/tornado-4.5.3/demos/benchmark/ |
| H A D | benchmark.py | 17 from tornado.ioloop import IOLoop
61 if options.ioloop:
62 IOLoop.configure(options.ioloop)
|
| /dports/devel/py-urwid/urwid-2.1.2/urwid/ |
| H A D | main_loop.py | 1087 def _patch_poll_impl(cls, ioloop): argument
1090 if ioloop in cls._ioloop_registry:
1095 ioloop._impl = cls.PollProxy(ioloop._impl, idle_map)
1097 def __init__(self, ioloop=None): argument
1098 if not ioloop:
1100 ioloop = IOLoop.instance()
1101 self._ioloop = ioloop
1102 self._patch_poll_impl(ioloop)
1109 ioloop = self._ioloop
1116 handle = ioloop.add_timeout(ioloop.time() + secs, wrapped)
[all …]
|
| /dports/www/py-tornado5/tornado-5.1.1/tornado/platform/ |
| H A D | twisted.py | 48 import tornado.ioloop
52 from tornado.ioloop import IOLoop
136 self._io_loop = tornado.ioloop.IOLoop.current()
386 self.handler(self.fileobj, tornado.ioloop.IOLoop.READ)
390 self.handler(self.fileobj, tornado.ioloop.IOLoop.WRITE)
394 self.handler(self.fileobj, tornado.ioloop.IOLoop.ERROR)
403 class TwistedIOLoop(tornado.ioloop.IOLoop):
453 if events & tornado.ioloop.IOLoop.READ:
456 if events & tornado.ioloop.IOLoop.WRITE:
462 if events & tornado.ioloop.IOLoop.READ:
[all …]
|
| /dports/mail/dovecot/dovecot-2.3.17/src/doveadm/ |
| H A D | client-connection-tcp.c | 35 struct ioloop *ioloop; member
70 struct ioloop *prev_ioloop = current_ioloop; in doveadm_server_log_handler()
83 if (conn->ioloop != NULL) in doveadm_server_log_handler()
84 io_loop_set_current(conn->ioloop); in doveadm_server_log_handler()
197 struct ioloop *prev_ioloop = current_ioloop; in doveadm_cmd_handle()
209 conn->ioloop = io_loop_create(); in doveadm_cmd_handle()
219 io_loop_destroy(&conn->ioloop); in doveadm_cmd_handle()
|
| /dports/www/p5-Mojo-Weixin/Mojo-Weixin-1.4.6/lib/Mojo/Weixin/ |
| H A D | Run.pm | 122 my $timer = $self->ioloop->timer(
196 sub start { shift->ioloop->start }
211 $self->ioloop->reactor->io($proc->{"hdr_$io"}, sub {
252 $self->ioloop->remove( $proc->{"hdr_$io"} );
301 $self->ioloop->remove($proc->{id_timeout});
472 $self->ioloop->remove($proc->{id_timeout});
525 next unless defined $self->ioloop;
|
| /dports/devel/taskctl/taskctl-1.4.2/vendor/github.com/chzyer/readline/ |
| H A D | std.go | 86 go c.ioloop()
90 func (c *CancelableStdin) ioloop() { func
152 s.ioloop()
156 func (s *FillableStdin) ioloop() { func
|
| /dports/net/evans/evans-0.9.1/vendor/github.com/chzyer/readline/ |
| H A D | std.go | 86 go c.ioloop()
90 func (c *CancelableStdin) ioloop() { func
152 s.ioloop()
156 func (s *FillableStdin) ioloop() { func
|
| /dports/deskutils/ultralist/ultralist-1.7.0/vendor/github.com/chzyer/readline/readline-2972be24d48e/ |
| H A D | std.go | 86 go c.ioloop()
90 func (c *CancelableStdin) ioloop() { func
152 s.ioloop()
156 func (s *FillableStdin) ioloop() { func
|
| /dports/deskutils/ultralist/ultralist-1.7.0/vendor/github.com/chzyer/readline/ |
| H A D | std.go | 86 go c.ioloop()
90 func (c *CancelableStdin) ioloop() { func
152 s.ioloop()
156 func (s *FillableStdin) ioloop() { func
|
| /dports/deskutils/pet/pet-0.4.0/vendor/github.com/chzyer/readline/ |
| H A D | std.go | 86 go c.ioloop()
90 func (c *CancelableStdin) ioloop() { func
152 s.ioloop()
156 func (s *FillableStdin) ioloop() { func
|
| /dports/x11-wm/fvwm3/fvwm3-1.0.4/bin/FvwmPrompt/vendor/github.com/abiosoft/readline/ |
| H A D | std.go | 86 go c.ioloop()
90 func (c *CancelableStdin) ioloop() { func
152 s.ioloop()
156 func (s *FillableStdin) ioloop() { func
|
| /dports/devel/awless/awless-0.1.11/vendor/github.com/chzyer/readline/ |
| H A D | std.go | 86 go c.ioloop()
90 func (c *CancelableStdin) ioloop() { func
152 s.ioloop()
156 func (s *FillableStdin) ioloop() { func
|
| /dports/sysutils/gomi/gomi-1.1.1/vendor/github.com/chzyer/readline/ |
| H A D | std.go | 86 go c.ioloop()
90 func (c *CancelableStdin) ioloop() { func
152 s.ioloop()
156 func (s *FillableStdin) ioloop() { func
|
| /dports/security/gopass/gopass-1.13.0/vendor/github.com/chzyer/readline/ |
| H A D | std.go | 86 go c.ioloop()
90 func (c *CancelableStdin) ioloop() { func
152 s.ioloop()
156 func (s *FillableStdin) ioloop() { func
|
| /dports/www/writefreely/writefreely-0.13.1/vendor/github.com/chzyer/readline/ |
| H A D | std.go | 86 go c.ioloop()
90 func (c *CancelableStdin) ioloop() { func
152 s.ioloop()
156 func (s *FillableStdin) ioloop() { func
|
| /dports/misc/fq/fq-0.0.2/vendor/github.com/wader/readline/ |
| H A D | std.go | 86 go c.ioloop()
90 func (c *CancelableStdin) ioloop() { func
152 s.ioloop()
156 func (s *FillableStdin) ioloop() { func
|
| /dports/sysutils/terraform-switcher/terraform-switcher-0.13.1201/vendor/github.com/chzyer/readline/ |
| H A D | std.go | 86 go c.ioloop()
90 func (c *CancelableStdin) ioloop() { func
152 s.ioloop()
156 func (s *FillableStdin) ioloop() { func
|
| /dports/devel/pprof/pprof-acf8798/vendor/github.com/chzyer/readline/ |
| H A D | std.go | 86 go c.ioloop()
90 func (c *CancelableStdin) ioloop() { func
152 s.ioloop()
156 func (s *FillableStdin) ioloop() { func
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/chzyer/readline/ |
| H A D | std.go | 86 go c.ioloop()
90 func (c *CancelableStdin) ioloop() { func
152 s.ioloop()
156 func (s *FillableStdin) ioloop() { func
|