mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2025-02-24 08:36:19 +00:00
Code Issues Projects Releases Wiki Activity

webrtc: Enhance debug messages when using unknown peer ID

Browse source 
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1115>
This commit is contained in:
Thibault Saunier 2022-11-23 11:09:39 -03:00 committed by Sebastian Dröge
parent 6936bf65c4
commit 8b8f10691c
1 changed files with 6 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
net/webrtc/signalling/src/handlers/mod.rs
View file

@ -264,7 +264,7 @@ impl Handler {
#[instrument(level = "debug", skip(self))] #[instrument(level = "debug", skip(self))]
fn start_session(&mut self, producer_id: &str, consumer_id: &str) -> Result<(), Error> { fn start_session(&mut self, producer_id: &str, consumer_id: &str) -> Result<(), Error> {
self.peers.get(producer_id).map_or_else( self.peers.get(producer_id).map_or_else(
|| Err(anyhow!("Peer '{producer_id}' hasn't been welcomed")), || Err(anyhow!("No producer with ID: '{producer_id}'")),
|peer| { |peer| {
if !peer.producing() { if !peer.producing() {
Err(anyhow!( Err(anyhow!(
@ -277,10 +277,9 @@ impl Handler {
}, },
)?; )?;
self.peers.get(consumer_id).map_or_else( self.peers
|| Err(anyhow!("Peer '{consumer_id}' hasn't been welcomed")), .get(consumer_id)
Ok, .map_or_else(|| Err(anyhow!("No consumer with ID: '{consumer_id}'")), Ok)?;
)?;
let session_id = uuid::Uuid::new_v4().to_string(); let session_id = uuid::Uuid::new_v4().to_string();
self.sessions.insert( self.sessions.insert(
@ -1083,7 +1082,7 @@ mod tests {
assert_eq!( assert_eq!(
sent_message, sent_message,
p::OutgoingMessage::Error { p::OutgoingMessage::Error {
details: "Peer 'producer' hasn't been welcomed".into() details: "No producer with ID: 'producer'".into()
} }
); );
} }
@ -1285,7 +1284,7 @@ mod tests {
assert_eq!( assert_eq!(
sent_message, sent_message,
p::OutgoingMessage::Error { p::OutgoingMessage::Error {
details: "Peer 'consumer' hasn't been welcomed".into() details: "No consumer with ID: 'consumer'".into()
} }
); );
} }