|
75 | 75 |
|
76 | 76 | from future.backports.email import parser as email_parser |
77 | 77 | from future.backports.email import message as email_message |
| 78 | +from future.backports.socket import create_connection as socket_create_connection |
78 | 79 | import io |
79 | 80 | import os |
80 | 81 | import socket |
@@ -843,7 +844,7 @@ def _tunnel(self): |
843 | 844 |
|
844 | 845 | def connect(self): |
845 | 846 | """Connect to the host and port specified in __init__.""" |
846 | | - self.sock = socket.create_connection((self.host,self.port), |
| 847 | + self.sock = socket_create_connection((self.host,self.port), |
847 | 848 | self.timeout, self.source_address) |
848 | 849 | if self._tunnel_host: |
849 | 850 | self._tunnel() |
@@ -1226,7 +1227,7 @@ def __init__(self, host, port=None, key_file=None, cert_file=None, |
1226 | 1227 | def connect(self): |
1227 | 1228 | "Connect to a host on a given (SSL) port." |
1228 | 1229 |
|
1229 | | - sock = socket.create_connection((self.host, self.port), |
| 1230 | + sock = socket_create_connection((self.host, self.port), |
1230 | 1231 | self.timeout, self.source_address) |
1231 | 1232 |
|
1232 | 1233 | if self._tunnel_host: |
@@ -1266,7 +1267,7 @@ def connect(self): |
1266 | 1267 | # def connect(self): |
1267 | 1268 | # "Connect to a host on a given (SSL) port." |
1268 | 1269 |
|
1269 | | - # sock = socket.create_connection((self.host, self.port), |
| 1270 | + # sock = socket_create_connection((self.host, self.port), |
1270 | 1271 | # self.timeout, self.source_address) |
1271 | 1272 | # if self._tunnel_host: |
1272 | 1273 | # self.sock = sock |
|
0 commit comments