| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/io/ |
| H A D | socket_test.cc | 30 SocketFd CreateTestSocket(socket_api::SocketProtocol protocol, in CreateTestSocket()
32 absl::StatusOr<SocketFd> socket = socket_api::CreateSocket( in CreateTestSocket()
49 socket = socket_api::CreateSocket( in CreateTestRawSocket()
51 socket_api::SocketProtocol::kRawIp, blocking); in CreateTestRawSocket()
54 socket = socket_api::CreateSocket( in CreateTestRawSocket()
56 socket_api::SocketProtocol::kRawIp, blocking); in CreateTestRawSocket()
59 socket = socket_api::CreateSocket(quiche::TestLoopback().address_family(), in CreateTestRawSocket()
60 socket_api::SocketProtocol::kRawIp, in CreateTestRawSocket()
78 absl::StatusOr<SocketFd> created_socket = socket_api::CreateSocket( in TEST()
79 localhost_address.address_family(), socket_api::SocketProtocol::kUdp); in TEST()
[all …]
|
| H A D | event_loop_connecting_client_socket_test.cc | 48 SocketFd connected_socket, socket_api::SocketProtocol protocol)>;
93 behavior()(connection_socket_descriptor_, socket_api::SocketProtocol::kTcp); in Run()
101 absl::StatusOr<socket_api::AcceptResult> connection_socket = in AcceptSocket()
102 socket_api::Accept(server_socket_descriptor(), /*blocking=*/true); in AcceptSocket()
108 QUICHE_CHECK(socket_api::Close(connection_socket_descriptor_).ok()); in CloseSocket()
109 QUICHE_CHECK(socket_api::Close(server_socket_descriptor()).ok()); in CloseSocket()
133 behavior()(server_socket_descriptor(), socket_api::SocketProtocol::kUdp); in Run()
142 socket_api::Connect(server_socket_descriptor(), client_socket_address_) in ConnectSocket()
147 QUICHE_CHECK(socket_api::Close(server_socket_descriptor()).ok()); in DisconnectSocket()
155 std::tuple<socket_api::SocketProtocol, QuicEventLoopFactory*>>,
[all …]
|
| H A D | event_loop_connecting_client_socket.cc | 25 socket_api::SocketProtocol protocol, in EventLoopConnectingClientSocket()
68 status = socket_api::SetSocketBlocking(descriptor_, /*blocking=*/true); in ConnectBlocking()
93 status = socket_api::SetSocketBlocking(descriptor_, /*blocking=*/false); in ConnectBlocking()
158 return socket_api::GetSocketAddress(descriptor_); in GetLocalAddress()
169 socket_api::SetSocketBlocking(descriptor_, /*blocking=*/true); in ReceiveBlocking()
190 socket_api::SetSocketBlocking(descriptor_, /*blocking=*/false); in ReceiveBlocking()
281 socket_api::CreateSocket(peer_address_.host().address_family(), protocol_, in Open()
312 socket_api::SetReceiveBufferSize(descriptor_, receive_buffer_size_); in Open()
325 socket_api::SetSendBufferSize(descriptor_, send_buffer_size_); in Open()
345 absl::Status status = socket_api::Close(descriptor_); in Close()
[all …]
|
| H A D | event_loop_socket_factory.cc | 33 socket_api::SocketProtocol::kTcp, peer_address, receive_buffer_size, in CreateTcpClientSocket()
43 socket_api::SocketProtocol::kUdp, peer_address, receive_buffer_size, in CreateConnectingUdpClientSocket()
|
| H A D | event_loop_connecting_client_socket.h | 34 socket_api::SocketProtocol protocol,
81 const socket_api::SocketProtocol protocol_;
|
| H A D | socket_win.inc | 18 namespace quic::socket_api {
209 } // namespace quic::socket_api
|
| H A D | socket_internal.h | 16 namespace quic::socket_api {
|
| H A D | socket_posix.inc | 32 namespace quic::socket_api {
312 } // namespace quic::socket_api
|
| H A D | socket.h | 37 namespace socket_api {
|
| H A D | socket.cc | 27 namespace quic::socket_api { namespace
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/masque/ |
| H A D | masque_server_session.cc | 79 QuicUdpSocketApi socket_api; in FdWrapper() local
81 socket_api.Create(address_family, in FdWrapper()
90 QuicUdpSocketApi socket_api; in ~FdWrapper() local
91 socket_api.Destroy(fd_); in ~FdWrapper()
587 QuicUdpSocketApi socket_api; in HandleMasqueRequest() local
588 if (!socket_api.Bind(fd_wrapper.fd(), empty_address)) { in HandleMasqueRequest()
660 QuicUdpSocketApi socket_api; in HandleConnectUdpSocketEvent() local
670 socket_api.ReadPacket(fd, packet_info_interested, &read_result); in HandleConnectUdpSocketEvent()
798 QuicUdpSocketApi socket_api; in ~ConnectUdpServerState() local
803 socket_api.Destroy(fd_); in ~ConnectUdpServerState()
[all …]
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/tools/ |
| H A D | quic_server.cc | 105 (void)socket_api::Close(fd_); in ~QuicServer()
121 QuicUdpSocketApi socket_api; in CreateUDPSocketAndListen() local
122 fd_ = socket_api.Create(address.host().AddressFamilyToInt(), in CreateUDPSocketAndListen()
130 overflow_supported_ = socket_api.EnableDroppedPacketCount(fd_); in CreateUDPSocketAndListen()
131 socket_api.EnableReceiveTimestamp(fd_); in CreateUDPSocketAndListen()
133 bool success = socket_api.Bind(fd_, address); in CreateUDPSocketAndListen()
|
| H A D | quic_server_test.cc | 149 QuicUdpSocketApi socket_api; in TEST_P() local
151 socket_api.Create(server_address_.host().AddressFamilyToInt(), in TEST_P()
161 socket_api.WritePacket(fd, buf, sizeof(buf), packet_info); in TEST_P()
|
| H A D | quic_client_default_network_helper.cc | 54 auto closer = absl::MakeCleanup([fd] { (void)socket_api::Close(fd); }); in CreateUDPSocketAndBind()
122 absl::Status rc = socket_api::Close(fd); in CleanUpUDPSocketImpl()
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/batch_writer/ |
| H A D | quic_batch_writer_test.cc | 18 QuicUdpSocketApi socket_api; in ShouldSkip() local
20 socket_api.Create(params.address_family, in ShouldSkip()
29 socket_api.Destroy(fd); in ShouldSkip()
|
| H A D | quic_batch_writer_test.h | 53 QuicUdpSocketApi socket_api; in CreateSocket() local
54 *fd = socket_api.Create(family, in CreateSocket()
61 socket_api.EnableDroppedPacketCount(*fd); in CreateSocket()
63 if (!socket_api.Bind(*fd, *address)) { in CreateSocket()
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/ |
| H A D | quic_udp_socket.cc | 87 absl::StatusOr<SocketFd> socket = socket_api::CreateSocket( in Create()
89 socket_api::SocketProtocol::kUdp, in Create()
114 absl::Status result = socket_api::Close(fd); in Destroy()
|
| H A D | quic_udp_socket_win.inc | 80 socket_api::SetReceiveBufferSize(fd, receive_buffer_size);
88 if (absl::Status status = socket_api::SetSendBufferSize(fd, send_buffer_size);
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/http/ |
| H A D | end_to_end_test.cc | 525 QuicUdpSocketApi socket_api; in TearDown() local
526 socket_api.Destroy(fd_); in TearDown()
535 QuicUdpSocketApi socket_api; in StartServer() local
536 socket_api.Destroy(fd_); in StartServer()
583 QuicUdpSocketApi socket_api; in StopServer() local
584 fd_ = socket_api.Create( in StopServer()
592 int rc = socket_api.Bind(fd_, server_address_); in StopServer()
|