connect_socket: single srv for all protos
This commit is contained in:
@@ -30,6 +30,7 @@ class WorkerJob():
|
|||||||
else: return 1
|
else: return 1
|
||||||
|
|
||||||
def connect_socket(self):
|
def connect_socket(self):
|
||||||
|
srv = random.choice(config.servers).strip()
|
||||||
protos = ['http', 'socks5', 'socks4'] if self.proto is None else self.proto
|
protos = ['http', 'socks5', 'socks4'] if self.proto is None else self.proto
|
||||||
|
|
||||||
for proto in protos:
|
for proto in protos:
|
||||||
@@ -40,7 +41,6 @@ class WorkerJob():
|
|||||||
rocksock.RocksockProxyFromURL('%s://%s' % (proto, self.proxy)),
|
rocksock.RocksockProxyFromURL('%s://%s' % (proto, self.proxy)),
|
||||||
]
|
]
|
||||||
|
|
||||||
srv = random.choice(config.servers).strip()
|
|
||||||
try:
|
try:
|
||||||
sock = rocksock.Rocksock(host=srv, port=6697, ssl=True, proxies=proxies, timeout=config.timeout)
|
sock = rocksock.Rocksock(host=srv, port=6697, ssl=True, proxies=proxies, timeout=config.timeout)
|
||||||
sock.connect()
|
sock.connect()
|
||||||
|
|||||||
Reference in New Issue
Block a user