Home
last modified time | relevance | path

Searched refs:IsOpen (Results 1 – 25 of 86) sorted by relevance

1234

/device/google/cuttlefish/host/commands/run_cvd/
Dboot_state_machine.cc100 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/
Dstreamer.cpp45 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()
Dmodem.cpp38 if (!monitor_sock->IsOpen()) { in StopModemSimulator()
86 modem_sim_socket->IsOpen(), in ModemSimulator()
/device/google/cuttlefish/common/libs/utils/
Dvsock_connection.cpp75 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()
Dsocket2socket_proxy.cpp41 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()
Dtcp_socket.cpp76 if (!fd_->IsOpen()) { in SendNoSignal()
99 if (!fd_->IsOpen()) {
106 if (!client->IsOpen()) { in Accept()
/device/google/cuttlefish/host/commands/modem_simulator/
Dchannel_monitor.cpp89 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/
Depoll.cpp73 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()
Dshared_fd.cpp275 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 …]
Dshared_fd_test.cpp33 EXPECT_TRUE(fds[0]->IsOpen()); in TEST()
34 EXPECT_TRUE(fds[1]->IsOpen()); in TEST()
/device/google/cuttlefish/host/libs/process_monitor/
Dprocess_monitor_channel.cc32 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()
Dprocess_monitor.cc171 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/
Dserver.cpp51 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/
Dmain.cpp95 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/
Dcasimir_controller.cpp29 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/
DTrustyConfirmationUI.cpp64 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/
Dmain.cpp43 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/
Dadb_connection_maintainer.cpp74 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/
Dgnss_grpc_proxy.cpp411 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/
Dmain.cpp32 if (!conn->IsOpen()) { in OpenConnection()
44 CHECK(server->IsOpen()) << "Error Creating proxy server: " in main()
/device/google/cuttlefish/host/example_custom_actions/
Dmain.cpp39 if (webrtc_socket->IsOpen()) { in main()
53 if (!webrtc_socket->IsOpen()) { in main()
/device/google/cuttlefish/host/commands/cvd_send_sms/unittest/
Dsms_sender_test.cc35 CHECK(client_fd_->IsOpen()); in SetUp()
36 CHECK(fake_server_fd_->IsOpen()); in SetUp()
/device/google/cuttlefish/host/commands/secure_env/
Dconfui_sign_server.cpp45 if (!server_fd_->IsOpen()) { in MainLoop()
50 if (!accepted_socket_fd->IsOpen()) { in MainLoop()
/device/google/cuttlefish/guest/monitoring/tombstone_transmit/
Dtombstone_transmit.cpp75 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/
Dmain.cc92 if (!pipe->IsOpen()) { in main()
101 if (subscriber_fd->IsOpen()) { in main()

1234