| /third_party/boost/libs/asio/include/boost/asio/detail/ |
| D | socket_holder.hpp | 35 : socket_(invalid_socket) in socket_holder()
41 : socket_(s) in socket_holder()
48 if (socket_ != invalid_socket) in ~socket_holder()
52 socket_ops::close(socket_, state, true, ec); in ~socket_holder()
59 return socket_; in get()
65 if (socket_ != invalid_socket) in reset()
69 socket_ops::close(socket_, state, true, ec); in reset()
70 socket_ = invalid_socket; in reset()
78 socket_ = s; in reset()
84 socket_type tmp = socket_; in release()
[all …]
|
| D | reactive_socket_service_base.hpp | 56 socket_type socket_; member
89 return impl.socket_ != invalid_socket; in is_open()
103 return impl.socket_; in native_handle()
114 return socket_ops::sockatmark(impl.socket_, ec); in at_mark()
121 return socket_ops::available(impl.socket_, ec); in available()
128 socket_ops::listen(impl.socket_, backlog, ec); in listen()
137 socket_ops::ioctl(impl.socket_, impl.state_, command.name(), in io_control()
152 socket_ops::set_user_non_blocking(impl.socket_, impl.state_, mode, ec); in non_blocking()
166 socket_ops::set_internal_non_blocking(impl.socket_, impl.state_, mode, ec); in native_non_blocking()
178 socket_ops::poll_read(impl.socket_, impl.state_, -1, ec); in wait()
[all …]
|
| D | win_iocp_socket_service.hpp | 70 : socket_(s), in native_handle_type()
76 : socket_(s), in native_handle_type()
84 socket_ = s; in operator =()
91 return socket_; in operator socket_type()
105 socket_type socket_; member in boost::asio::detail::win_iocp_socket_service::native_handle_type
230 return native_handle_type(impl.socket_, impl.remote_endpoint_); in native_handle()
231 return native_handle_type(impl.socket_); in native_handle()
238 socket_ops::bind(impl.socket_, endpoint.data(), endpoint.size(), ec); in bind()
247 socket_ops::setsockopt(impl.socket_, impl.state_, in set_option()
259 socket_ops::getsockopt(impl.socket_, impl.state_, in get_option()
[all …]
|
| D | reactive_socket_service.hpp | 147 return impl.socket_; in native_handle()
154 socket_ops::bind(impl.socket_, endpoint.data(), endpoint.size(), ec); in bind()
163 socket_ops::setsockopt(impl.socket_, impl.state_, in set_option()
175 socket_ops::getsockopt(impl.socket_, impl.state_, in get_option()
189 if (socket_ops::getsockname(impl.socket_, endpoint.data(), &addr_len, ec)) in local_endpoint()
201 if (socket_ops::getpeername(impl.socket_, in remote_endpoint()
212 socket_ops::shutdown(impl.socket_, what, ec); in shutdown()
228 return socket_ops::sync_sendto1(impl.socket_, impl.state_, in send_to()
236 return socket_ops::sync_sendto(impl.socket_, impl.state_, in send_to()
248 socket_ops::poll_write(impl.socket_, impl.state_, -1, ec); in send_to()
[all …]
|
| /third_party/boost/boost/asio/detail/ |
| D | socket_holder.hpp | 35 : socket_(invalid_socket) in socket_holder()
41 : socket_(s) in socket_holder()
48 if (socket_ != invalid_socket) in ~socket_holder()
52 socket_ops::close(socket_, state, true, ec); in ~socket_holder()
59 return socket_; in get()
65 if (socket_ != invalid_socket) in reset()
69 socket_ops::close(socket_, state, true, ec); in reset()
70 socket_ = invalid_socket; in reset()
78 socket_ = s; in reset()
84 socket_type tmp = socket_; in release()
[all …]
|
| D | reactive_socket_service_base.hpp | 56 socket_type socket_; member
89 return impl.socket_ != invalid_socket; in is_open()
103 return impl.socket_; in native_handle()
114 return socket_ops::sockatmark(impl.socket_, ec); in at_mark()
121 return socket_ops::available(impl.socket_, ec); in available()
128 socket_ops::listen(impl.socket_, backlog, ec); in listen()
137 socket_ops::ioctl(impl.socket_, impl.state_, command.name(), in io_control()
152 socket_ops::set_user_non_blocking(impl.socket_, impl.state_, mode, ec); in non_blocking()
166 socket_ops::set_internal_non_blocking(impl.socket_, impl.state_, mode, ec); in native_non_blocking()
178 socket_ops::poll_read(impl.socket_, impl.state_, -1, ec); in wait()
[all …]
|
| D | win_iocp_socket_service.hpp | 70 : socket_(s), in native_handle_type()
76 : socket_(s), in native_handle_type()
84 socket_ = s; in operator =()
91 return socket_; in operator socket_type()
105 socket_type socket_; member in boost::asio::detail::win_iocp_socket_service::native_handle_type
230 return native_handle_type(impl.socket_, impl.remote_endpoint_); in native_handle()
231 return native_handle_type(impl.socket_); in native_handle()
238 socket_ops::bind(impl.socket_, endpoint.data(), endpoint.size(), ec); in bind()
247 socket_ops::setsockopt(impl.socket_, impl.state_, in set_option()
259 socket_ops::getsockopt(impl.socket_, impl.state_, in get_option()
[all …]
|
| D | reactive_socket_service.hpp | 147 return impl.socket_; in native_handle()
154 socket_ops::bind(impl.socket_, endpoint.data(), endpoint.size(), ec); in bind()
163 socket_ops::setsockopt(impl.socket_, impl.state_, in set_option()
175 socket_ops::getsockopt(impl.socket_, impl.state_, in get_option()
189 if (socket_ops::getsockname(impl.socket_, endpoint.data(), &addr_len, ec)) in local_endpoint()
201 if (socket_ops::getpeername(impl.socket_, in remote_endpoint()
212 socket_ops::shutdown(impl.socket_, what, ec); in shutdown()
228 return socket_ops::sync_sendto1(impl.socket_, impl.state_, in send_to()
236 return socket_ops::sync_sendto(impl.socket_, impl.state_, in send_to()
248 socket_ops::poll_write(impl.socket_, impl.state_, -1, ec); in send_to()
[all …]
|
| /third_party/boost/libs/asio/include/boost/asio/detail/impl/ |
| D | reactive_socket_service_base.ipp | 45 impl.socket_ = invalid_socket;
54 impl.socket_ = other_impl.socket_;
55 other_impl.socket_ = invalid_socket;
60 reactor_.move_descriptor(impl.socket_,
71 impl.socket_ = other_impl.socket_;
72 other_impl.socket_ = invalid_socket;
77 other_service.reactor_.move_descriptor(impl.socket_,
84 if (impl.socket_ != invalid_socket)
87 "socket", &impl, impl.socket_, "close"));
89 reactor_.deregister_descriptor(impl.socket_, impl.reactor_data_,
[all …]
|
| /third_party/boost/boost/asio/detail/impl/ |
| D | reactive_socket_service_base.ipp | 45 impl.socket_ = invalid_socket;
54 impl.socket_ = other_impl.socket_;
55 other_impl.socket_ = invalid_socket;
60 reactor_.move_descriptor(impl.socket_,
71 impl.socket_ = other_impl.socket_;
72 other_impl.socket_ = invalid_socket;
77 other_service.reactor_.move_descriptor(impl.socket_,
84 if (impl.socket_ != invalid_socket)
87 "socket", &impl, impl.socket_, "close"));
89 reactor_.deregister_descriptor(impl.socket_, impl.reactor_data_,
[all …]
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/nonblocking/ |
| D | third_party_lib.cpp | 28 : socket_(socket) in session()
42 if (std::size_t len = socket_.read_some(boost::asio::buffer(data_), ec)) in do_read()
59 if (std::size_t len = socket_.write_some( in do_write()
68 tcp::socket& socket_; member in third_party_lib::session
82 : socket_(std::move(socket)) in connection()
89 socket_.non_blocking(true); in start()
103 socket_.async_wait(tcp::socket::wait_read, in do_operations()
123 socket_.close(); in do_operations()
131 socket_.async_wait(tcp::socket::wait_write, in do_operations()
151 socket_.close(); in do_operations()
[all …]
|
| /third_party/boost/libs/asio/example/cpp11/nonblocking/ |
| D | third_party_lib.cpp | 28 : socket_(socket) in session()
42 if (std::size_t len = socket_.read_some(boost::asio::buffer(data_), ec)) in do_read()
59 if (std::size_t len = socket_.write_some( in do_write()
68 tcp::socket& socket_; member in third_party_lib::session
82 : socket_(std::move(socket)) in connection()
89 socket_.non_blocking(true); in start()
103 socket_.async_wait(tcp::socket::wait_read, in do_operations()
123 socket_.close(); in do_operations()
131 socket_.async_wait(tcp::socket::wait_write, in do_operations()
151 socket_.close(); in do_operations()
[all …]
|
| /third_party/nghttp2/src/ |
| D | asio_client_session_tcp_impl.cc | 35 : session_impl(io_service, connect_timeout), socket_(io_service) {} in session_tcp_impl()
42 : session_impl(io_service, connect_timeout), socket_(io_service) { in session_tcp_impl()
43 socket_.open(local_endpoint.protocol()); in session_tcp_impl()
45 socket_.set_option(option); in session_tcp_impl()
46 socket_.bind(local_endpoint); in session_tcp_impl()
53 socket_.async_connect( in start_connect()
68 tcp::socket &session_tcp_impl::socket() { return socket_; } in socket()
72 socket_.async_read_some(boost::asio::buffer(rb_), h); in read_socket()
77 boost::asio::async_write(socket_, boost::asio::buffer(wb_, wblen_), h); in write_socket()
82 socket_.close(ignored_ec); in shutdown_socket()
|
| D | asio_client_session_tls_impl.cc | 36 : session_impl(io_service, connect_timeout), socket_(io_service, tls_ctx) { in session_tls_impl()
40 socket_.set_verify_callback(boost::asio::ssl::rfc2818_verification(host)); in session_tls_impl()
41 auto ssl = socket_.native_handle(); in session_tls_impl()
64 self->socket_.async_handshake( in start_connect()
76 if (!tls_h2_negotiated(self->socket_)) { in start_connect()
87 tcp::socket &session_tls_impl::socket() { return socket_.next_layer(); } in socket()
91 socket_.async_read_some(boost::asio::buffer(rb_), h); in read_socket()
96 boost::asio::async_write(socket_, boost::asio::buffer(wb_, wblen_), h); in write_socket()
101 socket_.lowest_layer().close(ignored_ec); in shutdown_socket()
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/nonblocking/ |
| D | third_party_lib.cpp | 30 : socket_(socket), in session()
45 if (std::size_t len = socket_.read_some(boost::asio::buffer(data_), ec)) in do_read()
62 if (std::size_t len = socket_.write_some( in do_write()
71 tcp::socket& socket_; member in third_party_lib::session
93 return socket_; in socket()
99 socket_.non_blocking(true); in start()
106 : socket_(ex), in connection()
107 session_impl_(socket_), in connection()
119 socket_.async_wait(tcp::socket::wait_read, in start_operations()
129 socket_.async_wait(tcp::socket::wait_write, in start_operations()
[all …]
|
| /third_party/boost/libs/asio/example/cpp03/nonblocking/ |
| D | third_party_lib.cpp | 30 : socket_(socket), in session()
45 if (std::size_t len = socket_.read_some(boost::asio::buffer(data_), ec)) in do_read()
62 if (std::size_t len = socket_.write_some( in do_write()
71 tcp::socket& socket_; member in third_party_lib::session
93 return socket_; in socket()
99 socket_.non_blocking(true); in start()
106 : socket_(ex), in connection()
107 session_impl_(socket_), in connection()
119 socket_.async_wait(tcp::socket::wait_read, in start_operations()
129 socket_.async_wait(tcp::socket::wait_write, in start_operations()
[all …]
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/timeouts/ |
| D | server.cpp | 147 socket_(std::move(socket)) in tcp_session()
176 socket_.close(ignored_error); in stop()
184 return !socket_.is_open(); in stopped()
203 boost::asio::async_read_until(socket_, in read_line()
281 boost::asio::async_write(socket_, in write_line()
330 tcp::socket socket_; member in tcp_session
332 steady_timer input_deadline_{socket_.get_executor()};
334 steady_timer non_empty_output_queue_{socket_.get_executor()};
335 steady_timer output_deadline_{socket_.get_executor()};
348 : socket_(io_context) in udp_broadcaster()
[all …]
|
| /third_party/boost/libs/asio/example/cpp11/timeouts/ |
| D | server.cpp | 147 socket_(std::move(socket)) in tcp_session()
176 socket_.close(ignored_error); in stop()
184 return !socket_.is_open(); in stopped()
203 boost::asio::async_read_until(socket_, in read_line()
281 boost::asio::async_write(socket_, in write_line()
330 tcp::socket socket_; member in tcp_session
332 steady_timer input_deadline_{socket_.get_executor()};
334 steady_timer non_empty_output_queue_{socket_.get_executor()};
335 steady_timer output_deadline_{socket_.get_executor()};
348 : socket_(io_context) in udp_broadcaster()
[all …]
|
| /third_party/boost/libs/asio/example/cpp11/chat/ |
| D | chat_client.cpp | 28 socket_(io_context) in chat_client()
49 boost::asio::post(io_context_, [this]() { socket_.close(); }); in close()
55 boost::asio::async_connect(socket_, endpoints, in do_connect()
67 boost::asio::async_read(socket_, in do_read_header()
77 socket_.close(); in do_read_header()
84 boost::asio::async_read(socket_, in do_read_body()
96 socket_.close(); in do_read_body()
103 boost::asio::async_write(socket_, in do_write()
118 socket_.close(); in do_write()
125 tcp::socket socket_; member in chat_client
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/chat/ |
| D | chat_client.cpp | 28 socket_(io_context) in chat_client()
49 boost::asio::post(io_context_, [this]() { socket_.close(); }); in close()
55 boost::asio::async_connect(socket_, endpoints, in do_connect()
67 boost::asio::async_read(socket_, in do_read_header()
77 socket_.close(); in do_read_header()
84 boost::asio::async_read(socket_, in do_read_body()
96 socket_.close(); in do_read_body()
103 boost::asio::async_write(socket_, in do_write()
118 socket_.close(); in do_write()
125 tcp::socket socket_; member in chat_client
|
| /third_party/boost/libs/asio/example/cpp03/multicast/ |
| D | receiver.cpp | 24 : socket_(io_context) in receiver()
29 socket_.open(listen_endpoint.protocol()); in receiver()
30 socket_.set_option(boost::asio::ip::udp::socket::reuse_address(true)); in receiver()
31 socket_.bind(listen_endpoint); in receiver()
34 socket_.set_option( in receiver()
37 socket_.async_receive_from( in receiver()
52 socket_.async_receive_from( in handle_receive_from()
61 boost::asio::ip::udp::socket socket_; member in receiver
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/multicast/ |
| D | receiver.cpp | 24 : socket_(io_context) in receiver()
29 socket_.open(listen_endpoint.protocol()); in receiver()
30 socket_.set_option(boost::asio::ip::udp::socket::reuse_address(true)); in receiver()
31 socket_.bind(listen_endpoint); in receiver()
34 socket_.set_option( in receiver()
37 socket_.async_receive_from( in receiver()
52 socket_.async_receive_from( in handle_receive_from()
61 boost::asio::ip::udp::socket socket_; member in receiver
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/http/server/ |
| D | connection.cpp | 22 : socket_(io_context), in connection()
30 return socket_; in socket()
35 socket_.async_read_some(boost::asio::buffer(buffer_), in start()
43 socket_.close(); in stop()
58 boost::asio::async_write(socket_, reply_.to_buffers(), in handle_read()
65 boost::asio::async_write(socket_, reply_.to_buffers(), in handle_read()
71 socket_.async_read_some(boost::asio::buffer(buffer_), in handle_read()
89 socket_.shutdown(boost::asio::ip::tcp::socket::shutdown_both, ignored_ec); in handle_write()
|
| /third_party/boost/libs/asio/example/cpp03/http/server/ |
| D | connection.cpp | 22 : socket_(io_context), in connection()
30 return socket_; in socket()
35 socket_.async_read_some(boost::asio::buffer(buffer_), in start()
43 socket_.close(); in stop()
58 boost::asio::async_write(socket_, reply_.to_buffers(), in handle_read()
65 boost::asio::async_write(socket_, reply_.to_buffers(), in handle_read()
71 socket_.async_read_some(boost::asio::buffer(buffer_), in handle_read()
89 socket_.shutdown(boost::asio::ip::tcp::socket::shutdown_both, ignored_ec); in handle_write()
|
| /third_party/boost/libs/asio/example/cpp11/multicast/ |
| D | receiver.cpp | 24 : socket_(io_context) in receiver()
29 socket_.open(listen_endpoint.protocol()); in receiver()
30 socket_.set_option(boost::asio::ip::udp::socket::reuse_address(true)); in receiver()
31 socket_.bind(listen_endpoint); in receiver()
34 socket_.set_option( in receiver()
43 socket_.async_receive_from( in do_receive()
57 boost::asio::ip::udp::socket socket_; member in receiver
|