Searched refs:client_fd (Results 1 – 5 of 5) sorted by relevance
29 Client::Client(cuttlefish::SharedFD fd) : client_fd(fd) {} in Client()32 : type(client_type), client_fd(fd) {} in Client()35 return client_fd == other.client_fd; in operator ==()50 client_fd->Write(response.data(), response.size()); in SendCommandResponse()93 auto client_fd = cuttlefish::SharedFD::Accept(*server_); in AcceptIncomingConnection() local94 if (!client_fd->IsOpen()) { in AcceptIncomingConnection()95 LOG(ERROR) << "Error accepting connection on socket: " << client_fd->StrError(); in AcceptIncomingConnection()97 auto client = std::make_unique<Client>(client_fd); in AcceptIncomingConnection()109 auto bytes_read = client.client_fd->Read(buffer.data(), buffer.size()); in ReadCommand()117 LOG(ERROR) << "Error reading from client fd: " << client.client_fd->StrError(); in ReadCommand()[all …]
45 cuttlefish::SharedFD client_fd; variable
693 call_status.remote_client = client.client_fd; in HandleRemoteCall()
169 cuttlefish::SharedFD client_fd; in ReadLoop() local171 if (!client_fd->IsOpen()) { in ReadLoop()172 client_fd = OpenPTY(); in ReadLoop()177 read_set.Set(client_fd); in ReadLoop()191 if (client_fd->IsOpen()) { in ReadLoop()192 EnqueueWrite(buf_ptr, client_fd); in ReadLoop()195 if (read_set.IsSet(client_fd)) { in ReadLoop()197 auto bytes_read = client_fd->Read(buf_ptr->data(), buf_ptr->size()); in ReadLoop()203 << client_fd->StrError(); in ReadLoop()204 client_fd->Close(); in ReadLoop()
107 auto bytes_read = ril_side_->client_fd->Read(buffer.data(), buffer.size()); in ReadCommandResponse()111 ril_side_->client_fd->Close(); in ReadCommandResponse()