Compare commits
1 Commits
78bc46c56b
...
v1.3.2
| Author | SHA1 | Date | |
|---|---|---|---|
|
0fe043acb5
|
@@ -39,7 +39,7 @@ impl Stats {
|
|||||||
}
|
}
|
||||||
|
|
||||||
pub fn set_failed(&self, failed: bool) {
|
pub fn set_failed(&self, failed: bool) {
|
||||||
self.failed.fetch_and(failed, Ordering::Relaxed);
|
self.failed.store(failed, Ordering::Relaxed);
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn rx(&self) -> Unit {
|
pub fn rx(&self) -> Unit {
|
||||||
|
|||||||
@@ -330,26 +330,6 @@ impl russh::server::Handler for Handler {
|
|||||||
Ok(session.channel_success(channel)?)
|
Ok(session.channel_success(channel)?)
|
||||||
}
|
}
|
||||||
|
|
||||||
async fn channel_close(
|
|
||||||
&mut self,
|
|
||||||
channel: ChannelId,
|
|
||||||
session: &mut Session,
|
|
||||||
) -> Result<(), Self::Error> {
|
|
||||||
if let Some(pty_channel) = self.pty_channel
|
|
||||||
&& pty_channel == channel
|
|
||||||
{
|
|
||||||
debug!("Pty channel closed");
|
|
||||||
|
|
||||||
session.disconnect(
|
|
||||||
russh::Disconnect::ByApplication,
|
|
||||||
"Remaining active connections have been closed",
|
|
||||||
"EN",
|
|
||||||
)?;
|
|
||||||
}
|
|
||||||
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn tcpip_forward(
|
async fn tcpip_forward(
|
||||||
&mut self,
|
&mut self,
|
||||||
address: &str,
|
address: &str,
|
||||||
|
|||||||
Reference in New Issue
Block a user