forked/hyper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

style(client): HttpConnector: use consistent naming - s/buf/buffer/ (#1840)

Browse Source 
Signed-off-by: Dietmar Maurer <dietmar@proxmox.com>
This commit is contained in:
Dietmar Maurer
2019-07-02 18:45:59 +02:00
committed by Sean McArthur
parent 386109c421
commit cf24765a22
1 changed files with 16 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/client/connect/http.rs
View File

@@ -35,8 +35,8 @@ pub struct HttpConnector<R = GaiResolver> {
nodelay: bool, nodelay: bool,
resolver: R, resolver: R,
reuse_address: bool, reuse_address: bool,
send_buf_size: Option<usize>, send_buffer_size: Option<usize>,
recv_buf_size: Option<usize>, recv_buffer_size: Option<usize>,
} }
/// Extra information about the transport when an HttpConnector is used. /// Extra information about the transport when an HttpConnector is used.
@@ -126,8 +126,8 @@ impl<R> HttpConnector<R> {
nodelay: false, nodelay: false,
resolver, resolver,
reuse_address: false, reuse_address: false,
send_buf_size: None, send_buffer_size: None,
recv_buf_size: None, recv_buffer_size: None,
} }
} }
@@ -167,14 +167,14 @@ impl<R> HttpConnector<R> {
/// Sets the value of the SO_SNDBUF option on the socket. /// Sets the value of the SO_SNDBUF option on the socket.
#[inline] #[inline]
pub fn set_send_buf_size(&mut self, size: Option<usize>) { pub fn set_send_buffer_size(&mut self, size: Option<usize>) {
self.send_buf_size = size; self.send_buffer_size = size;
} }
/// Sets the value of the SO_RCVBUF option on the socket. /// Sets the value of the SO_RCVBUF option on the socket.
#[inline] #[inline]
pub fn set_recv_buf_size(&mut self, size: Option<usize>) { pub fn set_recv_buffer_size(&mut self, size: Option<usize>) {
self.recv_buf_size = size; self.recv_buffer_size = size;
} }
/// Set that all sockets are bound to the configured address before connection. /// Set that all sockets are bound to the configured address before connection.
@@ -264,8 +264,8 @@ where
nodelay: self.nodelay, nodelay: self.nodelay,
port, port,
reuse_address: self.reuse_address, reuse_address: self.reuse_address,
send_buf_size: self.send_buf_size, send_buffer_size: self.send_buffer_size,
recv_buf_size: self.recv_buf_size, recv_buffer_size: self.recv_buffer_size,
} }
} }
} }
@@ -287,8 +287,8 @@ fn invalid_url<R: Resolve>(err: InvalidUrl, handle: &Option<Handle>) -> HttpConn
port: 0, port: 0,
happy_eyeballs_timeout: None, happy_eyeballs_timeout: None,
reuse_address: false, reuse_address: false,
send_buf_size: None, send_buffer_size: None,
recv_buf_size: None, recv_buffer_size: None,
} }
} }
@@ -324,8 +324,8 @@ pub struct HttpConnecting<R: Resolve = GaiResolver> {
nodelay: bool, nodelay: bool,
port: u16, port: u16,
reuse_address: bool, reuse_address: bool,
send_buf_size: Option<usize>, send_buffer_size: Option<usize>,
recv_buf_size: Option<usize>, recv_buffer_size: Option<usize>,
} }
enum State<R: Resolve> { enum State<R: Resolve> {
@@ -375,11 +375,11 @@ impl<R: Resolve> Future for HttpConnecting<R> {
sock.set_keepalive(Some(dur))?; sock.set_keepalive(Some(dur))?;
} }
if let Some(size) = self.send_buf_size { if let Some(size) = self.send_buffer_size {
sock.set_send_buffer_size(size)?; sock.set_send_buffer_size(size)?;
} }
if let Some(size) = self.recv_buf_size { if let Some(size) = self.recv_buffer_size {
sock.set_recv_buffer_size(size)?; sock.set_recv_buffer_size(size)?;
} }