aboutsummaryrefslogtreecommitdiffstats
path: root/libmproxy/flow.py
diff options
context:
space:
mode:
authorMaximilian Hils <git@maximilianhils.com>2014-01-31 03:01:51 +0100
committerMaximilian Hils <git@maximilianhils.com>2014-01-31 03:01:51 +0100
commit7d96ff00efd80b11ab35f7f1c9c7dd6aff9c9032 (patch)
tree28ff60b0d106822ff45803c4af8788d2f9173b7c /libmproxy/flow.py
parent30a44cbb41fab51a30e609ba6318e1e8c062f73a (diff)
downloadmitmproxy-7d96ff00efd80b11ab35f7f1c9c7dd6aff9c9032.tar.gz
mitmproxy-7d96ff00efd80b11ab35f7f1c9c7dd6aff9c9032.tar.bz2
mitmproxy-7d96ff00efd80b11ab35f7f1c9c7dd6aff9c9032.zip
remove _flow_map from state, improve logging
Diffstat (limited to 'libmproxy/flow.py')
-rw-r--r--libmproxy/flow.py16
1 files changed, 3 insertions, 13 deletions
diff --git a/libmproxy/flow.py b/libmproxy/flow.py
index d48c35dc..4032461d 100644
--- a/libmproxy/flow.py
+++ b/libmproxy/flow.py
@@ -236,7 +236,6 @@ class ServerPlaybackState:
return l.pop(0)
-
class StickyCookieState:
def __init__(self, flt):
"""
@@ -306,7 +305,6 @@ class StickyAuthState:
class State(object):
def __init__(self):
- self._flow_map = {}
self._flow_list = []
self.view = []
@@ -320,7 +318,7 @@ class State(object):
return self._limit_txt
def flow_count(self):
- return len(self._flow_map)
+ return len(self._flow_list)
def index(self, f):
return self._flow_list.index(f)
@@ -338,8 +336,6 @@ class State(object):
"""
f = req.flow
self._flow_list.append(f)
- self._flow_map[req] = f
- assert len(self._flow_list) == len(self._flow_map)
if f.match(self._limit):
self.view.append(f)
return f
@@ -348,10 +344,9 @@ class State(object):
"""
Add a response to the state. Returns the matching flow.
"""
- f = self._flow_map.get(resp.flow)
+ f = resp.flow
if not f:
return False
- f.response = resp
if f.match(self._limit) and not f in self.view:
self.view.append(f)
return f
@@ -361,18 +356,15 @@ class State(object):
Add an error response to the state. Returns the matching flow, or
None if there isn't one.
"""
- f = self._flow_map.get(err.flow)
+ f = err.flow
if not f:
return None
- f.error = err
if f.match(self._limit) and not f in self.view:
self.view.append(f)
return f
def load_flows(self, flows):
self._flow_list.extend(flows)
- for i in flows:
- self._flow_map[i.request] = i
self.recalculate_view()
def set_limit(self, txt):
@@ -405,8 +397,6 @@ class State(object):
self.view = self._flow_list[:]
def delete_flow(self, f):
- if f.request in self._flow_map:
- del self._flow_map[f.request]
self._flow_list.remove(f)
if f in self.view:
self.view.remove(f)