YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-04-02 02:35:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

aquatic_ws: use debug log level for "read message" and "sent message"

Browse source
This commit is contained in:
Joakim Frostegård 2020-05-25 18:51:04 +02:00
parent 6b881af20d
commit 689a874cbe
2 changed files with 3 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

1
TODO.md
View file

@ -2,7 +2,6 @@
## aquatic_ws ## aquatic_ws
* ipv4 and ipv6 state split: think about this more.. * ipv4 and ipv6 state split: think about this more..
* set debug level for various outputs
## aquatic_udp ## aquatic_udp
* mio: set oneshot for epoll and kqueue? otherwise, stop reregistering? * mio: set oneshot for epoll and kqueue? otherwise, stop reregistering?

6
aquatic_ws/src/lib/network/mod.rs
View file

@ -2,7 +2,7 @@ use std::time::Duration;
use std::io::ErrorKind; use std::io::ErrorKind;
use hashbrown::HashMap; use hashbrown::HashMap;
use log::{info, trace, error}; use log::{info, debug, error};
use native_tls::TlsAcceptor; use native_tls::TlsAcceptor;
use mio::{Events, Poll, Interest, Token}; use mio::{Events, Poll, Interest, Token};
use mio::net::TcpListener; use mio::net::TcpListener;
@ -190,7 +190,7 @@ pub fn run_handshakes_and_read_messages(
peer_addr: established_ws.peer_addr peer_addr: established_ws.peer_addr
}; };
trace!("read message"); debug!("read message");
if let Err(err) = in_message_sender if let Err(err) = in_message_sender
.send((meta, in_message)) .send((meta, in_message))
@ -256,7 +256,7 @@ pub fn send_out_messages(
match established_ws.ws.write_message(out_message.to_ws_message()){ match established_ws.ws.write_message(out_message.to_ws_message()){
Ok(()) => { Ok(()) => {
trace!("sent message"); debug!("sent message");
}, },
Err(Io(err)) if err.kind() == ErrorKind::WouldBlock => {}, Err(Io(err)) if err.kind() == ErrorKind::WouldBlock => {},
Err(tungstenite::Error::ConnectionClosed) => { Err(tungstenite::Error::ConnectionClosed) => {