| /device/google/cuttlefish/common/libs/fs/ |
| D | shared_fd.cpp | 205 SharedFD SharedFD::Accept(const FileInstance& listener, struct sockaddr* addr, in Accept()
207 return SharedFD( in Accept()
211 SharedFD SharedFD::Accept(const FileInstance& listener) { in Accept()
212 return SharedFD::Accept(listener, NULL, NULL); in Accept()
215 SharedFD SharedFD::Dup(int unmanaged_fd) { in Dup()
218 return SharedFD(std::shared_ptr<FileInstance>(new FileInstance(fd, error_num))); in Dup()
221 bool SharedFD::Pipe(SharedFD* fd0, SharedFD* fd1) { in Pipe()
232 SharedFD SharedFD::Event(int initval, int flags) { in Event()
237 SharedFD SharedFD::MemfdCreate(const std::string& name, unsigned int flags) { in MemfdCreate()
243 bool SharedFD::SocketPair(int domain, int type, int protocol, in SocketPair()
[all …]
|
| D | shared_fd.h | 111 class SharedFD {
113 inline SharedFD();
114 SharedFD(const std::shared_ptr<FileInstance>& in) : value_(in) {} in SharedFD() function
116 static SharedFD Accept(const FileInstance& listener, struct sockaddr* addr,
118 static SharedFD Accept(const FileInstance& listener);
119 static SharedFD Dup(int unmanaged_fd);
122 static SharedFD Open(const std::string& pathname, int flags, mode_t mode = 0);
123 static SharedFD Creat(const std::string& pathname, mode_t mode);
124 static bool Pipe(SharedFD* fd0, SharedFD* fd1);
125 static SharedFD Event(int initval = 0, int flags = 0);
[all …]
|
| D | shared_buf.h | 33 ssize_t ReadAll(SharedFD fd, std::string* buf);
43 ssize_t ReadExact(SharedFD fd, std::string* buf);
53 ssize_t ReadExact(SharedFD fd, std::vector<char>* buf);
63 ssize_t ReadExact(SharedFD fd, char* buf, size_t size);
74 ssize_t ReadExactBinary(SharedFD fd, T* binary_data) { in ReadExactBinary()
86 ssize_t WriteAll(SharedFD fd, const std::string& buf);
96 ssize_t WriteAll(SharedFD fd, const std::vector<char>& buf);
106 ssize_t WriteAll(SharedFD fd, const char* buf, size_t size);
117 ssize_t WriteAllBinary(SharedFD fd, const T* binary_data) { in WriteAllBinary()
|
| D | shared_select.h | 38 typedef std::set<SharedFD>::iterator iterator;
39 typedef std::set<SharedFD>::const_iterator const_iterator;
50 void Clr(const SharedFD& in) { in Clr()
54 bool IsSet(const SharedFD& in) const { in IsSet()
58 void Set(const SharedFD& in) { in Set()
67 std::set<SharedFD> value_;
|
| D | shared_buf.cc | 33 ssize_t WriteAll(SharedFD fd, const char* buf, size_t size) { in WriteAll()
49 ssize_t ReadExact(SharedFD fd, char* buf, size_t size) { in ReadExact()
65 ssize_t ReadAll(SharedFD fd, std::string* buf) { in ReadAll()
81 ssize_t ReadExact(SharedFD fd, std::string* buf) { in ReadExact()
85 ssize_t ReadExact(SharedFD fd, std::vector<char>* buf) { in ReadExact()
89 ssize_t WriteAll(SharedFD fd, const std::string& buf) { in WriteAll()
93 ssize_t WriteAll(SharedFD fd, const std::vector<char>& buf) { in WriteAll()
|
| D | tee.h | 51 void Start(SharedFD source);
55 TeeSubscriber SharedFDWriter(SharedFD fd);
58 cvd::SharedFD log_file_;
59 cvd::SharedFD original_stderr_;
67 void SetFile(SharedFD file);
|
| D | tee.cpp | 34 void Tee::Start(SharedFD source) { in Start()
86 TeeSubscriber SharedFDWriter(SharedFD fd) { in SharedFDWriter()
93 original_stderr_ = SharedFD::Dup(2); in TeeStderrToFile()
95 SharedFD stderr_read, stderr_write; in TeeStderrToFile()
96 SharedFD::Pipe(&stderr_read, &stderr_write); in TeeStderrToFile()
116 void TeeStderrToFile::SetFile(SharedFD file) { in SetFile()
|
| D | shared_fd_test.cpp | 26 using cvd::SharedFD;
31 SharedFD fds[2]; in TEST()
32 SharedFD::Pipe(fds, fds + 1); in TEST()
|
| /device/google/cuttlefish/common/frontend/socket_vsock_proxy/ |
| D | main.cpp | 38 explicit SocketSender(cvd::SharedFD socket) : socket_{socket} {} in SocketSender()
72 cvd::SharedFD socket_;
77 explicit SocketReceiver(cvd::SharedFD socket) : socket_{socket} {} in SocketReceiver()
96 cvd::SharedFD socket_;
130 void HandleConnection(cvd::SharedFD vsock, in HandleConnection()
131 cvd::SharedFD socket) { in HandleConnection()
141 auto server = cvd::SharedFD::SocketLocalServer(FLAGS_tcp_port, SOCK_STREAM); in TcpServer()
146 auto client_socket = cvd::SharedFD::Accept(*server); in TcpServer()
148 cvd::SharedFD vsock_socket = cvd::SharedFD::VsockClient( in TcpServer()
169 cvd::SharedFD OpenSocketConnection() { in OpenSocketConnection()
[all …]
|
| /device/google/cuttlefish/host/commands/console_forwarder/ |
| D | main.cpp | 48 ConsoleForwarder(cvd::SharedFD socket, in ConsoleForwarder()
49 cvd::SharedFD console_in, in ConsoleForwarder()
50 cvd::SharedFD console_out) : socket_(socket), in ConsoleForwarder()
62 void EnqueueWrite(std::vector<char> buffer, cvd::SharedFD fd) { in EnqueueWrite()
72 cvd::SharedFD fd; in WriteLoop()
109 cvd::SharedFD client_fd; in ReadLoop()
137 client_fd = cvd::SharedFD::Accept(*socket_); in ReadLoop()
158 cvd::SharedFD socket_;
159 cvd::SharedFD console_in_;
160 cvd::SharedFD console_out_;
[all …]
|
| /device/google/cuttlefish/host/commands/launch/ |
| D | launch_cvd.cc | 49 cvd::Subprocess StartAssembler(cvd::SharedFD assembler_stdin, in StartAssembler()
50 cvd::SharedFD assembler_stdout, in StartAssembler()
63 cvd::Subprocess StartRunner(cvd::SharedFD runner_stdin, in StartRunner()
73 void WriteFiles(cvd::FetcherConfig fetcher_config, cvd::SharedFD out) { in WriteFiles()
99 cvd::SharedFD assembler_stdout, assembler_stdout_capture; in main()
100 cvd::SharedFD::Pipe(&assembler_stdout_capture, &assembler_stdout); in main()
102 cvd::SharedFD launcher_report, assembler_stdin; in main()
105 cvd::SharedFD::Pipe(&assembler_stdin, &launcher_report); in main()
135 cvd::SharedFD runner_stdin_in, runner_stdin_out; in main()
136 cvd::SharedFD::Pipe(&runner_stdin_out, &runner_stdin_in); in main()
|
| /device/google/cuttlefish/host/commands/assemble_cvd/ |
| D | image_aggregator.cc | 53 auto file = cvd::SharedFD::Open(partition.image_file_path.c_str(), O_RDONLY); in BpttoolInput()
154 cvd::SharedFD JsonToFd(const Json::Value& json) { in JsonToFd()
157 cvd::SharedFD pipe[2]; in JsonToFd()
158 cvd::SharedFD::Pipe(&pipe[0], &pipe[1]); in JsonToFd()
168 Json::Value FdToJson(cvd::SharedFD fd) { in FdToJson()
179 cvd::SharedFD BpttoolMakeTable(const cvd::SharedFD& input) { in BpttoolMakeTable()
186 cvd::SharedFD output_pipe[2]; in BpttoolMakeTable()
187 cvd::SharedFD::Pipe(&output_pipe[0], &output_pipe[1]); in BpttoolMakeTable()
196 cvd::SharedFD BpttoolMakePartitionTable(cvd::SharedFD input) { in BpttoolMakePartitionTable()
203 cvd::SharedFD output_pipe[2]; in BpttoolMakePartitionTable()
[all …]
|
| D | boot_image_unpacker.h | 49 BootImageUnpacker(SharedFD boot_image, const std::string& cmdline, in BootImageUnpacker()
52 SharedFD vendor_boot_image, in BootImageUnpacker()
66 mutable SharedFD boot_image_;
67 mutable SharedFD vendor_boot_image_;
|
| /device/google/cuttlefish/host/commands/run_cvd/ |
| D | launch.cc | 69 cvd::SharedFD CreateUnixInputServer(const std::string& path) { in CreateUnixInputServer()
70 auto server = cvd::SharedFD::SocketLocalServer(path.c_str(), false, SOCK_STREAM, 0666); in CreateUnixInputServer()
74 return cvd::SharedFD(); in CreateUnixInputServer()
84 cvd::SharedFD touch_server; in CreateStreamerServers()
85 cvd::SharedFD keyboard_server; in CreateStreamerServers()
91 touch_server = cvd::SharedFD::VsockServer(SOCK_STREAM); in CreateStreamerServers()
94 keyboard_server = cvd::SharedFD::VsockServer(SOCK_STREAM); in CreateStreamerServers()
112 cvd::SharedFD frames_server; in CreateStreamerServers()
117 frames_server = cvd::SharedFD::VsockServer(SOCK_STREAM); in CreateStreamerServers()
134 std::vector<cvd::SharedFD> LaunchKernelLogMonitor( in LaunchKernelLogMonitor()
[all …]
|
| D | main.cc | 80 CvdBootStateMachine(cvd::SharedFD fg_launcher_pipe) in CvdBootStateMachine()
84 bool OnBootEvtReceived(cvd::SharedFD boot_events_pipe) { in OnBootEvtReceived()
133 cvd::SharedFD fg_launcher_pipe_;
142 cvd::ProcessMonitor* process_monitor, cvd::SharedFD boot_events_pipe, in SetUpHandlingOfBootEvents()
156 auto env = cvd::SharedFD::Open(config.cuttlefish_env_path().c_str(), in WriteCuttlefishEnvironment()
172 cvd::SharedFD DaemonizeLauncher(const vsoc::CuttlefishConfig& config) { in DaemonizeLauncher()
174 cvd::SharedFD read_end, write_end; in DaemonizeLauncher()
175 if (!cvd::SharedFD::Pipe(&read_end, &write_end)) { in DaemonizeLauncher()
177 return cvd::SharedFD(); // a closed FD in DaemonizeLauncher()
212 cvd::SharedFD::Open(log_path.c_str(), O_CREAT | O_WRONLY | O_TRUNC, in DaemonizeLauncher()
[all …]
|
| /device/google/cuttlefish/host/commands/kernel_log_monitor/ |
| D | main.cc | 40 std::vector<cvd::SharedFD> SubscribersFromCmdline() { in SubscribersFromCmdline()
51 std::vector<cvd::SharedFD> shared_fds; in SubscribersFromCmdline()
54 auto shared_fd = cvd::SharedFD::Dup(fd); in SubscribersFromCmdline()
81 cvd::SharedFD pipe; in main()
84 pipe = cvd::SharedFD::Open(log_name.c_str(), O_RDONLY); in main()
86 pipe = cvd::SharedFD::Dup(FLAGS_log_pipe_fd); in main()
|
| D | kernel_log_server.h | 49 KernelLogServer(cvd::SharedFD pipe_fd,
69 cvd::SharedFD pipe_fd_;
70 cvd::SharedFD log_fd_;
|
| /device/google/cuttlefish/host/commands/logcat_receiver/ |
| D | main.cpp | 36 cvd::SharedFD::Open(path.c_str(), O_CREAT | O_APPEND | O_WRONLY, 0666); in main()
40 cvd::SharedFD server_fd = cvd::SharedFD::Dup(FLAGS_server_fd); in main()
48 auto conn = cvd::SharedFD::Accept(*server_fd); in main()
|
| /device/google/cuttlefish/common/libs/utils/ |
| D | subprocess.cpp | 42 const std::map<cvd::SharedFD, int>& inherited_fds) { in validate_redirects() argument
88 subprocess.control_socket_ = SharedFD(); in Subprocess()
99 other.control_socket_ = SharedFD(); in operator =()
185 bool Command::BuildParameter(std::stringstream* stream, SharedFD shared_fd) { in BuildParameter()
202 cvd::SharedFD shared_fd) { in RedirectStdIO()
222 cvd::SharedFD::Dup(static_cast<int>(parent_channel))); in RedirectStdIO()
230 SharedFD parent_socket, child_socket; in Start()
232 if (!SharedFD::SocketPair(AF_LOCAL, SOCK_STREAM, 0, &parent_socket, in Start()
328 cvd::SharedFD pipe_read, pipe_write; in RunWithManagedStdio()
329 if (!cvd::SharedFD::Pipe(&pipe_read, &pipe_write)) { in RunWithManagedStdio()
[all …]
|
| D | network.cpp | 55 SharedFD OpenTapInterface(const std::string& interface_name) { in OpenTapInterface()
58 auto tap_fd = SharedFD::Open(TUNTAP_DEV, O_RDWR | O_NONBLOCK); in OpenTapInterface()
73 return cvd::SharedFD(); in OpenTapInterface()
86 return cvd::SharedFD(); in OpenTapInterface()
|
| D | subprocess.h | 46 Subprocess(pid_t pid, SharedFD control, SubprocessStopper stopper = KillSubprocess)
65 SharedFD control_socket() { return control_socket_; } in control_socket()
77 SharedFD control_socket_;
124 bool BuildParameter(std::stringstream* stream, SharedFD shared_fd);
190 bool RedirectStdIO(Subprocess::StdIOChannel channel, cvd::SharedFD shared_fd);
206 std::map<cvd::SharedFD, int> inherited_fds_{};
|
| /device/google/cuttlefish/host/commands/config_server/ |
| D | main.cpp | 34 cvd::SharedFD server_fd = cvd::SharedFD::Dup(FLAGS_server_fd); in main()
47 auto conn = cvd::SharedFD::Accept(*server_fd); in main()
|
| /device/google/cuttlefish/host/frontend/adb_connector/ |
| D | adb_connection_maintainer.cpp | 56 bool SendAll(cvd::SharedFD sock, const std::string& msg) { in SendAll()
72 std::string RecvAll(cvd::SharedFD sock, const size_t count) { in RecvAll()
96 bool AdbSendMessage(cvd::SharedFD sock, const std::string& message) { in AdbSendMessage()
108 auto sock = cvd::SharedFD::SocketLocalClient(kAdbDaemonPort, SOCK_STREAM); in AdbSendMessage()
126 std::string RecvAdbResponse(cvd::SharedFD sock) { in RecvAdbResponse()
137 int RecvUptimeResult(cvd::SharedFD sock) { in RecvUptimeResult()
185 auto sock = cvd::SharedFD::SocketLocalClient(kAdbDaemonPort, SOCK_STREAM); in WaitForAdbDisconnection()
|
| /device/google/cuttlefish/guest/commands/vsoc_input_service/ |
| D | vsoc_input_service.cpp | 80 cvd::SharedFD keyboard_fd; in ProcessEvents()
81 cvd::SharedFD touch_fd; in ProcessEvents()
85 keyboard_fd = cvd::SharedFD::VsockClient(2, FLAGS_keyboard_port, SOCK_STREAM); in ProcessEvents()
93 touch_fd = cvd::SharedFD::VsockClient(2, FLAGS_touch_port, SOCK_STREAM); in ProcessEvents()
|
| /device/google/cuttlefish/host/commands/tombstone_receiver/ |
| D | main.cpp | 61 cvd::SharedFD server_fd = cvd::SharedFD::Dup(FLAGS_server_fd); in main()
71 auto conn = cvd::SharedFD::Accept(*server_fd); in main()
|