/system/core/debuggerd/tombstoned/ |
H A D | intercept_manager.h | 37 android::base::unique_fd sockfd; member in struct:Intercept
|
H A D | intercept_manager.cpp | 36 static void intercept_close_cb(evutil_socket_t sockfd, short event, void* arg) { argument 40 CHECK_EQ(sockfd, intercept->sockfd.get()); 69 static void intercept_request_cb(evutil_socket_t sockfd, short ev, void* arg) { argument 73 CHECK_EQ(sockfd, intercept->sockfd.get()); 86 ssize_t result = recv_fd(sockfd, &intercept_request, sizeof(intercept_request), &rcv_fd); 111 TEMP_FAILURE_RETRY(write(sockfd, &response, sizeof(response))); 123 TEMP_FAILURE_RETRY(write(sockfd, &response, sizeof(response))); 132 if (TEMP_FAILURE_RETRY(write(sockfd, 158 intercept_accept_cb(evconnlistener* listener, evutil_socket_t sockfd, sockaddr*, int, void* arg) argument [all...] |
H A D | tombstoned.cpp | 78 static void crash_accept_cb(evconnlistener* listener, evutil_socket_t sockfd, sockaddr*, int, void*); 79 static void crash_request_cb(evutil_socket_t sockfd, short ev, void* arg); 80 static void crash_completed_cb(evutil_socket_t sockfd, short ev, void* arg); 170 static void crash_accept_cb(evconnlistener* listener, evutil_socket_t sockfd, sockaddr*, int, argument 176 event* crash_event = event_new(base, sockfd, EV_TIMEOUT | EV_READ, crash_request_cb, crash); 177 crash->crash_fd.reset(sockfd); 182 static void crash_request_cb(evutil_socket_t sockfd, short ev, void* arg) { argument 195 rc = TEMP_FAILURE_RETRY(read(sockfd, &request, sizeof(request))); 227 static void crash_completed_cb(evutil_socket_t sockfd, short ev, void* arg) { argument 238 rc = TEMP_FAILURE_RETRY(read(sockfd, [all...] |
/system/connectivity/wifilogd/ |
H A D | raw_os.cpp | 46 ssize_t RawOs::Recv(int sockfd, void* buf, size_t buflen, int flags) { argument 47 return recv(sockfd, buf, buflen, flags);
|
/system/core/debuggerd/ |
H A D | util.cpp | 31 ssize_t send_fd(int sockfd, const void* data, size_t len, unique_fd fd) { argument 44 return TEMP_FAILURE_RETRY(sendmsg(sockfd, &msg, 0)); 47 ssize_t recv_fd(int sockfd, void* _Nonnull data, size_t len, unique_fd* _Nullable out_fd) { argument 63 ssize_t result = TEMP_FAILURE_RETRY(recvmsg(sockfd, &msg, 0));
|
/system/core/debuggerd/client/ |
H A D | debuggerd_client.cpp | 65 unique_fd sockfd; local 68 auto set_timeout = [timeout_ms, &time_left](int sockfd) { 70 return sockfd; 82 if (setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof(timeout)) != 0) { 86 if (setsockopt(sockfd, SOL_SOCKET, SO_SNDTIMEO, &timeout, sizeof(timeout)) != 0) { 91 return sockfd; 94 sockfd.reset(socket(AF_LOCAL, SOCK_SEQPACKET, 0)); 95 if (sockfd == -1) { 100 if (socket_local_client_connect(set_timeout(sockfd.get()), kTombstonedInterceptSocketName, 107 if (!set_timeout(sockfd)) { [all...] |
/system/core/libcutils/ |
H A D | qtaguid.c | 98 int qtaguid_tagSocket(int sockfd, int tag, uid_t uid) { argument 105 snprintf(lineBuf, sizeof(lineBuf), "t %d %" PRIu64 " %d", sockfd, kTag, uid); 107 ALOGV("Tagging socket %d with tag %" PRIx64 "{%u,0} for uid %d", sockfd, kTag, tag, uid); 112 sockfd, kTag, tag, uid, res); 118 int qtaguid_untagSocket(int sockfd) { argument 122 ALOGV("Untagging socket %d", sockfd); 124 snprintf(lineBuf, sizeof(lineBuf), "u %d", sockfd); 127 ALOGI("Untagging socket %d failed errno=%d", sockfd, res);
|
/system/extras/simpleperf/ |
H A D | UnixSocket.cpp | 51 int sockfd = socket(AF_UNIX, SOCK_STREAM, 0); local 52 if (sockfd < 0) { 60 if (bind(sockfd, reinterpret_cast<sockaddr*>(&serv_addr), sizeof(serv_addr)) < 65 if (listen(sockfd, 1) < 0) { 70 new UnixSocketServer(sockfd, server_path)); 76 int sockfd = accept(server_fd_, nullptr, nullptr); local 77 if (sockfd < 0) { 82 new UnixSocketConnection(sockfd)); 87 int sockfd = socket(AF_UNIX, SOCK_STREAM, 0); local 88 if (sockfd < [all...] |
/system/bt/service/ipc/ |
H A D | linux_ipc_host.cc | 75 LinuxIPCHost::LinuxIPCHost(int sockfd, Adapter* adapter) argument 76 : adapter_(adapter), pfds_(1, {sockfd, POLLIN, 0}) {}
|
/system/netd/client/ |
H A D | NetdClient.cpp | 55 int netdClientAccept4(int sockfd, sockaddr* addr, socklen_t* addrlen, int flags) { argument 56 int acceptedSocket = libcAccept4(sockfd, addr, addrlen, flags); 78 int netdClientConnect(int sockfd, const sockaddr* addr, socklen_t addrlen) { argument 79 const bool shouldSetFwmark = (sockfd >= 0) && addr 83 if (int error = FwmarkClient().send(&command, sockfd, nullptr)) { 90 const int ret = libcConnect(sockfd, addr, addrlen); 101 FwmarkClient().send(&command, sockfd, &connectInfo);
|