if not self.update():
break
+ self.session.time = time.time()
+
while self.parse():
pass
sock.listen(1)
while not self.shared.stopped():
session = TcpSession(*sock.accept())
- client_req = TcpClientRequestor(self.dispatcher, session)
- client_req.start()
self.dispatcher.add_session(session)
self.dispatcher.collect_garbage()
-
-
-
+ client_req = TcpClientRequestor(self.dispatcher, session)
+ client_req.start()