diff options
| author | Vyacheslav Bakhmutov <m0sth8@yandex-team.ru> | 2014-06-13 14:14:55 +0700 |
|---|---|---|
| committer | Vyacheslav Bakhmutov <m0sth8@yandex-team.ru> | 2014-06-13 14:14:55 +0700 |
| commit | b7c1d057828054a7e8d5f9ccf2c3c93ca8888ed3 (patch) | |
| tree | 1b9dca008c5b1be260b74fce024b620b00dd7cc6 /libmproxy/flow.py | |
| parent | 00fd243810954b1ea7c108482513a7e92f2e8000 (diff) | |
| download | mitmproxy-b7c1d057828054a7e8d5f9ccf2c3c93ca8888ed3.tar.gz mitmproxy-b7c1d057828054a7e8d5f9ccf2c3c93ca8888ed3.tar.bz2 mitmproxy-b7c1d057828054a7e8d5f9ccf2c3c93ca8888ed3.zip | |
Remove global should_exit and fix tests
Diffstat (limited to 'libmproxy/flow.py')
| -rw-r--r-- | libmproxy/flow.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/libmproxy/flow.py b/libmproxy/flow.py index a440b850..b6b49022 100644 --- a/libmproxy/flow.py +++ b/libmproxy/flow.py @@ -654,6 +654,7 @@ class FlowMaster(controller.Master): self.server.config, f, self.masterq, + self.should_exit ) rt.start() # pragma: no cover if block: @@ -792,8 +793,8 @@ class FilteredFlowWriter: class RequestReplayThread(threading.Thread): name="RequestReplayThread" - def __init__(self, config, flow, masterq): - self.config, self.flow, self.channel = config, flow, controller.Channel(masterq) + def __init__(self, config, flow, masterq, should_exit): + self.config, self.flow, self.channel = config, flow, controller.Channel(masterq, should_exit) threading.Thread.__init__(self) def run(self): |