From dbc43b6e3021e34875d7d5bba04abf7ad1fc8633 Mon Sep 17 00:00:00 2001 From: Carl Hetherington Date: Mon, 29 Apr 2013 14:46:20 +0100 Subject: More cycle-breaking of shared_ptr for decoder / player. --- src/lib/video_source.cc | 25 ++++++++++++++++--------- 1 file changed, 16 insertions(+), 9 deletions(-) (limited to 'src/lib/video_source.cc') diff --git a/src/lib/video_source.cc b/src/lib/video_source.cc index 2de4db68d..4d505f9fe 100644 --- a/src/lib/video_source.cc +++ b/src/lib/video_source.cc @@ -36,22 +36,29 @@ process_video_proxy (weak_ptr sink, shared_ptr i, bool s void VideoSource::connect_video (shared_ptr s) { - /* If we bind, say, a Playlist (as the VideoSink) to a Decoder (which is owned - by the Playlist) we create a cycle. Use a weak_ptr to break it. + /* If we bind, say, a Player (as the VideoSink) to a Decoder (which is owned + by the Player) we create a cycle. Use a weak_ptr to break it. */ - Video.connect (bind (process_video_proxy, boost::weak_ptr (s), _1, _2, _3)); + Video.connect (bind (process_video_proxy, weak_ptr (s), _1, _2, _3)); } void -TimedVideoSource::connect_video (shared_ptr s) +TimedVideoSource::connect_video (shared_ptr s) { - Video.connect (bind (&TimedVideoSink::process_video, s, _1, _2, _3, _4)); + Video.connect (bind (process_video_proxy, weak_ptr (s), _1, _2, _3)); } -void -TimedVideoSource::connect_video (shared_ptr s) +static void +timed_process_video_proxy (weak_ptr sink, shared_ptr i, bool same, shared_ptr s, double t) { - Video.connect (bind (&VideoSink::process_video, s, _1, _2, _3)); + shared_ptr p = sink.lock (); + if (p) { + p->process_video (i, same, s, t); + } } - +void +TimedVideoSource::connect_video (shared_ptr s) +{ + Video.connect (bind (timed_process_video_proxy, weak_ptr (s), _1, _2, _3, _4)); +} -- cgit v1.2.3