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

aquatic_ws: add trace logging of requests

Browse source
This commit is contained in:
Joakim Frostegård 2021-02-10 21:28:59 +01:00
parent c0e0adbbae
commit de42d2e1b7
1 changed files with 10 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

10
aquatic_ws/src/lib/handler.rs
View file

@ -123,6 +123,8 @@ pub fn handle_announce_requests(
} }
} }
::log::trace!("received request from {:?}", request_sender_meta);
// Insert/update/remove peer who sent this request // Insert/update/remove peer who sent this request
{ {
let peer_status = PeerStatus::from_event_and_bytes_left( let peer_status = PeerStatus::from_event_and_bytes_left(
@ -197,6 +199,10 @@ pub fn handle_announce_requests(
offer_receiver.connection_meta, offer_receiver.connection_meta,
OutMessage::Offer(middleman_offer) OutMessage::Offer(middleman_offer)
); );
::log::trace!(
"sent middleman offer to {:?}",
offer_receiver.connection_meta
);
wake_socket_workers[offer_receiver.connection_meta.worker_index] = true; wake_socket_workers[offer_receiver.connection_meta.worker_index] = true;
} }
} }
@ -220,6 +226,10 @@ pub fn handle_announce_requests(
answer_receiver.connection_meta, answer_receiver.connection_meta,
OutMessage::Answer(middleman_answer) OutMessage::Answer(middleman_answer)
); );
::log::trace!(
"sent middleman answer to {:?}",
answer_receiver.connection_meta
);
wake_socket_workers[answer_receiver.connection_meta.worker_index] = true; wake_socket_workers[answer_receiver.connection_meta.worker_index] = true;
} }
} }