Home
last modified time | relevance | path

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

123456

/packages/modules/adb/daemon/
Dabb_service.cpp28 unique_fd sendCommand(std::string_view command);
31 static unique_fd startAbbProcess(unique_fd* error_fd);
37 unique_fd socket_fd_;
40 unique_fd AbbProcess::sendCommand(std::string_view command) { in sendCommand()
44 unique_fd error_fd; in sendCommand()
59 unique_fd fd; in sendCommand()
75 unique_fd AbbProcess::startAbbProcess(unique_fd* error_fd) { in startAbbProcess()
87 unique_fd execute_abb_command(std::string_view command) { in execute_abb_command()
Dservices.cpp63 void reconnect_service(unique_fd fd, atransport* t) { in reconnect_service()
68 unique_fd reverse_service(std::string_view command, atransport* transport) { in reverse_service()
75 return unique_fd{}; in reverse_service()
82 return unique_fd{s[0]}; in reverse_service()
87 unique_fd ShellService(std::string_view args, const atransport* transport) { in ShellService()
91 return unique_fd{}; in ShellService()
124 static void spin_service(unique_fd fd) { in spin_service()
131 unique_fd pipe_read, pipe_write; in spin_service()
146 [[maybe_unused]] static unique_fd reboot_device(const std::string& name) { in reboot_device()
149 auto reboot_service = [name](unique_fd fd) { in reboot_device()
[all …]
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 …]
Dtransport_local.cpp52 void server_socket_thread(std::function<unique_fd(std::string_view, std::string*)> listen_func, in server_socket_thread()
56 unique_fd serverfd; in server_socket_thread()
75 unique_fd fd(adb_socket_accept(serverfd, nullptr, nullptr)); in server_socket_thread()
91 unique_fd adb_listen(std::string_view addr, std::string* error) { in adb_listen()
92 return unique_fd{socket_spec_listen(addr, error, nullptr)}; in adb_listen()
100 int init_socket_transport(atransport* t, unique_fd fd, int adb_port, int local) { in init_socket_transport()
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);
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);
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()
Drestart_service_test.cpp38 unique_fd dontcare; in TEST()
41 unique_fd command_fd_ = create_service_thread( in TEST()
57 unique_fd command_fd_ = create_service_thread( in TEST()
69 unique_fd command_fd_ = create_service_thread("usb", restart_usb_service); in TEST()
Dusb_ffs.h21 bool open_functionfs(android::base::unique_fd* control, android::base::unique_fd* bulk_out,
22 android::base::unique_fd* bulk_in);
Djdwp_service.cpp47 using android::base::unique_fd;
149 JdwpProcess(unique_fd socket, ProcessInfo process) { in JdwpProcess()
190 std::vector<unique_fd> out_fds;
305 unique_fd create_jdwp_connection_fd(int pid) { in create_jdwp_connection_fd()
316 return unique_fd{}; in create_jdwp_connection_fd()
325 return unique_fd{fds[0]}; in create_jdwp_connection_fd()
329 return unique_fd{}; in create_jdwp_connection_fd()
516 unique_fd ufd(fd); in init_jdwp()
537 unique_fd create_jdwp_connection_fd(int pid) { in create_jdwp_connection_fd()
/packages/modules/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()
137 static void connect_service(unique_fd fd, std::string host) { in connect_service()
149 static void pair_service(unique_fd fd, std::string host, std::string password) { in pair_service()
[all …]
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()
Dsocket_test.cpp62 asocket* prev_tail = create_local_socket(unique_fd(first[1])); in TEST_F()
74 asocket* head = create_local_socket(unique_fd(intermediate[0])); in TEST_F()
77 asocket* tail = create_local_socket(unique_fd(intermediate[1])); in TEST_F()
84 asocket* end = create_local_socket(unique_fd(last[0])); in TEST_F()
108 unique_fd socket_fd;
110 unique_fd cause_close_fd;
243 asocket* head = create_local_socket(unique_fd(head_fd[1])); in TEST_F()
244 asocket* tail = create_local_socket(unique_fd(tail_fd[1])); in TEST_F()
287 unique_fd listen_fd; in TEST_F()
298 asocket* s = create_local_socket(unique_fd(accept_fd)); in TEST_F()
Dtransport_benchmark.cpp41 std::unique_ptr<Connection> MakeConnection(unique_fd fd);
44 std::unique_ptr<Connection> MakeConnection<FdConnection>(unique_fd fd) { in MakeConnection()
50 std::unique_ptr<Connection> MakeConnection<NonblockingFdConnection>(unique_fd fd) { in MakeConnection()
61 auto client = MakeConnection<ConnectionType>(unique_fd(fds[0])); in BM_Connection_Unidirectional()
62 auto server = MakeConnection<ConnectionType>(unique_fd(fds[1])); in BM_Connection_Unidirectional()
116 auto client = MakeConnection<ConnectionType>(unique_fd(fds[0])); in BM_Connection_Echo()
117 auto server = MakeConnection<ConnectionType>(unique_fd(fds[1])); in BM_Connection_Echo()
Dadb_unique_fd.h30 using unique_fd = android::base::unique_fd_impl<AdbCloser>; variable
32 using unique_fd = android::base::unique_fd; variable
/packages/modules/Connectivity/netd/
DBpfHandler.cpp36 using base::unique_fd;
53 static Status attachProgramToCgroup(const char* programPath, const unique_fd& cgroupFd, in attachProgramToCgroup()
55 unique_fd cgroupProg(retrieveProgram(programPath)); in attachProgramToCgroup()
66 unique_fd prog(retrieveProgram(programPath)); in checkProgramAccessible()
94 unique_fd cg_fd(open(cg2_path, O_DIRECTORY | O_RDONLY | O_CLOEXEC)); in initPrograms()
252 unique_fd fd0(bpf::mapRetrieveExclusiveRW(m1)); if (!fd0.ok()) abort(); // grabs exclusive lock in mapLockTest()
254 unique_fd fd1(bpf::mapRetrieveExclusiveRW(m2)); if (!fd1.ok()) abort(); // no conflict with fd0 in mapLockTest()
255 unique_fd fd2(bpf::mapRetrieveExclusiveRW(m2)); if ( fd2.ok()) abort(); // busy due to fd1 in mapLockTest()
256 unique_fd fd3(bpf::mapRetrieveRO(m2)); if (!fd3.ok()) abort(); // no lock taken in mapLockTest()
257 unique_fd fd4(bpf::mapRetrieveRW(m2)); if ( fd4.ok()) abort(); // busy due to fd1 in mapLockTest()
[all …]
/packages/services/Car/cpp/car_binder_lib/largeParcelable/include/
DSharedMemory.h37 using ::android::base::unique_fd;
45 explicit SharedMemory(unique_fd fd);
73 inline unique_fd getDupFd() const { in getDupFd()
74 unique_fd fd(dup(getFd())); in getDupFd()
92 unique_fd mOwnedFd;
/packages/modules/adb/libs/adbconnection/
Dadbconnection_server.cpp34 using android::base::unique_fd;
76 unique_fd s(socket(AF_UNIX, SOCK_SEQPACKET | SOCK_NONBLOCK | SOCK_CLOEXEC, 0)); in adbconnection_listen()
93 std::vector<unique_fd> pending_connections; in adbconnection_listen()
95 unique_fd epfd(epoll_create1(EPOLL_CLOEXEC)); in adbconnection_listen()
113 unique_fd client( in adbconnection_listen()
133 [&](const unique_fd& fd) { return fd.get() == event.data.fd; }); in adbconnection_listen()
/packages/services/Car/cpp/car_binder_lib/largeParcelable/tests/
DMappedFileSharedMemoryTest.cpp33 using ::android::base::unique_fd;
38 unique_fd fd(-1); in TEST()
46 unique_fd fd(0); in TEST()
67 unique_fd fd(ashmem_create_region("SharedMemory", TEST_SIZE)); in TEST()
111 unique_fd fd(ashmem_create_region("SharedMemory", TEST_SIZE)); in TEST()
131 unique_fd fd(ashmem_create_region("SharedMemory", TEST_SIZE)); in TEST()
/packages/modules/Virtualization/virtualizationmanager/
Dfuzzer.cpp35 using android::base::unique_fd;
41 Result<unique_fd> get_service_fd() { in get_service_fd()
42 unique_fd server_fd, client_fd; in get_service_fd()
47 unique_fd wait_fd, ready_fd; in get_service_fd()
93 unique_fd fd = OR_RETURN(get_service_fd()); in inner_fuzz()
/packages/modules/adb/client/
Dincremental_server.cpp152 File(const char* filepath, FileId id, int64_t size, unique_fd fd, int64_t tree_offset, in File()
153 unique_fd tree_fd) in File()
191 unique_fd fd_;
194 unique_fd tree_fd_;
200 IncrementalServer(unique_fd adb_fd, unique_fd output_fd, std::vector<File> files) in IncrementalServer()
252 unique_fd const adb_fd_;
253 unique_fd const output_fd_;
658 static std::pair<unique_fd, int64_t> open_fd(const char* filepath) { in open_fd()
664 unique_fd fd(adb_open(filepath, O_RDONLY)); in open_fd()
672 static std::pair<unique_fd, int64_t> open_signature(int64_t file_size, const char* filepath) { in open_signature()
[all …]
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);
Dadb_install.cpp152 static unique_fd send_command(const std::vector<std::string>& cmd_args, std::string* error) { in send_command()
156 return unique_fd(adb_connect(android::base::Join(cmd_args, " "), error)); in send_command()
199 unique_fd local_fd(adb_open(file, O_RDONLY | O_CLOEXEC)); in install_app_streamed()
232 unique_fd remote_fd = send_command(cmd_args, &error); in install_app_streamed()
578 unique_fd fd = send_command(cmd_args, &error); in install_multiple_app_streamed()
623 unique_fd local_fd(adb_open(file, O_RDONLY | O_CLOEXEC)); in install_multiple_app_streamed()
631 unique_fd remote_fd = send_command(cmd_args, &error); in install_multiple_app_streamed()
662 unique_fd fd = send_command(service_args, &error); in install_multiple_app_streamed()
767 unique_fd fd = send_command(multi_package_cmd_args, &error); in install_multi_package()
825 unique_fd fd; in install_multi_package()
[all …]
/packages/modules/DnsResolver/tests/
Dtun_forwarder.h37 TunForwarder(base::unique_fd tunFd);
45 static base::unique_fd createTun(const std::string& ifname);
97 base::unique_fd mTunFd;
98 base::unique_fd mEventFd;
/packages/modules/adb/fdevent/
Dfdevent.cpp63 fdevent* fdevent_context::Create(unique_fd fd, std::variant<fd_func, fd_func2> func, void* arg) { in Create()
91 unique_fd fdevent_context::Destroy(fdevent* fde) { in Destroy()
100 unique_fd fd = std::move(fde->fd); in Destroy()
221 unique_fd ufd(fd); in fdevent_create()
226 unique_fd ufd(fd); in fdevent_create()
230 unique_fd fdevent_release(fdevent* fde) { in fdevent_release()

123456