/device/google/cuttlefish/host/commands/run_cvd/ |
D | boot_state_machine.cc | 100 if (!log->IsOpen()) { in DaemonizeLauncher() 107 if (!dev_null->IsOpen()) { in DaemonizeLauncher() 171 if (interrupt_fd_write_->IsOpen()) { in ~CvdBootStateMachine() 179 if (restore_complete_stop_write_->IsOpen()) { in ~CvdBootStateMachine() 202 CF_EXPECT(interrupt_fd_read_->IsOpen(), interrupt_fd_read_->StrError()); in ResultSetup() 203 CF_EXPECT(interrupt_fd_write_->IsOpen(), interrupt_fd_write_->StrError()); in ResultSetup() 207 CF_EXPECTF(reboot_notification_->IsOpen(), in ResultSetup() 213 CF_EXPECTF(boot_events_pipe->IsOpen(), "Could not get boot events pipe: {}", in ResultSetup() 243 CHECK(restore_adbd_pipe->IsOpen()) in ResultSetup() 299 .events = restore_complete_pipe->IsOpen() in ThreadLoop() [all …]
|
/device/google/cuttlefish/host/commands/run_cvd/launch/ |
D | streamer.cpp | 45 if (!server->IsOpen()) { in CreateUnixInputServer() 143 CF_EXPECT(touch_socket->IsOpen(), touch_socket->StrError()); in ResultSetup() 149 CF_EXPECT(rotary_server_->IsOpen(), rotary_server_->StrError()); in ResultSetup() 151 CF_EXPECT(keyboard_server_->IsOpen(), keyboard_server_->StrError()); in ResultSetup() 154 CF_EXPECT(frames_server_->IsOpen(), frames_server_->StrError()); in ResultSetup() 160 CF_EXPECT(audio_server_->IsOpen(), audio_server_->StrError()); in ResultSetup() 306 CF_EXPECT(switches_server_->IsOpen(), switches_server_->StrError()); in ResultSetup() 309 CF_EXPECT(kernel_log_events_pipe_->IsOpen(), in ResultSetup()
|
D | modem.cpp | 38 if (!monitor_sock->IsOpen()) { in StopModemSimulator() 86 modem_sim_socket->IsOpen(), in ModemSimulator()
|
/device/google/cuttlefish/common/libs/utils/ |
D | vsock_connection.cpp | 75 return fd_->IsOpen(); in IsConnected() 217 if (!fd_->IsOpen()) { in Connect() 220 return fd_->IsOpen(); in Connect() 226 if (server_fd_->IsOpen()) { in ServerShutdown() 236 if (!server_fd_->IsOpen()) { in Connect() 240 if (server_fd_->IsOpen()) { in Connect() 242 return fd_->IsOpen(); in Connect()
|
D | socket2socket_proxy.cpp | 41 if (!stop_fd_->IsOpen()) { in ProxyPair() 58 if (stop_fd_->IsOpen() && stop_fd_->EventfdWrite(1) != 0) { in ~ProxyPair() 116 if (!stop_fd_->IsOpen()) { in ProxyServer() 131 while (server_fd->IsOpen()) { in ProxyServer() 152 if (!client->IsOpen()) { in ProxyServer() 157 if (target->IsOpen()) { in ProxyServer()
|
D | tcp_socket.cpp | 76 if (!fd_->IsOpen()) { in SendNoSignal() 99 if (!fd_->IsOpen()) { 106 if (!client->IsOpen()) { in Accept()
|
/device/google/cuttlefish/host/commands/modem_simulator/ |
D | channel_monitor.cpp | 89 if (server_->IsOpen()) { in ChannelMonitor() 104 if (remote_client->client_read_fd_->IsOpen() && in SetRemoteClient() 105 remote_client->client_write_fd_->IsOpen()) { in SetRemoteClient() 112 if (write_pipe_->IsOpen()) { in SetRemoteClient() 122 if (!client_fd->IsOpen()) { in AcceptIncomingConnection() 223 if (write_pipe_->IsOpen()) { in CloseRemoteConnection() 236 if (write_pipe_->IsOpen()) { in ~ChannelMonitor()
|
/device/google/cuttlefish/common/libs/fs/ |
D | epoll.cpp | 73 CF_EXPECT(epoll_fd_->IsOpen(), "Empty Epoll instance"); in Add() 96 CF_EXPECT(epoll_fd_->IsOpen(), "Empty Epoll instance"); in AddOrModify() 115 CF_EXPECT(epoll_fd_->IsOpen(), "Empty Epoll instance"); in Modify() 134 CF_EXPECT(epoll_fd_->IsOpen(), "Empty Epoll instance"); in Delete() 152 CF_EXPECT(epoll_fd_->IsOpen(), "Empty Epoll instance"); in Wait() 171 if (!ret.fd->IsOpen()) { in Wait()
|
D | shared_fd.cpp | 275 if (IsOpen() && FD_ISSET(fd_, in)) { in IsSet() 290 if (!IsOpen()) { in Set() 505 CF_EXPECTF(ret->IsOpen(), "Failed to open '{}': '{}'", path, ret->StrError()); in Fifo() 542 if (!rval->IsOpen()) { in SocketLocalClient() 559 if (!rval->IsOpen()) { in SocketLocalClient() 575 if (!rval->IsOpen()) { in SocketClient() 593 if (!rval->IsOpen()) { in Socket6Client() 630 if(!rval->IsOpen()) { in SocketLocalServer() 663 if (!rval->IsOpen()) { in SocketLocalServer() 718 if (!vsock->IsOpen()) { in VsockServer() [all …]
|
D | shared_fd_test.cpp | 33 EXPECT_TRUE(fds[0]->IsOpen()); in TEST() 34 EXPECT_TRUE(fds[1]->IsOpen()); in TEST()
|
/device/google/cuttlefish/host/libs/process_monitor/ |
D | process_monitor_channel.cc | 32 CF_EXPECTF(fd->IsOpen(), "File descriptor to write ParentToChildMessage", in Write() 44 CF_EXPECTF(fd->IsOpen(), "File descriptor to read ParentToChildMessage", in Read() 59 CF_EXPECTF(fd->IsOpen(), "File descriptor to write ChildToParentResponse", in Write() 71 CF_EXPECTF(fd->IsOpen(), "File descriptor to read ChildToParentResponse", in Read()
|
D | process_monitor.cc | 171 CF_EXPECT(channel_to_secure_env->IsOpen(), in SuspendResumeImpl() 365 CF_EXPECT(parent_monitor_socket_->IsOpen(), in StopMonitoredProcesses() 387 CF_EXPECT(parent_monitor_socket_->IsOpen(), in SuspendMonitoredProcesses() 403 CF_EXPECT(parent_monitor_socket_->IsOpen(), in ResumeMonitoredProcesses() 419 CF_EXPECT(!parent_monitor_socket_->IsOpen(), in StartAndMonitorProcesses()
|
/device/google/cuttlefish/common/frontend/socket_vsock_proxy/ |
D | server.cpp | 51 if (server->IsOpen()) { in Start() 78 if (!server->IsOpen() && !socketErrorIsRecoverable(server->GetErrno())) { in Start() 85 } while (!server->IsOpen()); in Start() 99 CF_EXPECT(sfd_->IsOpen(), "Could not start duplicate server for passed fd"); in Start()
|
/device/google/cuttlefish/host/commands/console_forwarder/ |
D | main.cpp | 95 CHECK(pty_shared_fd->IsOpen()) in OpenPTY() 154 if (!client_fd->IsOpen()) { in ReadLoop() 174 if (client_fd->IsOpen()) { in ReadLoop() 221 CHECK(console_in->IsOpen()) << "Error dupping fd " << FLAGS_console_in_fd in ConsoleForwarderMain() 226 CHECK(console_out->IsOpen()) << "Error dupping fd " << FLAGS_console_out_fd in ConsoleForwarderMain()
|
/device/google/cuttlefish/host/commands/casimir_control_server/ |
D | casimir_controller.cpp | 29 CF_EXPECT(!sock_->IsOpen()); in Init() 32 CF_EXPECT(sock_->IsOpen(), in Init() 79 CF_EXPECT(sock_->IsOpen()); in Poll() 88 CF_EXPECT(sock_->IsOpen()); in SendApdu()
|
/device/google/cuttlefish/guest/hals/confirmationui/ |
D | TrustyConfirmationUI.cpp | 64 CHECK(host_fd_->IsOpen()) << "ConfUI: " << GetVirtioConsoleDevicePath() << " is not open."; 72 if (host_fd_->IsOpen()) { 79 if (host_fd_->IsOpen()) { in ~TrustyConfirmationUI() 93 if (!host_fd_->IsOpen()) { in HostMessageFetcherLoop()
|
/device/google/cuttlefish/host/commands/tcp_connector/ |
D | main.cpp | 43 if ((*fd)->IsOpen()) { in OpenSocket() 78 if (!fifo_in->IsOpen()) { in main() 86 if (!fifo_out->IsOpen()) { in main()
|
/device/google/cuttlefish/host/frontend/adb_connector/ |
D | adb_connection_maintainer.cpp | 74 if (!sock->IsOpen()) { in AdbSendMessage() 156 if (!sock->IsOpen()) { in WaitForAdbAuthorization() 208 if (!sock->IsOpen()) { in WaitForAdbDisconnection()
|
/device/google/cuttlefish/host/commands/gnss_grpc_proxy/ |
D | gnss_grpc_proxy.cpp | 411 if (!gnss_in->IsOpen()) { in RunServer() 420 if (!gnss_out->IsOpen()) { in RunServer() 429 if (!fixed_location_in->IsOpen()) { in RunServer() 439 if (!fixed_location_out->IsOpen()) { in RunServer()
|
/device/google/cuttlefish/host/frontend/operator_proxy/ |
D | main.cpp | 32 if (!conn->IsOpen()) { in OpenConnection() 44 CHECK(server->IsOpen()) << "Error Creating proxy server: " in main()
|
/device/google/cuttlefish/host/example_custom_actions/ |
D | main.cpp | 39 if (webrtc_socket->IsOpen()) { in main() 53 if (!webrtc_socket->IsOpen()) { in main()
|
/device/google/cuttlefish/host/commands/cvd_send_sms/unittest/ |
D | sms_sender_test.cc | 35 CHECK(client_fd_->IsOpen()); in SetUp() 36 CHECK(fake_server_fd_->IsOpen()); in SetUp()
|
/device/google/cuttlefish/host/commands/secure_env/ |
D | confui_sign_server.cpp | 45 if (!server_fd_->IsOpen()) { in MainLoop() 50 if (!accepted_socket_fd->IsOpen()) { in MainLoop()
|
/device/google/cuttlefish/guest/monitoring/tombstone_transmit/ |
D | tombstone_transmit.cpp | 75 while (log_fd->IsOpen() && ifs.is_open() && !ifs.eof()) { in tombstone_send_to_host() 82 if (!log_fd->IsOpen()) { in tombstone_send_to_host()
|
/device/google/cuttlefish/host/commands/kernel_log_monitor/ |
D | main.cc | 92 if (!pipe->IsOpen()) { in main() 101 if (subscriber_fd->IsOpen()) { in main()
|