| /system/core/libcutils/ |
| D | qtaguid.cpp | 73 int qtaguid_tagSocket(int sockfd, int tag, uid_t uid) { in qtaguid_tagSocket() argument
74 ALOGV("Tagging socket %d with tag %u for uid %d", sockfd, tag, uid); in qtaguid_tagSocket()
75 return getHandler().netdTagSocket(sockfd, tag, uid); in qtaguid_tagSocket()
78 int qtaguid_untagSocket(int sockfd) { in qtaguid_untagSocket() argument
79 ALOGV("Untagging socket %d", sockfd); in qtaguid_untagSocket()
80 return getHandler().netdUntagSocket(sockfd); in qtaguid_untagSocket()
|
| /system/core/debuggerd/tombstoned/ |
| D | intercept_manager.cpp | 41 static void intercept_close_cb(evutil_socket_t sockfd, short event, void* arg) { in intercept_close_cb() argument
44 CHECK_EQ(sockfd, intercept->sockfd.get()); in intercept_close_cb()
83 static void intercept_request_cb(evutil_socket_t sockfd, short ev, void* arg) { in intercept_request_cb() argument
87 CHECK_EQ(sockfd, intercept->sockfd.get()); in intercept_request_cb()
100 ReceiveFileDescriptors(sockfd, &intercept_request, sizeof(intercept_request), &rcv_fd); in intercept_request_cb()
123 TEMP_FAILURE_RETRY(write(sockfd, &response, sizeof(response))); in intercept_request_cb()
131 if (TEMP_FAILURE_RETRY(write(sockfd, &response, sizeof(response))) == -1) { in intercept_request_cb()
146 event_assign(intercept->intercept_event, intercept_manager->base, sockfd, EV_READ | EV_TIMEOUT, in intercept_request_cb()
155 static void intercept_accept_cb(evconnlistener* listener, evutil_socket_t sockfd, sockaddr*, int, in intercept_accept_cb() argument
159 intercept->sockfd.reset(sockfd); in intercept_accept_cb()
[all …]
|
| D | tombstoned_client.cpp | 42 unique_fd sockfd( in tombstoned_connect() local
46 if (sockfd == -1) { in tombstoned_connect()
56 if (TEMP_FAILURE_RETRY(write(sockfd, &packet, sizeof(packet))) != sizeof(packet)) { in tombstoned_connect()
66 rc = ReceiveFileDescriptors(sockfd, &packet, sizeof(packet), &tmp_output_fd, &tmp_proto_fd); in tombstoned_connect()
68 rc = ReceiveFileDescriptors(sockfd, &packet, sizeof(packet), &tmp_output_fd); in tombstoned_connect()
92 *tombstoned_socket = std::move(sockfd); in tombstoned_connect()
|
| D | tombstoned.cpp | 281 static void crash_accept_cb(evconnlistener* listener, evutil_socket_t sockfd, sockaddr*, int,
283 static void crash_request_cb(evutil_socket_t sockfd, short ev, void* arg);
284 static void crash_completed_cb(evutil_socket_t sockfd, short ev, void* arg);
336 static void crash_accept_cb(evconnlistener* listener, evutil_socket_t sockfd, sockaddr*, int, in crash_accept_cb() argument
344 event* crash_event = event_new(base, sockfd, EV_TIMEOUT | EV_READ, crash_request_cb, crash); in crash_accept_cb()
345 crash->crash_socket_fd.reset(sockfd); in crash_accept_cb()
350 static void crash_request_cb(evutil_socket_t sockfd, short ev, void* arg) { in crash_request_cb() argument
362 ssize_t rc = TEMP_FAILURE_RETRY(read(sockfd, &request, sizeof(request))); in crash_request_cb()
392 int ret = getsockopt(sockfd, SOL_SOCKET, SO_PEERCRED, &cr, &len); in crash_request_cb()
432 static void crash_completed(borrowed_fd sockfd, std::unique_ptr<Crash> crash) { in crash_completed() argument
[all …]
|
| D | intercept_manager.h | 39 android::base::unique_fd sockfd; member
|
| /system/core/debuggerd/client/ |
| D | debuggerd_client.cpp | 136 auto update_timeout = [timeout_ms, &output_fd](int sockfd, auto end) { in debuggerd_trigger_dump() argument
147 if (setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof(timeout)) != 0) { in debuggerd_trigger_dump()
151 if (setsockopt(sockfd, SOL_SOCKET, SO_SNDTIMEO, &timeout, sizeof(timeout)) != 0) { in debuggerd_trigger_dump()
158 unique_fd sockfd(socket(AF_LOCAL, SOCK_SEQPACKET, 0)); in debuggerd_trigger_dump() local
159 if (sockfd == -1) { in debuggerd_trigger_dump()
164 if (!update_timeout(sockfd, end)) return false; in debuggerd_trigger_dump()
166 if (socket_local_client_connect(sockfd.get(), kTombstonedInterceptSocketName, in debuggerd_trigger_dump()
198 if (!update_timeout(sockfd, end)) return false; in debuggerd_trigger_dump()
199 ssize_t rc = SendFileDescriptors(sockfd, &req, sizeof(req), pipe_write.get()); in debuggerd_trigger_dump()
206 auto get_response = [&output_fd](const char* kind, int sockfd, InterceptResponse* response) { in debuggerd_trigger_dump() argument
[all …]
|
| /system/netd/client/ |
| D | NetdClient.cpp | 127 int netdClientAccept4(int sockfd, sockaddr* addr, socklen_t* addrlen, int flags) { in netdClientAccept4() argument
128 int acceptedSocket = libcAccept4(sockfd, addr, addrlen, flags); in netdClientAccept4()
150 int netdClientConnect(int sockfd, const sockaddr* addr, socklen_t addrlen) { in netdClientConnect() argument
151 const bool shouldSetFwmark = shouldMarkSocket(sockfd, addr); in netdClientConnect()
155 int error = FwmarkClient().send(&command, sockfd, &connectInfo); in netdClientConnect()
164 const int ret = libcConnect(sockfd, addr, addrlen); in netdClientConnect()
175 FwmarkClient().send(&command, sockfd, &connectInfo); in netdClientConnect()
200 int netdClientSendmmsg(int sockfd, const mmsghdr* msgs, unsigned int msgcount, int flags) { in netdClientSendmmsg() argument
201 if (propertyValueIsTrue(PROPERTY_REDIRECT_SOCKET_CALLS_HOOKED) && !checkSocket(sockfd)) { in netdClientSendmmsg()
208 FwmarkClient().send(&command, sockfd, &sendmmsgInfo); in netdClientSendmmsg()
[all …]
|
| /system/libbase/ |
| D | abi_compatibility.cpp | 33 ssize_t SendFileDescriptorVector(int sockfd, const void* data, size_t len, in SendFileDescriptorVector() argument
35 return SendFileDescriptorVector(borrowed_fd(sockfd), data, len, fds); in SendFileDescriptorVector()
38 ssize_t ReceiveFileDescriptorVector(int sockfd, void* data, size_t len, size_t max_fds, in ReceiveFileDescriptorVector() argument
40 return ReceiveFileDescriptorVector(borrowed_fd(sockfd), data, len, max_fds, fds); in ReceiveFileDescriptorVector()
|
| D | cmsg.cpp | 32 ssize_t SendFileDescriptorVector(borrowed_fd sockfd, const void* data, size_t len, in SendFileDescriptorVector() argument
71 return TEMP_FAILURE_RETRY(sendmsg(sockfd.get(), &msg, flags)); in SendFileDescriptorVector()
74 ssize_t ReceiveFileDescriptorVector(borrowed_fd sockfd, void* data, size_t len, size_t max_fds, in ReceiveFileDescriptorVector() argument
103 ssize_t rc = TEMP_FAILURE_RETRY(recvmsg(sockfd.get(), &msg, flags)); in ReceiveFileDescriptorVector()
|
| /system/core/libcutils/include/cutils/ |
| D | qtaguid.h | 29 extern int qtaguid_tagSocket(int sockfd, int tag, uid_t uid);
34 extern int qtaguid_untagSocket(int sockfd);
|
| /system/core/libcutils/include_outside_system/cutils/ |
| D | qtaguid.h | 29 extern int qtaguid_tagSocket(int sockfd, int tag, uid_t uid);
34 extern int qtaguid_untagSocket(int sockfd);
|
| /system/libbase/include/android-base/ |
| D | unique_fd.h | 236 int sockfd[2]; in Socketpair() local
237 if (socketpair(domain, type, protocol, sockfd) != 0) { in Socketpair()
240 left->reset(sockfd[0]); in Socketpair()
241 right->reset(sockfd[1]); in Socketpair()
|
| /system/core/fs_mgr/libsnapshot/snapuserd/include/snapuserd/ |
| D | snapuserd_client.h | 49 explicit SnapuserdClient(android::base::unique_fd&& sockfd);
|
| /system/core/fs_mgr/libsnapshot/snapuserd/ |
| D | snapuserd_client.cpp | 61 SnapuserdClient::SnapuserdClient(android::base::unique_fd&& sockfd) : sockfd_(std::move(sockfd)) {} in SnapuserdClient() argument
|
| /system/core/debuggerd/ |
| D | debuggerd_test.cpp | 2065 unique_fd sockfd(socket_local_client(kTombstonedCrashSocketName, in TEST() local
2067 if (sockfd == -1) { in TEST()
2073 if (TEMP_FAILURE_RETRY(write(sockfd, &packet, sizeof(packet))) != sizeof(packet)) { in TEST()
|
| /system/netd/tests/ |
| D | binder_test.cpp | 5561 int retry_bind(int sockfd, struct sockaddr* addr, socklen_t addrlen) { in retry_bind() argument
5565 ret = bind(sockfd, addr, addrlen); in retry_bind()
|