/third_party/boost/libs/asio/test/generic/ |
D | raw_protocol.cpp | 72 rp::socket socket1(ioc); in test() local 90 socket1 = rp::socket(ioc); in test() 91 socket1 = std::move(socket2); in test() 92 socket1 = boost::asio::ip::icmp::socket(ioc); in test() 97 rp::socket::executor_type ex = socket1.get_executor(); in test() 102 rp::socket::lowest_layer_type& lowest_layer = socket1.lowest_layer(); in test() 105 socket1.open(rp(af_inet, ipproto_icmp)); in test() 106 socket1.open(rp(af_inet, ipproto_icmp), ec); in test() 111 socket1.assign(rp(af_inet, ipproto_icmp), native_socket2); in test() 114 socket1.assign(rp(af_inet, ipproto_icmp), native_socket3, ec); in test() [all …]
|
D | datagram_protocol.cpp | 72 dp::socket socket1(ioc); in test() local 90 socket1 = dp::socket(ioc); in test() 91 socket1 = std::move(socket2); in test() 92 socket1 = boost::asio::ip::udp::socket(ioc); in test() 97 dp::socket::executor_type ex = socket1.get_executor(); in test() 102 dp::socket::lowest_layer_type& lowest_layer = socket1.lowest_layer(); in test() 105 socket1.open(dp(af_inet, ipproto_udp)); in test() 106 socket1.open(dp(af_inet, ipproto_udp), ec); in test() 111 socket1.assign(dp(af_inet, ipproto_udp), native_socket2); in test() 114 socket1.assign(dp(af_inet, ipproto_udp), native_socket3, ec); in test() [all …]
|
D | stream_protocol.cpp | 80 sp::socket socket1(ioc); in test() local 100 socket1 = sp::socket(ioc); in test() 101 socket1 = std::move(socket2); in test() 102 socket1 = boost::asio::ip::tcp::socket(ioc); in test() 107 sp::socket::executor_type ex = socket1.get_executor(); in test() 112 sp::socket::lowest_layer_type& lowest_layer = socket1.lowest_layer(); in test() 115 socket1.open(sp(af_inet, ipproto_tcp)); in test() 116 socket1.open(sp(af_inet, ipproto_tcp), ec); in test() 124 socket1.assign(sp(af_inet, ipproto_tcp), native_socket2); in test() 131 socket1.assign(sp(af_inet, ipproto_tcp), native_socket3, ec); in test() [all …]
|
D | seq_packet_protocol.cpp | 71 spp::socket socket1(ioc); in test() local 87 socket1 = spp::socket(ioc); in test() 88 socket1 = std::move(socket2); in test() 93 spp::socket::executor_type ex = socket1.get_executor(); in test() 98 spp::socket::lowest_layer_type& lowest_layer = socket1.lowest_layer(); in test() 101 socket1.open(spp(af_inet, 0)); in test() 102 socket1.open(spp(af_inet, 0), ec); in test() 107 socket1.assign(spp(af_inet, 0), native_socket2); in test() 110 socket1.assign(spp(af_inet, 0), native_socket3, ec); in test() 113 bool is_open = socket1.is_open(); in test() [all …]
|
/third_party/boost/libs/asio/test/local/ |
D | datagram_protocol.cpp | 65 dp::socket socket1(ioc); in test() local 79 dp::socket::executor_type ex = socket1.get_executor(); in test() 84 dp::socket::lowest_layer_type& lowest_layer = socket1.lowest_layer(); in test() 87 socket1.open(dp()); in test() 88 socket1.open(dp(), ec); in test() 91 socket1.assign(dp(), native_socket3); in test() 93 socket1.assign(dp(), native_socket4, ec); in test() 95 bool is_open = socket1.is_open(); in test() 98 socket1.close(); in test() 99 socket1.close(ec); in test() [all …]
|
D | stream_protocol.cpp | 73 sp::socket socket1(ioc); in test() local 87 sp::socket::executor_type ex = socket1.get_executor(); in test() 92 sp::socket::lowest_layer_type& lowest_layer = socket1.lowest_layer(); in test() 95 socket1.open(sp()); in test() 96 socket1.open(sp(), ec); in test() 99 socket1.assign(sp(), native_socket3); in test() 101 socket1.assign(sp(), native_socket4, ec); in test() 103 bool is_open = socket1.is_open(); in test() 106 socket1.close(); in test() 107 socket1.close(ec); in test() [all …]
|
/third_party/boost/libs/asio/test/ip/ |
D | icmp.cpp | 94 ip::icmp::socket socket1(ioc); in test() local 123 socket1 = ip::icmp::socket(ioc); in test() 124 socket1 = std::move(socket2); in test() 129 ip::icmp::socket::executor_type ex = socket1.get_executor(); in test() 134 ip::icmp::socket::lowest_layer_type& lowest_layer = socket1.lowest_layer(); in test() 137 const ip::icmp::socket& socket14 = socket1; in test() 142 socket1.open(ip::icmp::v4()); in test() 143 socket1.open(ip::icmp::v6()); in test() 144 socket1.open(ip::icmp::v4(), ec); in test() 145 socket1.open(ip::icmp::v6(), ec); in test() [all …]
|
D | udp.cpp | 110 ip::udp::socket socket1(ioc); in test() local 139 socket1 = ip::udp::socket(ioc); in test() 140 socket1 = std::move(socket2); in test() 145 ip::udp::socket::executor_type ex = socket1.get_executor(); in test() 150 ip::udp::socket::lowest_layer_type& lowest_layer = socket1.lowest_layer(); in test() 153 const ip::udp::socket& socket14 = socket1; in test() 158 socket1.open(ip::udp::v4()); in test() 159 socket1.open(ip::udp::v6()); in test() 160 socket1.open(ip::udp::v4(), ec); in test() 161 socket1.open(ip::udp::v6(), ec); in test() [all …]
|
D | tcp.cpp | 247 ip::tcp::socket socket1(ioc); in test() local 276 socket1 = ip::tcp::socket(ioc); in test() 277 socket1 = std::move(socket2); in test() 282 ip::tcp::socket::executor_type ex = socket1.get_executor(); in test() 287 ip::tcp::socket::lowest_layer_type& lowest_layer = socket1.lowest_layer(); in test() 290 const ip::tcp::socket& socket14 = socket1; in test() 295 socket1.open(ip::tcp::v4()); in test() 296 socket1.open(ip::tcp::v6()); in test() 297 socket1.open(ip::tcp::v4(), ec); in test() 298 socket1.open(ip::tcp::v6(), ec); in test() [all …]
|
/third_party/node/test/cctest/ |
D | test_inspector_socket_server.cc | 505 SocketWrapper socket1(&loop); in TEST_F() local 506 socket1.Connect(HOST, server.port()); in TEST_F() 507 socket1.TestHttpRequest("/json/list", "[ ]"); in TEST_F() 509 socket1.TestHttpRequest("/json/list", "[ ]"); in TEST_F() 510 socket1.Close(); in TEST_F() 518 SocketWrapper socket1(&loop); in TEST_F() local 519 socket1.Connect(HOST, server.port()); in TEST_F() 520 socket1.TestHttpRequest("/json/list", "[ ]"); in TEST_F() 522 socket1.TestHttpRequest("/json/list", "[ ]"); in TEST_F() 523 socket1.Close(); in TEST_F() [all …]
|
/third_party/boost/libs/asio/include/boost/asio/local/ |
D | connect_pair.hpp | 37 void connect_pair(basic_socket<Protocol, Executor1>& socket1, 42 BOOST_ASIO_SYNC_OP_VOID connect_pair(basic_socket<Protocol, Executor1>& socket1, 46 inline void connect_pair(basic_socket<Protocol, Executor1>& socket1, in connect_pair() argument 50 connect_pair(socket1, socket2, ec); in connect_pair() 56 basic_socket<Protocol, Executor1>& socket1, in connect_pair() argument 71 socket1.assign(protocol, sv[0], ec); in connect_pair() 85 socket1.close(temp_ec); in connect_pair()
|
/third_party/boost/boost/asio/local/ |
D | connect_pair.hpp | 37 void connect_pair(basic_socket<Protocol, Executor1>& socket1, 42 BOOST_ASIO_SYNC_OP_VOID connect_pair(basic_socket<Protocol, Executor1>& socket1, 46 inline void connect_pair(basic_socket<Protocol, Executor1>& socket1, in connect_pair() argument 50 connect_pair(socket1, socket2, ec); in connect_pair() 56 basic_socket<Protocol, Executor1>& socket1, in connect_pair() argument 71 socket1.assign(protocol, sv[0], ec); in connect_pair() 85 socket1.close(temp_ec); in connect_pair()
|
/third_party/node/test/parallel/ |
D | test-cluster-dgram-ipv6only.js | 26 const socket1 = dgram.createSocket({ constant 33 socket1.on('error', common.mustNotCall()); 36 socket1.bind({ 40 const { port } = socket1.address(); 46 socket1.close(close);
|
D | test-cluster-dgram-reuse.js | 24 const socket1 = dgram.createSocket(options); constant 27 socket1.bind(0, () => { 28 socket2.bind(socket1.address().port, () => { 31 socket1.close(close);
|
/third_party/node/test/known_issues/ |
D | test-dgram-bind-shared-ports-after-port-0.js | 50 const socket1 = dgram.createSocket('udp4', () => {}); constant 51 socket1.on('error', PRT1 === 0 ? () => {} : assert.fail); 52 socket1.bind( 54 () => process.send({ message: 'success', port1: socket1.address().port })
|
/third_party/node/lib/internal/streams/ |
D | duplexpair.js | 44 this.socket1 = new DuplexSocket(); 46 this.socket1[kOtherSide] = this.socket2; 47 this.socket2[kOtherSide] = this.socket1;
|
/third_party/node/test/sequential/ |
D | test-dgram-bind-shared-ports.js | 76 const socket1 = dgram.createSocket('udp4', common.mustNotCall()); constant 80 socket1.on('error', (err) => assert.fail(err)); 103 socket1.bind(opt1, common.mustCall(() => { 104 const port1 = socket1.address().port;
|
/third_party/boost/libs/asio/doc/overview/ |
D | posix.qbk | 22 local::stream_protocol::socket socket1(my_io_context); 24 local::connect_pair(socket1, socket2); 29 local::datagram_protocol::socket socket1(my_io_context); 31 local::connect_pair(socket1, socket2);
|
/third_party/boost/libs/asio/test/ssl/ |
D | stream.cpp | 75 ip::tcp::socket socket1(ioc, ip::tcp::v4()); in test() local 76 ssl::stream<ip::tcp::socket&> stream2(socket1, context); in test()
|
/third_party/node/lib/ |
D | tls.js | 359 const { socket1, socket2 } = new DuplexPair(); 364 this.encrypted = socket1;
|
/third_party/gstreamer/gstplugins_base/gst-libs/gst/rtsp/ |
D | gstrtspconnection.c | 169 GSocket *socket0, *socket1; member 925 conn->socket1 = socket; in setup_tunneling() 926 conn->write_socket = conn->socket1; in setup_tunneling() 2876 conn->socket1 = NULL; in gst_rtsp_connection_close() 3361 res = set_qos_dscp (conn->socket1, qos_dscp); in gst_rtsp_connection_set_qos_dscp() 3618 conn->socket1 = conn2->socket0; in gst_rtsp_connection_do_tunnel() 3626 conn->socket1 = conn->socket0; in gst_rtsp_connection_do_tunnel() 3639 conn2->socket1 = NULL; in gst_rtsp_connection_do_tunnel() 3648 conn->read_socket = conn->socket1; in gst_rtsp_connection_do_tunnel() 3846 conn->socket1 = NULL; in gst_rtsp_source_dispatch_read()
|
/third_party/boost/libs/asio/doc/ |
D | reference.qbk | 102624 basic_socket< Protocol, Executor1 > & socket1, 102633 basic_socket< Protocol, Executor1 > & socket1, 102656 basic_socket< Protocol, Executor1 > & socket1, 102676 basic_socket< Protocol, Executor1 > & socket1,
|