diff options
author | Alex Crichton <alex@alexcrichton.com> | 2015-01-17 15:23:18 -0800 |
---|---|---|
committer | Alex Crichton <alex@alexcrichton.com> | 2015-01-17 15:23:18 -0800 |
commit | e2b22f1665ecfb776e17ced93473cf5695ed00d4 (patch) | |
tree | d43a5b3dca2f6adc8507ad79a33df8c4a215f8a9 /src/channel.rs | |
parent | ea6e306c68450a88024bbc615361144297703ed0 (diff) | |
download | ssh2-rs-e2b22f1665ecfb776e17ced93473cf5695ed00d4.zip |
Update to rust master
Diffstat (limited to 'src/channel.rs')
-rw-r--r-- | src/channel.rs | 15 |
1 files changed, 6 insertions, 9 deletions
diff --git a/src/channel.rs b/src/channel.rs index b111e4a..7db0719 100644 --- a/src/channel.rs +++ b/src/channel.rs @@ -1,6 +1,5 @@ use std::cmp; use std::io; -use std::marker; use libc::{c_uint, c_int, size_t, c_char, c_void, c_uchar}; use {raw, Session, Error}; @@ -10,10 +9,9 @@ use {raw, Session, Error}; /// /// Channels denote all of SCP uploads and downloads, shell sessions, remote /// process executions, and other general-purpose sessions. -pub struct Channel<'a> { +pub struct Channel<'sess> { raw: *mut raw::LIBSSH2_CHANNEL, - sess: &'a Session, - marker: marker::NoSync, + sess: &'sess Session, read_limit: Option<u64>, } @@ -50,7 +48,7 @@ pub struct WriteWindow { pub window_size_initial: u32, } -impl<'a> Channel<'a> { +impl<'sess> Channel<'sess> { /// Wraps a raw pointer in a new Channel structure tied to the lifetime of the /// given session. /// @@ -60,7 +58,6 @@ impl<'a> Channel<'a> { Channel { raw: raw, sess: sess, - marker: marker::NoSync, read_limit: None, } } @@ -387,7 +384,7 @@ impl<'a> Channel<'a> { } } -impl<'a> Writer for Channel<'a> { +impl<'sess> Writer for Channel<'sess> { fn write(&mut self, buf: &[u8]) -> io::IoResult<()> { self.write_stream(0, buf).map_err(|e| { io::IoError { @@ -409,7 +406,7 @@ impl<'a> Writer for Channel<'a> { } } -impl<'a> Reader for Channel<'a> { +impl<'sess> Reader for Channel<'sess> { fn read(&mut self, buf: &mut [u8]) -> io::IoResult<usize> { self.read_stream(0, buf).map_err(|e| { if self.eof() { @@ -426,7 +423,7 @@ impl<'a> Reader for Channel<'a> { } #[unsafe_destructor] -impl<'a> Drop for Channel<'a> { +impl<'sess> Drop for Channel<'sess> { fn drop(&mut self) { unsafe { assert_eq!(raw::libssh2_channel_free(self.raw), 0) } } |