diff options
| author | Aldo Cortesi <aldo@nullcube.com> | 2016-05-26 12:31:29 +1200 |
|---|---|---|
| committer | Aldo Cortesi <aldo@nullcube.com> | 2016-05-28 11:00:00 +1200 |
| commit | 7c4843857be0ad165fca46dcad24a213fc3bd284 (patch) | |
| tree | 4a4ae7df627ca9700c2f1fab8b3a9f77c085a2ec /mitmproxy/flow.py | |
| parent | abf3cae54e715e53559b4c7103f8b2247ed791dc (diff) | |
| download | mitmproxy-7c4843857be0ad165fca46dcad24a213fc3bd284.tar.gz mitmproxy-7c4843857be0ad165fca46dcad24a213fc3bd284.tar.bz2 mitmproxy-7c4843857be0ad165fca46dcad24a213fc3bd284.zip | |
Sketch out a more solid core
- Decorator for handler methods
- Stricter checking for double-acks and non-acks
Diffstat (limited to 'mitmproxy/flow.py')
| -rw-r--r-- | mitmproxy/flow.py | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/mitmproxy/flow.py b/mitmproxy/flow.py index a09a81a7..21aa3051 100644 --- a/mitmproxy/flow.py +++ b/mitmproxy/flow.py @@ -985,36 +985,36 @@ class FlowMaster(controller.ServerMaster): if block: rt.join() + @controller.handler def handle_log(self, l): self.add_event(l.msg, l.level) - l.reply() + @controller.handler def handle_clientconnect(self, root_layer): self.run_script_hook("clientconnect", root_layer) - root_layer.reply() + @controller.handler def handle_clientdisconnect(self, root_layer): self.run_script_hook("clientdisconnect", root_layer) - root_layer.reply() + @controller.handler def handle_serverconnect(self, server_conn): self.run_script_hook("serverconnect", server_conn) - server_conn.reply() + @controller.handler def handle_serverdisconnect(self, server_conn): self.run_script_hook("serverdisconnect", server_conn) - server_conn.reply() + @controller.handler def handle_next_layer(self, top_layer): self.run_script_hook("next_layer", top_layer) - top_layer.reply() + @controller.handler def handle_error(self, f): self.state.update_flow(f) self.run_script_hook("error", f) if self.client_playback: self.client_playback.clear(f) - f.reply() return f def handle_request(self, f): |