Grasscutters/mitmproxy
3
0
Fork 0
mirror of https://github.com/Grasscutters/mitmproxy.git synced 2024-11-26 02:10:59 +00:00
Code Issues Projects Releases Wiki Activity

Refactoring.

Browse Source
This commit is contained in:
Aldo Cortesi 2011-03-29 10:57:50 +13:00
parent c3105153a5
commit d917cfd916
2 changed files with 8 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
libmproxy/console.py
View File

@ -1023,6 +1023,10 @@ class ConsoleMaster(flow.FlowMaster):
self.onekey = False
self.view_connlist()
self.masterq = Queue.Queue()
slave = controller.Slave(self.masterq, self.server)
slave.start()
self.ui.run_wrapper(self.loop)
# If True, quit just pops out to connection list view.
print >> sys.stderr, "Shutting down..."
@ -1294,16 +1298,12 @@ class ConsoleMaster(flow.FlowMaster):
return size
def loop(self):
q = Queue.Queue()
self.masterq = q
slave = controller.Slave(q, self.server)
slave.start()
try:
while not controller.exit:
startloop = time.time()
self.statusbar.redraw()
size = self.drawscreen()
self.tick(q)
self.tick(self.masterq)
self.ui.set_input_timeouts(max_wait=0.1)
keys = self.ui.get_input()
for k in keys:

8
libmproxy/controller.py
View File

@ -59,7 +59,7 @@ class Slave(threading.Thread):
class Master:
def __init__(self, server):
self.server = server
self.masterq = None
self.masterq = Queue.Queue()
def tick(self, q):
try:
@ -75,12 +75,10 @@ class Master:
pass
def run(self):
q = Queue.Queue()
self.masterq = q
slave = Slave(q, self.server)
slave = Slave(self.masterq, self.server)
slave.start()
while not exit:
self.tick(q)
self.tick(self.masterq)
self.shutdown()
def handle(self, msg):