diff options
| author | Wim Taymans <wim.taymans@gmail.com> | 2008-09-30 15:08:52 +0000 |
|---|---|---|
| committer | Tim-Philipp Müller <tim.muller@collabora.co.uk> | 2009-08-11 02:30:37 +0100 |
| commit | 55b7860cc4dbdf591dbe2543f3a5be946b027a97 (patch) | |
| tree | 7b021684d775b06105f0fa96de64a00195c1f381 | |
| parent | c2c69bfb865d2cf0da10204514edf34d7d935025 (diff) | |
gst/rtpmanager/rtpsession.c: Ref the rtpsource object before we release the session lock when we emit the signals.
Original commit message from CVS:
* gst/rtpmanager/rtpsession.c: (on_new_ssrc), (on_ssrc_collision),
(on_ssrc_validated), (on_ssrc_active), (on_ssrc_sdes),
(on_bye_ssrc), (on_bye_timeout), (on_timeout), (on_sender_timeout):
Ref the rtpsource object before we release the session lock when we emit
the signals.
| -rw-r--r-- | gst/rtpmanager/rtpsession.c | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/gst/rtpmanager/rtpsession.c b/gst/rtpmanager/rtpsession.c index 8e5909ff2..8e543b314 100644 --- a/gst/rtpmanager/rtpsession.c +++ b/gst/rtpmanager/rtpsession.c @@ -462,77 +462,95 @@ rtp_session_get_property (GObject * object, guint prop_id, static void on_new_ssrc (RTPSession * sess, RTPSource * source) { + g_object_ref (source); RTP_SESSION_UNLOCK (sess); g_signal_emit (sess, rtp_session_signals[SIGNAL_ON_NEW_SSRC], 0, source); RTP_SESSION_LOCK (sess); + g_object_unref (source); } static void on_ssrc_collision (RTPSession * sess, RTPSource * source) { + g_object_ref (source); RTP_SESSION_UNLOCK (sess); g_signal_emit (sess, rtp_session_signals[SIGNAL_ON_SSRC_COLLISION], 0, source); RTP_SESSION_LOCK (sess); + g_object_unref (source); } static void on_ssrc_validated (RTPSession * sess, RTPSource * source) { + g_object_ref (source); RTP_SESSION_UNLOCK (sess); g_signal_emit (sess, rtp_session_signals[SIGNAL_ON_SSRC_VALIDATED], 0, source); RTP_SESSION_LOCK (sess); + g_object_unref (source); } static void on_ssrc_active (RTPSession * sess, RTPSource * source) { + g_object_ref (source); RTP_SESSION_UNLOCK (sess); g_signal_emit (sess, rtp_session_signals[SIGNAL_ON_SSRC_ACTIVE], 0, source); RTP_SESSION_LOCK (sess); + g_object_unref (source); } static void on_ssrc_sdes (RTPSession * sess, RTPSource * source) { + g_object_ref (source); GST_DEBUG ("SDES changed for SSRC %08x", source->ssrc); RTP_SESSION_UNLOCK (sess); g_signal_emit (sess, rtp_session_signals[SIGNAL_ON_SSRC_SDES], 0, source); RTP_SESSION_LOCK (sess); + g_object_unref (source); } static void on_bye_ssrc (RTPSession * sess, RTPSource * source) { + g_object_ref (source); RTP_SESSION_UNLOCK (sess); g_signal_emit (sess, rtp_session_signals[SIGNAL_ON_BYE_SSRC], 0, source); RTP_SESSION_LOCK (sess); + g_object_unref (source); } static void on_bye_timeout (RTPSession * sess, RTPSource * source) { + g_object_ref (source); RTP_SESSION_UNLOCK (sess); g_signal_emit (sess, rtp_session_signals[SIGNAL_ON_BYE_TIMEOUT], 0, source); RTP_SESSION_LOCK (sess); + g_object_unref (source); } static void on_timeout (RTPSession * sess, RTPSource * source) { + g_object_ref (source); RTP_SESSION_UNLOCK (sess); g_signal_emit (sess, rtp_session_signals[SIGNAL_ON_TIMEOUT], 0, source); RTP_SESSION_LOCK (sess); + g_object_unref (source); } static void on_sender_timeout (RTPSession * sess, RTPSource * source) { + g_object_ref (source); RTP_SESSION_UNLOCK (sess); g_signal_emit (sess, rtp_session_signals[SIGNAL_ON_SENDER_TIMEOUT], 0, source); RTP_SESSION_LOCK (sess); + g_object_unref (source); } /** |