/system/core/libcutils/ |
H A D | sockets.cpp | 38 int socket_get_local_port(cutils_socket_t sock) { argument 42 if (getsockname(sock, reinterpret_cast<sockaddr*>(&addr), &addr_size) == 0) {
|
H A D | socket_inaddr_any_server_windows.c | 42 SOCKET sock = socket(AF_INET6, type, 0); local 43 if (sock == INVALID_SOCKET) { 53 if (setsockopt(sock, SOL_SOCKET, SO_EXCLUSIVEADDRUSE, (char*)&exclusive, 55 setsockopt(sock, IPPROTO_IPV6, IPV6_V6ONLY, (char*)&v6_only, 57 closesocket(sock); 67 if (bind(sock, (struct sockaddr*)&addr, sizeof(addr)) == SOCKET_ERROR) { 68 closesocket(sock); 73 if (type == SOCK_STREAM && listen(sock, LISTEN_BACKLOG) == SOCKET_ERROR) { 74 closesocket(sock); 78 return sock; [all...] |
H A D | socket_network_client_windows.c | 54 SOCKET sock = socket(address->ai_family, address->ai_socktype, local 56 if (sock == INVALID_SOCKET) { 61 if (connect(sock, address->ai_addr, address->ai_addrlen) == SOCKET_ERROR) { 62 closesocket(sock); 68 return sock;
|
H A D | sockets_unix.cpp | 51 int socket_close(int sock) { argument 52 return close(sock); 55 int socket_set_receive_timeout(cutils_socket_t sock, int timeout_ms) { argument 59 return setsockopt(sock, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv)); 62 ssize_t socket_send_buffers(cutils_socket_t sock, argument 78 return writev(sock, iovec_buffers, num_buffers);
|
H A D | sockets_windows.cpp | 53 int socket_close(cutils_socket_t sock) { argument 54 return closesocket(sock); 57 int socket_set_receive_timeout(cutils_socket_t sock, int timeout_ms) { argument 58 return setsockopt(sock, SOL_SOCKET, SO_RCVTIMEO, 62 ssize_t socket_send_buffers(cutils_socket_t sock, argument 80 if (WSASend(sock, wsa_buffers, num_buffers, &bytes_sent, 0, nullptr,
|
/system/core/libmemunreachable/ |
H A D | LeakPipe.cpp | 24 bool LeakPipe::SendFd(int sock, int fd) { argument 45 int ret = sendmsg(sock, &hdr, 0); 58 int LeakPipe::ReceiveFd(int sock) { argument 72 int ret = recvmsg(sock, &hdr, 0);
|
/system/core/fastboot/ |
H A D | socket_mock.h | 81 void AddAccept(std::unique_ptr<Socket> sock); 93 std::unique_ptr<Socket> sock; member in struct:SocketMock::Event
|
H A D | socket_test.cpp | 64 static bool SendString(Socket* sock, const std::string& message) { argument 65 return sock->Send(message.c_str(), message.length()); 70 static bool ReceiveString(Socket* sock, const std::string& message) { argument 72 ssize_t bytes = sock->ReceiveAll(&received[0], received.length(), kTestTimeoutMs); 175 std::unique_ptr<Socket> sock = Socket::NewServer(Socket::Protocol::kUdp, 0); local 184 sock->socket_send_buffers_function_ = [&buffers, &mock_return_value]( 196 EXPECT_TRUE(sock->Send(buffers)); 199 EXPECT_FALSE(sock->Send(buffers)); 202 EXPECT_FALSE(sock->Send(buffers)); 205 EXPECT_FALSE(sock 212 std::unique_ptr<Socket> sock = Socket::NewServer(Socket::Protocol::kTcp, 0); local [all...] |
H A D | socket_mock.cpp | 120 std::unique_ptr<Socket> sock = std::move(events_.front().sock); local 122 return sock; 145 void SocketMock::AddAccept(std::unique_ptr<Socket> sock) { argument 146 events_.push(Event(EventType::kAccept, "", false, std::move(sock))); 151 : type(_type), message(_message), status(_status), sock(std::move(_sock)) {}
|
H A D | tcp.cpp | 69 TcpTransport(std::unique_ptr<Socket> sock) : socket_(std::move(sock)) {} argument 188 std::unique_ptr<Transport> Connect(std::unique_ptr<Socket> sock, std::string* error) { argument 189 if (sock == nullptr) { 194 return TcpTransport::NewTransport(std::move(sock), error);
|
H A D | socket.cpp | 34 Socket::Socket(cutils_socket_t sock) : sock_(sock) {} argument 112 UdpSocket(Type type, cutils_socket_t sock); 125 UdpSocket::UdpSocket(Type type, cutils_socket_t sock) : Socket(sock) { argument 170 TcpSocket(cutils_socket_t sock) : Socket(sock) {} argument 249 cutils_socket_t sock = socket_network_client(host.c_str(), port, SOCK_DGRAM); local 250 if (sock != INVALID_SOCKET) { 251 return std::unique_ptr<UdpSocket>(new UdpSocket(UdpSocket::Type::kClient, sock)); 254 cutils_socket_t sock = socket_network_client(host.c_str(), port, SOCK_STREAM); local 269 cutils_socket_t sock = socket_inaddr_any_server(port, SOCK_DGRAM); local 274 cutils_socket_t sock = socket_inaddr_any_server(port, SOCK_STREAM); local [all...] |
H A D | udp.cpp | 380 std::unique_ptr<Transport> Connect(std::unique_ptr<Socket> sock, std::string* error) { argument 381 if (sock == nullptr) { 386 return UdpTransport::NewTransport(std::move(sock), error);
|
/system/core/libcutils/tests/ |
H A D | sockets_test.cpp | 76 void TestReceiveTimeout(cutils_socket_t sock) { argument 81 EXPECT_EQ(0, socket_set_receive_timeout(sock, 20)); 83 EXPECT_EQ(-1, recv(sock, buffer, sizeof(buffer), 0)); 87 EXPECT_EQ(0, socket_set_receive_timeout(sock, 1250)); 89 EXPECT_EQ(-1, recv(sock, buffer, sizeof(buffer), 0)); 160 cutils_socket_t sock = socket_inaddr_any_server(0, SOCK_DGRAM); local 161 ASSERT_NE(INVALID_SOCKET, sock); 163 TestReceiveTimeout(sock); 165 EXPECT_EQ(0, socket_close(sock));
|
/system/core/logd/ |
H A D | LogListener.cpp | 123 int sock = android_get_control_socket(socketName); local 125 if (sock < 0) { 126 sock = socket_local_server(socketName, 132 if (setsockopt(sock, SOL_SOCKET, SO_PASSCRED, &on, sizeof(on)) < 0) { 135 return sock;
|
H A D | CommandListener.cpp | 302 int sock = android_get_control_socket(socketName); local 304 if (sock < 0) { 305 sock = socket_local_server(socketName, 310 return sock;
|
H A D | LogReader.cpp | 210 int sock = android_get_control_socket(socketName); local 212 if (sock < 0) { 213 sock = socket_local_server(socketName, 218 return sock;
|
H A D | main.cpp | 386 int sock = TEMP_FAILURE_RETRY( local 390 if (sock < 0) { 394 ssize_t ret = TEMP_FAILURE_RETRY(write(sock, reinit, sizeof(reinit))); 400 p.fd = sock; 412 ret = TEMP_FAILURE_RETRY(read(sock, buffer, sizeof(buffer)));
|
/system/vold/ |
H A D | vdc.cpp | 39 static int do_monitor(int sock, int stop_after_cmd); 40 static int do_cmd(int sock, int argc, char **argv); 45 int sock; local 67 while ((sock = socket_local_client(sockname, 79 exit(do_monitor(sock, 0)); 81 exit(do_cmd(sock, argc, argv)); 85 static int do_cmd(int sock, int argc, char **argv) { argument 103 if (TEMP_FAILURE_RETRY(write(sock, cmd.c_str(), cmd.length() + 1)) < 0) { 108 return do_monitor(sock, seq); 111 static int do_monitor(int sock, in argument [all...] |
/system/netd/server/ |
H A D | NetlinkManager.cpp | 67 NetlinkHandler *NetlinkManager::setupSocket(int *sock, int netlinkFamily, argument 79 if ((*sock = socket(PF_NETLINK, SOCK_DGRAM | SOCK_CLOEXEC, netlinkFamily)) < 0) { 84 if (setsockopt(*sock, SOL_SOCKET, SO_RCVBUFFORCE, &sz, sizeof(sz)) < 0) { 86 close(*sock); 90 if (setsockopt(*sock, SOL_SOCKET, SO_PASSCRED, &on, sizeof(on)) < 0) { 92 close(*sock); 96 if (bind(*sock, (struct sockaddr *) &nladdr, sizeof(nladdr)) < 0) { 98 close(*sock); 103 if (android_nflog_send_config_cmd(*sock, 0, NFULNL_CFG_CMD_PF_UNBIND, AF_INET) < 0) { 107 if (android_nflog_send_config_cmd(*sock, [all...] |
H A D | ndc.c | 35 static int do_monitor(int sock, int stop_after_cmd); 36 static int do_cmd(int sock, int argc, char **argv); 39 int sock; local 47 if ((sock = socket_local_client(argv[1], 50 if ((sock = socket_local_client("netd", 63 exit(do_monitor(sock, 0)); 64 exit(do_cmd(sock, argc-cmdOffset, &(argv[cmdOffset]))); 67 static int do_cmd(int sock, int argc, char **argv) { argument 106 if (write(sock, final_cmd, strlen(final_cmd) + 1) < 0) { 114 return do_monitor(sock, 117 do_monitor(int sock, int stop_after_cmd) argument [all...] |
/system/bt/tools/bdtool/ |
H A D | bdtool.c | 201 const btsock_interface_t *sock = bt_interface->get_profile_interface(BT_PROFILE_SOCKETS_ID); local 204 int error = sock->listen(BTSOCK_RFCOMM, "meow", (const uint8_t *)&HFP_AG_UUID, 0, &rfcomm_fd, 0, app_uid); 211 error = sock->listen(BTSOCK_SCO, NULL, NULL, 5, &sock_fd, 0, app_uid); 229 const btsock_interface_t *sock = bt_interface->get_profile_interface(BT_PROFILE_SOCKETS_ID); local 232 int error = sock->connect(&bt_remote_bdaddr, BTSOCK_RFCOMM, (const uint8_t *)&HFP_AG_UUID, 0, &rfcomm_fd, 0, app_uid); 243 error = sock->connect(&bt_remote_bdaddr, BTSOCK_SCO, NULL, 5, &sock_fd, 0, app_uid);
|
/system/bt/tools/hci/ |
H A D | main.c | 171 int sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); local 172 if (sock == INVALID_FD) 180 OSI_NO_INTR(ret = connect(sock, (const struct sockaddr *)&addr, 185 if (send(sock, &type, 1, 0) != 1) 188 if (send(sock, &length, 2, 0) != 2) 191 if (send(sock, packet, length, 0) != (ssize_t)length) 194 close(sock); 198 close(sock);
|
/system/core/liblog/ |
H A D | logger.h | 32 /* Union, sock or fd of zero is not allowed unless static initialized */ 35 int sock; member in union:android_log_context
|
H A D | logd_reader.c | 270 int sock = socket_local_client("logd", ANDROID_SOCKET_NAMESPACE_RESERVED, local 272 if (sock < 0) { 273 return sock; 281 ret = TEMP_FAILURE_RETRY(write(sock, buf, len)); 288 while ((ret = TEMP_FAILURE_RETRY(read(sock, cp, len))) > 0) { 299 p.fd = sock; 323 close(sock); 488 int sock = transp->context.sock; local 489 if (sock > [all...] |
/system/core/libsysutils/src/ |
H A D | FrameworkListener.cpp | 42 FrameworkListener::FrameworkListener(int sock) : argument 43 SocketListener(sock, true) {
|