aboutsummaryrefslogtreecommitdiffstats
path: root/libmproxy/flow.py
diff options
context:
space:
mode:
authorMaximilian Hils <git@maximilianhils.com>2015-09-08 15:36:37 +0200
committerMaximilian Hils <git@maximilianhils.com>2015-09-08 15:36:37 +0200
commit4b8e162a8b5b72c054b5d0f9bcc7801ed8d90e49 (patch)
treed585d558f1860869f00e00199761894d6bd47834 /libmproxy/flow.py
parentc3ba98b68127b1a0d974e564c0c9af97b97f2a06 (diff)
parent8dfa15c2d460839667092e578311fad53cf7bea9 (diff)
downloadmitmproxy-4b8e162a8b5b72c054b5d0f9bcc7801ed8d90e49.tar.gz
mitmproxy-4b8e162a8b5b72c054b5d0f9bcc7801ed8d90e49.tar.bz2
mitmproxy-4b8e162a8b5b72c054b5d0f9bcc7801ed8d90e49.zip
Merge branch 'master' into readthedocs
Diffstat (limited to 'libmproxy/flow.py')
-rw-r--r--libmproxy/flow.py28
1 files changed, 16 insertions, 12 deletions
diff --git a/libmproxy/flow.py b/libmproxy/flow.py
index 547d0f60..d037d36e 100644
--- a/libmproxy/flow.py
+++ b/libmproxy/flow.py
@@ -945,21 +945,25 @@ class FlowMaster(controller.Master):
self.add_event(l.msg, l.level)
l.reply()
- def handle_clientconnect(self, cc):
- self.run_script_hook("clientconnect", cc)
- cc.reply()
+ def handle_clientconnect(self, root_layer):
+ self.run_script_hook("clientconnect", root_layer)
+ root_layer.reply()
- def handle_clientdisconnect(self, r):
- self.run_script_hook("clientdisconnect", r)
- r.reply()
+ def handle_clientdisconnect(self, root_layer):
+ self.run_script_hook("clientdisconnect", root_layer)
+ root_layer.reply()
- def handle_serverconnect(self, sc):
- self.run_script_hook("serverconnect", sc)
- sc.reply()
+ def handle_serverconnect(self, server_conn):
+ self.run_script_hook("serverconnect", server_conn)
+ server_conn.reply()
- def handle_serverdisconnect(self, sc):
- self.run_script_hook("serverdisconnect", sc)
- sc.reply()
+ def handle_serverdisconnect(self, server_conn):
+ self.run_script_hook("serverdisconnect", server_conn)
+ server_conn.reply()
+
+ def handle_next_layer(self, top_layer):
+ self.run_script_hook("next_layer", top_layer)
+ top_layer.reply()
def handle_error(self, f):
self.state.update_flow(f)