diff options
Diffstat (limited to 'src/main.rs')
| -rw-r--r-- | src/main.rs | 20 |
1 files changed, 13 insertions, 7 deletions
diff --git a/src/main.rs b/src/main.rs index 78d5e8d..3dcc273 100644 --- a/src/main.rs +++ b/src/main.rs @@ -69,6 +69,9 @@ fn trigger_packet_event( Encapsulation::PPP(_, _) => { // TODO } + Encapsulation::PPPoE(_, _) => { + // TODO + } } } } @@ -139,13 +142,16 @@ fn handle_one_packet(data: &[u8], len: u32, thread_ctx: &mut ThreadContext) { } } - if packet.get_inner_most_tuple().is_some() { - let flow_id = packet.get_flow_id().unwrap(); - let session = session_mgr.borrow_mut().update(flow_id); - trigger_packet_event(&packet, Some(session.clone()), &mut queue); - trigger_session_event(Some(session.clone()), &mut queue); - } else { - trigger_packet_event(&packet, None, &mut queue); + match packet.get_inner_most_tuple() { + Some(_) => { + let flow_id = packet.get_flow_id().unwrap(); + let session = session_mgr.borrow_mut().update(flow_id); + trigger_packet_event(&packet, Some(session.clone()), &mut queue); + trigger_session_event(Some(session.clone()), &mut queue); + } + None => { + trigger_packet_event(&packet, None, &mut queue); + } } event_mgr.borrow_mut().dispatch(Some(&packet), &mut queue); |