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-06-05 15:08:58 +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/932>
This commit is contained in:
Thibault Saunier 2022-11-23 11:09:39 -03:00 committed by GStreamer Marge Bot
parent a0f6e84ec2
commit 4ec441560b
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
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!(
@ -278,7 +278,7 @@ impl Handler {
)?; )?;
self.peers.get(consumer_id).map_or_else( self.peers.get(consumer_id).map_or_else(
|| Err(anyhow!("Peer '{consumer_id}' hasn't been welcomed")), || Err(anyhow!("No consumer with ID: '{consumer_id}'")),
Ok, Ok,
)?; )?;
@ -1083,7 +1083,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 +1285,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()
} }
); );
} }