username/ppf
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

take care of "failinc"

Browse Source
This commit is contained in:
mickael
2019-01-06 14:57:09 +00:00
parent cff3e1304c
commit 1adf78119d
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
proxywatchd.py
View File

@@ -46,19 +46,19 @@ class WorkerJob():
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()
sock.send('%s\n' % random.choice(['NICK', 'USER', 'JOIN', 'MODE', 'PART', 'INVITE', 'KNOCK', 'WHOIS', 'WHO', 'NOTICE', 'PRIVMSG', 'PING', 'QUIT'])) sock.send('%s\n' % random.choice(['NICK', 'USER', 'JOIN', 'MODE', 'PART', 'INVITE', 'KNOCK', 'WHOIS', 'WHO', 'NOTICE', 'PRIVMSG', 'PING', 'QUIT']))
return sock, proto, duration, torhost, srv return sock, proto, duration, torhost, srv, 0
except KeyboardInterrupt as e: except KeyboardInterrupt as e:
raise(e) raise(e)
except: sock.disconnect() except: sock.disconnect()
return None, None, None, None, None return None, None, None, None, None, 1
def run(self): def run(self):
self.nextcheck = (time.time() + 1800 + ((1+int(self.failcount)) * 3600)) self.nextcheck = (time.time() + 1800 + ((1+int(self.failcount)) * 3600))
sock, proto, duration, tor, srv = self.connect_socket() sock, proto, duration, tor, srv, failinc = self.connect_socket()
if not sock: if not sock:
self.failcount += 1 self.failcount += failinc
return return
try: try:
recv = sock.recv(6) recv = sock.recv(6)