diff options
| author | luwenpeng <[email protected]> | 2023-09-06 18:30:14 +0800 |
|---|---|---|
| committer | luwenpeng <[email protected]> | 2023-09-07 14:27:24 +0800 |
| commit | e16b028be675ee35f4d08521accbc52ee6e6b182 (patch) | |
| tree | 03ea80f57d4f2c2b98dd125fa9baa2cfd770dc88 /src/plugin | |
| parent | 142e30257e2d852b381f1ca47257095b888627cd (diff) | |
[refactor] Decouple packets from sessions/events
Diffstat (limited to 'src/plugin')
| -rw-r--r-- | src/plugin/example.rs | 23 |
1 files changed, 14 insertions, 9 deletions
diff --git a/src/plugin/example.rs b/src/plugin/example.rs index eb38c2c..a3ca852 100644 --- a/src/plugin/example.rs +++ b/src/plugin/example.rs @@ -44,22 +44,22 @@ impl EventHandle for ExamplePulgin { self.tcp_opening_event = event_mgr .borrow_mut() - .event2index(BUILDIN_TCP_OPENING_EVENT); + .event2index(BUILTIN_TCP_OPENING_EVENT); event_mgr .borrow_mut() .register(self.tcp_opening_event, Box::new(self.clone())); - self.tcp_active_event = event_mgr.borrow_mut().event2index(BUILDIN_TCP_ACTIVE_EVENT); + self.tcp_active_event = event_mgr.borrow_mut().event2index(BUILTIN_TCP_ACTIVE_EVENT); event_mgr .borrow_mut() .register(self.tcp_active_event, Box::new(self.clone())); - self.tcp_expire_event = event_mgr.borrow_mut().event2index(BUILDIN_TCP_EXPIRE_EVENT); + self.tcp_expire_event = event_mgr.borrow_mut().event2index(BUILTIN_TCP_EXPIRE_EVENT); event_mgr .borrow_mut() .register(self.tcp_expire_event, Box::new(self.clone())); - self.tcp_closed_event = event_mgr.borrow_mut().event2index(BUILDIN_TCP_CLOSED_EVENT); + self.tcp_closed_event = event_mgr.borrow_mut().event2index(BUILTIN_TCP_CLOSED_EVENT); event_mgr .borrow_mut() .register(self.tcp_closed_event, Box::new(self.clone())); @@ -72,7 +72,12 @@ impl EventHandle for ExamplePulgin { .register(self.http_opening_event, Box::new(self.clone())); } - fn handle(&mut self, index: usize, packet: &Packet, session: Option<Rc<RefCell<Session>>>) { + fn handle( + &mut self, + index: usize, + packet: Option<&Packet>, + session: Option<Rc<RefCell<Session>>>, + ) { if session.is_none() { return; } @@ -83,22 +88,22 @@ impl EventHandle for ExamplePulgin { let session = session.unwrap(); if index == self.tcp_opening_event { println!( - "{} handle BUILDIN_TCP_OPENING_EVENT: {:?}", + "{} handle BUILTIN_TCP_OPENING_EVENT: {:?}", self.plugin_name, session ); } else if index == self.tcp_active_event { println!( - "{} handle BUILDIN_TCP_ACTIVE_EVENT: {:?}", + "{} handle BUILTIN_TCP_ACTIVE_EVENT: {:?}", self.plugin_name, session ); } else if index == self.tcp_expire_event { println!( - "{} handle BUILDIN_TCP_EXPIRE_EVENT: {:?}", + "{} handle BUILTIN_TCP_EXPIRE_EVENT: {:?}", self.plugin_name, session ); } else if index == self.tcp_closed_event { println!( - "{} handle BUILDIN_TCP_CLOSED_EVENT: {:?}", + "{} handle BUILTIN_TCP_CLOSED_EVENT: {:?}", self.plugin_name, session ); } else if index == self.http_opening_event { |