Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
path: root/net
diff options
context:
space:
mode:
authorFrançois Laignel <fengalin@free.fr>2021-04-20 15:58:11 +0300
committerFrançois Laignel <fengalin@free.fr>2021-04-20 19:19:58 +0300
commit67c5871957a583c5817156891cb6586a54e6d5f4 (patch)
tree3d9aff3447876b8d17df180b8a0e9b9594f90b5d /net
parent27bc5c89cad7dfec9cc12c6c87beca76a4a0b139 (diff)
fix-getters-calls 0.3.0 pass
Diffstat (limited to 'net')
-rw-r--r--net/reqwest/build.rs2
-rw-r--r--net/reqwest/src/reqwesthttpsrc/imp.rs10
-rw-r--r--net/reqwest/tests/reqwesthttpsrc.rs14
-rw-r--r--net/rusoto/build.rs2
-rw-r--r--net/rusoto/src/aws_transcriber/imp.rs6
-rw-r--r--net/rusoto/src/s3src/imp.rs2
6 files changed, 18 insertions, 18 deletions
diff --git a/net/reqwest/build.rs b/net/reqwest/build.rs
index 17be1215e..cda12e57e 100644
--- a/net/reqwest/build.rs
+++ b/net/reqwest/build.rs
@@ -1,3 +1,3 @@
fn main() {
- gst_plugin_version_helper::get_info()
+ gst_plugin_version_helper::info()
}
diff --git a/net/reqwest/src/reqwesthttpsrc/imp.rs b/net/reqwest/src/reqwesthttpsrc/imp.rs
index 6bb40c8ef..5b67d9958 100644
--- a/net/reqwest/src/reqwesthttpsrc/imp.rs
+++ b/net/reqwest/src/reqwesthttpsrc/imp.rs
@@ -178,7 +178,7 @@ impl ReqwestHttpSrc {
return Ok(client.clone());
}
- let srcpad = src.get_static_pad("src").unwrap();
+ let srcpad = src.static_pad("src").unwrap();
let mut q = gst::query::Context::new(REQWEST_CLIENT_CONTEXT);
if srcpad.peer_query(&mut q) {
if let Some(context) = q.context_owned() {
@@ -471,15 +471,15 @@ impl ReqwestHttpSrc {
gst_debug!(CAT, obj: src, "Got content type {}", content_type);
if let Some(ref mut caps) = caps {
let caps = caps.get_mut().unwrap();
- let s = caps.get_mut_structure(0).unwrap();
+ let s = caps.structure_mut(0).unwrap();
s.set("content-type", &content_type.as_ref());
} else if content_type.type_() == "audio" && content_type.subtype() == "L16" {
let channels = content_type
- .get_param("channels")
+ .param("channels")
.and_then(|s| s.as_ref().parse::<i32>().ok())
.unwrap_or(2);
let rate = content_type
- .get_param("rate")
+ .param("rate")
.and_then(|s| s.as_ref().parse::<i32>().ok())
.unwrap_or(44_100);
@@ -1014,7 +1014,7 @@ impl PushSrcImpl for ReqwestHttpSrc {
if let Some(tags) = tags {
gst_debug!(CAT, obj: src, "Sending iradio tags {:?}", tags);
- let pad = src.get_static_pad("src").unwrap();
+ let pad = src.static_pad("src").unwrap();
pad.push_event(gst::event::Tag::new(tags));
}
diff --git a/net/reqwest/tests/reqwesthttpsrc.rs b/net/reqwest/tests/reqwesthttpsrc.rs
index 4e51c184d..11cb5d9af 100644
--- a/net/reqwest/tests/reqwesthttpsrc.rs
+++ b/net/reqwest/tests/reqwesthttpsrc.rs
@@ -81,7 +81,7 @@ impl Harness {
})
.build();
- let srcpad = src.get_static_pad("src").unwrap();
+ let srcpad = src.static_pad("src").unwrap();
srcpad.link(&pad).unwrap();
let bus = gst::Bus::new();
@@ -459,7 +459,7 @@ fn test_extra_headers() {
assert_eq!(headers.get("baz").unwrap(), "1");
assert_eq!(
headers
- .get_all("list")
+ .all("list")
.iter()
.map(|v| v.to_str().unwrap())
.collect::<Vec<&str>>(),
@@ -467,7 +467,7 @@ fn test_extra_headers() {
);
assert_eq!(
headers
- .get_all("array")
+ .all("array")
.iter()
.map(|v| v.to_str().unwrap())
.collect::<Vec<&str>>(),
@@ -640,7 +640,7 @@ fn test_iradio_mode() {
// Check if everything was read
assert_eq!(cursor.position(), 11);
- let srcpad = h.src.get_static_pad("src").unwrap();
+ let srcpad = h.src.static_pad("src").unwrap();
let caps = srcpad.current_caps().unwrap();
assert_eq!(
caps,
@@ -652,7 +652,7 @@ fn test_iradio_mode() {
{
use gst::EventView;
- let tag_event = srcpad.get_sticky_event(gst::EventType::Tag, 0).unwrap();
+ let tag_event = srcpad.sticky_event(gst::EventType::Tag, 0).unwrap();
if let EventView::Tag(tags) = tag_event.view() {
let tags = tags.tag();
assert_eq!(
@@ -721,7 +721,7 @@ fn test_audio_l16() {
// Check if everything was read
assert_eq!(cursor.position(), 11);
- let srcpad = h.src.get_static_pad("src").unwrap();
+ let srcpad = h.src.static_pad("src").unwrap();
let caps = srcpad.current_caps().unwrap();
assert_eq!(
caps,
@@ -1172,7 +1172,7 @@ fn test_cookies() {
},
);
- let context = h.src.get_context("gst.reqwest.client").expect("No context");
+ let context = h.src.context("gst.reqwest.client").expect("No context");
h2.src.set_context(&context);
// Set the HTTP source to Playing so that everything can start
diff --git a/net/rusoto/build.rs b/net/rusoto/build.rs
index 17be1215e..cda12e57e 100644
--- a/net/rusoto/build.rs
+++ b/net/rusoto/build.rs
@@ -1,3 +1,3 @@
fn main() {
- gst_plugin_version_helper::get_info()
+ gst_plugin_version_helper::info()
}
diff --git a/net/rusoto/src/aws_transcriber/imp.rs b/net/rusoto/src/aws_transcriber/imp.rs
index a7d7fba82..32015e129 100644
--- a/net/rusoto/src/aws_transcriber/imp.rs
+++ b/net/rusoto/src/aws_transcriber/imp.rs
@@ -821,7 +821,7 @@ impl Transcriber {
}
let in_caps = self.sinkpad.current_caps().unwrap();
- let s = in_caps.get_structure(0).unwrap();
+ let s = in_caps.structure(0).unwrap();
let sample_rate: i32 = s.get("rate").unwrap().unwrap();
let settings = self.settings.lock().unwrap();
@@ -962,7 +962,7 @@ impl ObjectSubclass for Transcriber {
type ParentType = gst::Element;
fn with_class(klass: &Self::Class) -> Self {
- let templ = klass.get_pad_template("sink").unwrap();
+ let templ = klass.pad_template("sink").unwrap();
let sinkpad = gst::Pad::builder_with_template(&templ, Some("sink"))
.chain_function(|pad, parent, buffer| {
Transcriber::catch_panic_pad_function(
@@ -980,7 +980,7 @@ impl ObjectSubclass for Transcriber {
})
.build();
- let templ = klass.get_pad_template("src").unwrap();
+ let templ = klass.pad_template("src").unwrap();
let srcpad = gst::Pad::builder_with_template(&templ, Some("src"))
.activatemode_function(|pad, parent, mode, active| {
Transcriber::catch_panic_pad_function(
diff --git a/net/rusoto/src/s3src/imp.rs b/net/rusoto/src/s3src/imp.rs
index 07cb4ab05..72f328d31 100644
--- a/net/rusoto/src/s3src/imp.rs
+++ b/net/rusoto/src/s3src/imp.rs
@@ -175,7 +175,7 @@ impl S3Src {
offset + length - 1
);
- let response = client.get_object(request);
+ let response = client.object(request);
let output = s3utils::wait(&self.canceller, response).map_err(|err| match err {
WaitError::FutureError(err) => Some(gst::error_msg!(