Skip to content

Commit d4909b4

Browse files
committed
重命名 WebSocket 升级处理函数,调整日志级别为调试,优化代码可读性
1 parent 3542c43 commit d4909b4

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

rust_http_proxy/src/location.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ pub(crate) enum RequestSpec<'a> {
110110
}
111111

112112
impl<'a> RequestSpec<'a> {
113-
async fn handle_websocket_upgrade(
113+
async fn handle_websocket_upgrade_reverse(
114114
upstream_req: Request<Incoming>, client_upgrade_fut: hyper::upgrade::OnUpgrade, traffic_label: AccessLabel,
115115
reverse_client: &legacy::Client<
116116
HttpsConnector<HttpConnector<CustomGaiDNSResolver>>,
@@ -225,7 +225,7 @@ impl<'a> RequestSpec<'a> {
225225
let client_upgrade_fut = hyper::upgrade::on(&mut *request);
226226
let upstream_req =
227227
Self::build_upstream_req(location, upstream, *request, original_scheme_host_port)?;
228-
return Self::handle_websocket_upgrade(
228+
return Self::handle_websocket_upgrade_reverse(
229229
upstream_req,
230230
client_upgrade_fut,
231231
traffic_label,

rust_http_proxy/src/proxy.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -300,7 +300,7 @@ impl ProxyHandler {
300300
async fn handle_websocket_upgrade_forward(
301301
&self, mut req: Request<Incoming>, traffic_label: AccessLabel,
302302
) -> Result<Response<BoxBody<Bytes, io::Error>>, io::Error> {
303-
info!("[forward] WebSocket upgrade request to {}", &traffic_label.target);
303+
debug!("[forward] WebSocket upgrade request to {}", &traffic_label.target);
304304

305305
// 在消费 request 之前先获取客户端的 upgrade future
306306
let client_upgrade = hyper::upgrade::on(&mut req);

0 commit comments

Comments
 (0)