mirror of
https://github.com/Mayuri-Chan/pyrofork.git
synced 2026-01-03 14:04:51 +00:00
Workaround proxy sockets not timing out properly
This commit is contained in:
parent
52effe19d5
commit
cf06939a55
1 changed files with 4 additions and 1 deletions
|
|
@ -20,6 +20,7 @@ import asyncio
|
||||||
import ipaddress
|
import ipaddress
|
||||||
import logging
|
import logging
|
||||||
import socket
|
import socket
|
||||||
|
|
||||||
import socks
|
import socks
|
||||||
|
|
||||||
log = logging.getLogger(__name__)
|
log = logging.getLogger(__name__)
|
||||||
|
|
@ -58,6 +59,8 @@ class TCP:
|
||||||
password=proxy.get("password", None)
|
password=proxy.get("password", None)
|
||||||
)
|
)
|
||||||
|
|
||||||
|
self.socket.settimeout(TCP.TIMEOUT)
|
||||||
|
|
||||||
log.info("Using proxy %s", hostname)
|
log.info("Using proxy %s", hostname)
|
||||||
else:
|
else:
|
||||||
self.socket = socket.socket(
|
self.socket = socket.socket(
|
||||||
|
|
@ -65,7 +68,7 @@ class TCP:
|
||||||
else socket.AF_INET
|
else socket.AF_INET
|
||||||
)
|
)
|
||||||
|
|
||||||
self.socket.setblocking(False)
|
self.socket.setblocking(False)
|
||||||
|
|
||||||
async def connect(self, address: tuple):
|
async def connect(self, address: tuple):
|
||||||
try:
|
try:
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue