(s, address, expiration)
| 1191 | |
| 1192 | |
| 1193 | def _connect(s, address, expiration): |
| 1194 | err = s.connect_ex(address) |
| 1195 | if err == 0: |
| 1196 | return |
| 1197 | if err in (errno.EINPROGRESS, errno.EWOULDBLOCK, errno.EALREADY): |
| 1198 | _wait_for_writable(s, expiration) |
| 1199 | err = s.getsockopt(socket.SOL_SOCKET, socket.SO_ERROR) |
| 1200 | if err != 0: |
| 1201 | raise OSError(err, os.strerror(err)) |
| 1202 | |
| 1203 | |
| 1204 | def tcp( |
no test coverage detected
searching dependent graphs…