| /external/fio/examples/ |
| netio.fio | 4 #Use hostname=/tmp.fio.sock for local unix domain sockets
|
| /external/ipsec-tools/src/racoon/samples/roadwarrior/client/ |
| racoon.conf | 5 adminsock "/var/racoon/racoon.sock" "root" "operator" 0660;
|
| /external/libevent/test/ |
| regress_testutils.c | 100 evutil_socket_t sock; local
103 sock = socket(AF_INET, SOCK_DGRAM, 0);
104 if (sock < 0) {
108 evutil_make_socket_nonblocking(sock);
114 if (bind(sock, (struct sockaddr*)&my_addr, sizeof(my_addr)) < 0) {
115 evutil_closesocket(sock);
118 port = evdns_add_server_port_with_base(base, sock, 0, cb, arg);
120 *portnum = regress_get_socket_port(sock);
122 *psock = sock;
|
| /external/libnl/src/ |
| nl-link-list.c | 38 struct nl_sock *sock; local
46 sock = nl_cli_alloc_socket();
47 nl_cli_connect(sock, NETLINK_ROUTE);
92 link_cache = nl_cli_link_alloc_cache_family(sock,
|
| nl-link-stats.c | 81 struct nl_sock *sock; local
85 sock = nl_cli_alloc_socket();
86 nl_cli_connect(sock, NETLINK_ROUTE);
87 link_cache = nl_cli_link_alloc_cache(sock);
|
| /external/libvncserver/libvncclient/ |
| listen.c | 106 client->sock = AcceptTcpConnection(client->listenSock);
108 client->sock = AcceptTcpConnection(client->listen6Sock);
110 if (client->sock < 0)
112 if (!SetNonBlocking(client->sock))
131 close(client->sock);
205 client->sock = AcceptTcpConnection(client->listenSock);
207 client->sock = AcceptTcpConnection(client->listen6Sock);
209 if (client->sock < 0)
211 if (!SetNonBlocking(client->sock))
|
| /external/python/cpython3/Lib/asyncio/ |
| selector_events.py | 44 def _set_nodelay(sock):
45 if (sock.family in {socket.AF_INET, socket.AF_INET6} and
46 sock.type == socket.SOCK_STREAM and
47 sock.proto == socket.IPPROTO_TCP):
48 sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
50 def _set_nodelay(sock):
70 def _make_socket_transport(self, sock, protocol, waiter=None, *,
72 return _SelectorSocketTransport(self, sock, protocol, waiter,
100 def _make_datagram_transport(self, sock, protocol,
102 return _SelectorDatagramTransport(self, sock, protocol
[all...] |
| /external/python/cpython3/Lib/test/ |
| test_smtpnet.py | 12 with socket.create_connection((host, port)) as sock:
14 sock = context.wrap_socket(sock, server_hostname=host)
18 sock.close()
|
| test_telnetlib.py | 27 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
28 self.sock.settimeout(60) # Safety net. Look issue 11812
29 self.port = support.bind_port(self.sock)
30 self.thread = threading.Thread(target=server, args=(self.evt,self.sock))
42 telnet.sock.close()
56 self.assertEqual(telnet.sock.gettimeout(), 30)
57 telnet.sock.close()
67 self.assertTrue(telnet.sock.gettimeout() is None)
68 telnet.sock.close()
72 self.assertEqual(telnet.sock.gettimeout(), 30
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/javax/net/ssl/ |
| SSLSessionBindingListenerTest.java | 63 SSLSocket sock = (SSLSocket) SSLSocketFactory.getDefault() local
65 SSLSession ss = sock.getSession();
77 SSLSocket sock = (SSLSocket) SSLSocketFactory.getDefault() local
79 SSLSession ss = sock.getSession();
|
| /system/core/libcutils/tests/ |
| sockets_test.cpp | 78 void TestReceiveTimeout(cutils_socket_t sock) {
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/ |
| LeakPipe.cpp | 26 bool LeakPipe::SendFd(int sock, int fd) {
47 int ret = sendmsg(sock, &hdr, 0);
60 int LeakPipe::ReceiveFd(int sock) {
74 int ret = recvmsg(sock, &hdr, 0);
|
| /device/linaro/bootloader/edk2/NetworkPkg/TcpDxe/ |
| TcpMain.c | 88 SOCKET *Sock;
94 Sock = SOCK_FROM_THIS (This);
102 return SockGetMode (Sock, &TcpMode);
135 SOCKET *Sock;
173 Sock = SOCK_FROM_THIS (This);
176 return SockFlush (Sock);
179 Status = SockConfigure (Sock, TcpConfigData);
182 Sock->ConfigureState = SO_NO_MAPPING;
223 SOCKET *Sock;
230 Sock = SOCK_FROM_THIS (This);
[all...] |
| /external/mdnsresponder/mDNSWindows/ |
| mDNSWin32.c | 142 mDNSlocal void TCPCanRead( TCPSocket * sock );
143 mDNSlocal mStatus TCPBeginRecv( TCPSocket * sock );
146 mDNSlocal void CALLBACK TCPFreeSocket( TCPSocket *sock );
149 mDNSlocal void UDPCloseSocket( UDPSocket * sock );
150 mDNSlocal void CALLBACK UDPFreeSocket( UDPSocket * sock );
164 mDNSlocal void DispatchUDPEvent( mDNS * const m, UDPSocket * sock );
165 mDNSlocal void DispatchTCPEvent( mDNS * const m, TCPSocket * sock );
965 TCPSocket * sock = NULL; local
977 sock = (TCPSocket *) malloc( sizeof( TCPSocket ) );
978 require_action( sock, exit, err = mStatus_NoMemoryErr )
1111 TCPSocket * sock = NULL; local
1275 TCPSocket * sock = ( TCPSocket* ) context; local
1370 TCPSocket * sock; local
1400 UDPSocket* sock = NULL; local
2915 SocketRef sock; local
3258 UDPSocket * sock = NULL; local
3839 SOCKET sock; local
4161 SocketRef sock; local
[all...] |
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| test_telnetlib.py | 47 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
48 self.sock.settimeout(60) # Safety net. Look issue 11812
49 self.port = test_support.bind_port(self.sock)
50 self.thread = threading.Thread(target=server, args=(self.evt,self.sock))
61 telnet.sock.close()
70 self.assertEqual(telnet.sock.gettimeout(), 30)
71 telnet.sock.close()
81 self.assertTrue(telnet.sock.gettimeout() is None)
82 telnet.sock.close()
86 self.assertEqual(telnet.sock.gettimeout(), 30
[all...] |
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| test_telnetlib.py | 47 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
48 self.sock.settimeout(60) # Safety net. Look issue 11812
49 self.port = test_support.bind_port(self.sock)
50 self.thread = threading.Thread(target=server, args=(self.evt,self.sock))
61 telnet.sock.close()
70 self.assertEqual(telnet.sock.gettimeout(), 30)
71 telnet.sock.close()
81 self.assertTrue(telnet.sock.gettimeout() is None)
82 telnet.sock.close()
86 self.assertEqual(telnet.sock.gettimeout(), 30
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_telnetlib.py | 47 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
48 self.sock.settimeout(60) # Safety net. Look issue 11812
49 self.port = test_support.bind_port(self.sock)
50 self.thread = threading.Thread(target=server, args=(self.evt,self.sock))
61 telnet.sock.close()
70 self.assertEqual(telnet.sock.gettimeout(), 30)
71 telnet.sock.close()
81 self.assertTrue(telnet.sock.gettimeout() is None)
82 telnet.sock.close()
86 self.assertEqual(telnet.sock.gettimeout(), 30
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_telnetlib.py | 47 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
48 self.sock.settimeout(60) # Safety net. Look issue 11812
49 self.port = test_support.bind_port(self.sock)
50 self.thread = threading.Thread(target=server, args=(self.evt,self.sock))
61 telnet.sock.close()
70 self.assertEqual(telnet.sock.gettimeout(), 30)
71 telnet.sock.close()
81 self.assertTrue(telnet.sock.gettimeout() is None)
82 telnet.sock.close()
86 self.assertEqual(telnet.sock.gettimeout(), 30
[all...] |
| /kernel/tests/net/test/ |
| sock_diag_test.py | 101 def assertSocketClosed(self, sock):
102 self.assertRaisesErrno(ENOTCONN, sock.getpeername)
104 def assertSocketConnected(self, sock):
105 sock.getpeername() # No errors? Socket is alive and connected.
108 for sock in socketpair:
109 self.assertSocketClosed(sock)
140 def _EventDuringBlockingCall(self, sock, call, expected_errno, event):
141 """Simulates an external event during a blocking call on sock.
144 sock: The socket to use.
145 call: A function, the call to make. Takes one parameter, sock
[all...] |
| /external/wpa_supplicant_8/src/drivers/ |
| driver_wired.c | 120 static void handle_read(int sock, void *eloop_ctx, void *sock_ctx)
125 len = recv(sock, buf, sizeof(buf), 0);
135 static void handle_dhcp(int sock, void *eloop_ctx, void *sock_ctx)
143 len = recv(sock, buf, sizeof(buf), 0);
176 drv->common.sock = socket(PF_PACKET, SOCK_RAW, htons(ETH_P_PAE));
177 if (drv->common.sock < 0) {
183 if (eloop_register_read_sock(drv->common.sock, handle_read,
191 if (ioctl(drv->common.sock, SIOCGIFINDEX, &ifr) != 0) {
203 if (bind(drv->common.sock, (struct sockaddr *) &addr, sizeof(addr)) < 0)
210 if (wired_multicast_membership(drv->common.sock, ifr.ifr_ifindex
[all...] |
| /external/python/cpython2/Lib/test/ |
| test_ftplib.py | 108 sock = socket.socket()
109 sock.bind((self.socket.getsockname()[0], 0))
110 sock.listen(5)
111 sock.settimeout(10)
112 ip, port = sock.getsockname()[:2]
116 conn, addr = sock.accept()
127 sock = socket.socket(socket.AF_INET6)
128 sock.bind((self.socket.getsockname()[0], 0))
129 sock.listen(5)
130 sock.settimeout(10
[all...] |
| /external/autotest/client/bin/net/ |
| net_utils_unittest.py | [all...] |
| /device/google/cuttlefish_common/host/frontend/vnc_server/ |
| vnc_server.h | 44 void StartClient(ClientSocket sock);
46 void StartClientThread(ClientSocket sock);
|
| /external/android-clat/ |
| setif.c | 134 static int do_anycast_setsockopt(int sock, int what, struct in6_addr *addr, int ifindex) {
147 ret = setsockopt(sock, SOL_IPV6, what, &mreq, sizeof(mreq));
157 * sock - the socket to add the address to
161 int add_anycast_address(int sock, struct in6_addr *addr, const char *ifname) {
170 return do_anycast_setsockopt(sock, IPV6_JOIN_ANYCAST, addr, ifindex);
175 * sock - the socket to remove from, must have had the address added via add_anycast_address
178 int del_anycast_address(int sock, struct in6_addr *addr) {
179 return do_anycast_setsockopt(sock, IPV6_LEAVE_ANYCAST, addr, 0);
|
| /external/libnl/src/lib/ |
| cls.c | 32 struct nl_cache *nl_cli_cls_alloc_cache(struct nl_sock *sock, int ifindex,
38 if ((err = rtnl_cls_alloc_cache(sock, ifindex, parent, &cache)) < 0)
|
