Home
last modified time | relevance | path

Searched refs:socket_api (Results 1 – 19 of 19) sorted by relevance

/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/io/
H A Dsocket_test.cc30 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 Devent_loop_connecting_client_socket_test.cc48 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 Devent_loop_connecting_client_socket.cc25 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 Devent_loop_socket_factory.cc33 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 Devent_loop_connecting_client_socket.h34 socket_api::SocketProtocol protocol,
81 const socket_api::SocketProtocol protocol_;
H A Dsocket_win.inc18 namespace quic::socket_api {
209 } // namespace quic::socket_api
H A Dsocket_internal.h16 namespace quic::socket_api {
H A Dsocket_posix.inc32 namespace quic::socket_api {
312 } // namespace quic::socket_api
H A Dsocket.h37 namespace socket_api {
H A Dsocket.cc27 namespace quic::socket_api { namespace
/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/masque/
H A Dmasque_server_session.cc79 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 Dquic_server.cc105 (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 Dquic_server_test.cc149 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 Dquic_client_default_network_helper.cc54 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 Dquic_batch_writer_test.cc18 QuicUdpSocketApi socket_api; in ShouldSkip() local
20 socket_api.Create(params.address_family, in ShouldSkip()
29 socket_api.Destroy(fd); in ShouldSkip()
H A Dquic_batch_writer_test.h53 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 Dquic_udp_socket.cc87 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 Dquic_udp_socket_win.inc80 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 Dend_to_end_test.cc525 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()