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-11-27 14:01:04 +00:00
Code Issues Projects Releases Wiki Activity

threadshare: Update for tokio API changes

Browse source
This commit is contained in:
Sebastian Dröge 2018-04-24 12:32:03 +03:00
parent 2dfca38977
commit da8390ef7b
1 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
gst-plugin-threadshare/src/iocontext.rs
View file

@ -134,8 +134,6 @@ impl IOContextRunner {
::tokio_reactor::with_default(&handle, &mut enter, |mut enter| { ::tokio_reactor::with_default(&handle, &mut enter, |mut enter| {
::tokio_timer::with_default(&timer_handle, &mut enter, |enter| loop { ::tokio_timer::with_default(&timer_handle, &mut enter, |enter| loop {
use tokio::executor::current_thread::Turn;
let now = time::Instant::now(); let now = time::Instant::now();
if self.shutdown.load(atomic::Ordering::SeqCst) > RUNNING { if self.shutdown.load(atomic::Ordering::SeqCst) > RUNNING {
@ -150,10 +148,11 @@ impl IOContextRunner {
} }
gst_trace!(CONTEXT_CAT, "Turning current thread '{}'", self.name); gst_trace!(CONTEXT_CAT, "Turning current thread '{}'", self.name);
while let Turn(true) = current_thread while current_thread
.enter(enter) .enter(enter)
.turn(Some(time::Duration::from_millis(0))) .turn(Some(time::Duration::from_millis(0)))
.unwrap() .unwrap()
.has_polled()
{} {}
gst_trace!(CONTEXT_CAT, "Turned current thread '{}'", self.name); gst_trace!(CONTEXT_CAT, "Turned current thread '{}'", self.name);