diff options
author | Aldo Cortesi <aldo@nullcube.com> | 2011-01-27 13:32:24 +1300 |
---|---|---|
committer | Aldo Cortesi <aldo@nullcube.com> | 2011-01-27 13:32:24 +1300 |
commit | efe11a0782a668b4310849f7696cc89004d82f45 (patch) | |
tree | 70169d8f7074480e5df469a3a2c9482cb28298da /libmproxy/flow.py | |
parent | 077272ec9703ff1b3f20f69c971adf63a6dd05c1 (diff) | |
download | mitmproxy-efe11a0782a668b4310849f7696cc89004d82f45.tar.gz mitmproxy-efe11a0782a668b4310849f7696cc89004d82f45.tar.bz2 mitmproxy-efe11a0782a668b4310849f7696cc89004d82f45.zip |
Kill deadlock that sometimes occurred on shutdown.
Diffstat (limited to 'libmproxy/flow.py')
-rw-r--r-- | libmproxy/flow.py | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/libmproxy/flow.py b/libmproxy/flow.py index 8eb7342a..296b6738 100644 --- a/libmproxy/flow.py +++ b/libmproxy/flow.py @@ -78,14 +78,13 @@ class Flow: return isinstance(self.connection, ReplayConnection) def kill(self): - if self.intercepting: - if not self.request.acked: - self.request.kill = True - self.request.ack() - elif self.response and not self.response.acked: - self.response.kill = True - self.response.ack() - self.intercepting = False + if self.request and not self.request.acked: + self.request.kill = True + self.request.ack() + elif self.response and not self.response.acked: + self.response.kill = True + self.response.ack() + self.intercepting = False def intercept(self): self.intercepting = True |