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

12

/system/core/libcutils/
H A Dsockets.cpp34 int socket_get_local_port(cutils_socket_t sock) { argument
38 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_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,
H A Dsockets_unix.cpp66 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 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 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 Dsockets_test.cpp78 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 DLeakPipe.cpp26 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 Dvdc.cpp40 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 Dlogd_writer.c53 .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 DLogListener.cpp146 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 DCommandListener.cpp359 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 DNetlinkListener.cpp60 NetlinkListener::NetlinkListener(UniqueFd event, UniqueFd sock) argument
61 : mEvent(std::move(event)), mSock(std::move(sock)), mWorker([this]() { run(); }) {
H A DNetlinkManager.cpp71 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 Dndc.cpp35 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 DNetdConstants.cpp169 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 DNetlinkCommands.cpp34 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 Dbdtool.c211 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 Dmain.c178 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 DFrameworkListener.cpp43 FrameworkListener::FrameworkListener(int sock) : argument
44 SocketListener(sock, true) {
/system/netd/libnetdutils/include/netdutils/
H A DSyscalls.h47 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 Dconnect_benchmark.cpp134 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...]

Completed in 348 milliseconds

12