diff options
Diffstat (limited to 'src/main.rs')
| -rw-r--r-- | src/main.rs | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/main.rs b/src/main.rs index 012db40..78d5e8d 100644 --- a/src/main.rs +++ b/src/main.rs @@ -11,7 +11,7 @@ use stellar_rs::plugin::example::ExamplePulgin; use stellar_rs::session::session::Session; use stellar_rs::session::session::SessionProto; use stellar_rs::session::session::SessionState; -use stellar_rs::thread::thread::ThreadContex; +use stellar_rs::thread::thread::ThreadContext; fn trigger_packet_event( packet: &Packet, @@ -117,9 +117,9 @@ fn trigger_session_event(session: Option<Rc<RefCell<Session>>>, queue: &mut Even } } -fn handle_one_packet(data: &[u8], len: u32, ctx: Rc<RefCell<ThreadContex>>) { - let event_mgr = ctx.borrow().get_event_mgr(); - let session_mgr = ctx.borrow().get_session_mgr(); +fn handle_one_packet(data: &[u8], len: u32, thread_ctx: &mut ThreadContext) { + let event_mgr = thread_ctx.get_event_mgr(); + let session_mgr = thread_ctx.get_session_mgr(); let mut queue = EventQueue::new(); let mut packet = Packet::new(data, len); @@ -162,9 +162,9 @@ fn main() { plugin2.init(&mut event_mgr); let event_mgr = Rc::new(RefCell::new(event_mgr)); - let thread_ctx = Rc::new(RefCell::new(ThreadContex::new(event_mgr))); + let mut thread_ctx = ThreadContext::new(event_mgr); PacketCapture::show_devices(); let mut cap = PacketCapture::new("en0"); - cap.poll_packet(handle_one_packet, thread_ctx); + cap.poll_packet(handle_one_packet, &mut thread_ctx); } |