Update for stream lock API changes: don't take stream log in sink event handlers any longer and change GST_STREAM_LOC...

Original commit message from CVS:
* ext/dv/gstdvdemux.c: (gst_dvdemux_handle_sink_event):
* ext/flac/gstflacdec.c: (gst_flacdec_loop),
(gst_flacdec_src_event):
* ext/flac/gstflacenc.c: (gst_flacenc_sink_event):
* ext/ladspa/gstsignalprocessor.c: (gst_signal_processor_event),
(gst_signal_processor_getrange), (gst_signal_processor_chain):
* gst/avi/gstavidemux.c: (gst_avi_demux_handle_seek):
* gst/flx/gstflxdec.c: (gst_flxdec_src_event_handler),
(gst_flxdec_sink_event_handler):
* gst/matroska/matroska-demux.c:
(gst_matroska_demux_handle_seek_event):
* gst/wavparse/gstwavparse.c: (gst_wavparse_handle_seek):
Update for stream lock API changes: don't take stream log
in sink event handlers any longer and change GST_STREAM_LOCK
to GST_PAD_STREAM_LOCK. Don't leak references in flxdec event
functions.

2 files changed, 2 insertions, 15 deletions

diff --git a/ext/flac/gstflacdec.c b/ext/flac/gstflacdec.c
index c609e2e5..af2c8dc6 100644
--- a/ext/flac/gstflacdec.c
+++ b/ext/flac/gstflacdec.c
@@ -527,8 +527,6 @@ gst_flacdec_loop (GstPad * sinkpad)
 
   flacdec = GST_FLACDEC (GST_OBJECT_PARENT (sinkpad));
 
-  GST_STREAM_LOCK (sinkpad);
-
   GST_DEBUG ("flacdec: entering loop");
   if (flacdec->init) {
     GST_DEBUG ("flacdec: initializing decoder");
@@ -563,7 +561,6 @@ analyze_state:
     case FLAC__SEEKABLE_STREAM_DECODER_OK:
     case FLAC__SEEKABLE_STREAM_DECODER_SEEKING:
       GST_DEBUG ("flacdec: everything ok");
-      GST_STREAM_UNLOCK (sinkpad);
       return;
 
     case FLAC__SEEKABLE_STREAM_DECODER_END_OF_STREAM:{
@@ -577,8 +574,6 @@ analyze_state:
 
       GST_DEBUG ("pausing");
       gst_pad_pause_task (sinkpad);
-
-      GST_STREAM_UNLOCK (sinkpad);
       return;
     }
 
@@ -602,8 +597,6 @@ analyze_state:
 
       GST_DEBUG ("pausing");
       gst_pad_pause_task (sinkpad);
-
-      GST_STREAM_UNLOCK (sinkpad);
       return;
     }
   }
@@ -765,7 +758,7 @@ gst_flacdec_src_event (GstPad * pad, GstEvent * event)
         GST_DEBUG ("Initializing seek");
         g_print ("Grab seek lock\n");
         gst_pad_push_event (flacdec->srcpad, gst_event_new_flush_start ());
-        GST_STREAM_LOCK (flacdec->sinkpad);
+        GST_PAD_STREAM_LOCK (flacdec->sinkpad);
         g_print ("Got seek lock\n");
         gst_pad_push_event (flacdec->srcpad, gst_event_new_flush_stop ());
         GST_DEBUG ("Ready");
@@ -773,7 +766,7 @@ gst_flacdec_src_event (GstPad * pad, GstEvent * event)
         flacdec->seek_value = pos;
         gst_pad_start_task (flacdec->sinkpad,
             (GstTaskFunction) gst_flacdec_loop, flacdec->sinkpad);
-        GST_STREAM_UNLOCK (flacdec->sinkpad);
+        GST_PAD_STREAM_UNLOCK (flacdec->sinkpad);
       } else
         res = FALSE;
       break;
diff --git a/ext/flac/gstflacenc.c b/ext/flac/gstflacenc.c
index 79f3de0b..360ff67b 100644
--- a/ext/flac/gstflacenc.c
+++ b/ext/flac/gstflacenc.c
@@ -600,7 +600,6 @@ gst_flacenc_sink_event (GstPad * pad, GstEvent * event)
       GstFormat format;
       gint64 start, stream_time;
 
-      GST_STREAM_LOCK (pad);
       if (flacenc->offset == 0) {
         gst_event_parse_newsegment (event, NULL, NULL, &format, &start, NULL,
             &stream_time);
@@ -623,14 +622,11 @@ gst_flacenc_sink_event (GstPad * pad, GstEvent * event)
       }
       gst_event_unref (event);
       /* don't push it downstream, we'll generate our own via seek to 0 */
-      GST_STREAM_UNLOCK (pad);
       break;
     }
     case GST_EVENT_EOS:
-      GST_STREAM_LOCK (pad);
       FLAC__seekable_stream_encoder_finish (flacenc->encoder);
       ret = gst_pad_event_default (pad, event);
-      GST_STREAM_UNLOCK (pad);
       break;
     case GST_EVENT_TAG:
       if (flacenc->tags) {
@@ -639,9 +635,7 @@ gst_flacenc_sink_event (GstPad * pad, GstEvent * event)
       } else {
         g_assert_not_reached ();
       }
-      GST_STREAM_LOCK (pad);
       ret = gst_pad_event_default (pad, event);
-      GST_STREAM_UNLOCK (pad);
       break;
     default:
       ret = gst_pad_event_default (pad, event);