| /system/bt/btif/src/ |
| D | btif_sock_l2cap.cc | 95 static void btsock_l2cap_server_listen(l2cap_socket* sock);
121 static char packet_get_head_l(l2cap_socket* sock, uint8_t** data, in packet_get_head_l() argument
123 struct packet* p = sock->first_packet; in packet_get_head_l()
127 if (data) *data = sock->first_packet->data; in packet_get_head_l()
128 if (len) *len = sock->first_packet->len; in packet_get_head_l()
129 sock->first_packet = p->next; in packet_get_head_l()
130 if (sock->first_packet) in packet_get_head_l()
131 sock->first_packet->prev = NULL; in packet_get_head_l()
133 sock->last_packet = NULL; in packet_get_head_l()
135 if (len) sock->bytes_buffered -= *len; in packet_get_head_l()
[all …]
|
| /system/core/libstats/ |
| D | statsd_writer.c | 87 .sock = -EBADF,
99 i = atomic_load(&statsdLoggerWrite.sock); in statsdOpen()
108 int sock = TEMP_FAILURE_RETRY(socket(PF_UNIX, flags, 0)); in statsdOpen() local
109 if (sock < 0) { in statsdOpen()
116 setsockopt(sock, SOL_SOCKET, SO_SNDBUF, &sndbuf, bufLen); in statsdOpen()
123 connect(sock, (struct sockaddr*)&un, sizeof(struct sockaddr_un))) < 0) { in statsdOpen()
129 i = atomic_exchange(&statsdLoggerWrite.sock, ret); in statsdOpen()
134 close(sock); in statsdOpen()
136 ret = atomic_exchange(&statsdLoggerWrite.sock, sock); in statsdOpen()
137 if ((ret >= 0) && (ret != sock)) { in statsdOpen()
[all …]
|
| /system/core/liblog/ |
| D | logd_writer.cpp | 53 .context.sock = -EBADF,
65 i = atomic_load(&logdLoggerWrite.context.sock); in logdOpen()
67 int sock = TEMP_FAILURE_RETRY(socket(PF_UNIX, SOCK_DGRAM | SOCK_CLOEXEC | SOCK_NONBLOCK, 0)); in logdOpen() local
68 if (sock < 0) { in logdOpen()
76 if (TEMP_FAILURE_RETRY(connect(sock, (struct sockaddr*)&un, sizeof(struct sockaddr_un))) < in logdOpen()
83 i = atomic_exchange(&logdLoggerWrite.context.sock, ret); in logdOpen()
88 close(sock); in logdOpen()
90 ret = atomic_exchange(&logdLoggerWrite.context.sock, sock); in logdOpen()
91 if ((ret >= 0) && (ret != sock)) { in logdOpen()
103 int sock = atomic_exchange(&logdLoggerWrite.context.sock, negative_errno); in __logdClose() local
[all …]
|
| D | logd_reader.cpp | 134 int sock = socket_local_client("logd", SOCK_STREAM); in send_log_msg() local
135 if (sock < 0) { in send_log_msg()
136 return sock; in send_log_msg()
144 ret = TEMP_FAILURE_RETRY(write(sock, buf, len)); in send_log_msg()
151 while ((ret = TEMP_FAILURE_RETRY(read(sock, cp, len))) > 0) { in send_log_msg()
162 p.fd = sock; in send_log_msg()
186 close(sock); in send_log_msg()
333 int e, ret, remaining, sock; in logdOpen() local
339 sock = atomic_load(&transp->context.sock); in logdOpen()
340 if (sock > 0) { in logdOpen()
[all …]
|
| /system/core/libcutils/ |
| D | socket_inaddr_any_server_windows.cpp | 42 SOCKET sock = socket(AF_INET6, type, 0); in socket_inaddr_any_server() local
43 if (sock == INVALID_SOCKET) { in socket_inaddr_any_server()
53 if (setsockopt(sock, SOL_SOCKET, SO_EXCLUSIVEADDRUSE, (char*)&exclusive, in socket_inaddr_any_server()
55 setsockopt(sock, IPPROTO_IPV6, IPV6_V6ONLY, (char*)&v6_only, in socket_inaddr_any_server()
57 closesocket(sock); in socket_inaddr_any_server()
67 if (bind(sock, (struct sockaddr*)&addr, sizeof(addr)) == SOCKET_ERROR) { in socket_inaddr_any_server()
68 closesocket(sock); in socket_inaddr_any_server()
73 if (type == SOCK_STREAM && listen(sock, LISTEN_BACKLOG) == SOCKET_ERROR) { in socket_inaddr_any_server()
74 closesocket(sock); in socket_inaddr_any_server()
78 return sock; in socket_inaddr_any_server()
|
| D | sockets_windows.cpp | 53 int socket_close(cutils_socket_t sock) { in socket_close() argument
54 return closesocket(sock); in socket_close()
57 int socket_set_receive_timeout(cutils_socket_t sock, int timeout_ms) { in socket_set_receive_timeout() argument
58 return setsockopt(sock, SOL_SOCKET, SO_RCVTIMEO, in socket_set_receive_timeout()
62 ssize_t socket_send_buffers(cutils_socket_t sock, in socket_send_buffers() argument
80 if (WSASend(sock, wsa_buffers, num_buffers, &bytes_sent, 0, nullptr, in socket_send_buffers()
|
| D | sockets_unix.cpp | 30 int socket_close(int sock) { in socket_close() argument
31 return close(sock); in socket_close()
34 int socket_set_receive_timeout(cutils_socket_t sock, int timeout_ms) { in socket_set_receive_timeout() argument
38 return setsockopt(sock, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv)); in socket_set_receive_timeout()
41 ssize_t socket_send_buffers(cutils_socket_t sock, in socket_send_buffers() argument
57 return writev(sock, iovec_buffers, num_buffers); in socket_send_buffers()
|
| D | socket_network_client_windows.cpp | 54 SOCKET sock = socket(address->ai_family, address->ai_socktype, in socket_network_client() local
56 if (sock == INVALID_SOCKET) { in socket_network_client()
61 if (connect(sock, address->ai_addr, address->ai_addrlen) == SOCKET_ERROR) { in socket_network_client()
62 closesocket(sock); in socket_network_client()
68 return sock; in socket_network_client()
|
| D | sockets_test.cpp | 78 void TestReceiveTimeout(cutils_socket_t sock) { in TestReceiveTimeout() argument
83 EXPECT_EQ(0, socket_set_receive_timeout(sock, 20)); in TestReceiveTimeout()
85 EXPECT_EQ(-1, recv(sock, buffer, sizeof(buffer), 0)); in TestReceiveTimeout()
89 EXPECT_EQ(0, socket_set_receive_timeout(sock, 1250)); in TestReceiveTimeout()
91 EXPECT_EQ(-1, recv(sock, buffer, sizeof(buffer), 0)); in TestReceiveTimeout()
162 cutils_socket_t sock = socket_inaddr_any_server(0, SOCK_DGRAM); in TEST() local
163 ASSERT_NE(INVALID_SOCKET, sock); in TEST()
165 TestReceiveTimeout(sock); in TEST()
167 EXPECT_EQ(0, socket_close(sock)); in TEST()
|
| /system/netd/libnetdutils/include/netdutils/ |
| D | Syscalls.h | 50 virtual Status getsockname(Fd sock, sockaddr* addr, socklen_t* addrlen) const = 0;
52 virtual Status getsockopt(Fd sock, int level, int optname, void *optval,
55 virtual Status setsockopt(Fd sock, int level, int optname, const void* optval,
58 virtual Status bind(Fd sock, const sockaddr* addr, socklen_t addrlen) const = 0;
60 virtual Status connect(Fd sock, const sockaddr* addr, socklen_t addrlen) const = 0;
62 virtual StatusOr<ifreq> ioctl(Fd sock, unsigned long request, ifreq* ifr) const = 0;
74 virtual StatusOr<size_t> sendto(Fd sock, const Slice buf, int flags, const sockaddr* dst,
77 virtual StatusOr<Slice> recvfrom(Fd sock, const Slice dst, int flags, sockaddr* src,
117 StatusOr<SockaddrT> getsockname(Fd sock) const { in getsockname() argument
120 RETURN_IF_NOT_OK(getsockname(sock, asSockaddrPtr(&addr), &addrlen)); in getsockname()
[all …]
|
| D | MockSyscalls.h | 39 MOCK_CONST_METHOD3(getsockname, Status(Fd sock, sockaddr* addr, socklen_t* addrlen));
40 MOCK_CONST_METHOD5(getsockopt, Status(Fd sock, int level, int optname, void* optval,
42 MOCK_CONST_METHOD5(setsockopt, Status(Fd sock, int level, int optname, const void* optval,
45 MOCK_CONST_METHOD3(bind, Status(Fd sock, const sockaddr* addr, socklen_t addrlen));
46 MOCK_CONST_METHOD3(connect, Status(Fd sock, const sockaddr* addr, socklen_t addrlen));
47 MOCK_CONST_METHOD3(ioctl, StatusOr<ifreq>(Fd sock, unsigned long request, ifreq* ifr));
56 MOCK_CONST_METHOD5(sendto, StatusOr<size_t>(Fd sock, const Slice buf, int flags,
58 MOCK_CONST_METHOD5(recvfrom, StatusOr<Slice>(Fd sock, const Slice dst, int flags, sockaddr* src,
|
| /system/netd/server/ |
| D | NetlinkCommands.cpp | 35 int sock = socket(AF_NETLINK, SOCK_DGRAM | SOCK_CLOEXEC, protocol); in openNetlinkSocket() local
36 if (sock == -1) { in openNetlinkSocket()
39 if (connect(sock, reinterpret_cast<const sockaddr*>(&KERNEL_NLADDR), in openNetlinkSocket()
43 return sock; in openNetlinkSocket()
46 int recvNetlinkAck(int sock) { in recvNetlinkAck() argument
52 int ret = recv(sock, &response, sizeof(response), 0); in recvNetlinkAck()
89 int sock = openNetlinkSocket(NETLINK_ROUTE); in sendNetlinkRequest() local
90 if (sock < 0) { in sendNetlinkRequest()
91 return sock; in sendNetlinkRequest()
96 if (writev(sock, iov, iovlen) == -1) { in sendNetlinkRequest()
[all …]
|
| D | NetlinkManager.cpp | 66 NetlinkHandler *NetlinkManager::setupSocket(int *sock, int netlinkFamily, in setupSocket() argument
79 if ((*sock = socket(PF_NETLINK, SOCK_DGRAM | SOCK_CLOEXEC, netlinkFamily)) < 0) { in setupSocket()
87 if (setsockopt(*sock, SOL_SOCKET, SO_RCVBUFFORCE, &sz, sizeof(sz)) < 0 && in setupSocket()
88 setsockopt(*sock, SOL_SOCKET, SO_RCVBUF, &sz, sizeof(sz)) < 0) { in setupSocket()
90 close(*sock); in setupSocket()
94 if (setsockopt(*sock, SOL_SOCKET, SO_PASSCRED, &on, sizeof(on)) < 0) { in setupSocket()
96 close(*sock); in setupSocket()
100 if (bind(*sock, (struct sockaddr *) &nladdr, sizeof(nladdr)) < 0) { in setupSocket()
102 close(*sock); in setupSocket()
107 if (android_nflog_send_config_cmd(*sock, 0, NFULNL_CFG_CMD_PF_UNBIND, AF_INET) < 0) { in setupSocket()
[all …]
|
| /system/netd/libnetdutils/ |
| D | SocketOption.cpp | 29 Status enableSockopt(Fd sock, int level, int optname) { in enableSockopt() argument
32 return sys.setsockopt(sock, level, optname, &on, sizeof(on)); in enableSockopt()
35 Status enableTcpKeepAlives(Fd sock, unsigned idleTime, unsigned numProbes, unsigned probeInterval) { in enableTcpKeepAlives() argument
36 RETURN_IF_NOT_OK(enableSockopt(sock, SOL_SOCKET, SO_KEEPALIVE)); in enableTcpKeepAlives()
40 RETURN_IF_NOT_OK(sys.setsockopt(sock, SOL_TCP, TCP_KEEPIDLE, &idleTime, sizeof(idleTime))); in enableTcpKeepAlives()
43 RETURN_IF_NOT_OK(sys.setsockopt(sock, SOL_TCP, TCP_KEEPCNT, &numProbes, sizeof(numProbes))); in enableTcpKeepAlives()
46 RETURN_IF_NOT_OK(sys.setsockopt(sock, SOL_TCP, TCP_KEEPINTVL, &probeInterval, in enableTcpKeepAlives()
|
| D | Syscalls.cpp | 53 UniqueFd sock(::socket(domain, type, protocol)); in socket() local
54 if (!isWellFormed(sock)) { in socket()
57 return sock; in socket()
60 Status getsockname(Fd sock, sockaddr* addr, socklen_t* addrlen) const override { in getsockname() argument
61 auto rv = ::getsockname(sock.get(), addr, addrlen); in getsockname()
68 Status getsockopt(Fd sock, int level, int optname, void* optval, in getsockopt() argument
70 auto rv = ::getsockopt(sock.get(), level, optname, optval, optlen); in getsockopt()
77 Status setsockopt(Fd sock, int level, int optname, const void* optval, in setsockopt() argument
79 auto rv = ::setsockopt(sock.get(), level, optname, optval, optlen); in setsockopt()
86 Status bind(Fd sock, const sockaddr* addr, socklen_t addrlen) const override { in bind() argument
[all …]
|
| /system/core/fastboot/ |
| D | socket.cpp | 34 Socket::Socket(cutils_socket_t sock) : sock_(sock) {} in Socket() argument
112 UdpSocket(Type type, cutils_socket_t sock);
125 UdpSocket::UdpSocket(Type type, cutils_socket_t sock) : Socket(sock) { in UdpSocket() argument
170 explicit TcpSocket(cutils_socket_t sock) : Socket(sock) {} in TcpSocket() argument
249 cutils_socket_t sock = socket_network_client(host.c_str(), port, SOCK_DGRAM); in NewClient() local
250 if (sock != INVALID_SOCKET) { in NewClient()
251 return std::unique_ptr<UdpSocket>(new UdpSocket(UdpSocket::Type::kClient, sock)); in NewClient()
254 cutils_socket_t sock = socket_network_client(host.c_str(), port, SOCK_STREAM); in NewClient() local
255 if (sock != INVALID_SOCKET) { in NewClient()
256 return std::unique_ptr<TcpSocket>(new TcpSocket(sock)); in NewClient()
[all …]
|
| /system/hardware/interfaces/net/netd/testutils/ |
| D | VtsHalNetNetdTestUtils.cpp | 34 int sock = socket(AF_INET6, SOCK_STREAM, 0); in checkNetworkExists() local
35 if (sock == -1) { in checkNetworkExists()
38 int ret = android_setsocknetwork(netHandle, sock); in checkNetworkExists()
42 close(sock); in checkNetworkExists()
103 int sock = socket(ai->ai_family, SOCK_DGRAM, 0); in checkReachability() local
104 if (sock == -1 || android_setsocknetwork(netHandle, sock) == -1) { in checkReachability()
110 ret = connect(sock, ai->ai_addr, ai->ai_addrlen); in checkReachability()
111 close(sock); in checkReachability()
|
| /system/netd/tests/benchmarks/ |
| D | connect_benchmark.cpp | 112 int sock = socket(AF_INET, SOCK_STREAM | SOCK_CLOEXEC, 0); in ipv4_loopback() local
113 if (sock < 0) { in ipv4_loopback()
121 if (connect(sock, (sockaddr*) &server, sizeof(server))) { in ipv4_loopback()
123 close(sock); in ipv4_loopback()
139 close(sock); in ipv4_loopback()
144 close(sock); in ipv4_loopback()
169 int sock = socket(AF_INET6, SOCK_STREAM | SOCK_CLOEXEC, 0); in ipv6_loopback() local
170 if (sock < 0) { in ipv6_loopback()
178 if (connect(sock, (sockaddr*) &server, sizeof(server))) { in ipv6_loopback()
180 close(sock); in ipv6_loopback()
[all …]
|
| /system/core/base/include/android-base/ |
| D | cmsg.h | 54 ssize_t SendFileDescriptorVector(int sock, const void* data, size_t len,
61 ssize_t ReceiveFileDescriptorVector(int sock, void* data, size_t len, size_t max_fds,
67 ssize_t SendFileDescriptors(int sock, const void* data, size_t len, Args&&... sent_fds) { in SendFileDescriptors() argument
74 return SendFileDescriptorVector(sock, data, len, fds); in SendFileDescriptors()
82 ssize_t ReceiveFileDescriptors(int sock, void* data, size_t len, Args&&... received_fds) { in ReceiveFileDescriptors() argument
87 ssize_t rc = ReceiveFileDescriptorVector(sock, data, len, fds.size(), &result); in ReceiveFileDescriptors()
|
| /system/core/libcutils/include/cutils/ |
| D | sockets.h | 103 int socket_close(cutils_socket_t sock);
111 int socket_set_receive_timeout(cutils_socket_t sock, int timeout_ms);
116 int socket_get_local_port(cutils_socket_t sock);
139 ssize_t socket_send_buffers(cutils_socket_t sock,
|
| /system/core/libcutils/include_vndk/cutils/ |
| D | sockets.h | 103 int socket_close(cutils_socket_t sock);
111 int socket_set_receive_timeout(cutils_socket_t sock, int timeout_ms);
116 int socket_get_local_port(cutils_socket_t sock);
139 ssize_t socket_send_buffers(cutils_socket_t sock,
|
| /system/bt/tools/hci/ |
| D | main.c | 178 int sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); in write_hci_command() local
179 if (sock == INVALID_FD) goto error; in write_hci_command()
186 OSI_NO_INTR(ret = connect(sock, (const struct sockaddr*)&addr, sizeof(addr))); in write_hci_command()
189 if (send(sock, &type, 1, 0) != 1) goto error; in write_hci_command()
191 if (send(sock, &length, 2, 0) != 2) goto error; in write_hci_command()
193 if (send(sock, packet, length, 0) != (ssize_t)length) goto error; in write_hci_command()
195 close(sock); in write_hci_command()
199 close(sock); in write_hci_command()
|
| /system/core/adb/daemon/ |
| D | reboot_service.cpp | 52 android::base::unique_fd sock(socket(AF_UNIX, SOCK_STREAM, 0)); in reboot_service() local
53 if (sock < 0) { in reboot_service()
61 if (connect(sock, reinterpret_cast<sockaddr*>(&addr), sizeof(addr)) == -1) { in reboot_service()
67 auto ret = adb_write(sock, &msg_switch_to_fastboot, sizeof(msg_switch_to_fastboot)); in reboot_service()
|
| /system/netd/tests/ |
| D | bpf_base_test.cpp | 105 int sock = socket(AF_INET6, SOCK_STREAM | SOCK_CLOEXEC, 0); in TEST_F() local
106 ASSERT_LE(0, sock); in TEST_F()
107 uint64_t cookie = getSocketCookie(sock); in TEST_F()
109 ASSERT_EQ(0, qtaguid_tagSocket(sock, TEST_TAG, TEST_UID)); in TEST_F()
114 ASSERT_EQ(0, qtaguid_untagSocket(sock)); in TEST_F()
125 int sock = socket(AF_INET6, SOCK_STREAM | SOCK_CLOEXEC, 0); in TEST_F() local
126 ASSERT_LE(0, sock); in TEST_F()
127 uint64_t cookie = getSocketCookie(sock); in TEST_F()
129 ASSERT_EQ(0, qtaguid_tagSocket(sock, TEST_TAG, TEST_UID)); in TEST_F()
134 ASSERT_EQ(0, close(sock)); in TEST_F()
|
| /system/core/libmemunreachable/ |
| D | LeakPipe.cpp | 26 bool LeakPipe::SendFd(int sock, int fd) { in SendFd() argument
47 int ret = sendmsg(sock, &hdr, 0); in SendFd()
60 int LeakPipe::ReceiveFd(int sock) { in ReceiveFd() argument
74 int ret = recvmsg(sock, &hdr, 0); in ReceiveFd()
|