Searched defs:sock (Results 1 - 25 of 33) sorted by relevance

12

/system/core/libcutils/
H A Dsockets.cpp38 int socket_get_local_port(cutils_socket_t sock) { argument
42 if (getsockname(sock, reinterpret_cast<sockaddr*>(&addr), &addr_size) == 0) {
H A Dsocket_inaddr_any_server_windows.c42 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 Dsocket_network_client_windows.c54 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 Dsockets_unix.cpp51 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 Dsockets_windows.cpp53 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 DLeakPipe.cpp24 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 Dsocket_mock.h81 void AddAccept(std::unique_ptr<Socket> sock);
93 std::unique_ptr<Socket> sock; member in struct:SocketMock::Event
H A Dsocket_test.cpp64 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 Dsocket_mock.cpp120 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 Dtcp.cpp69 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 Dsocket.cpp34 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 Dudp.cpp380 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 Dsockets_test.cpp76 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 DLogListener.cpp123 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 DCommandListener.cpp302 int sock = android_get_control_socket(socketName); local
304 if (sock < 0) {
305 sock = socket_local_server(socketName,
310 return sock;
H A DLogReader.cpp210 int sock = android_get_control_socket(socketName); local
212 if (sock < 0) {
213 sock = socket_local_server(socketName,
218 return sock;
H A Dmain.cpp386 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 Dvdc.cpp39 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 DNetlinkManager.cpp67 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 Dndc.c35 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 Dbdtool.c201 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 Dmain.c171 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 Dlogger.h32 /* Union, sock or fd of zero is not allowed unless static initialized */
35 int sock; member in union:android_log_context
H A Dlogd_reader.c270 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 DFrameworkListener.cpp42 FrameworkListener::FrameworkListener(int sock) : argument
43 SocketListener(sock, true) {

Completed in 565 milliseconds

12