tuxmain/rust-rpxy
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix some owned args

Browse source
This commit is contained in:
Jun Kurihara 2022-07-09 18:16:48 +09:00
commit b1ef8c1079
No known key found for this signature in database
GPG key ID: 48ADFD173ED22B03
3 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/proxy/proxy_handler.rs
View file

@ -19,7 +19,7 @@ where
mut req: Request<Body>,
client_addr: SocketAddr, // アクセス制御用
) -> Result<Response<Body>> {
let request_log = log_request_msg(&req, client_addr);
let request_log = log_request_msg(&req, &client_addr);
// Here we start to handle with server_name
// Find backend application for given server_name
@ -71,7 +71,7 @@ where
// Build request from destination information
let req_forwarded = if let Ok(req) = self.generate_request_forwarded(
client_addr,
&client_addr,
req,
upstream_scheme_host,
&upgrade_in_request,
@ -186,7 +186,7 @@ where
fn generate_request_forwarded<B: core::fmt::Debug>(
&self,
client_addr: SocketAddr,
client_addr: &SocketAddr,
mut req: Request<B>,
upstream_scheme_host: &Uri,
upgrade: &Option<String>,

4
src/proxy/utils_headers.rs
View file

@ -11,7 +11,7 @@ use std::net::SocketAddr;
pub(super) fn apply_upstream_options_to_header(
headers: &mut HeaderMap,
_client_addr: SocketAddr,
_client_addr: &SocketAddr,
upstream_scheme_host: &Uri,
upstream: &Upstream,
) -> Result<()> {
@ -48,7 +48,7 @@ pub(super) fn append_header_entry(
pub(super) fn add_forwarding_header(
headers: &mut HeaderMap,
client_addr: SocketAddr,
client_addr: &SocketAddr,
tls: bool,
) -> Result<()> {
// default process

2
src/proxy/utils_request.rs
View file

@ -5,7 +5,7 @@ use std::net::SocketAddr;
////////////////////////////////////////////////////
// Functions of utils for request messages
pub(super) fn log_request_msg<B>(req: &Request<B>, client_addr: SocketAddr) -> String {
pub(super) fn log_request_msg<B>(req: &Request<B>, client_addr: &SocketAddr) -> String {
let server_name = req.headers().get(header::HOST).map_or_else(
|| {
req