Skip to content
Snippets Groups Projects
Commit af2e7c89 authored by zimio's avatar zimio
Browse files

move plug_idle into socks5queue

parent af9d304c
No related branches found
No related tags found
No related merge requests found
......@@ -328,6 +328,8 @@ class SocksQueue:
if sock_hash not in self.senders:
self.senders[sock_hash] = Socks5Sender(self.idlequeue, sock_hash, self,
sock[0], sock[1][0], sock[1][1], fingerprint='server')
# Start waiting for data
self.idlequeue.plug_idle(self.senders[sock_hash], False, True)
self.connected += 1
def process_result(self, result, actor):
......@@ -764,8 +766,7 @@ class Socks5Sender(Socks5, IdleObject):
self.connected = True
self.state = 1 # waiting for first bytes
self.file_props = None
# start waiting for data
self.idlequeue.plug_idle(self, False, True)
def read_timeout(self):
self.idlequeue.remove_timeout(self.fd)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment