aboutsummaryrefslogtreecommitdiffstats
path: root/libmproxy/flow.py
diff options
context:
space:
mode:
authorAldo Cortesi <aldo@nullcube.com>2011-01-27 13:32:24 +1300
committerAldo Cortesi <aldo@nullcube.com>2011-01-27 13:32:24 +1300
commitefe11a0782a668b4310849f7696cc89004d82f45 (patch)
tree70169d8f7074480e5df469a3a2c9482cb28298da /libmproxy/flow.py
parent077272ec9703ff1b3f20f69c971adf63a6dd05c1 (diff)
downloadmitmproxy-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.py15
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