Skip to content

Commit 26e55ff

Browse files
committed
Change negotiate_ssl back to taking &self
It's not clear that &mut is necessary and it makes connection calls a bit nicer looking.
1 parent f957f10 commit 26e55ff

File tree

7 files changed

+97
-99
lines changed

7 files changed

+97
-99
lines changed

src/io/mod.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,5 @@ pub trait NegotiateSsl {
2323
///
2424
/// The host portion of the connection parameters is provided for hostname
2525
/// verification.
26-
fn negotiate_ssl(&mut self, host: &str, stream: Stream)
27-
-> Result<Box<StreamWrapper>, Box<Error>>;
26+
fn negotiate_ssl(&self, host: &str, stream: Stream) -> Result<Box<StreamWrapper>, Box<Error>>;
2827
}

src/io/openssl.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,7 @@ impl StreamWrapper for SslStream<Stream> {
1616
}
1717

1818
impl NegotiateSsl for SslContext {
19-
fn negotiate_ssl(&mut self, _: &str, stream: Stream)
20-
-> Result<Box<StreamWrapper>, Box<Error>> {
19+
fn negotiate_ssl(&self, _: &str, stream: Stream) -> Result<Box<StreamWrapper>, Box<Error>> {
2120
let stream = try!(SslStream::new(self, stream));
2221
Ok(Box::new(stream))
2322
}

src/lib.rs

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
//! }
1616
//!
1717
//! fn main() {
18-
//! let conn = Connection::connect("postgresql://postgres@localhost", &mut SslMode::None)
18+
//! let conn = Connection::connect("postgresql://postgres@localhost", &SslMode::None)
1919
//! .unwrap();
2020
//!
2121
//! conn.execute("CREATE TABLE person (
@@ -379,15 +379,15 @@ pub struct CancelData {
379379
/// # use postgres::{Connection, SslMode};
380380
/// # use std::thread;
381381
/// # let url = "";
382-
/// let conn = Connection::connect(url, &mut SslMode::None).unwrap();
382+
/// let conn = Connection::connect(url, &SslMode::None).unwrap();
383383
/// let cancel_data = conn.cancel_data();
384384
/// thread::spawn(move || {
385385
/// conn.execute("SOME EXPENSIVE QUERY", &[]).unwrap();
386386
/// });
387387
/// # let _ =
388-
/// postgres::cancel_query(url, &mut SslMode::None, cancel_data);
388+
/// postgres::cancel_query(url, &SslMode::None, cancel_data);
389389
/// ```
390-
pub fn cancel_query<T>(params: T, ssl: &mut SslMode, data: CancelData)
390+
pub fn cancel_query<T>(params: T, ssl: &SslMode, data: CancelData)
391391
-> result::Result<(), ConnectError>
392392
where T: IntoConnectParams {
393393
let params = try!(params.into_connect_params());
@@ -497,7 +497,7 @@ impl Drop for InnerConnection {
497497
}
498498

499499
impl InnerConnection {
500-
fn connect<T>(params: T, ssl: &mut SslMode) -> result::Result<InnerConnection, ConnectError>
500+
fn connect<T>(params: T, ssl: &SslMode) -> result::Result<InnerConnection, ConnectError>
501501
where T: IntoConnectParams {
502502
let params = try!(params.into_connect_params());
503503
let stream = try!(priv_io::initialize_stream(&params, ssl));
@@ -986,15 +986,15 @@ impl Connection {
986986
/// # use postgres::{Connection, SslMode, ConnectError};
987987
/// # fn f() -> Result<(), ConnectError> {
988988
/// let url = "postgresql://postgres:hunter2@localhost:2994/foodb";
989-
/// let conn = try!(Connection::connect(url, &mut SslMode::None));
989+
/// let conn = try!(Connection::connect(url, &SslMode::None));
990990
/// # Ok(()) };
991991
/// ```
992992
///
993993
/// ```rust,no_run
994994
/// # use postgres::{Connection, SslMode, ConnectError};
995995
/// # fn f() -> Result<(), ConnectError> {
996996
/// let url = "postgresql://postgres@%2Frun%2Fpostgres";
997-
/// let conn = try!(Connection::connect(url, &mut SslMode::None));
997+
/// let conn = try!(Connection::connect(url, &SslMode::None));
998998
/// # Ok(()) };
999999
/// ```
10001000
///
@@ -1014,10 +1014,10 @@ impl Connection {
10141014
/// database: None,
10151015
/// options: vec![],
10161016
/// };
1017-
/// let conn = try!(Connection::connect(params, &mut SslMode::None));
1017+
/// let conn = try!(Connection::connect(params, &SslMode::None));
10181018
/// # Ok(()) };
10191019
/// ```
1020-
pub fn connect<T>(params: T, ssl: &mut SslMode) -> result::Result<Connection, ConnectError>
1020+
pub fn connect<T>(params: T, ssl: &SslMode) -> result::Result<Connection, ConnectError>
10211021
where T: IntoConnectParams {
10221022
InnerConnection::connect(params, ssl).map(|conn| {
10231023
Connection { conn: RefCell::new(conn) }
@@ -1049,7 +1049,7 @@ impl Connection {
10491049
///
10501050
/// ```rust,no_run
10511051
/// # use postgres::{Connection, SslMode};
1052-
/// # let conn = Connection::connect("", &mut SslMode::None).unwrap();
1052+
/// # let conn = Connection::connect("", &SslMode::None).unwrap();
10531053
/// let maybe_stmt = conn.prepare("SELECT foo FROM bar WHERE baz = $1");
10541054
/// let stmt = match maybe_stmt {
10551055
/// Ok(stmt) => stmt,
@@ -1072,7 +1072,7 @@ impl Connection {
10721072
/// # use postgres::{Connection, SslMode};
10731073
/// # fn f() -> postgres::Result<()> {
10741074
/// # let x = 10i32;
1075-
/// # let conn = Connection::connect("", &mut SslMode::None).unwrap();
1075+
/// # let conn = Connection::connect("", &SslMode::None).unwrap();
10761076
/// let stmt = try!(conn.prepare_cached("SELECT foo FROM bar WHERE baz = $1"));
10771077
/// for row in try!(stmt.query(&[&x])) {
10781078
/// println!("foo: {}", row.get::<_, String>(0));
@@ -1111,7 +1111,7 @@ impl Connection {
11111111
/// ```rust,no_run
11121112
/// # use postgres::{Connection, SslMode};
11131113
/// # fn foo() -> Result<(), postgres::Error> {
1114-
/// # let conn = Connection::connect("", &mut SslMode::None).unwrap();
1114+
/// # let conn = Connection::connect("", &SslMode::None).unwrap();
11151115
/// let trans = try!(conn.transaction());
11161116
/// try!(trans.execute("UPDATE foo SET bar = 10", &[]));
11171117
/// // ...
@@ -1499,7 +1499,7 @@ impl<'conn> Statement<'conn> {
14991499
///
15001500
/// ```rust,no_run
15011501
/// # use postgres::{Connection, SslMode};
1502-
/// # let conn = Connection::connect("", &mut SslMode::None).unwrap();
1502+
/// # let conn = Connection::connect("", &SslMode::None).unwrap();
15031503
/// # let bar = 1i32;
15041504
/// # let baz = true;
15051505
/// let stmt = conn.prepare("UPDATE foo SET bar = $1 WHERE baz = $2").unwrap();
@@ -1558,7 +1558,7 @@ impl<'conn> Statement<'conn> {
15581558
///
15591559
/// ```rust,no_run
15601560
/// # use postgres::{Connection, SslMode};
1561-
/// # let conn = Connection::connect("", &mut SslMode::None).unwrap();
1561+
/// # let conn = Connection::connect("", &SslMode::None).unwrap();
15621562
/// let stmt = conn.prepare("SELECT foo FROM bar WHERE baz = $1").unwrap();
15631563
/// # let baz = true;
15641564
/// let rows = match stmt.query(&[&baz]) {
@@ -1872,7 +1872,7 @@ impl<'a> Row<'a> {
18721872
///
18731873
/// ```rust,no_run
18741874
/// # use postgres::{Connection, SslMode};
1875-
/// # let conn = Connection::connect("", &mut SslMode::None).unwrap();
1875+
/// # let conn = Connection::connect("", &SslMode::None).unwrap();
18761876
/// # let stmt = conn.prepare("").unwrap();
18771877
/// # let mut result = stmt.query(&[]).unwrap();
18781878
/// # let row = result.iter().next().unwrap();

src/priv_io.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -118,14 +118,14 @@ fn open_socket(params: &ConnectParams) -> Result<InternalStream, ConnectError> {
118118
}
119119
}
120120

121-
pub fn initialize_stream(params: &ConnectParams, ssl: &mut SslMode)
121+
pub fn initialize_stream(params: &ConnectParams, ssl: &SslMode)
122122
-> Result<Box<StreamWrapper>, ConnectError> {
123123
let mut socket = Stream(try!(open_socket(params)));
124124

125125
let (ssl_required, negotiator) = match *ssl {
126126
SslMode::None => return Ok(Box::new(socket)),
127-
SslMode::Prefer(ref mut negotiator) => (false, negotiator),
128-
SslMode::Require(ref mut negotiator) => (true, negotiator),
127+
SslMode::Prefer(ref negotiator) => (false, negotiator),
128+
SslMode::Require(ref negotiator) => (true, negotiator),
129129
};
130130

131131
try!(socket.write_message(&SslRequest { code: message::SSL_CODE }));

src/types/slice.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ use types::IsNull;
1616
/// ```rust,no_run
1717
/// # fn foo() -> postgres::Result<()> {
1818
/// # use postgres::{Connection, SslMode, Slice};
19-
/// # let conn = Connection::connect("", &mut SslMode::None).unwrap();
19+
/// # let conn = Connection::connect("", &SslMode::None).unwrap();
2020
/// let values = &[1i32, 2, 3, 4, 5, 6];
2121
/// let stmt = try!(conn.prepare("SELECT * FROM foo WHERE id = ANY($1)"));
2222
/// for row in &try!(stmt.query(&[&Slice(values)])) {

0 commit comments

Comments
 (0)