Home
last modified time | relevance | path

Searched refs:tcp_socket (Results 1 – 25 of 56) sorted by relevance

123

/external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/cares/cares/src/lib/
Dares_fds.c49 if (server->tcp_socket != ARES_SOCKET_BAD) in ares_fds()
51 FD_SET(server->tcp_socket, read_fds); in ares_fds()
53 FD_SET(server->tcp_socket, write_fds); in ares_fds()
54 if (server->tcp_socket >= nfds) in ares_fds()
55 nfds = server->tcp_socket + 1; in ares_fds()
Dares__close_sockets.c48 if (server->tcp_socket != ARES_SOCKET_BAD) in ares__close_sockets()
50 SOCK_STATE_CALLBACK(channel, server->tcp_socket, 0, 0); in ares__close_sockets()
51 ares__close_socket(channel, server->tcp_socket); in ares__close_sockets()
52 server->tcp_socket = ARES_SOCKET_BAD; in ares__close_sockets()
Dares_getsock.c51 if (server->tcp_socket != ARES_SOCKET_BAD) in ares_getsock()
55 socks[sockindex] = server->tcp_socket; in ares_getsock()
Dares_process.c233 if (!server->qhead || server->tcp_socket == ARES_SOCKET_BAD || in write_tcp_data()
238 if(!FD_ISSET(server->tcp_socket, write_fds)) in write_tcp_data()
242 if(server->tcp_socket != write_fd) in write_tcp_data()
252 FD_CLR(server->tcp_socket, write_fds); in write_tcp_data()
273 wcount = socket_writev(channel, server->tcp_socket, vec, (int)n); in write_tcp_data()
290 scount = socket_write(channel, server->tcp_socket, sendreq->data, sendreq->len); in write_tcp_data()
319 SOCK_STATE_CALLBACK(channel, server->tcp_socket, 1, 0); in advance_tcp_send_queue()
385 if (server->tcp_socket == ARES_SOCKET_BAD || server->is_broken) in read_tcp_data()
389 if(!FD_ISSET(server->tcp_socket, read_fds)) in read_tcp_data()
393 if(server->tcp_socket != read_fd) in read_tcp_data()
[all …]
/external/grpc-grpc/examples/python/wait_for_ready/
Dwait_for_ready_example.py35 tcp_socket = socket.socket(socket.AF_INET6)
37 tcp_socket = socket.socket(socket.AF_INET)
38 tcp_socket.bind(("", 0))
39 address_tuple = tcp_socket.getsockname()
41 tcp_socket.close()
Dasyncio_wait_for_ready_example.py35 tcp_socket = socket.socket(socket.AF_INET6)
37 tcp_socket = socket.socket(socket.AF_INET)
38 tcp_socket.bind(("", 0))
39 address_tuple = tcp_socket.getsockname()
41 tcp_socket.close()
/external/sdv/vsomeip/third_party/boost/asio/example/cpp11/timeouts/
Dblocking_token_tcp_client.cpp26 using tcp_socket = boost::asio::basic_stream_socket< typedef
35 close_after(std::chrono::steady_clock::duration t, tcp_socket& s) in close_after()
44 tcp_socket& socket_;
133 tcp_socket& socket_;
158 tcp_socket socket(io_context); in main()
/external/sdv/vsomeip/third_party/boost/asio/example/cpp03/windows/
Dtransmit_file.cpp26 boost::asio::io_context::executor_type> tcp_socket; typedef
33 void transmit_file(tcp_socket& socket, in transmit_file()
74 tcp_socket& socket() in socket()
105 socket_.shutdown(tcp_socket::shutdown_both, ignored_ec); in handle_write()
108 tcp_socket socket_;
/external/sdv/vsomeip/third_party/boost/asio/example/cpp03/timeouts/
Dblocking_token_tcp_client.cpp27 boost::asio::io_context::executor_type> tcp_socket; typedef
35 close_after(boost::asio::chrono::steady_clock::duration t, tcp_socket& s) in close_after()
44 tcp_socket& socket_;
133 tcp_socket& socket_;
159 tcp_socket socket(io_context); in main()
/external/cronet/stable/net/socket/
Dtcp_socket_posix.cc254 int TCPSocketPosix::Accept(std::unique_ptr<TCPSocketPosix>* tcp_socket, in Accept() argument
257 DCHECK(tcp_socket); in Accept()
267 tcp_socket, address, std::move(callback))); in Accept()
269 rv = HandleAcceptCompleted(tcp_socket, address, rv); in Accept()
524 std::unique_ptr<TCPSocketPosix>* tcp_socket, in AcceptCompleted() argument
529 std::move(callback).Run(HandleAcceptCompleted(tcp_socket, address, rv)); in AcceptCompleted()
533 std::unique_ptr<TCPSocketPosix>* tcp_socket, in HandleAcceptCompleted() argument
537 rv = BuildTcpSocketPosix(tcp_socket, address); in HandleAcceptCompleted()
550 std::unique_ptr<TCPSocketPosix>* tcp_socket, in BuildTcpSocketPosix() argument
561 *tcp_socket = in BuildTcpSocketPosix()
[all …]
Dtcp_socket_posix.h190 void AcceptCompleted(std::unique_ptr<TCPSocketPosix>* tcp_socket,
194 int HandleAcceptCompleted(std::unique_ptr<TCPSocketPosix>* tcp_socket,
197 int BuildTcpSocketPosix(std::unique_ptr<TCPSocketPosix>* tcp_socket,
/external/cronet/tot/net/socket/
Dtcp_socket_posix.cc254 int TCPSocketPosix::Accept(std::unique_ptr<TCPSocketPosix>* tcp_socket, in Accept() argument
257 DCHECK(tcp_socket); in Accept()
267 tcp_socket, address, std::move(callback))); in Accept()
269 rv = HandleAcceptCompleted(tcp_socket, address, rv); in Accept()
524 std::unique_ptr<TCPSocketPosix>* tcp_socket, in AcceptCompleted() argument
529 std::move(callback).Run(HandleAcceptCompleted(tcp_socket, address, rv)); in AcceptCompleted()
533 std::unique_ptr<TCPSocketPosix>* tcp_socket, in HandleAcceptCompleted() argument
537 rv = BuildTcpSocketPosix(tcp_socket, address); in HandleAcceptCompleted()
550 std::unique_ptr<TCPSocketPosix>* tcp_socket, in BuildTcpSocketPosix() argument
561 *tcp_socket = in BuildTcpSocketPosix()
[all …]
Dtcp_socket_posix.h190 void AcceptCompleted(std::unique_ptr<TCPSocketPosix>* tcp_socket,
194 int HandleAcceptCompleted(std::unique_ptr<TCPSocketPosix>* tcp_socket,
197 int BuildTcpSocketPosix(std::unique_ptr<TCPSocketPosix>* tcp_socket,
/external/webrtc/rtc_base/
Dtest_client_unittest.cc61 std::unique_ptr<AsyncTCPSocket> tcp_socket = absl::WrapUnique( in TestTcpInternal() local
63 ASSERT_TRUE(tcp_socket != nullptr); in TestTcpInternal()
65 TestClient client(std::move(tcp_socket)); in TestTcpInternal()
/external/webrtc/p2p/base/
Dbasic_packet_socket_factory.cc173 AsyncPacketSocket* tcp_socket; in CreateClientTcpSocket() local
175 tcp_socket = new cricket::AsyncStunTCPSocket(socket); in CreateClientTcpSocket()
177 tcp_socket = new AsyncTCPSocket(socket); in CreateClientTcpSocket()
180 return tcp_socket; in CreateClientTcpSocket()
/external/sdv/vsomeip/test/malicious_data_tests/
Dmalicious_data_test_msg_sender.cpp61 boost::asio::ip::tcp::socket tcp_socket(io_); in TEST_F() local
145 its_acceptor.async_accept(tcp_socket, [&](boost::system::error_code _error) { in TEST_F()
148 tcp_socket.set_option(boost::asio::ip::tcp::no_delay(true)); in TEST_F()
217 tcp_socket.send(boost::asio::buffer(its_malicious_data)); in TEST_F()
273 tcp_socket.shutdown(boost::asio::socket_base::shutdown_both, ec); in TEST_F()
275 tcp_socket.close(ec); in TEST_F()
291 boost::asio::ip::tcp::socket tcp_socket(io_); in TEST_F() local
383 its_acceptor.async_accept(tcp_socket, [&](boost::system::error_code _error) { in TEST_F()
386 tcp_socket.set_option(boost::asio::ip::tcp::no_delay(true)); in TEST_F()
444 tcp_socket.receive( in TEST_F()
[all …]
/external/sdv/vsomeip/third_party/boost/asio/example/cpp17/coroutines_ts/
Decho_server_with_default.cpp25 using tcp_socket = use_awaitable_t<>::as_default_on_t<tcp::socket>; typedef
28 awaitable<void> echo(tcp_socket socket) in echo()
Decho_server_with_as_single_default.cpp28 using tcp_socket = default_token::as_default_on_t<tcp::socket>; typedef
31 awaitable<void> echo(tcp_socket socket) in echo()
/external/selinux/python/audit2allow/
Dtest_dummy_policy.cil71 (class tcp_socket (ioctl name_bind name_connect))
72 (classorder (blk_file file dir tcp_socket))
Dtest.log7 …ontext=system_u:system_r:httpd_t:s0 tcontext=system_u:object_r:reserved_port_t:s0 tclass=tcp_socket
9 …context=system_u:system_r:smbd_t:s0 tcontext=system_u:object_r:reserved_port_t:s0 tclass=tcp_socket
13 …ontext=system_u:system_r:httpd_t:s0 tcontext=system_u:object_r:reserved_port_t:s0 tclass=tcp_socket
18 …scontext=system_u:system_r:httpd_t:s0 tcontext=system_u:object_r:mysqld_port_t:s0 tclass=tcp_socket
20 …ontext=system_u:system_r:httpd_t:s0 tcontext=system_u:object_r:reserved_port_t:s0 tclass=tcp_socket
37 …octlcmd=0x2a scontext=root:system_r:smbd_t:s0 tcontext=root:object_r:default_t:s0 tclass=tcp_socket
/external/selinux/secilc/docs/
Dcil_access_vector_rules.md236 (allow type_1 type_2 (tcp_socket (ioctl))) ;; pre-requisite
237 (allowx type_1 type_2 (ioctl tcp_socket (range 0x2000 0x20FF)))
263 (allowx type_1 type_2 (ioctl tcp_socket (range 0x2000 0x20FF)))
265 (auditallow type_1 type_2 (tcp_socket (ioctl))) ;; pre-requisite
266 (auditallowx type_1 type_2 (ioctl tcp_socket (range 0x2005 0x2010)))
289 …(allowx type_1 type_2 (ioctl tcp_socket (0x1))) ;; pre-requisite, just some irrelevant random ioctl
290 (dontauditx type_1 type_2 (ioctl tcp_socket (range 0x3000 0x30FF)))
/external/sdv/vsomeip/third_party/boost/process/test/
Dlimit_fd.cpp107 boost::asio::ip::tcp::socket tcp_socket(ioc);
111 tcp_socket.open(boost::asio::ip::tcp::v4());
114 …BOOST_CHECK(bt::is_stream_handle(socket_to_handle(tcp_socket.native_handle()), ec)); BOOST_CHECK_M…
/external/selinux/libsepol/tests/policies/test-hooks/
Dcmp_policy.conf25 class tcp_socket
204 class tcp_socket
Dsmall-base.conf25 class tcp_socket
204 class tcp_socket
/external/selinux/libsepol/tests/policies/test-expander/
Drole-base.conf25 class tcp_socket
204 class tcp_socket

123