Home
last modified time | relevance | path

Searched refs:io_context (Results 1 – 25 of 463) sorted by relevance

12345678910>>...19

/third_party/boost/boost/asio/impl/
Dio_context.ipp2 // impl/io_context.ipp
19 #include <boost/asio/io_context.hpp>
37 io_context::io_context()
43 io_context::io_context(int concurrency_hint)
49 io_context::impl_type& io_context::add_impl(io_context::impl_type* impl)
56 io_context::~io_context()
60 io_context::count_type io_context::run()
69 io_context::count_type io_context::run(boost::system::error_code& ec)
75 io_context::count_type io_context::run_one()
84 io_context::count_type io_context::run_one(boost::system::error_code& ec)
[all …]
Dio_context.hpp36 inline Service& use_service(io_context& ioc) in use_service()
47 io_context& ioc) in use_service()
54 inline io_context::executor_type
55 io_context::get_executor() BOOST_ASIO_NOEXCEPT in get_executor()
63 std::size_t io_context::run_for( in run_for()
70 std::size_t io_context::run_until( in run_until()
81 std::size_t io_context::run_one_for( in run_one_for()
88 std::size_t io_context::run_one_until( in run_one_until()
117 inline void io_context::reset() in reset()
122 struct io_context::initiate_dispatch
[all …]
/third_party/skia/third_party/externals/microhttpd/src/microspdy/
Dio_openssl.c82 if(NULL == (daemon->io_context = SSL_CTX_new(TLSv1_server_method()))) in SPDYF_openssl_init()
101 SSL_CTX_set_options(daemon->io_context, options); in SPDYF_openssl_init()
102 if(1 != SSL_CTX_use_certificate_file(daemon->io_context, daemon->certfile , SSL_FILETYPE_PEM)) in SPDYF_openssl_init()
105 SSL_CTX_free(daemon->io_context); in SPDYF_openssl_init()
108 if(1 != SSL_CTX_use_PrivateKey_file(daemon->io_context, daemon->keyfile, SSL_FILETYPE_PEM)) in SPDYF_openssl_init()
111 SSL_CTX_free(daemon->io_context); in SPDYF_openssl_init()
114 … SSL_CTX_set_next_protos_advertised_cb(daemon->io_context, &spdyf_next_protos_advertised_cb, NULL); in SPDYF_openssl_init()
115 if (1 != SSL_CTX_set_cipher_list(daemon->io_context, "HIGH")) in SPDYF_openssl_init()
118 SSL_CTX_free(daemon->io_context); in SPDYF_openssl_init()
129 SSL_CTX_free(daemon->io_context); in SPDYF_openssl_deinit()
[all …]
/third_party/boost/libs/process/test/
Dasync.cpp42 boost::asio::io_context io_context; variable
49 boost::asio::deadline_timer timeout{io_context, boost::posix_time::seconds(2)};
50 timeout.async_wait([&](boost::system::error_code ec){if (!ec) io_context.stop();}); in __anondc3481c20202()
54 ec, io_context,
68 ec, io_context,
78 io_context.run();
94 boost::asio::io_context io_context; variable
100 boost::asio::deadline_timer timeout{io_context, boost::posix_time::seconds(3)};
101 timeout.async_wait([&](boost::system::error_code ec){if (!ec) io_context.stop();}); in __anondc3481c20502()
114 io_context,
[all …]
/third_party/boost/libs/asio/example/cpp03/tutorial/daytime7/
Dserver.cpp36 static pointer create(boost::asio::io_context& io_context) in create() argument
38 return pointer(new tcp_connection(io_context)); in create()
55 tcp_connection(boost::asio::io_context& io_context) in tcp_connection() argument
56 : socket_(io_context) in tcp_connection()
71 tcp_server(boost::asio::io_context& io_context) in tcp_server() argument
72 : io_context_(io_context), in tcp_server()
73 acceptor_(io_context, tcp::endpoint(tcp::v4(), 13)) in tcp_server()
100 boost::asio::io_context& io_context_;
107 udp_server(boost::asio::io_context& io_context) in udp_server() argument
108 : socket_(io_context, udp::endpoint(udp::v4(), 13)) in udp_server()
[all …]
/third_party/boost/boost/asio/
Dio_context.hpp212 class io_context class
248 BOOST_ASIO_DECL io_context();
257 BOOST_ASIO_DECL explicit io_context(int concurrency_hint);
291 BOOST_ASIO_DECL ~io_context();
633 detail::wrapped_handler<io_context&, Handler>
639 io_context(const io_context&) BOOST_ASIO_DELETED;
640 io_context& operator=(const io_context&) BOOST_ASIO_DELETED;
653 friend Service& use_service(io_context& ioc);
672 class io_context::basic_executor_type : detail::io_context_bits
883 io_context& query(execution::context_t) const BOOST_ASIO_NOEXCEPT in query()
[all …]
/third_party/boost/libs/asio/doc/overview/
Dimplementation.qbk25 `io_context::run()`, `io_context::run_one()`, `io_context::poll()` or
26 `io_context::poll_one()`.
28 * An additional thread per `io_context` is used to emulate asynchronous host
45 `io_context::run()`, `io_context::run_one()`, `io_context::poll()` or
46 `io_context::poll_one()`.
48 * An additional thread per `io_context` is used to emulate asynchronous host
66 calls `io_context::run()`, `io_context::run_one()`, `io_context::poll()` or
67 `io_context::poll_one()`.
69 * An additional thread per `io_context` is used to emulate asynchronous host
88 `io_context::run()`, `io_context::run_one()`, `io_context::poll()` or
[all …]
/third_party/boost/libs/asio/example/cpp03/tutorial/daytime3/
Dserver.cpp34 static pointer create(boost::asio::io_context& io_context) in create() argument
36 return pointer(new tcp_connection(io_context)); in create()
55 tcp_connection(boost::asio::io_context& io_context) in tcp_connection() argument
56 : socket_(io_context) in tcp_connection()
72 tcp_server(boost::asio::io_context& io_context) in tcp_server() argument
73 : io_context_(io_context), in tcp_server()
74 acceptor_(io_context, tcp::endpoint(tcp::v4(), 13)) in tcp_server()
101 boost::asio::io_context& io_context_;
109 boost::asio::io_context io_context; in main() local
110 tcp_server server(io_context); in main()
[all …]
/third_party/boost/boost/beast/core/detail/
Dget_io_context.hpp30 net::io_context*
31 get_io_context(net::io_context& ioc) in get_io_context()
37 net::io_context*
38 get_io_context(net::io_context::executor_type const& ex) in get_io_context()
44 net::io_context*
46 net::io_context::executor_type> const& ex) in get_io_context()
52 net::io_context*
62 net::io_context*
66 net::io_context::executor_type>(); in get_io_context()
73 net::io_context*
[all …]
/third_party/boost/doc/html/boost_asio/example/cpp03/fork/
Ddaemon.cpp26 udp_daytime_server(boost::asio::io_context& io_context) in udp_daytime_server() argument
27 : socket_(io_context, udp::endpoint(udp::v4(), 13)) in udp_daytime_server()
66 boost::asio::io_context io_context; in main() local
71 udp_daytime_server server(io_context); in main()
76 boost::asio::signal_set signals(io_context, SIGINT, SIGTERM); in main()
78 boost::bind(&boost::asio::io_context::stop, &io_context)); in main()
83 io_context.notify_fork(boost::asio::io_context::fork_prepare); in main()
178 io_context.notify_fork(boost::asio::io_context::fork_child); in main()
182 io_context.run(); in main()
Dprocess_per_connection.cpp28 server(boost::asio::io_context& io_context, unsigned short port) in server() argument
29 : io_context_(io_context), in server()
30 signal_(io_context, SIGCHLD), in server()
31 acceptor_(io_context, tcp::endpoint(tcp::v4(), port)), in server()
32 socket_(io_context) in server()
71 io_context_.notify_fork(boost::asio::io_context::fork_prepare); in handle_accept()
78 io_context_.notify_fork(boost::asio::io_context::fork_child); in handle_accept()
95 io_context_.notify_fork(boost::asio::io_context::fork_parent); in handle_accept()
133 boost::asio::io_context& io_context_;
150 boost::asio::io_context io_context; in main() local
[all …]
/third_party/boost/doc/html/boost_asio/example/cpp11/fork/
Dprocess_per_connection.cpp26 server(boost::asio::io_context& io_context, unsigned short port) in server() argument
27 : io_context_(io_context), in server()
28 signal_(io_context, SIGCHLD), in server()
29 acceptor_(io_context, {tcp::v4(), port}), in server()
30 socket_(io_context)
70 io_context_.notify_fork(boost::asio::io_context::fork_prepare); in accept()
78 io_context_.notify_fork(boost::asio::io_context::fork_child); in accept()
97 io_context_.notify_fork(boost::asio::io_context::fork_parent); in accept()
134 boost::asio::io_context& io_context_;
151 boost::asio::io_context io_context; in main() local
[all …]
Ddaemon.cpp25 udp_daytime_server(boost::asio::io_context& io_context) in udp_daytime_server() argument
26 : socket_(io_context, {udp::v4(), 13}) in udp_daytime_server()
62 boost::asio::io_context io_context; in main() local
67 udp_daytime_server server(io_context); in main()
72 boost::asio::signal_set signals(io_context, SIGINT, SIGTERM); in main()
76 io_context.stop(); in main()
82 io_context.notify_fork(boost::asio::io_context::fork_prepare); in main()
177 io_context.notify_fork(boost::asio::io_context::fork_child); in main()
181 io_context.run(); in main()
/third_party/boost/libs/asio/example/cpp11/fork/
Dprocess_per_connection.cpp26 server(boost::asio::io_context& io_context, unsigned short port) in server() argument
27 : io_context_(io_context), in server()
28 signal_(io_context, SIGCHLD), in server()
29 acceptor_(io_context, {tcp::v4(), port}), in server()
30 socket_(io_context)
70 io_context_.notify_fork(boost::asio::io_context::fork_prepare); in accept()
78 io_context_.notify_fork(boost::asio::io_context::fork_child); in accept()
97 io_context_.notify_fork(boost::asio::io_context::fork_parent); in accept()
134 boost::asio::io_context& io_context_;
151 boost::asio::io_context io_context; in main() local
[all …]
Ddaemon.cpp25 udp_daytime_server(boost::asio::io_context& io_context) in udp_daytime_server() argument
26 : socket_(io_context, {udp::v4(), 13}) in udp_daytime_server()
62 boost::asio::io_context io_context; in main() local
67 udp_daytime_server server(io_context); in main()
72 boost::asio::signal_set signals(io_context, SIGINT, SIGTERM); in main()
76 io_context.stop(); in main()
82 io_context.notify_fork(boost::asio::io_context::fork_prepare); in main()
177 io_context.notify_fork(boost::asio::io_context::fork_child); in main()
181 io_context.run(); in main()
/third_party/boost/libs/asio/example/cpp03/fork/
Ddaemon.cpp26 udp_daytime_server(boost::asio::io_context& io_context) in udp_daytime_server() argument
27 : socket_(io_context, udp::endpoint(udp::v4(), 13)) in udp_daytime_server()
66 boost::asio::io_context io_context; in main() local
71 udp_daytime_server server(io_context); in main()
76 boost::asio::signal_set signals(io_context, SIGINT, SIGTERM); in main()
78 boost::bind(&boost::asio::io_context::stop, &io_context)); in main()
83 io_context.notify_fork(boost::asio::io_context::fork_prepare); in main()
178 io_context.notify_fork(boost::asio::io_context::fork_child); in main()
182 io_context.run(); in main()
Dprocess_per_connection.cpp28 server(boost::asio::io_context& io_context, unsigned short port) in server() argument
29 : io_context_(io_context), in server()
30 signal_(io_context, SIGCHLD), in server()
31 acceptor_(io_context, tcp::endpoint(tcp::v4(), port)), in server()
32 socket_(io_context) in server()
71 io_context_.notify_fork(boost::asio::io_context::fork_prepare); in handle_accept()
78 io_context_.notify_fork(boost::asio::io_context::fork_child); in handle_accept()
95 io_context_.notify_fork(boost::asio::io_context::fork_parent); in handle_accept()
133 boost::asio::io_context& io_context_;
150 boost::asio::io_context io_context; in main() local
[all …]
/third_party/boost/doc/html/boost_asio/example/cpp03/spawn/
Decho_server.cpp26 explicit session(boost::asio::io_context& io_context) in session() argument
27 : strand_(boost::asio::make_strand(io_context)), in session()
28 socket_(io_context), in session()
29 timer_(io_context) in session()
79 boost::asio::strand<boost::asio::io_context::executor_type> strand_;
84 void do_accept(boost::asio::io_context& io_context, in do_accept() argument
87 tcp::acceptor acceptor(io_context, tcp::endpoint(tcp::v4(), port)); in do_accept()
92 boost::shared_ptr<session> new_session(new session(io_context)); in do_accept()
108 boost::asio::io_context io_context; in main() local
110 boost::asio::spawn(io_context, in main()
[all …]
/third_party/boost/libs/asio/example/cpp03/spawn/
Decho_server.cpp26 explicit session(boost::asio::io_context& io_context) in session() argument
27 : strand_(boost::asio::make_strand(io_context)), in session()
28 socket_(io_context), in session()
29 timer_(io_context) in session()
79 boost::asio::strand<boost::asio::io_context::executor_type> strand_;
84 void do_accept(boost::asio::io_context& io_context, in do_accept() argument
87 tcp::acceptor acceptor(io_context, tcp::endpoint(tcp::v4(), port)); in do_accept()
92 boost::shared_ptr<session> new_session(new session(io_context)); in do_accept()
108 boost::asio::io_context io_context; in main() local
110 boost::asio::spawn(io_context, in main()
[all …]
/third_party/boost/libs/asio/example/cpp03/windows/
Dtransmit_file.cpp26 boost::asio::io_context::executor_type> tcp_socket;
29 boost::asio::io_context::executor_type> tcp_acceptor;
68 static pointer create(boost::asio::io_context& io_context, in create() argument
71 return pointer(new connection(io_context, filename)); in create()
94 connection(boost::asio::io_context& io_context, const std::string& filename) in connection() argument
95 : socket_(io_context), in connection()
97 file_(io_context) in connection()
116 server(boost::asio::io_context& io_context, in server() argument
118 : acceptor_(io_context, tcp::endpoint(tcp::v4(), port)), in server()
160 boost::asio::io_context io_context; in main() local
[all …]
/third_party/boost/doc/html/boost_asio/example/cpp03/windows/
Dtransmit_file.cpp26 boost::asio::io_context::executor_type> tcp_socket;
29 boost::asio::io_context::executor_type> tcp_acceptor;
68 static pointer create(boost::asio::io_context& io_context, in create() argument
71 return pointer(new connection(io_context, filename)); in create()
94 connection(boost::asio::io_context& io_context, const std::string& filename) in connection() argument
95 : socket_(io_context), in connection()
97 file_(io_context) in connection()
116 server(boost::asio::io_context& io_context, in server() argument
118 : acceptor_(io_context, tcp::endpoint(tcp::v4(), port)), in server()
160 boost::asio::io_context io_context; in main() local
[all …]
/third_party/boost/libs/asio/test/local/
Dconnect_pair.cpp43 boost::asio::io_context io_context; in test() local
46 dp::socket s1(io_context); in test()
47 dp::socket s2(io_context); in test()
50 dp::socket s3(io_context); in test()
51 dp::socket s4(io_context); in test()
54 sp::socket s5(io_context); in test()
55 sp::socket s6(io_context); in test()
58 sp::socket s7(io_context); in test()
59 sp::socket s8(io_context); in test()
/third_party/boost/libs/asio/test/
Dconnect.cpp76 boost::asio::io_context io_context_;
142 boost::asio::io_context io_context; in test_connect_range() local
143 boost::asio::ip::tcp::socket socket(io_context); in test_connect_range()
176 boost::asio::io_context io_context; in test_connect_range_ec() local
177 boost::asio::ip::tcp::socket socket(io_context); in test_connect_range_ec()
208 boost::asio::io_context io_context; in test_connect_range_cond() local
209 boost::asio::ip::tcp::socket socket(io_context); in test_connect_range_cond()
339 boost::asio::io_context io_context; in test_connect_range_cond_ec() local
340 boost::asio::ip::tcp::socket socket(io_context); in test_connect_range_cond_ec()
435 boost::asio::io_context io_context; in test_connect_iter() local
[all …]
/third_party/boost/libs/asio/example/cpp11/futures/
Ddaytime_client.cpp21 void get_daytime(boost::asio::io_context& io_context, const char* hostname) in get_daytime() argument
25 udp::resolver resolver(io_context); in get_daytime()
35 udp::socket socket(io_context, udp::v4()); in get_daytime()
79 boost::asio::io_context io_context; in main() local
80 auto work = boost::asio::require(io_context.get_executor(), in main()
82 std::thread thread([&io_context](){ io_context.run(); }); in main()
84 get_daytime(io_context, argv[1]); in main()
86 io_context.stop(); in main()
/third_party/boost/doc/html/boost_asio/example/cpp11/futures/
Ddaytime_client.cpp21 void get_daytime(boost::asio::io_context& io_context, const char* hostname) in get_daytime() argument
25 udp::resolver resolver(io_context); in get_daytime()
35 udp::socket socket(io_context, udp::v4()); in get_daytime()
79 boost::asio::io_context io_context; in main() local
80 auto work = boost::asio::require(io_context.get_executor(), in main()
82 std::thread thread([&io_context](){ io_context.run(); }); in main()
84 get_daytime(io_context, argv[1]); in main()
86 io_context.stop(); in main()

12345678910>>...19