| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Demo/sockets/ |
| D | mcast.py | 19 import socket
32 addrinfo = socket.getaddrinfo(group, None)[0]
34 s = socket.socket(addrinfo[0], socket.SOCK_DGRAM)
38 if addrinfo[0] == socket.AF_INET: # IPv4
39 s.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, ttl_bin)
41 s.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_MULTICAST_HOPS, ttl_bin)
51 addrinfo = socket.getaddrinfo(group, None)[0]
54 s = socket.socket(addrinfo[0], socket.SOCK_DGRAM)
58 s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
63 group_bin = socket.inet_pton(addrinfo[0], addrinfo[4][0])
[all …]
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| D | test_socket.py | 7 import socket
20 def try_address(host, port=0, family=socket.AF_INET):
24 sock = socket.socket(family, socket.SOCK_STREAM)
26 except (socket.error, socket.gaierror):
34 SUPPORTS_IPV6 = socket.has_ipv6 and try_address('::1', family=socket.AF_INET6)
49 self.serv = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
60 self.serv = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
173 self.cli = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
187 self.cli = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
229 self.serv, self.cli = socket.socketpair()
[all …]
|
| D | test_asyncore.py | 5 import socket
34 self.socket = dummysocket()
37 self.socket.close()
69 except socket.timeout:
194 self.assertEqual(c.socket.closed, False)
210 self.assertEqual(c.socket.closed, True)
313 d = asyncore.dispatcher(socket.socket())
323 self.assertEqual(family, socket.AF_INET)
356 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
371 d.create_socket(socket.AF_INET, socket.SOCK_STREAM)
[all …]
|
| D | test_ssl.py | 7 import socket
40 ssl.sslwrap_simple(socket.socket(socket.AF_INET))
47 ssl.sslwrap_simple(socket.socket(socket.AF_INET)._sock)
67 s = socket.socket(socket.AF_INET)
158 s = ssl.wrap_socket(socket.socket(socket.AF_INET),
161 s = ssl.wrap_socket(socket.socket(socket.AF_INET),
166 s = ssl.wrap_socket(socket.socket(socket.AF_INET),
175 s = socket.socket(socket.AF_INET)
185 s = socket.socket(socket.AF_INET)
187 self.assertRaises(socket.error, ss.recv, 1)
[all …]
|
| D | test_timeout.py | 10 import socket
17 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
102 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
122 self.assertRaises(socket.error, self.sock.connect, addr)
139 self.assertRaises(socket.timeout, self.sock.recv, 1024)
156 self.assertRaises(socket.error, self.sock.accept)
167 self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
173 self.assertRaises(socket.error, self.sock.recvfrom, 8192)
|
| D | test_urllib2net.py | 7 import socket
85 self.assertTrue(abused_fileobject.__class__ is socket._fileobject)
89 self.assertTrue(fileobject.__class__ is socket._fileobject)
214 if isinstance(err[0], socket.timeout):
224 except socket.timeout:
242 self.assertTrue(socket.getdefaulttimeout() is None)
249 self.assertTrue(socket.getdefaulttimeout() is None)
252 socket.setdefaulttimeout(60)
256 socket.setdefaulttimeout(None)
260 self.assertTrue(socket.getdefaulttimeout() is None)
[all …]
|
| D | test_poplib.py | 9 import socket
111 def __init__(self, address, af=socket.AF_INET):
114 self.create_socket(af, socket.SOCK_STREAM)
119 self.host, self.port = self.socket.getsockname()[:2]
234 self.socket = ssl.wrap_socket(self.socket, certfile=CERTFILE,
246 self.socket.do_handshake()
254 except socket.error, err:
283 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
296 except socket.timeout:
306 self.assertTrue(socket.getdefaulttimeout() is None)
[all …]
|
| D | test_ftplib.py | 9 import socket
102 s = socket.create_connection((ip, port), timeout=10)
107 sock = socket.socket()
108 sock.bind((self.socket.getsockname()[0], 0))
121 s = socket.create_connection((ip, port), timeout=10)
126 sock = socket.socket(socket.AF_INET6)
127 sock.bind((self.socket.getsockname()[0], 0))
211 def __init__(self, address, af=socket.AF_INET):
214 self.create_socket(af, socket.SOCK_STREAM)
219 self.host, self.port = self.socket.getsockname()[:2]
[all …]
|
| D | test_smtplib.py | 3 import socket
26 except socket.timeout:
49 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
80 self.assertTrue(socket.getdefaulttimeout() is None)
81 socket.setdefaulttimeout(30)
85 socket.setdefaulttimeout(None)
90 self.assertTrue(socket.getdefaulttimeout() is None)
91 socket.setdefaulttimeout(30)
95 socket.setdefaulttimeout(None)
127 except socket.timeout:
[all …]
|
| D | test_httplib.py | 5 import socket
38 raise socket.error(errno.EPIPE, "gotcha")
307 self.assertRaises(socket.error,
358 self.serv = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
391 self.serv = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
404 self.assertTrue(socket.getdefaulttimeout() is None)
405 socket.setdefaulttimeout(30)
410 socket.setdefaulttimeout(None)
415 self.assertTrue(socket.getdefaulttimeout() is None)
416 socket.setdefaulttimeout(30)
[all …]
|
| D | test_socketserver.py | 10 import socket
27 HAVE_UNIX_SOCKETS = hasattr(socket, "AF_UNIX")
85 if proto == socket.AF_INET:
123 self.assertEqual(server.server_address, server.socket.getsockname())
157 s = socket.socket(proto, socket.SOCK_STREAM)
168 s = socket.socket(proto, socket.SOCK_DGRAM)
|
| D | test_telnetlib.py | 1 import socket
37 except socket.timeout:
49 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
68 self.assertTrue(socket.getdefaulttimeout() is None)
69 socket.setdefaulttimeout(30)
73 socket.setdefaulttimeout(None)
79 self.assertTrue(socket.getdefaulttimeout() is None)
80 socket.setdefaulttimeout(30)
84 socket.setdefaulttimeout(None)
102 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/ |
| D | SocketServer.py | 132 import socket
145 if hasattr(socket, "AF_UNIX"):
260 timeout = self.socket.gettimeout()
280 except socket.error:
394 address_family = socket.AF_INET
396 socket_type = socket.SOCK_STREAM
405 self.socket = socket.socket(self.address_family,
418 self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
419 self.socket.bind(self.server_address)
420 self.server_address = self.socket.getsockname()
[all …]
|
| D | asyncore.py | 50 import socket
115 except socket.error, e:
248 except socket.error, err:
260 self.socket = None
294 sock = socket.socket(family, type)
299 self.socket = sock
307 self.socket.setsockopt(
308 socket.SOL_SOCKET, socket.SO_REUSEADDR,
309 self.socket.getsockopt(socket.SOL_SOCKET,
310 socket.SO_REUSEADDR) | 1
[all …]
|
| D | ssl.py | 89 from socket import socket, _fileobject, _delegate_methods, error as socket_error
90 from socket import getnameinfo as _getnameinfo
94 class SSLSocket(socket):
105 socket.__init__(self, _sock=sock._sock)
119 socket.getpeername(self)
224 return socket.sendall(self, data, flags)
283 socket.shutdown(self, how)
288 socket.close(self)
307 socket.connect(self, addr)
335 newsock, addr = socket.accept(self)
[all …]
|
| D | smtplib.py | 44 import socket
228 timeout=socket._GLOBAL_DEFAULT_TIMEOUT):
251 fqdn = socket.getfqdn()
258 addr = socket.gethostbyname(socket.gethostname())
259 except socket.gaierror:
277 return socket.create_connection((port, host), timeout)
297 raise socket.error, "nonnumeric port"
315 except socket.error:
348 except socket.error:
764 timeout=socket._GLOBAL_DEFAULT_TIMEOUT):
[all …]
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.10/Lib/ |
| D | SocketServer.py | 132 import socket
146 if hasattr(socket, "AF_UNIX"):
271 timeout = self.socket.gettimeout()
291 except socket.error:
405 address_family = socket.AF_INET
407 socket_type = socket.SOCK_STREAM
416 self.socket = socket.socket(self.address_family,
433 self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
434 self.socket.bind(self.server_address)
435 self.server_address = self.socket.getsockname()
[all …]
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/logging/ |
| D | handlers.py | 27 import logging, socket, os, cPickle, struct, time, re
455 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
479 except socket.error:
512 except socket.error:
594 s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
713 facility=LOG_USER, socktype=socket.SOCK_DGRAM):
732 self.socket = socket.socket(socket.AF_INET, socktype)
733 if socktype == socket.SOCK_STREAM:
734 self.socket.connect(address)
738 self.socket = socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM)
[all …]
|
| /device/google/cuttlefish/guest/hals/ril/libril/ |
| D | RilSapSocket.cpp | 90 RLOGD("SocketName:%s",current->socket->name); in printList()
91 RLOGD("Socket id:%d",current->socket->id); in printList()
104 if(socketId == current->socket->id) { in getSocketById()
105 sap_socket = current->socket; in getSocketById()
149 RilSapSocket* socket = NULL; in addSocketToList() local
153 socket = new RilSapSocket(socketName, socketid, uimFuncs); in addSocketToList()
157 delete socket; in addSocketToList()
160 listItem->socket = socket; in addSocketToList()
163 RLOGD("Adding socket with id: %d", socket->id); in addSocketToList()
183 if(strcmp(current->socket->name, socketName) == 0) { in SocketExists()
|
| /device/generic/goldfish/radio/libril/ |
| D | RilSapSocket.cpp | 90 RLOGD("SocketName:%s",current->socket->name); in printList()
91 RLOGD("Socket id:%d",current->socket->id); in printList()
104 if(socketId == current->socket->id) { in getSocketById()
105 sap_socket = current->socket; in getSocketById()
149 RilSapSocket* socket = NULL; in addSocketToList() local
153 socket = new RilSapSocket(socketName, socketid, uimFuncs); in addSocketToList()
157 delete socket; in addSocketToList()
160 listItem->socket = socket; in addSocketToList()
163 RLOGD("Adding socket with id: %d", socket->id); in addSocketToList()
183 if(strcmp(current->socket->name, socketName) == 0) { in SocketExists()
|
| /device/generic/goldfish/wifi/mac80211_create_radios/ |
| D | main.cpp | 120 int createRadios(struct nl_sock* socket, const int netlinkFamily, in createRadios() argument
133 int ret = nl_send_auto(socket, msg.get()); in createRadios()
144 std::unique_ptr<struct nl_sock, nl_sock_deleter> socket(nl_socket_alloc()); in manageRadios() local
145 if (!socket) { RETURN_ERROR("nl_socket_alloc", 1); } in manageRadios()
148 ret = genl_connect(socket.get()); in manageRadios()
151 const int netlinkFamily = genl_ctrl_resolve(socket.get(), kHwSimFamilyName); in manageRadios()
154 ret = createRadios(socket.get(), netlinkFamily, nRadios, macPrefix); in manageRadios()
|
| /device/google/cuttlefish/host/commands/run_cvd/ |
| D | launch.cc | 185 auto socket = cvd::SharedFD::VsockServer(SOCK_STREAM); in LaunchLogcatReceiverIfEnabled() local
186 if (!socket->IsOpen()) { in LaunchLogcatReceiverIfEnabled()
188 << socket->StrError(); in LaunchLogcatReceiverIfEnabled()
192 cmd.AddParameter("-server_fd=", socket); in LaunchLogcatReceiverIfEnabled()
195 return { socket->VsockServerPort() }; in LaunchLogcatReceiverIfEnabled()
200 auto socket = cvd::SharedFD::VsockServer(SOCK_STREAM); in LaunchConfigServer() local
201 if (!socket->IsOpen()) { in LaunchConfigServer()
203 << socket->StrError(); in LaunchConfigServer()
207 cmd.AddParameter("-server_fd=", socket); in LaunchConfigServer()
210 return { socket->VsockServerPort() }; in LaunchConfigServer()
[all …]
|
| /device/google/cuttlefish/shared/sepolicy/vendor/ |
| D | adbd.te | 1 allow adbd self:{ socket vsock_socket } {create listen accept rw_socket_perms_no_ioctl};
3 allow adbd unlabeled:{socket vsock_socket} rw_socket_perms_no_ioctl;
10 allow su unlabeled:{ socket vsock_socket } rw_socket_perms_no_ioctl;
|
| D | socket_vsock_proxy.te | 7 allow socket_vsock_proxy self:{ socket vsock_socket } { create read write listen accept bind };
9 # TODO: socket returned by accept() has unlabeled context on it. Give it a
11 allow socket_vsock_proxy unlabeled:{ socket vsock_socket } { getopt read write shutdown };
|
| /device/google/cuttlefish/common/frontend/socket_vsock_proxy/ |
| D | main.cpp | 38 explicit SocketSender(cvd::SharedFD socket) : socket_{socket} {} in SocketSender() argument
77 explicit SocketReceiver(cvd::SharedFD socket) : socket_{socket} {} in SocketReceiver() argument
131 cvd::SharedFD socket) { in HandleConnection() argument
133 std::thread(SocketToVsock, SocketReceiver{socket}, SocketSender{vsock}); in HandleConnection()
134 VsockToSocket(SocketSender{socket}, SocketReceiver{vsock}); in HandleConnection()
|