hex/wstunnel
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

lower log lvl for received frame

Browse source
This commit is contained in:
Σrebe - Romain GERARD 2024-08-29 22:37:30 +02:00
parent 3b52fe2eb3
commit 878319b027
No known key found for this signature in database
GPG key ID: 7A42B4B97E0332F4
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/tunnel/transport/websocket.rs
View file

@ -14,7 +14,7 @@ use hyper::upgrade::Upgraded;
use hyper::Request; use hyper::Request;
use hyper_util::rt::TokioExecutor; use hyper_util::rt::TokioExecutor;
use hyper_util::rt::TokioIo; use hyper_util::rt::TokioIo;
use log::{debug, info}; use log::debug;
use std::io; use std::io;
use std::io::ErrorKind; use std::io::ErrorKind;
use std::ops::DerefMut; use std::ops::DerefMut;
@ -122,7 +122,7 @@ impl TunnelWrite for WebsocketTunnelWrite {
async fn handle_pending_operations(&mut self) -> Result<(), io::Error> { async fn handle_pending_operations(&mut self) -> Result<(), io::Error> {
while let Ok(frame) = self.pending_operations.try_recv() { while let Ok(frame) = self.pending_operations.try_recv() {
info!("received frame {:?}", frame.opcode); debug!("received frame {:?}", frame.opcode);
match frame.opcode { match frame.opcode {
OpCode::Close => { OpCode::Close => {
if self.inner.write_frame(frame).await.is_err() { if self.inner.write_frame(frame).await.is_err() {