Skip to content

Commit

Permalink
One More
Browse files Browse the repository at this point in the history
  • Loading branch information
DmitryDodzin committed Jul 17, 2024
1 parent 0abcfd9 commit 49e45e0
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions mirrord/agent/src/vpn.rs
Original file line number Diff line number Diff line change
Expand Up @@ -12,9 +12,8 @@ use tokio::{
io::unix::{AsyncFd, AsyncFdReadyGuard},
net::UdpSocket,
select,
sync::mpsc::{self, error::SendError, Receiver, Sender},
sync::mpsc::{self, Receiver, Sender},
};
use tracing::debug;

use crate::{
error::{AgentError, Result},
Expand Down Expand Up @@ -73,7 +72,7 @@ impl VpnApi {
}
}

/// Sends the [`LayerTcpOutgoing`] message to the background task.
/// Sends the [`ClientVpn`] message to the background task.
#[tracing::instrument(level = "trace", skip(self))]
pub(crate) async fn layer_message(&mut self, message: ClientVpn) -> Result<()> {
if self.layer_tx.send(message).await.is_ok() {
Expand All @@ -83,7 +82,7 @@ impl VpnApi {
}
}

/// Receives a [`DaemonTcpOutgoing`] message from the background task.
/// Receives a [`ServerVpn`] message from the background task.
pub(crate) async fn daemon_message(&mut self) -> Result<ServerVpn> {
match self.daemon_rx.recv().await {
Some(msg) => Ok(msg),
Expand Down

0 comments on commit 49e45e0

Please sign in to comment.