| /system/core/logd/ |
| LogListener.cpp | 150 int sock = android_get_control_socket(socketName); local
152 if (sock < 0) { // logd started up in init.sh
153 sock = socket_local_server(
157 if (setsockopt(sock, SOL_SOCKET, SO_PASSCRED, &on, sizeof(on))) {
161 return sock;
|
| /system/netd/server/ |
| 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) {
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, iov, iovlen) == -1)
[all...] |
| /external/javassist/src/main/javassist/tools/rmi/ |
| ObjectImporter.java | 155 Socket sock = new Socket(servername, port); local
156 OutputStream out = sock.getOutputStream();
165 InputStream in = new BufferedInputStream(sock.getInputStream());
172 sock.close();
224 Socket sock = new Socket(servername, port); local
226 sock.getOutputStream());
237 InputStream ins = new BufferedInputStream(sock.getInputStream());
250 sock.close();
|
| /external/nist-sip/java/gov/nist/javax/sip/stack/ |
| TLSMessageProcessor.java | 75 private ServerSocket sock; field in class:TLSMessageProcessor
106 this.sock = sipStack.getNetworkLayer().createSSLServerSocket(this.getPort(), 0,
108 ((SSLServerSocket) this.sock).setNeedClientAuth(false);
109 ((SSLServerSocket) this.sock).setUseClientMode(false);
110 ((SSLServerSocket) this.sock).setWantClientAuth(true);
112 ((SSLServerSocket) this.sock).setEnabledCipherSuites(enabledCiphers);
113 ((SSLServerSocket)this.sock).setWantClientAuth(true);
147 Socket newsock = sock.accept();
197 sock.close();
|
| UDPMessageChannel.java | 391 ((UDPMessageProcessor)this.messageProcessor).sock.send(keepalive);
705 DatagramSocket sock; local
713 sock = ((UDPMessageProcessor) messageProcessor).sock;
718 // sock = new DatagramSocket(0,sipStack.stackInetAddress);
721 sock = new DatagramSocket();
724 sock.send(reply);
726 sock.close();
769 DatagramSocket sock; local
771 sock = ((UDPMessageProcessor) messageProcessor).sock
[all...] |
| /external/sl4a/Common/src/com/googlecode/android_scripting/facade/wifi/ |
| HttpFacade.java | 124 Socket sock = mServerSocket.accept(); local
126 mSockets.put(socketCnt, sock);
250 Socket sock = mSockets.get(key); local
252 sock.close();
254 Log.e("Failed to close socket " + key + " on port " + sock.getLocalPort());
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/util/net/ |
| HttpHelperFuncTest.java | 150 Socket sock = mSS.accept(); local
152 OutputStream oStream = sock.getOutputStream();
156 sock.close();
|
| /art/runtime/jdwp/ |
| jdwp_socket.cc | 220 int sock; local
230 sock = accept(listenSock, &addr.addrPlain, &addrlen);
231 if (sock < 0 && errno != EINTR) {
243 } while (sock < 0);
249 clientSock = sock;
|
| /bionic/tests/ |
| ifaddrs_test.cpp | 132 sockaddr_in* sock = reinterpret_cast<sockaddr_in*>(&ifr.ifr_addr); local
133 in_addr_t addr = sock->sin_addr.s_addr;
147 auto sock = reinterpret_cast<sockaddr_in*>(addr->ifa_addr); local
148 inet_addrs[addr->ifa_name].insert(sock->sin_addr.s_addr);
151 auto sock = reinterpret_cast<sockaddr_in*>(addr->ifa_broadaddr); local
152 broad_addrs[addr->ifa_name].insert(sock->sin_addr.s_addr);
|
| /device/google/cuttlefish_common/common/frontend/socket_forward_proxy/ |
| main.cpp | 217 auto sock = cvd::SharedFD::SocketLocalClient(port, SOCK_STREAM); local
218 if (sock->IsOpen()) {
219 return sock;
232 auto sock = OpenSocketConnection(conn.first.port()); local
233 CHECK(sock->IsOpen());
235 LaunchWorkers(std::move(conn), std::move(sock));
|
| /external/android-clat/ |
| clatd_microbenchmark.c | 166 int sock = socket(AF_INET, SOCK_DGRAM | SOCK_NONBLOCK, IPPROTO_UDP); local
169 if (setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on)) == -1) die("SO_REUSEADDR");
172 if (setsockopt(sock, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv)) == -1) die("SO_RCVTIMEO");
179 if (bind(sock, (struct sockaddr *) &addr, sizeof(addr)) == -1) die ("bind");
181 return sock;
186 int sock = open_socket(); local
198 if (recvfrom(sock, buf, sizeof(buf), 0, NULL, NULL) == -1) die("recvfrom");
200 benchmark("Blocking", fd, sock, NUMPACKETS, 1, payload, sizeof(payload), payload_sum);
205 benchmark("No read", fd, sock, NUMPACKETS, 0, payload, sizeof(payload), payload_sum);
210 benchmark("Nonblocking", fd, sock, NUMPACKETS, 1, payload, sizeof(payload), payload_sum)
[all...] |
| /external/apache-http/src/org/apache/http/impl/conn/ |
| DefaultClientConnectionOperator.java | 145 Socket sock = plain_sf.createSocket(); local
146 conn.opening(sock, target);
149 Socket connsock = plain_sf.connectSocket(sock,
153 if (sock != connsock) {
154 sock = connsock;
155 conn.opening(sock, target);
168 prepareSocket(sock, context, params);
170 Socket layeredsock = layered_sf.createSocket(sock,
174 if (layeredsock != sock) {
179 conn.openCompleted(sf.isSecure(sock), params)
239 final Socket sock; local
[all...] |
| /external/autotest/client/profilers/powertop/src/ |
| wireless.c | 202 int sock; local
245 sock = socket(AF_INET, SOCK_DGRAM, 0);
246 if (sock<0)
252 ret = ioctl(sock, SIOCGIFFLAGS, &ifr);
254 close(sock);
265 ret = ioctl(sock, SIOCETHTOOL, &ifr);
269 close(sock);
|
| /external/boringssl/src/crypto/bio/ |
| bio_test.cc | 46 static int closesocket(int sock) { return close(sock); }
58 explicit ScopedSocket(int sock) : sock_(sock) {}
118 int sock = accept(listening_sock, (struct sockaddr *) &ss, &len); local
119 ASSERT_NE(-1, sock) << LastSocketError();
120 ScopedSocket sock_closer(sock);
125 recv(sock, buf, sizeof(buf), 0))
|
| /external/boringssl/src/tool/ |
| client.cc | 192 static bool WaitForSession(SSL *ssl, int sock) {
196 if (!SocketSetNonBlocking(sock, true)) {
206 FD_SET(static_cast<SOCKET>(sock), &read_fds);
208 FD_SET(sock, &read_fds);
210 int ret = select(sock + 1, &read_fds, NULL, NULL, NULL);
235 bool (*cb)(SSL *ssl, int sock)) {
236 int sock = -1; local
238 if (!Connect(&sock, args_map["-http-tunnel"]) ||
239 !DoHTTPTunnel(sock, args_map["-connect"])) {
242 } else if (!Connect(&sock, args_map["-connect"]))
[all...] |
| server.cc | 333 int sock = -1; local
334 if (!listener.Accept(&sock)) {
338 BIO *bio = BIO_new_socket(sock, BIO_CLOSE);
358 result = TransferData(ssl.get(), sock);
|
| /external/curl/lib/ |
| pingpong.c | 84 curl_socket_t sock = conn->sock[FIRSTSOCKET]; local
113 rc = Curl_socket_check(pp->sendleft?CURL_SOCKET_BAD:sock, /* reading */
115 pp->sendleft?sock:CURL_SOCKET_BAD, /* writing */
211 result = Curl_write(conn, conn->sock[FIRSTSOCKET], s, write_len,
472 socks[0] = conn->sock[FIRSTSOCKET];
488 curl_socket_t sock = conn->sock[FIRSTSOCKET]; local
489 CURLcode result = Curl_write(conn, sock, pp->sendthis + pp->sendsize -
|
| socks.c | 121 curl_socket_t sock = conn->sock[sockindex]; local
134 (void)curlx_nonblock(sock, FALSE);
244 code = Curl_write_plain(conn, sock, (char *)socksreq,
254 code = Curl_write_plain(conn, sock, (char *)hostname, hostnamelen,
265 result = Curl_blockread_all(conn, sock, (char *)socksreq, packetsize,
344 (void)curlx_nonblock(sock, TRUE);
383 curl_socket_t sock = conn->sock[sockindex]; local
413 (void)curlx_nonblock(sock, TRUE)
[all...] |
| socks_gssapi.c | 106 curl_socket_t sock = conn->sock[sockindex]; local
202 code = Curl_write_plain(conn, sock, (char *)socksreq, 4, &written);
212 code = Curl_write_plain(conn, sock, (char *)gss_send_token.value,
240 result = Curl_blockread_all(conn, sock, (char *)socksreq, 4, &actualread);
279 result = Curl_blockread_all(conn, sock, (char *)gss_recv_token.value,
408 code = Curl_write_plain(conn, sock, (char *)socksreq, 4, &written);
418 code = Curl_write_plain(conn, sock, socksreq, 1, &written);
426 code = Curl_write_plain(conn, sock, (char *)gss_w_token.value,
437 result = Curl_blockread_all(conn, sock, (char *)socksreq, 4, &actualread)
[all...] |
| socks_sspi.c | 66 curl_socket_t sock = conn->sock[sockindex]; local
204 code = Curl_write_plain(conn, sock, (char *)socksreq, 4, &written);
217 code = Curl_write_plain(conn, sock, (char *)sspi_send_token.pvBuffer,
258 result = Curl_blockread_all(conn, sock, (char *)socksreq, 4, &actualread);
298 result = Curl_blockread_all(conn, sock, (char *)sspi_recv_token.pvBuffer,
466 code = Curl_write_plain(conn, sock, (char *)socksreq, 4, &written);
477 code = Curl_write_plain(conn, sock, (char *)socksreq, 1, &written);
485 code = Curl_write_plain(conn, sock, (char *)sspi_send_token.pvBuffer,
498 result = Curl_blockread_all(conn, sock, (char *)socksreq, 4, &actualread)
[all...] |
| /external/curl/tests/libtest/ |
| libntlmconnect.c | 42 curl_socket_t sock; local
60 sock = CURL_SOCKET_BAD;
62 sock = (curl_socket_t)longdata;
64 if(sock != CURL_SOCKET_BAD) {
68 sockets[idx] = sock;
70 else if(sock != sockets[idx]) {
74 curlx_sztosi(idx), (int)sockets[idx], (int)sock);
|
| /external/libevent/sample/ |
| dns-example.c | 193 evutil_socket_t sock; local
195 sock = socket(PF_INET, SOCK_DGRAM, 0);
196 if (sock == -1) {
200 evutil_make_socket_nonblocking(sock);
204 if (bind(sock, (struct sockaddr*)&my_addr, sizeof(my_addr))<0) {
208 evdns_add_server_port_with_base(event_base, sock, 0, evdns_server_callback, NULL);
|
| /external/libevent/test/ |
| bench_httpclient.c | 114 frob_socket(evutil_socket_t sock)
120 if (setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (void*)&one, sizeof(one))<0)
125 if (setsockopt(sock, SOL_SOCKET, SO_LINGER, (void*)&l, sizeof(l))<0)
133 evutil_socket_t sock; local
146 if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0)
148 if (evutil_make_socket_nonblocking(sock) < 0) {
149 evutil_closesocket(sock);
152 frob_socket(sock);
153 if (connect(sock, (struct sockaddr*)&sin, sizeof(sin)) < 0) {
154 int e = evutil_socket_geterror(sock);
[all...] |
| /external/libnl/src/ |
| nf-exp-add.c | 59 struct nl_sock *sock; local
175 sock = nl_cli_alloc_socket();
176 nl_cli_connect(sock, NETLINK_NETFILTER);
178 if ((err = nfnl_exp_add(sock, exp, nlflags)) < 0)
|
| nf-exp-delete.c | 58 struct nl_sock *sock; local
153 sock = nl_cli_alloc_socket();
154 nl_cli_connect(sock, NETLINK_NETFILTER);
156 if ((err = nfnl_exp_del(sock, exp, nlflags)) < 0)
|
