mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-09-21 03:20:22 +00:00
d6627ae8e0
Original commit message from CVS: * examples/switch/switcher.c (my_bus_callback, switch_timer, last_message_received, main): * gst/switch/gstswitch.c (gst_switch_release_pad, gst_switch_request_new_pad, gst_switch_chain, gst_switch_event, gst_switch_set_property, gst_switch_get_property, gst_switch_get_linked_pad, gst_switch_getcaps, gst_switch_bufferalloc, gst_switch_dispose, gst_switch_init): * gst/switch/gstswitch.h (switch_mutex, GST_SWITCH_LOCK, GST_SWITCH_UNLOCK): Add an extra lock to protect against certain variables instead of using the object lock. Fix case where caps are different in the sink pads causes deadlock. Update example to use different caps on each sink pad.
83 lines
2.5 KiB
C
83 lines
2.5 KiB
C
/* GStreamer
|
|
* Copyright (C) 2003 Julien Moutte <julien@moutte.net>
|
|
*
|
|
* This library is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU Library General Public
|
|
* License as published by the Free Software Foundation; either
|
|
* version 2 of the License, or (at your option) any later version.
|
|
*
|
|
* This library is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* Library General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Library General Public
|
|
* License along with this library; if not, write to the
|
|
* Free Software Foundation, Inc., 59 Temple Place - Suite 330,
|
|
* Boston, MA 02111-1307, USA.
|
|
*/
|
|
|
|
#ifndef __GST_SWITCH_H__
|
|
#define __GST_SWITCH_H__
|
|
|
|
#include <gst/gst.h>
|
|
|
|
G_BEGIN_DECLS
|
|
|
|
#define GST_TYPE_SWITCH \
|
|
(gst_switch_get_type())
|
|
#define GST_SWITCH(obj) \
|
|
(G_TYPE_CHECK_INSTANCE_CAST((obj), GST_TYPE_SWITCH, GstSwitch))
|
|
#define GST_SWITCH_CLASS(klass) \
|
|
(G_TYPE_CHECK_CLASS_CAST((klass), GST_TYPE_SWITCH, GstSwitchClass))
|
|
#define GST_IS_SWITCH(obj) \
|
|
(G_TYPE_CHECK_INSTANCE_TYPE((obj), GST_TYPE_SWITCH))
|
|
#define GST_IS_SWITCH_CLASS(klass) \
|
|
(G_TYPE_CHECK_CLASS_TYPE((klass), GST_TYPE_SWITCH))
|
|
|
|
typedef struct _GstSwitch GstSwitch;
|
|
typedef struct _GstSwitchClass GstSwitchClass;
|
|
|
|
struct _GstSwitch {
|
|
GstElement element;
|
|
|
|
GstPad *active_sinkpad;
|
|
GstPad *srcpad;
|
|
GstPad *previous_sinkpad;
|
|
|
|
guint nb_sinkpads;
|
|
/* this hash table stores for key of the pad pointer
|
|
* the last new segment event received for this pad
|
|
* so when switching we can send new segment events
|
|
*/
|
|
GHashTable *newsegment_events;
|
|
/* flag to decide whether we need to send a new segment event
|
|
* before we receive the next buffer */
|
|
gboolean need_to_send_newsegment;
|
|
/* flag to decide whether to queue buffers received from current
|
|
* pads */
|
|
gboolean queue_buffers;
|
|
GstClockTime stop_value;
|
|
GstClockTime start_value;
|
|
GstClockTime current_start;
|
|
GstClockTime last_ts;
|
|
/* this hash tables stores for key of the pad pointer
|
|
* a GList of stored buffers that need to be sent once the
|
|
* new segment has been sent
|
|
*/
|
|
GHashTable *stored_buffers;
|
|
GMutex *switch_mutex;
|
|
};
|
|
|
|
#define GST_SWITCH_LOCK(obj) g_mutex_lock(obj->switch_mutex)
|
|
#define GST_SWITCH_UNLOCK(obj) g_mutex_unlock(obj->switch_mutex)
|
|
|
|
struct _GstSwitchClass {
|
|
GstElementClass parent_class;
|
|
};
|
|
|
|
GType gst_switch_get_type (void);
|
|
|
|
G_END_DECLS
|
|
|
|
#endif /* __GST_SWITCH_H__ */
|