31 # create listening socket on random port |
31 # create listening socket on random port |
32 self.ls = _socket.socket(socket.AF_INET, socket.SOCK_STREAM) |
32 self.ls = _socket.socket(socket.AF_INET, socket.SOCK_STREAM) |
33 self.ls.listen(1) |
33 self.ls.listen(1) |
34 |
34 |
35 self.sockaddr = af_inet.sockaddr_in('127.0.0.1', self.ls.getsockname().port) |
35 self.sockaddr = af_inet.sockaddr_in('127.0.0.1', self.ls.getsockname().port) |
36 self.addr = endpoint.SockAddr(self.sockaddr) |
36 self.addr = endpoint.Address(self.sockaddr) |
37 |
37 |
38 def test_connect (self) : |
38 def test_connect (self) : |
39 cc = tcp.Client(self.addr) |
39 cc = tcp.Client(self.addr) |
40 cs = cc.connect() |
40 cs = cc.connect() |
41 |
41 |
43 |
43 |
44 def test_connect_bind (self) : |
44 def test_connect_bind (self) : |
45 sockaddr = af_inet.sockaddr_in('127.0.0.1', self.sockaddr.port + 1) |
45 sockaddr = af_inet.sockaddr_in('127.0.0.1', self.sockaddr.port + 1) |
46 |
46 |
47 # connect with bind() |
47 # connect with bind() |
48 cc = tcp.Client(self.addr, bind_endpoint=endpoint.SockAddr(sockaddr)) |
48 cc = tcp.Client(self.addr, bind_endpoint=endpoint.Address(sockaddr)) |
49 cs = cc.connect() |
49 cs = cc.connect() |
50 |
50 |
51 self.assertEquals(cs.sock.getsockname(), sockaddr) |
51 self.assertEquals(cs.sock.getsockname(), sockaddr) |
52 self.assertEquals(cs.sock.getpeername(), self.sockaddr) |
52 self.assertEquals(cs.sock.getpeername(), self.sockaddr) |
53 |
53 |
54 def test_connect_bind6 (self) : |
54 def test_connect_bind6 (self) : |
55 sockaddr = af_inet6.sockaddr_in6('::1', self.sockaddr.port + 1) |
55 sockaddr = af_inet6.sockaddr_in6('::1', self.sockaddr.port + 1) |
56 |
56 |
57 # connect with bind() |
57 # connect with bind() |
58 cc = tcp.Client(self.addr, bind_endpoint=endpoint.SockAddr(sockaddr)) |
58 cc = tcp.Client(self.addr, bind_endpoint=endpoint.Address(sockaddr)) |
59 |
59 |
60 # should fail (IPv6 -> IPv4) |
60 # should fail (IPv6 -> IPv4) |
61 self.assertRaises(socket.SocketConnectEndpointError, cc.connect) |
61 self.assertRaises(socket.SocketConnectEndpointError, cc.connect) |
62 |
62 |
63 def test_connect_inet (self) : |
63 def test_connect_inet (self) : |
64 cc = tcp.Client(endpoint.InetAddr('localhost', self.sockaddr.port)) |
64 cc = tcp.Client(endpoint.InetEndpoint('localhost', self.sockaddr.port)) |
65 cs = cc.connect() |
65 cs = cc.connect() |
66 |
66 |
67 self.assertEquals(cs.sock.getpeername(), self.sockaddr) |
67 self.assertEquals(cs.sock.getpeername(), self.sockaddr) |
68 |
68 |
69 |
69 |