gst/switch/gstswitch.c (gst_stream_selector_block): Implement the block() signal...

Original commit message from CVS:
2007-12-17  Andy Wingo  <wingo@pobox.com>

* gst/switch/gstswitch.c (gst_stream_selector_block): Implement
the block() signal. This implementation will be replaced in future
patches, however. Patch 4/12.

diff --git a/ChangeLog b/ChangeLog
index 7d485efe3ebb699c8875110180ef4a81fd8fbf93..5310be6b9cabfc91bd200fbde9943ec2a6319274 100644 (file)
--- a/ChangeLog
+++ b/ChangeLog
@@ -1,5 +1,9 @@
 2007-12-17  Andy Wingo  <wingo@pobox.com>
 
+       * gst/switch/gstswitch.c (gst_stream_selector_block): Implement
+       the block() signal. This implementation will be replaced in future
+       patches, however. Patch 4/12.
+
        * gst/switch/gstswitch.h (struct _GstStreamSelectorClass): Fix
        vmethod prototypes.
 

diff --git a/gst/switch/gstswitch.c b/gst/switch/gstswitch.c
index 269ac91ebd76bd61668efc5fa4c6a24bc2769dac..fefdebac4db86e9de81c23769dd2e72d135ca0fa 100644 (file)
--- a/gst/switch/gstswitch.c
+++ b/gst/switch/gstswitch.c
@@ -721,10 +721,58 @@ gst_stream_selector_release_pad (GstElement * element, GstPad * pad)
   gst_element_remove_pad (GST_ELEMENT (sel), pad);
 }
 
+static void
+block_func (GstPad * pad, gboolean blocked, gpointer user_data)
+{
+  GST_DEBUG_OBJECT (pad, "got blocked = %d", blocked ? 1 : 0);
+}
+
+static void
+foreach_set_blocking (GstPad * pad, gpointer user_data)
+{
+  gboolean block = GPOINTER_TO_INT (user_data);
+
+  gst_pad_set_blocked_async (pad, block, block_func, NULL);
+}
+
+static gboolean
+block_all_pads (GstStreamSelector * self, gboolean block)
+{
+  GstIterator *iter;
+  GstIteratorResult res;
+
+  iter = gst_element_iterate_sink_pads (GST_ELEMENT (self));
+
+  while (TRUE) {
+    res = gst_iterator_foreach (iter, (GFunc) foreach_set_blocking,
+        GINT_TO_POINTER (block));
+    switch (res) {
+      case GST_ITERATOR_RESYNC:
+        gst_iterator_resync (iter);
+        break;
+      case GST_ITERATOR_DONE:
+        goto done;
+      default:
+        goto error;
+    }
+  }
+
+done:
+  GST_DEBUG_OBJECT (self, "block_all_pads(%d) succeeded", block);
+  gst_iterator_free (iter);
+  return TRUE;
+
+error:
+  GST_WARNING_OBJECT (self, "block(%d) signal error: %d", block, res);
+  gst_iterator_free (iter);
+  return FALSE;
+}
+
+
 static void
 gst_stream_selector_block (GstStreamSelector * self)
 {
-  return;
+  block_all_pads (self, TRUE);
 }
 
 static void