/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()
|