pijul/thrussh - Change JBFDZQ46EJFVOM3LLBH6SF2BTH4MQY4OTNAP4CVN4PMITYXO6Z5QC

Formatting

Created by pmeunier on November 28, 2020

JBFDZQ46EJFVOM3LLBH6SF2BTH4MQY4OTNAP4CVN4PMITYXO6Z5QC

Dependencies

In channels

tokio-0.2

main

Change contents

Replacement in thrussh-keys/src/lib.rs at line 330 [5.21590]

B:BD[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> {

Deletion in thrussh-config/src/lib.rs at line 8 [5.161114]
B:BD[5.161223] → [5.161223:161244]
```
use std::path::Path;
```
Insertion in thrussh-config/src/lib.rs at line 9 [5.161114]
[4.29]
[5.161244]
```
use std::path::Path;
```

Replacement in thrussh-config/src/lib.rs at line 52 [5.161114]

B:BD[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 [5.161114]

B:BD[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 [5.166688]

B:BD[3.196] → [3.196:268]

        (SshRead {
            id: self.id,
            r
        }, w)

[3.196]

[3.268]

        (SshRead { id: self.id, r }, w)

Deletion in thrussh/src/ssh_read.rs at line 55 [5.166688]
B:BD[5.167826] → [3.275:276]

Replacement in thrussh/src/session.rs at line 226 [5.171602]

B:BD[5.179515] → [6.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 [5.203388]

B:BD[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 [5.203388]
B:BD[3.1103] → [3.1103:1121]
```
            break
```
[3.1103]
[3.1121]
```
            break;
```

Replacement in thrussh/src/client/mod.rs at line 809 [5.334998]

B:BD[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.334998]

B:BD[5.364252] → [6.202:298]

B:BD[6.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?;