mirror of
https://github.com/edera-dev/krata.git
synced 2025-08-03 13:11:31 +00:00
network: move entry creation logging to NAT itself
This commit is contained in:
@ -254,6 +254,7 @@ impl NatRouter {
|
|||||||
.nat(key, self.tx_sender.clone(), self.reclaim_sender.clone())
|
.nat(key, self.tx_sender.clone(), self.reclaim_sender.clone())
|
||||||
.await
|
.await
|
||||||
{
|
{
|
||||||
|
debug!("creating nat entry for key: {}", key);
|
||||||
Some(entry.insert(handler))
|
Some(entry.insert(handler))
|
||||||
} else {
|
} else {
|
||||||
None
|
None
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
use async_trait::async_trait;
|
use async_trait::async_trait;
|
||||||
|
|
||||||
use log::{debug, warn};
|
use log::warn;
|
||||||
|
|
||||||
use tokio::sync::mpsc::channel;
|
use tokio::sync::mpsc::channel;
|
||||||
use tokio::sync::mpsc::Sender;
|
use tokio::sync::mpsc::Sender;
|
||||||
@ -27,8 +27,6 @@ impl NatHandlerFactory for ProxyNatHandlerFactory {
|
|||||||
tx_sender: Sender<Vec<u8>>,
|
tx_sender: Sender<Vec<u8>>,
|
||||||
reclaim_sender: Sender<NatKey>,
|
reclaim_sender: Sender<NatKey>,
|
||||||
) -> Option<Box<dyn NatHandler>> {
|
) -> Option<Box<dyn NatHandler>> {
|
||||||
debug!("creating proxy nat entry for key: {}", key);
|
|
||||||
|
|
||||||
match key.protocol {
|
match key.protocol {
|
||||||
NatKeyProtocol::Udp => {
|
NatKeyProtocol::Udp => {
|
||||||
let (rx_sender, rx_receiver) = channel::<Vec<u8>>(4);
|
let (rx_sender, rx_receiver) = channel::<Vec<u8>>(4);
|
||||||
@ -47,7 +45,7 @@ impl NatHandlerFactory for ProxyNatHandlerFactory {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
pub enum ProxyNatSelect {
|
pub(crate) enum ProxyNatSelect {
|
||||||
External(usize),
|
External(usize),
|
||||||
Internal(Vec<u8>),
|
Internal(Vec<u8>),
|
||||||
Close,
|
Close,
|
||||||
|
Reference in New Issue
Block a user