Home
last modified time | relevance | path

Searched refs:unique_fd (Results 1 – 25 of 300) sorted by relevance

12345678910>>...12

/system/core/adb/daemon/
Dabb_service.cpp31 unique_fd sendCommand(std::string_view command);
34 static unique_fd startAbbProcess(unique_fd* error_fd);
40 unique_fd socket_fd_;
43 unique_fd AbbProcess::sendCommand(std::string_view command) { in sendCommand()
47 unique_fd error_fd; in sendCommand()
62 unique_fd fd; in sendCommand()
78 unique_fd AbbProcess::startAbbProcess(unique_fd* error_fd) { in startAbbProcess()
88 unique_fd execute_abb_command(std::string_view command) { in execute_abb_command()
Drestart_service.h22 void restart_root_service(unique_fd fd);
23 void restart_unroot_service(unique_fd fd);
24 void restart_tcp_service(unique_fd fd, int port);
25 void restart_usb_service(unique_fd fd);
Dshell_service.h39 unique_fd StartSubprocess(std::string name, const char* terminal_type, SubprocessType type,
43 unique_fd StartSubprocess(std::string name, const char* terminal_type, SubprocessType type,
45 SubprocessProtocol error_protocol, unique_fd* error_fd);
52 unique_fd StartCommandInProcess(std::string name, Command command, SubprocessProtocol protocol);
55 unique_fd ReportError(SubprocessProtocol protocol, const std::string& message);
Dusb_ffs.h21 bool open_functionfs(android::base::unique_fd* control, android::base::unique_fd* bulk_out,
22 android::base::unique_fd* bulk_in);
Dservices.cpp61 void reconnect_service(unique_fd fd, atransport* t) { in reconnect_service()
66 unique_fd reverse_service(std::string_view command, atransport* transport) { in reverse_service()
73 return unique_fd{}; in reverse_service()
80 return unique_fd{s[0]}; in reverse_service()
85 unique_fd ShellService(std::string_view args, const atransport* transport) { in ShellService()
89 return unique_fd{}; in ShellService()
122 static void spin_service(unique_fd fd) { in spin_service()
129 unique_fd pipe_read, pipe_write; in spin_service()
144 [[maybe_unused]] static unique_fd reboot_device(const std::string& name) { in reboot_device()
147 auto reboot_service = [name](unique_fd fd) { in reboot_device()
[all …]
Drestart_service.cpp31 void restart_root_service(unique_fd fd) { in restart_root_service()
46 void restart_unroot_service(unique_fd fd) { in restart_unroot_service()
57 void restart_tcp_service(unique_fd fd, int port) { in restart_tcp_service()
68 void restart_usb_service(unique_fd fd) { in restart_usb_service()
Dshell_service.cpp133 bool CreateSocketpair(unique_fd* fd1, unique_fd* fd2) { in CreateSocketpair()
185 int OpenPtyChildFd(const char* pts_name, unique_fd* error_sfd);
193 unique_fd* PollLoop(SubprocessPollfds* pfds);
197 unique_fd* PassInput();
198 unique_fd* PassOutput(unique_fd* sfd, ShellProtocol::Id id);
206 unique_fd local_socket_sfd_;
209 unique_fd stdinout_sfd_, stderr_sfd_, protocol_sfd_;
236 unique_fd child_stdinout_sfd, child_stderr_sfd; in ForkAndExec()
237 unique_fd parent_error_sfd, child_error_sfd; in ForkAndExec()
299 unique_fd pty_master(posix_openpt(O_RDWR | O_NOCTTY | O_CLOEXEC)); in ForkAndExec()
[all …]
/system/tools/aidl/tests/
Daidl_test_client_file_descriptors.cpp30 using android::base::unique_fd;
56 bool DoWrite(const string& name, const unique_fd& fd, const string& buf) { in DoWrite()
75 bool DoRead(const string& name, const unique_fd& fd, const string& expected) { in DoRead()
96 bool DoPipe(unique_fd* read_side, unique_fd* write_side) { in DoPipe()
98 unique_fd return_fd; in DoPipe()
114 unique_fd return_fd; in ConfirmFileDescriptors()
115 unique_fd read_fd; in ConfirmFileDescriptors()
116 unique_fd write_fd; in ConfirmFileDescriptors()
145 vector<unique_fd> array; in ConfirmFileDescriptorArrays()
152 vector<unique_fd> repeated; in ConfirmFileDescriptorArrays()
[all …]
/system/hardware/interfaces/suspend/1.0/default/
DSystemSuspend.h38 using ::android::base::unique_fd;
83 SystemSuspend(unique_fd wakeupCountFd, unique_fd stateFd, unique_fd suspendStatsFd,
84 size_t maxNativeStatsEntries, unique_fd kernelWakelockStatsFd,
104 unique_fd mWakeupCountFd;
105 unique_fd mStateFd;
107 unique_fd mSuspendStatsFd;
123 unique_fd mWakeLockFd;
124 unique_fd mWakeUnlockFd;
Dmain.cpp36 using android::base::unique_fd;
51 unique_fd wakeupCountFd{TEMP_FAILURE_RETRY(open(kSysPowerWakeupCount, O_CLOEXEC | O_RDWR))}; in main()
55 unique_fd stateFd{TEMP_FAILURE_RETRY(open(kSysPowerState, O_CLOEXEC | O_RDWR))}; in main()
59 unique_fd kernelWakelockStatsFd{ in main()
64 unique_fd suspendStatsFd{ in main()
/system/core/fs_mgr/libdm/
Dloop_control_test.cpp33 using unique_fd = android::base::unique_fd; typedef
35 static unique_fd TempFile() { in TempFile()
38 unique_fd fd(CreateTempFile("temp", 0)); in TempFile()
53 unique_fd fd = TempFile(); in TEST()
60 unique_fd loop_fd(open(loop.device().c_str(), O_RDWR)); in TEST()
Dtest_util.cpp29 using unique_fd = android::base::unique_fd; typedef
33 unique_fd CreateTempFile(const std::string& name, size_t size) { in CreateTempFile()
34 unique_fd fd(syscall(__NR_memfd_create, name.c_str(), MFD_ALLOW_SEALING)); in CreateTempFile()
/system/core/base/
Dcmsg_test.cpp28 using android::base::unique_fd;
57 unique_fd send;
58 unique_fd recv;
63 unique_fd fd1;
64 unique_fd fd2;
74 unique_fd received; in TEST_P()
86 unique_fd received1, received2; in TEST_P()
108 unique_fd received; in TEST_P()
121 unique_fd received; in TEST_P()
139 std::vector<unique_fd> received1; in TEST_P()
[all …]
/system/core/adb/
Dservices.cpp46 void service_bootstrap_func(std::string service_name, std::function<void(unique_fd)> func, in service_bootstrap_func()
47 unique_fd fd) { in service_bootstrap_func()
54 unique_fd create_service_thread(const char* service_name, std::function<void(unique_fd)> func) { in create_service_thread()
58 return unique_fd(); in create_service_thread()
71 std::thread(service_bootstrap_func, service_name, func, unique_fd(s[1])).detach(); in create_service_thread()
74 return unique_fd(s[0]); in create_service_thread()
77 unique_fd service_to_fd(std::string_view name, atransport* transport) { in service_to_fd()
78 unique_fd ret; in service_to_fd()
105 static void wait_for_state(unique_fd fd, state_info* sinfo) { in wait_for_state()
187 static void connect_service(unique_fd fd, std::string host) { in connect_service()
[all …]
Dadb_unique_fd.h30 using unique_fd = android::base::unique_fd_impl<AdbCloser>; variable
32 using unique_fd = android::base::unique_fd; variable
Dtransport_fd.cpp35 static void CreateWakeFds(unique_fd* read, unique_fd* write) { in CreateWakeFds()
42 *read = unique_fd(wake_fds[0]); in CreateWakeFds()
43 *write = unique_fd(wake_fds[1]); in CreateWakeFds()
47 NonblockingFdConnection(unique_fd fd) : started_(false), fd_(std::move(fd)) { in NonblockingFdConnection()
228 unique_fd fd_;
229 unique_fd wake_fd_read_;
230 unique_fd wake_fd_write_;
239 std::unique_ptr<Connection> Connection::FromFd(unique_fd fd) { in FromFd()
/system/bpf/libbpf_android/include/bpf/
DBpfUtils.h77 inline int writeToMapEntry(const base::unique_fd& map_fd, const void* key, const void* value, in writeToMapEntry()
87 inline int findMapEntry(const base::unique_fd& map_fd, const void* key, void* value) { in findMapEntry()
95 inline int deleteMapEntry(const base::unique_fd& map_fd, const void* key) { in deleteMapEntry()
102 inline int getNextMapKey(const base::unique_fd& map_fd, const void* key, void* next_key) { in getNextMapKey()
110 inline int getFirstMapKey(const base::unique_fd& map_fd, void* firstKey) { in getFirstMapKey()
114 inline int bpfFdPin(const base::unique_fd& map_fd, const char* pathname) { in bpfFdPin()
148 inline int attachProgram(bpf_attach_type type, const base::unique_fd& prog_fd, in attachProgram()
149 const base::unique_fd& cg_fd) { in attachProgram()
157 inline int detachProgram(bpf_attach_type type, const base::unique_fd& cg_fd) { in detachProgram()
/system/core/libsysutils/src/
DSocketListener_test.cpp35 using android::base::unique_fd;
46 unique_fd serverSocket(const std::string& path) { in serverSocket()
49 unique_fd fd(socket(PF_UNIX, SOCK_STREAM | SOCK_CLOEXEC | SOCK_NONBLOCK, 0)); in serverSocket()
62 unique_fd clientSocket(const std::string& path) { in clientSocket()
63 unique_fd fd(socket(PF_UNIX, SOCK_STREAM | SOCK_CLOEXEC | SOCK_NONBLOCK, 0)); in clientSocket()
140 unique_fd client_fd = clientSocket(mSocketPath); in testCommand()
149 unique_fd mSserverFd;
176 unique_fd client1 = clientSocket(mSocketPath); in TEST_F()
177 unique_fd client2 = clientSocket(mSocketPath); in TEST_F()
/system/core/debuggerd/
Ddebuggerd_test.cpp60 using android::base::unique_fd;
97 static void tombstoned_intercept(pid_t target_pid, unique_fd* intercept_fd, unique_fd* output_fd, in tombstoned_intercept()
110 unique_fd output_pipe_write; in tombstoned_intercept()
157 unique_fd crasher_pipe;
158 unique_fd intercept_fd;
163 void StartIntercept(unique_fd* output_fd, DebuggerdDumpType intercept_type = kDebuggerdTombstone);
189 void CrasherTest::StartIntercept(unique_fd* output_fd, DebuggerdDumpType intercept_type) { in StartIntercept()
216 unique_fd read_pipe; in StartProcess()
217 unique_fd crasher_read_pipe; in StartProcess()
268 static void ConsumeFd(unique_fd fd, std::string* output) { in ConsumeFd()
[all …]
/system/core/debuggerd/tombstoned/
Dtombstoned_client.cpp33 using android::base::unique_fd;
35 bool tombstoned_connect(pid_t pid, unique_fd* tombstoned_socket, unique_fd* output_fd, in tombstoned_connect()
37 unique_fd sockfd( in tombstoned_connect()
57 unique_fd tmp_output_fd; in tombstoned_connect()
/system/netd/client/
DNetdClientTest.cpp64 android::base::unique_fd ipv4(socketFuncPtr(AF_INET, SOCK_STREAM | SOCK_CLOEXEC, 0)), in expectAllowNetworkingForProcess()
70 android::base::unique_fd dnsproxydSocket(openDnsProxyFuncPtr()); in expectAllowNetworkingForProcess()
76 android::base::unique_fd unixSocket(socketFuncPtr(AF_UNIX, SOCK_STREAM | SOCK_CLOEXEC, 0)); in expectNotAllowNetworkingForProcess()
78 android::base::unique_fd ipv4(socketFuncPtr(AF_INET, SOCK_STREAM | SOCK_CLOEXEC, 0)); in expectNotAllowNetworkingForProcess()
81 android::base::unique_fd ipv6(socketFuncPtr(AF_INET6, SOCK_STREAM | SOCK_CLOEXEC, 0)); in expectNotAllowNetworkingForProcess()
86 android::base::unique_fd dnsproxydSocket(openDnsProxyFuncPtr()); in expectNotAllowNetworkingForProcess()
100 android::base::unique_fd clientFd, serverFd; in TEST()
/system/core/adb/client/
Dfastdeploy.h36 unique_fd install_patch(int argc, const char** argv);
37 unique_fd apply_patch_on_device(const char* output_path);
39 unique_fd patch_fd);
/system/core/adb/libs/adbconnection/
Dadbconnection_server.cpp31 using android::base::unique_fd;
46 unique_fd s(socket(AF_UNIX, SOCK_SEQPACKET | SOCK_NONBLOCK | SOCK_CLOEXEC, 0)); in adbconnection_listen()
62 std::vector<unique_fd> pending_connections; in adbconnection_listen()
64 unique_fd epfd(epoll_create1(EPOLL_CLOEXEC)); in adbconnection_listen()
82 unique_fd client( in adbconnection_listen()
102 [&](const unique_fd& fd) { return fd.get() == event.data.fd; }); in adbconnection_listen()
/system/netd/tests/
Dnetd_client_test.cpp41 android::base::unique_fd sock(socket(AF_INET6, SOCK_DGRAM | SOCK_CLOEXEC, IPPROTO_UDP)); in checkNetworkConnectivity()
61 android::base::unique_fd ipv4(socket(AF_INET, SOCK_STREAM | SOCK_CLOEXEC, 0)), in expectHasNetworking()
80 android::base::unique_fd unixSocket(socket(AF_UNIX, SOCK_STREAM | SOCK_CLOEXEC, 0)); in expectNoNetworking()
82 android::base::unique_fd ipv4(socket(AF_INET, SOCK_STREAM | SOCK_CLOEXEC, 0)); in expectNoNetworking()
85 android::base::unique_fd ipv6(socket(AF_INET6, SOCK_STREAM | SOCK_CLOEXEC, 0)); in expectNoNetworking()
/system/core/fs_mgr/tests/
Dfile_wait_test.cpp25 using android::base::unique_fd;
43 unique_fd fd(open(test_file_.c_str(), O_CREAT | O_TRUNC | O_RDWR, 0700)); in TEST_F()
58 unique_fd fd(open(test_file_.c_str(), O_CREAT | O_TRUNC | O_RDWR, 0700)); in TEST_F()
67 unique_fd fd(open(test_file_.c_str(), O_CREAT | O_TRUNC | O_RDWR, 0700)); in TEST_F()
76 unique_fd fd(open(test_file_.c_str(), O_CREAT | O_TRUNC | O_RDWR, 0700)); in TEST_F()

12345678910>>...12