/system/core/libcutils/ |
H A D | sockets.cpp | 34 int socket_get_local_port(cutils_socket_t sock) { argument 38 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_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,
|
H A D | sockets_unix.cpp | 66 int socket_close(int sock) { argument 67 return close(sock); 70 int socket_set_receive_timeout(cutils_socket_t sock, int timeout_ms) { argument 74 return setsockopt(sock, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv)); 77 ssize_t socket_send_buffers(cutils_socket_t sock, argument 93 return writev(sock, iovec_buffers, num_buffers);
|
/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 explicit 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);
|
/system/core/libcutils/tests/ |
H A D | sockets_test.cpp | 78 void TestReceiveTimeout(cutils_socket_t sock) { argument 83 EXPECT_EQ(0, socket_set_receive_timeout(sock, 20)); 85 EXPECT_EQ(-1, recv(sock, buffer, sizeof(buffer), 0)); 89 EXPECT_EQ(0, socket_set_receive_timeout(sock, 1250)); 91 EXPECT_EQ(-1, recv(sock, buffer, sizeof(buffer), 0)); 162 cutils_socket_t sock = socket_inaddr_any_server(0, SOCK_DGRAM); local 163 ASSERT_NE(INVALID_SOCKET, sock); 165 TestReceiveTimeout(sock); 167 EXPECT_EQ(0, socket_close(sock));
|
/system/core/libmemunreachable/ |
H A D | LeakPipe.cpp | 26 bool LeakPipe::SendFd(int sock, int fd) { argument 47 int ret = sendmsg(sock, &hdr, 0); 60 int LeakPipe::ReceiveFd(int sock) { argument 74 int ret = recvmsg(sock, &hdr, 0);
|
/system/vold/ |
H A D | vdc.cpp | 40 static int do_monitor(int sock, int stop_after_cmd); 41 static int do_cmd(int sock, int argc, char **argv); 46 int sock; local 75 while ((sock = socket_local_client(sockname, 87 exit(do_monitor(sock, 0)); 89 exit(do_cmd(sock, argc, argv)); 93 static int do_cmd(int sock, int argc, char **argv) { argument 111 if (TEMP_FAILURE_RETRY(write(sock, cmd.c_str(), cmd.length() + 1)) < 0) { 116 return do_monitor(sock, seq); 119 static int do_monitor(int sock, in argument [all...] |
/system/core/liblog/ |
H A D | logd_writer.c | 53 .context.sock = -EBADF, 65 i = atomic_load(&logdLoggerWrite.context.sock); 67 int sock = TEMP_FAILURE_RETRY( local 69 if (sock < 0) { 77 if (TEMP_FAILURE_RETRY(connect(sock, (struct sockaddr*)&un, 84 i = atomic_exchange(&logdLoggerWrite.context.sock, ret); 89 close(sock); 91 ret = atomic_exchange(&logdLoggerWrite.context.sock, sock); 92 if ((ret >= 0) && (ret != sock)) { 104 int sock = atomic_exchange(&logdLoggerWrite.context.sock, negative_errno); local 130 int sock; local [all...] |
/system/core/logd/ |
H A D | LogListener.cpp | 146 int sock = android_get_control_socket(socketName); local 148 if (sock < 0) { // logd started up in init.sh 149 sock = socket_local_server( 153 if (setsockopt(sock, SOL_SOCKET, SO_PASSCRED, &on, sizeof(on))) { 157 return sock;
|
H A D | CommandListener.cpp | 359 int sock = android_get_control_socket(socketName); local 361 if (sock < 0) { 362 sock = socket_local_server( 366 return sock;
|
/system/netd/server/ |
H A D | NetlinkListener.cpp | 60 NetlinkListener::NetlinkListener(UniqueFd event, UniqueFd sock) argument 61 : mEvent(std::move(event)), mSock(std::move(sock)), mWorker([this]() { run(); }) {
|
H A D | NetlinkManager.cpp | 71 NetlinkHandler *NetlinkManager::setupSocket(int *sock, int netlinkFamily, argument 84 if ((*sock = socket(PF_NETLINK, SOCK_DGRAM | SOCK_CLOEXEC, netlinkFamily)) < 0) { 89 if (setsockopt(*sock, SOL_SOCKET, SO_RCVBUFFORCE, &sz, sizeof(sz)) < 0) { 91 close(*sock); 95 if (setsockopt(*sock, SOL_SOCKET, SO_PASSCRED, &on, sizeof(on)) < 0) { 97 close(*sock); 101 if (bind(*sock, (struct sockaddr *) &nladdr, sizeof(nladdr)) < 0) { 103 close(*sock); 108 if (android_nflog_send_config_cmd(*sock, 0, NFULNL_CFG_CMD_PF_UNBIND, AF_INET) < 0) { 112 if (android_nflog_send_config_cmd(*sock, [all...] |
H A D | ndc.cpp | 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...] |
H A D | NetdConstants.cpp | 169 void setCloseOnExec(const char *sock) { argument 170 int fd = android_get_control_socket(sock); 173 ALOGE("Can't get fd flags for control socket %s", sock); 178 ALOGE("Can't set control socket %s to FD_CLOEXEC", sock);
|
H A D | NetlinkCommands.cpp | 34 int sock = socket(AF_NETLINK, SOCK_DGRAM | SOCK_CLOEXEC, protocol); local 35 if (sock == -1) { 38 if (connect(sock, reinterpret_cast<const sockaddr*>(&KERNEL_NLADDR), 42 return sock; 45 int recvNetlinkAck(int sock) { argument 51 int ret = recv(sock, &response, sizeof(response), 0); 88 int sock = openNetlinkSocket(NETLINK_ROUTE); local 89 if (sock < 0) { 90 return sock; 95 if (writev(sock, io 117 processNetlinkDump(int sock, const NetlinkDumpCallback& callback) argument [all...] |
/system/bt/tools/bdtool/ |
H A D | bdtool.c | 211 const btsock_interface_t* sock = local 216 sock->listen(BTSOCK_RFCOMM, "meow", (const uint8_t*)&HFP_AG_UUID, 0, 225 error = sock->listen(BTSOCK_SCO, NULL, NULL, 5, &sock_fd, 0, app_uid); 245 const btsock_interface_t* sock = local 250 sock->connect(&bt_remote_bdaddr, BTSOCK_RFCOMM, 262 error = sock->connect(&bt_remote_bdaddr, BTSOCK_SCO, NULL, 5, &sock_fd, 0,
|
/system/bt/tools/hci/ |
H A D | main.c | 178 int sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); local 179 if (sock == INVALID_FD) goto error; 186 OSI_NO_INTR(ret = connect(sock, (const struct sockaddr*)&addr, sizeof(addr))); 189 if (send(sock, &type, 1, 0) != 1) goto error; 191 if (send(sock, &length, 2, 0) != 2) goto error; 193 if (send(sock, packet, length, 0) != (ssize_t)length) goto error; 195 close(sock); 199 close(sock);
|
/system/core/libsysutils/src/ |
H A D | FrameworkListener.cpp | 43 FrameworkListener::FrameworkListener(int sock) : argument 44 SocketListener(sock, true) {
|
/system/netd/libnetdutils/include/netdutils/ |
H A D | Syscalls.h | 47 virtual Status getsockname(Fd sock, sockaddr* addr, socklen_t* addrlen) const = 0; 49 virtual Status setsockopt(Fd sock, int level, int optname, const void* optval, 52 virtual Status bind(Fd sock, const sockaddr* addr, socklen_t addrlen) const = 0; 54 virtual Status connect(Fd sock, const sockaddr* addr, socklen_t addrlen) const = 0; 64 virtual StatusOr<size_t> sendto(Fd sock, const Slice buf, int flags, const sockaddr* dst, 67 virtual StatusOr<Slice> recvfrom(Fd sock, const Slice dst, int flags, sockaddr* src, 107 StatusOr<SockaddrT> getsockname(Fd sock) const { 110 RETURN_IF_NOT_OK(getsockname(sock, asSockaddrPtr(&addr), &addrlen)); 115 Status setsockopt(Fd sock, int level, int optname, const SockoptT& opt) const { argument 116 return setsockopt(sock, leve 120 bind(Fd sock, const SockaddrT& addr) const argument 125 connect(Fd sock, const SockaddrT& addr) const argument 147 sendto(Fd sock, const Slice buf, int flags, const SockaddrT& dst) const argument 152 recvfrom(Fd sock, const Slice dst, int flags) const argument 157 recvfrom(Fd sock, const Slice dst, int flags) const argument [all...] |
/system/netd/tests/benchmarks/ |
H A D | connect_benchmark.cpp | 134 int sock = socket(AF_INET, SOCK_STREAM, 0); local 135 if (sock < 0) { 143 if (connect(sock, (sockaddr*) &server, sizeof(server))) { 145 close(sock); 161 close(sock); 166 close(sock); 191 int sock = socket(AF_INET6, SOCK_STREAM, 0); local 192 if (sock < 0) { 200 if (connect(sock, (sockaddr*) &server, sizeof(server))) { 202 close(sock); [all...] |