Formatting

Dependencies

• [2] OGPWDWHU Compilation error on Windows
• [3] KNLLUDOI Correct usage of `tokio::select!`
• [4] 2Q2DF2RO Updating thrussh-config to make it usable in real projects
• [5] PBHNTGEX Fixing a channel window error
• [6] Y5HHIQXV Wait for the connection to be encrypted in `connect`
• [7] 7FRJYUI6 Reboot because of a bad change
• [8] SJBZKVM5 Debug messages

Change contents

• replacement in thrussh-keys/src/lib.rs at line 330
  [5.34005]→[2.0:104](∅→∅)
  − pub fn learn_known_hosts(host: &str, port: u16, pubkey: &key::PublicKey) -> Result<(), anyhow::Error> {
  [5.34005]

  [5.34094]
  + pub fn learn_known_hosts(

  + host: &str,

  + port: u16,

  + pubkey: &key::PublicKey,

  + ) -> Result<(), anyhow::Error> {
• edit in thrussh-config/src/lib.rs at line 8
  [5.161223]→[5.161223:161244](∅→∅)
  − use std::path::Path;
• edit in thrussh-config/src/lib.rs at line 9
  [4.29]

  [5.161244]
  + use std::path::Path;
• replacement in thrussh-config/src/lib.rs at line 52
  [4.622]→[4.622:734](∅→∅)
  − Stream::tcp_connect(&(self.host_name.as_str(), self.port).to_socket_addrs()?.next().unwrap()).await
  [4.622]

  [5.162203]
  + Stream::tcp_connect(

  + &(self.host_name.as_str(), self.port)

  + .to_socket_addrs()?

  + .next()

  + .unwrap(),

  + )

  + .await
• replacement in thrussh-config/src/lib.rs at line 109
  [4.891]→[4.891:1057](∅→∅)
  − },

  − "port" => if let Ok(port) = value.trim_start().parse() {

  − config.port = port

  − },
  [4.891]

  [5.163592]
  + }

  + "port" => {

  + if let Ok(port) = value.trim_start().parse() {

  + config.port = port

  + }

  + }
• replacement in thrussh/src/ssh_read.rs at line 51
  [3.196]→[3.196:268](∅→∅)
  − (SshRead {

  − id: self.id,

  − r

  − }, w)
  [3.196]

  [3.268]
  + (SshRead { id: self.id, r }, w)
• edit in thrussh/src/ssh_read.rs at line 55
  [5.167826]→[3.275:276](∅→∅)
  −
• replacement in thrussh/src/session.rs at line 226
  [5.179515]→[5.0:85](∅→∅)
  − debug!("buffer: {:?} {:?}", write.len(), channel.recipient_window_size);
  [5.179515]

  [5.179572]
  + debug!(

  + "buffer: {:?} {:?}",

  + write.len(),

  + channel.recipient_window_size

  + );
• replacement in thrussh/src/server/mod.rs at line 445
  [3.297]→[3.297:475](∅→∅)
  − async fn start_reading<R: AsyncRead + Unpin>(mut stream_read: R, mut buffer: SSHBuffer, cipher: Arc<crate::cipher::CipherPair>) -> Result<(usize, R, SSHBuffer), anyhow::Error> {
  [3.297]

  [3.475]
  + async fn start_reading<R: AsyncRead + Unpin>(

  + mut stream_read: R,

  + mut buffer: SSHBuffer,

  + cipher: Arc<crate::cipher::CipherPair>,

  + ) -> Result<(usize, R, SSHBuffer), anyhow::Error> {
• replacement in thrussh/src/server/mod.rs at line 578
  [3.1103]→[3.1103:1121](∅→∅)
  − break
  [3.1103]

  [3.1121]
  + break;
• replacement in thrussh/src/client/mod.rs at line 809
  [5.358296]→[3.1242:1420](∅→∅)
  − async fn start_reading<R: AsyncRead + Unpin>(mut stream_read: R, mut buffer: SSHBuffer, cipher: Arc<crate::cipher::CipherPair>) -> Result<(usize, R, SSHBuffer), anyhow::Error> {
  [5.358296]

  [3.1420]
  + async fn start_reading<R: AsyncRead + Unpin>(

  + mut stream_read: R,

  + mut buffer: SSHBuffer,

  + cipher: Arc<crate::cipher::CipherPair>,

  + ) -> Result<(usize, R, SSHBuffer), anyhow::Error> {
• replacement in thrussh/src/client/mod.rs at line 933
  [5.364252]→[5.202:298](∅→∅),[5.298]→[3.2016:2097](∅→∅)
  − debug!("writing to stream: {:?} bytes", self.common.write_buffer.buffer.len());

  − stream_write.write_all(&self.common.write_buffer.buffer).await?;
  [5.364252]

  [3.2097]
  + debug!(

  + "writing to stream: {:?} bytes",

  + self.common.write_buffer.buffer.len()

  + );

  + stream_write

  + .write_all(&self.common.write_buffer.buffer)

  + .await?;