diff options
Diffstat (limited to 'src/wireguard/router/peer.rs')
| -rw-r--r-- | src/wireguard/router/peer.rs | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/wireguard/router/peer.rs b/src/wireguard/router/peer.rs index 192d4e2..40442a8 100644 --- a/src/wireguard/router/peer.rs +++ b/src/wireguard/router/peer.rs @@ -276,7 +276,9 @@ impl<E: Endpoint, C: Callbacks, T: tun::Writer, B: udp::Writer<E>> Peer<E, C, T, dec: Arc<DecryptionState<E, C, T, B>>, msg: Vec<u8>, ) -> Option<Job<Self, Inbound<E, C, T, B>>> { - Some(Job::new(self.clone(), Inbound::new(msg, dec, src))) + let job = Job::new(self.clone(), Inbound::new(msg, dec, src)); + self.inbound.send(job.clone()); + Some(job) } pub fn send_job(&self, msg: Vec<u8>, stage: bool) -> Option<Job<Self, Outbound>> { |