Lines Matching refs:socket
6 import socket
24 def try_address(host, port=0, family=socket.AF_INET):
28 sock = socket.socket(family, socket.SOCK_STREAM)
30 except (socket.error, socket.gaierror):
53 self.serv = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
64 self.serv = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
176 self.cli = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
190 self.cli = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
232 self.serv, self.cli = socket.socketpair()
254 s = _socket.socket(_socket.AF_INET, _socket.SOCK_STREAM)
266 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
279 s = socket.socket()._sock
289 raise socket.error
291 raise socket.herror
293 raise socket.gaierror
294 self.assertRaises(socket.error, raise_error,
296 self.assertRaises(socket.error, raise_herror,
298 self.assertRaises(socket.error, raise_gaierror,
303 s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
342 socket.AF_INET
343 socket.SOCK_STREAM
344 socket.SOCK_DGRAM
345 socket.SOCK_RAW
346 socket.SOCK_RDM
347 socket.SOCK_SEQPACKET
348 socket.SOL_SOCKET
349 socket.SO_REUSEADDR
353 hostname = socket.gethostname()
355 ip = socket.gethostbyname(hostname)
356 except socket.error:
361 hname, aliases, ipaddrs = socket.gethostbyaddr(ip)
362 except socket.error:
366 fqhn = socket.getfqdn(ip)
377 socket.getnameinfo(__name__,0)
386 socket.getnameinfo(('x', 0, 0, 0), 0)
387 except socket.error:
393 sizes = {socket.htonl: 32, socket.ntohl: 32,
394 socket.htons: 16, socket.ntohs: 16}
408 socket.ntohl(k)
409 socket.ntohs(k)
410 socket.htonl(k)
411 socket.htons(k)
413 self.assertRaises(OverflowError, socket.ntohl, k)
414 self.assertRaises(OverflowError, socket.ntohs, k)
415 self.assertRaises(OverflowError, socket.htonl, k)
416 self.assertRaises(OverflowError, socket.htons, k)
434 port = socket.getservbyname(service, 'tcp')
436 except socket.error:
439 raise socket.error
441 port2 = socket.getservbyname(service)
445 udpport = socket.getservbyname(service, 'udp')
446 except socket.error:
451 eq(socket.getservbyport(port2), service)
452 eq(socket.getservbyport(port, 'tcp'), service)
454 eq(socket.getservbyport(udpport, 'udp'), service)
456 self.assertRaises(OverflowError, socket.getservbyport, -1)
457 self.assertRaises(OverflowError, socket.getservbyport, 65536)
462 self.assertEqual(socket.getdefaulttimeout(), None)
463 s = socket.socket()
468 socket.setdefaulttimeout(10)
469 self.assertEqual(socket.getdefaulttimeout(), 10)
470 s = socket.socket()
475 socket.setdefaulttimeout(None)
476 self.assertEqual(socket.getdefaulttimeout(), None)
477 s = socket.socket()
482 self.assertRaises(ValueError, socket.setdefaulttimeout, -1)
485 self.assertRaises(TypeError, socket.setdefaulttimeout, "spam")
487 @unittest.skipUnless(hasattr(socket, 'inet_aton'),
492 self.assertEqual('\x00'*4, socket.inet_aton('0.0.0.0'))
493 self.assertEqual('\xff'*4, socket.inet_aton('255.255.255.255'))
495 @unittest.skipUnless(hasattr(socket, 'inet_pton'),
498 from socket import inet_aton as f, inet_pton, AF_INET
512 @unittest.skipUnless(hasattr(socket, 'inet_pton'),
516 from socket import inet_pton, AF_INET6, has_ipv6
531 @unittest.skipUnless(hasattr(socket, 'inet_ntop'),
534 from socket import inet_ntoa as f, inet_ntop, AF_INET
546 @unittest.skipUnless(hasattr(socket, 'inet_ntop'),
550 from socket import inet_ntop, AF_INET6, has_ipv6
574 tempsock = socket.socket()
583 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
591 my_ip_addr = socket.gethostbyname(socket.gethostname())
592 except socket.error:
601 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
603 reuse = sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR)
608 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
610 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
611 reuse = sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR)
616 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
619 self.assertRaises(socket.error, sock.send, "spam")
623 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
624 self.assertEqual(sock.family, socket.AF_INET)
625 self.assertEqual(sock.type, socket.SOCK_STREAM)
630 sock = socket.socket()
651 self.assertTrue(hasattr(socket.socket, 'ioctl'))
652 self.assertTrue(hasattr(socket, 'SIO_RCVALL'))
653 self.assertTrue(hasattr(socket, 'RCVALL_ON'))
654 self.assertTrue(hasattr(socket, 'RCVALL_OFF'))
655 self.assertTrue(hasattr(socket, 'SIO_KEEPALIVE_VALS'))
656 s = socket.socket()
659 s.ioctl(socket.SIO_KEEPALIVE_VALS, (1, 100, 100))
663 socket.getaddrinfo('localhost', 80)
664 except socket.gaierror as err:
665 if err.errno == socket.EAI_SERVICE:
670 for info in socket.getaddrinfo(HOST, None):
674 socket.getaddrinfo('localhost', 80)
675 socket.getaddrinfo('127.0.0.1', 80)
676 socket.getaddrinfo(None, 80)
678 socket.getaddrinfo('::1', 80)
681 socket.getaddrinfo(HOST, "http")
682 socket.getaddrinfo(HOST, 80)
683 socket.getaddrinfo(HOST, 80L)
684 socket.getaddrinfo(HOST, None)
686 infos = socket.getaddrinfo(HOST, None, socket.AF_INET)
688 self.assertEqual(family, socket.AF_INET)
689 infos = socket.getaddrinfo(HOST, None, 0, socket.SOCK_STREAM)
691 self.assertEqual(socktype, socket.SOCK_STREAM)
693 socket.getaddrinfo(HOST, None, 0, 0, socket.SOL_TCP)
694 socket.getaddrinfo(HOST, None, 0, 0, 0, socket.AI_PASSIVE)
697 socket.getaddrinfo(None, 0, socket.AF_UNSPEC, socket.SOCK_STREAM, 0,
698 socket.AI_PASSIVE)
701 if hasattr(socket, 'AI_NUMERICSERV'):
705 socket.getaddrinfo("localhost", None, 0, 0, 0,
706 socket.AI_NUMERICSERV)
707 except socket.gaierror:
712 if not hasattr(signal, 'alarm') or not hasattr(socket, 'socketpair'):
721 c, s = socket.socketpair()
733 self.assertRaises(socket.timeout, c.sendall,
749 srv = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
758 srv = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
765 self.assertRaises(OverflowError, socket.getnameinfo,
767 s = socket.socket(socket.AF_INET6, socket.SOCK_STREAM)
830 @unittest.skipUnless(hasattr(socket, 'fromfd'),
835 sock = socket.fromfd(fd, socket.AF_INET, socket.SOCK_STREAM)
924 @unittest.skipUnless(hasattr(socket, 'socketpair'),
961 except socket.error:
987 except socket.error:
1017 except socket.error:
1153 raise socket.error(errno.EINTR)
1162 fo = socket._fileobject(mock_sock, **kwargs)
1173 fo = socket._fileobject(mock_sock, **kwargs)
1198 fo = socket._fileobject(mock_sock, bufsize=0)
1307 self.cli = socket.create_connection((HOST, self.port))
1315 class MockSocket(socket.socket):
1317 raise socket.timeout('timed out')
1322 old_socket = socket.socket
1323 socket.socket = self.MockSocket
1327 socket.socket = old_socket
1331 cli = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
1333 with self.assertRaises(socket.error) as cm:
1341 with self.assertRaises(socket.error) as cm:
1342 socket.create_connection((HOST, port))
1372 with self.assertRaises(socket.timeout):
1373 socket.create_connection((HOST, 1234))
1397 self.cli = socket.create_connection((HOST, self.port), timeout=30)
1403 self.cli = socket.create_connection((HOST, self.port), timeout=30,
1413 self.assertTrue(socket.getdefaulttimeout() is None)
1414 socket.setdefaulttimeout(42)
1416 self.cli = socket.create_connection((HOST, self.port))
1419 socket.setdefaulttimeout(None)
1425 self.assertTrue(socket.getdefaulttimeout() is None)
1426 socket.setdefaulttimeout(30)
1428 self.cli = socket.create_connection((HOST, self.port), timeout=None)
1431 socket.setdefaulttimeout(None)
1436 self.cli = socket.create_connection((HOST, self.port), timeout=30)
1441 self.cli = socket.create_connection((HOST, self.port), 30)
1468 self.cli = sock = socket.create_connection((HOST, self.port))
1473 self.cli = sock = socket.create_connection((HOST, self.port), timeout=1)
1474 self.assertRaises(socket.timeout, lambda: sock.recv(5))
1492 f = socket._fileobject(s)
1497 f = socket._fileobject(s, close=True)
1507 self.assertRaises(socket.timeout, raise_timeout,
1515 except socket.timeout:
1517 except socket.error:
1540 except socket.timeout:
1564 self.assertRaises(socket.timeout, raise_timeout,
1572 except socket.timeout:
1574 except socket.error:
1584 self.assertTrue(issubclass(socket.error, Exception))
1585 self.assertTrue(issubclass(socket.herror, socket.error))
1586 self.assertTrue(issubclass(socket.gaierror, socket.error))
1587 self.assertTrue(issubclass(socket.timeout, socket.error))
1596 s1 = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
1599 s2 = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
1607 s = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
1613 s = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
1614 self.assertRaises(socket.error, s.bind, address)
1713 if not hasattr(socket, "AF_TIPC"):
1735 srv = socket.socket(socket.AF_TIPC, socket.SOCK_RDM)
1736 cli = socket.socket(socket.AF_TIPC, socket.SOCK_RDM)
1738 srv.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
1739 srvaddr = (socket.TIPC_ADDR_NAMESEQ, TIPC_STYPE,
1743 sendaddr = (socket.TIPC_ADDR_NAME, TIPC_STYPE,
1761 self.srv = socket.socket(socket.AF_TIPC, socket.SOCK_STREAM)
1762 self.srv.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
1763 srvaddr = (socket.TIPC_ADDR_NAMESEQ, TIPC_STYPE,
1775 self.cli = socket.socket(socket.AF_TIPC, socket.SOCK_STREAM)
1776 addr = (socket.TIPC_ADDR_NAME, TIPC_STYPE,