Lines Matching refs:protocol_sfd_
209 unique_fd stdinout_sfd_, stderr_sfd_, protocol_sfd_; member in __anon0e077fa70111::Subprocess
470 if (!CreateSocketpair(&protocol_sfd_, &local_socket_sfd_)) { in ConnectProtocolEndpoints()
475 D("protocol FD = %d", protocol_sfd_.get()); in ConnectProtocolEndpoints()
477 input_ = std::make_unique<ShellProtocol>(protocol_sfd_); in ConnectProtocolEndpoints()
478 output_ = std::make_unique<ShellProtocol>(protocol_sfd_); in ConnectProtocolEndpoints()
556 if (protocol_sfd_ == -1) { in PassDataStreams()
564 pfds.protocol_pfd() = {.fd = protocol_sfd_.get(), .events = POLLIN}; in PassDataStreams()
568 while (protocol_sfd_ != -1 && (stdinout_sfd_ != -1 || stderr_sfd_ != -1)) { in PassDataStreams()
578 if (dead_sfd == &protocol_sfd_) { in PassDataStreams()
664 return &protocol_sfd_; in PollLoop()
677 PLOG(ERROR) << "error reading protocol FD " << protocol_sfd_.get(); in PassInput()
679 return &protocol_sfd_; in PassInput()
752 PLOG(ERROR) << "error reading protocol FD " << protocol_sfd_.get(); in PassOutput()
754 return &protocol_sfd_; in PassOutput()
784 if (protocol_sfd_ != -1) { in WaitForExit()
791 protocol_sfd_.reset(-1); in WaitForExit()