/external/python/cpython3/Lib/asyncio/ |
D | trsock.py | 17 self._sock = sock 28 return self._sock.family 32 return self._sock.type 36 return self._sock.proto 65 return self._sock.fileno() 68 return self._sock.dup() 71 return self._sock.get_inheritable() 76 self._sock.shutdown(how) 79 return self._sock.getsockopt(*args, **kwargs) 82 self._sock.setsockopt(*args, **kwargs) [all …]
|
D | proactor_events.py | 54 self._sock = sock 74 if self._sock is None: 78 if self._sock is not None: 114 if self._sock is not None: 161 if hasattr(self._sock, 'shutdown'): 162 self._sock.shutdown(socket.SHUT_RDWR) 163 self._sock.close() 164 self._sock = None 299 self._read_fut = self._loop._proactor.recv(self._sock, 32768) 387 self._sock.shutdown(socket.SHUT_WR) [all …]
|
D | selector_events.py | 586 return await self.sock_sendfile(transp._sock, file, offset, count, 623 _sock = None variable in _SelectorTransport 637 self._sock = sock 653 if self._sock is None: 703 if self._sock is not None: 705 self._sock.close() 738 self._sock.close() 739 self._sock = None 774 base_events._set_nodelay(self._sock) 831 nbytes = self._sock.recv_into(buf) [all …]
|
/external/python/cpython2/Lib/ |
D | socket.py | 189 def __init__(self, family=AF_INET, type=SOCK_STREAM, proto=0, _sock=None): argument 190 if _sock is None: 191 _sock = _realsocket(family, type, proto) 192 self._sock = _sock 194 setattr(self, method, getattr(_sock, method)) 199 self._sock = _closedsocket() 200 dummy = self._sock._dummy 206 sock, addr = self._sock.accept() 207 return _socketobject(_sock=sock), addr 214 return _socketobject(_sock=self._sock) [all …]
|
D | ssl.py | 575 socket.__init__(self, _sock=sock._sock) 610 self._sslobj = self._context._wrap_socket(self._sock, server_side, 736 return self._sock.send(data, flags) 744 return self._sock.sendto(data, flags_or_addr) 746 return self._sock.sendto(data, flags_or_addr, addr) 774 return self._sock.recv(buflen, flags) 789 return self._sock.recv_into(buffer, nbytes, flags) 797 return self._sock.recvfrom(buflen, flags) 805 return self._sock.recvfrom_into(buffer, nbytes, flags) 863 … self._sslobj = self.context._wrap_socket(self._sock, False, self.server_hostname, ssl_sock=self) [all …]
|
D | CGIHTTPServer.py | 282 while select.select([self.rfile._sock], [], [], 0)[0]: 283 if not self.rfile._sock.recv(1):
|
/external/libnl/python/netlink/ |
D | core.py | 188 self._sock = capi.nl_socket_alloc_cb(cb._cb) 190 self._sock = capi.nl_socket_alloc() 194 if self._sock is None: 198 capi.nl_socket_free(self._sock) 205 return capi.nl_socket_get_local_port(self._sock) 209 capi.nl_socket_set_local_port(self._sock, int(value)) 213 return capi.nl_socket_get_peer_port(self._sock) 217 capi.nl_socket_set_peer_port(self._sock, int(value)) 221 return capi.nl_socket_get_peer_groups(self._sock) 225 capi.nl_socket_set_peer_groups(self._sock, value) [all …]
|
/external/python/cpython2/Lib/test/ |
D | test_urllib2net.py | 84 httpresponse = abused_fileobject._sock 256 self.assertIsNone(u.fp._sock.fp._sock.gettimeout()) 267 self.assertEqual(u.fp._sock.fp._sock.gettimeout(), 60) 278 self.assertIsNone(u.fp._sock.fp._sock.gettimeout()) 284 self.assertEqual(u.fp._sock.fp._sock.gettimeout(), 120) 292 self.assertIsNone(u.fp.fp._sock.gettimeout()) 302 self.assertEqual(u.fp.fp._sock.gettimeout(), 60) 312 self.assertIsNone(u.fp.fp._sock.gettimeout()) 317 self.assertEqual(u.fp.fp._sock.gettimeout(), 60)
|
D | test_socket.py | 279 s = socket.socket()._sock 1241 self._sock = sock 1245 n = self._sock.send(data, flags) 1250 self._sock.sendall(data, flags) 1254 return getattr(self._sock, attr) 1261 self.serv_file._sock = self.SocketMemo(self.serv_file._sock) 1282 self.assertEqual(self.serv_file._sock.getsent(), [msg1, msg2, msg3])
|
D | ssl_servers.py | 95 sock = self.rfile.raw._sock
|
/external/autotest/client/deps/lansim/src/py/ |
D | tuntap.py | 118 self._sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) 129 ifs = fcntl.ioctl(self._sock, pyiftun.SIOCGIFMTU, 136 ifs = fcntl.ioctl(self._sock, pyiftun.SIOCGIFFLAGS, 143 ifs = fcntl.ioctl(self._sock, pyiftun.SIOCSIFFLAGS, 154 ifs = fcntl.ioctl(self._sock, pyiftun.SIOCGIFADDR, 170 ifs = fcntl.ioctl(self._sock, pyiftun.SIOCSIFADDR, 177 ifs = fcntl.ioctl(self._sock, pyiftun.SIOCSIFNETMASK, 187 ifs = fcntl.ioctl(self._sock, pyiftun.SIOCGIFHWADDR, 202 ifs = fcntl.ioctl(self._sock, pyiftun.SIOCSIFHWADDR,
|
D | simulator_unittest.py | 35 self._sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 36 self._sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 37 self._sock.bind((host, port)) 38 self._sock.listen(1) 45 rlist, wlist, xlist = select.select([self._sock], [], [], 1.) 46 if self._sock in rlist: 47 conn, (addr, port) = self._sock.accept() 51 self._sock.close()
|
/external/python/cpython3/Lib/test/test_asyncio/ |
D | functional.py | 184 self._sock = sock 191 self._prog(TestSocketWrapper(self._sock)) 206 self._sock = sock 228 with self._sock: 229 self._sock.setblocking(False) 241 [self._sock, self._s1], [], [], self._timeout) 246 if self._sock in r: 248 conn, addr = self._sock.accept() 274 return self._sock.getsockname()
|
/external/python/cpython3/Lib/test/ |
D | test_urllib2net.py | 272 self.assertIsNone(u.fp.raw._sock.gettimeout()) 284 self.assertEqual(u.fp.raw._sock.gettimeout(), 60) 296 self.assertIsNone(u.fp.raw._sock.gettimeout()) 303 self.assertEqual(u.fp.raw._sock.gettimeout(), 120) 313 self.assertIsNone(u.fp.fp.raw._sock.gettimeout()) 325 self.assertEqual(u.fp.fp.raw._sock.gettimeout(), 60) 337 self.assertIsNone(u.fp.fp.raw._sock.gettimeout()) 344 self.assertEqual(u.fp.fp.raw._sock.gettimeout(), 60)
|
/external/autotest/client/cros/netprotos/ |
D | zeroconf.py | 90 self._sock = host.socket(socket.AF_INET, socket.SOCK_DGRAM) 91 self._sock.listen(MDNS_IP_ADDR, MDNS_PORT, self._mdns_request) 98 self._sock.close() 226 self._sock.send(str(resp_dns), MDNS_IP_ADDR, MDNS_PORT) 465 self._sock.send(str(mdns), MDNS_IP_ADDR, MDNS_PORT)
|
/external/python/cpython2/Lib/multiprocessing/ |
D | reduction.py | 184 s = socket.socket(_sock=s) 193 _sock = fromfd(fd, family, type_, proto) 195 return _sock
|
/external/libnl/python/netlink/route/ |
D | link.py | 381 return capi.rtnl_link_enslave(sock._sock, self._rtnl_link, slave._rtnl_link) 387 return capi.rtnl_link_release(sock._sock, self._rtnl_link, slave._rtnl_link) 396 ret = capi.rtnl_link_add(sock._sock, self._rtnl_link, flags) 407 ret = capi.rtnl_link_change(sock._sock, self._orig, self._rtnl_link, flags) 416 ret = capi.rtnl_link_delete(sock._sock, self._rtnl_link) 541 link = capi.get_from_kernel(sock._sock, 0, name)
|
D | address.py | 317 ret = capi.rtnl_addr_add(socket._sock, self._rtnl_addr, flags) 323 ret = capi.rtnl_addr_delete(socket._sock, self._rtnl_addr, flags)
|
/external/python/cpython3/Lib/ |
D | socket.py | 682 self._sock = sock 704 return self._sock.recv_into(b) 722 return self._sock.send(b) 754 return self._sock.fileno() 774 self._sock._decref_socketios() 775 self._sock = None
|
D | socketserver.py | 793 self._sock = sock 799 self._sock.sendall(b) 804 return self._sock.fileno()
|
/external/llvm-project/lldb/packages/Python/lldbsuite/test/tools/lldb-server/ |
D | lldbgdbserverutils.py | 958 self._sock = sock 962 self._sock.sendall(frame) 966 new_bytes = self._sock.recv(4096) 1029 """).format(self._proc, self._sock, self._receive_buffer,
|
/external/python/httplib2/tests/ |
D | __init__.py | 64 self._sock = sock 66 self._sock = None 74 if self._sock is None: 77 chunk = self._sock.recv(8 << 10)
|
/external/python/httplib2/python3/httplib2/ |
D | socks.py | 153 self, family=socket.AF_INET, type=socket.SOCK_STREAM, proto=0, _sock=None argument 155 _orgsocket.__init__(self, family, type, proto, _sock)
|
/external/python/httplib2/python2/httplib2/ |
D | socks.py | 153 self, family=socket.AF_INET, type=socket.SOCK_STREAM, proto=0, _sock=None argument 155 _orgsocket.__init__(self, family, type, proto, _sock)
|
/external/rust/crates/tokio/tests/ |
D | tcp_accept.rs | 151 let _sock = TcpStream::connect(addr).await.unwrap(); in accept_many() localVariable
|