mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2024-12-27 04:20:28 +00:00
Code Issues Projects Releases Wiki Activity

webrtchttp: Do not import element_imp_error

Browse source 
element_imp_error and such macros should not be imported but rather
only be accessed via gst namespace.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/949>
This commit is contained in:
Sanchayan Maity 2022-11-29 10:40:01 +05:30
parent 0b1b8b91b9
commit 2eba3b321e
2 changed files with 15 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
net/webrtchttp/src/whepsrc/imp.rs
View file

@ -13,7 +13,7 @@ use crate::utils::{
use crate::GstRsWebRTCICETransportPolicy;
use bytes::Bytes;
use futures::future;
use gst::{element_imp_error, glib, prelude::*, subclass::prelude::*, ErrorMessage};
use gst::{glib, prelude::*, subclass::prelude::*, ErrorMessage};
use gst_sdp::*;
use gst_webrtc::*;
use once_cell::sync::Lazy;
@ -469,7 +469,7 @@ impl WhepSrc {
}
WebRTCICEConnectionState::Failed => {
self_.terminate_session();
element_imp_error!(self_, gst::ResourceError::Failed, ["ICE failed"]);
gst::element_imp_error!(self_, gst::ResourceError::Failed, ["ICE failed"]);
}
WebRTCICEConnectionState::Disconnected => (),
WebRTCICEConnectionState::Closed => (),
@ -498,7 +498,7 @@ impl WhepSrc {
WebRTCPeerConnectionState::Disconnected => (),
WebRTCPeerConnectionState::Failed => {
self_.terminate_session();
element_imp_error!(
gst::element_imp_error!(
self_,
gst::ResourceError::Failed,
["PeerConnection failed"]
@ -550,7 +550,7 @@ impl WhepSrc {
let endpoint =
reqwest::Url::parse(settings.whep_endpoint.as_ref().unwrap().as_str());
if let Err(e) = endpoint {
element_imp_error!(
gst::element_imp_error!(
self_,
gst::ResourceError::Failed,
["Could not parse WHEP endpoint URL :{}", e]
@ -568,7 +568,7 @@ impl WhepSrc {
drop(state);
if let Err(e) = self_.initial_post_request(endpoint.unwrap()) {
element_imp_error!(
gst::element_imp_error!(
self_,
gst::ResourceError::Failed,
["Error in initial post request - {}", e.to_string()]
@ -801,7 +801,7 @@ impl WhepSrc {
let reply = match reply {
Ok(Some(reply)) => reply,
Ok(None) => {
element_imp_error!(
gst::element_imp_error!(
self_,
gst::LibraryError::Failed,
["generate offer::Promise returned with no reply"]
@ -809,7 +809,7 @@ impl WhepSrc {
return;
}
Err(e) => {
element_imp_error!(
gst::element_imp_error!(
self_,
gst::LibraryError::Failed,
["generate offer::Promise returned with error {:?}", e]
@ -835,7 +835,7 @@ impl WhepSrc {
);
} else {
gst::error!(CAT, imp: self_, "Reply without an offer: {}", reply);
element_imp_error!(
gst::element_imp_error!(
self_,
gst::LibraryError::Failed,
["generate offer::Promise returned with no reply"]
@ -907,7 +907,7 @@ impl WhepSrc {
let offer_sdp = match local_desc {
None => {
element_imp_error!(
gst::element_imp_error!(
self,
gst::ResourceError::Failed,
["Local description is not set"]
@ -925,7 +925,7 @@ impl WhepSrc {
);
if let Err(e) = self.send_sdp(offer_sdp.sdp()) {
element_imp_error!(
gst::element_imp_error!(
self,
gst::ResourceError::Failed,
["Error in sending answer - {}", e.to_string()]
@ -1034,7 +1034,7 @@ impl WhepSrc {
(State::Stopped, whep_resource_url.clone())
}
_ => {
element_imp_error!(
gst::element_imp_error!(
self,
gst::ResourceError::Failed,
["Terminated in unexpected state"]

9
net/webrtchttp/src/whipsink/imp.rs
View file

@ -12,7 +12,6 @@ use crate::utils::{
};
use crate::GstRsWebRTCICETransportPolicy;
use futures::future;
use gst::element_imp_error;
use gst::glib;
use gst::prelude::*;
use gst::subclass::prelude::*;
@ -498,7 +497,7 @@ impl WhipSink {
/* Note that we check for a valid WHIP endpoint in change_state */
let endpoint = reqwest::Url::parse(settings.whip_endpoint.as_ref().unwrap().as_str());
if let Err(e) = endpoint {
element_imp_error!(
gst::element_imp_error!(
self,
gst::ResourceError::Failed,
["Could not parse endpoint URL: {}", e]
@ -520,7 +519,7 @@ impl WhipSink {
let offer_sdp = match local_desc {
None => {
element_imp_error!(
gst::element_imp_error!(
self,
gst::ResourceError::Failed,
["Local description is not set"]
@ -540,7 +539,7 @@ impl WhipSink {
match self.do_post(offer_sdp, endpoint.unwrap()) {
Ok(_) => (),
Err(e) => {
element_imp_error!(
gst::element_imp_error!(
self,
gst::ResourceError::Failed,
["Failed to send offer: {}", e]
@ -831,7 +830,7 @@ impl WhipSink {
(State::Stopped, resource_url.clone())
}
_ => {
element_imp_error!(
gst::element_imp_error!(
self,
gst::ResourceError::Failed,
["Terminated in unexpected state"]