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

threadshare: Add FIXME comment for refactoring opportunities

Browse source
This commit is contained in:
Sebastian Dröge 2018-04-04 18:11:06 +03:00
parent 28100d3a63
commit 88933790e7
4 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
gst-plugin-threadshare/src/appsrc.rs
View file

@ -465,6 +465,7 @@ impl AppSrc {
if let (&Some(ref pending_future_id), &Some(ref io_context)) = if let (&Some(ref pending_future_id), &Some(ref io_context)) =
(pending_future_id, io_context) (pending_future_id, io_context)
{ {
// FIXME: This should all go into a helper function
let pending_futures = io_context.drain_pending_futures(*pending_future_id); let pending_futures = io_context.drain_pending_futures(*pending_future_id);
if !pending_futures.is_empty() { if !pending_futures.is_empty() {

1
gst-plugin-threadshare/src/proxy.rs
View file

@ -1031,6 +1031,7 @@ impl ProxySrc {
if let (&Some(ref pending_future_id), &Some(ref io_context)) = if let (&Some(ref pending_future_id), &Some(ref io_context)) =
(pending_future_id, io_context) (pending_future_id, io_context)
{ {
// FIXME: This should all go into a helper function
let pending_futures = io_context.drain_pending_futures(*pending_future_id); let pending_futures = io_context.drain_pending_futures(*pending_future_id);
if !pending_futures.is_empty() { if !pending_futures.is_empty() {

1
gst-plugin-threadshare/src/queue.rs
View file

@ -662,6 +662,7 @@ impl Queue {
if let (&Some(ref pending_future_id), &Some(ref io_context)) = if let (&Some(ref pending_future_id), &Some(ref io_context)) =
(pending_future_id, io_context) (pending_future_id, io_context)
{ {
// FIXME: This should all go into a helper function
let pending_futures = io_context.drain_pending_futures(*pending_future_id); let pending_futures = io_context.drain_pending_futures(*pending_future_id);
if !pending_futures.is_empty() { if !pending_futures.is_empty() {

1
gst-plugin-threadshare/src/udpsrc.rs
View file

@ -406,6 +406,7 @@ impl UdpSrc {
if let (&Some(ref pending_future_id), &Some(ref io_context)) = if let (&Some(ref pending_future_id), &Some(ref io_context)) =
(pending_future_id, io_context) (pending_future_id, io_context)
{ {
// FIXME: This should all go into a helper function
let pending_futures = io_context.drain_pending_futures(*pending_future_id); let pending_futures = io_context.drain_pending_futures(*pending_future_id);
if !pending_futures.is_empty() { if !pending_futures.is_empty() {