summaryrefslogtreecommitdiff
path: root/plugins/elements/gstqueue.c
AgeCommit message (Collapse)AuthorFilesLines
2005-11-30docs/gst/gstreamer-sections.txt: remove double entries from the docsThomas Vander Stichele1-6/+6
Original commit message from CVS: * docs/gst/gstreamer-sections.txt: remove double entries from the docs * gst/gst_private.h: * gst/gstinfo.c: (_gst_debug_init): remove the THREAD debug category * gst/Makefile.am: * gst/gstqueue.c: * gst/gstqueue.h: * docs/gst/gstreamer.types: * plugins/elements/gstqueue.c: (gst_queue_get_type), (gst_queue_init), (gst_queue_finalize), (gst_queue_change_state): completely move queue and fix up debugging categories
2005-11-29move queue from core to the elements plugin çThomas Vander Stichele1-6/+4
Original commit message from CVS: * gst/gst.c: * plugins/elements/Makefile.am: * plugins/elements/gstelements.c: * plugins/elements/gstqueue.c: move queue from core to the elements plugin ç
2005-11-28Makefile.am: don't run checks if we don't have checkThomas Vander Stichele1-3/+3
Original commit message from CVS: * Makefile.am: don't run checks if we don't have check * common/check.mak: remove the registry when running make torture * docs/gst/gstreamer-sections.txt: remove second multiply * gst/gstqueue.c: (gst_queue_loop): fix a compile warning when disabling debug
2005-11-22gst/: correctly fix GEnumValues so that nick is the short lowercase dashed tagThomas Vander Stichele1-3/+3
Original commit message from CVS: * gst/elements/Makefile.am: * gst/elements/gstfakesink.c: (gst_fake_sink_state_error_get_type): * gst/elements/gstfakesrc.c: (gst_fake_src_data_get_type), (gst_fake_src_sizetype_get_type), (gst_fake_src_filltype_get_type), (gst_fake_src_init), (gst_fake_src_prepare_buffer), (gst_fake_src_alloc_buffer), (gst_fake_src_get_size): * gst/elements/gstfakesrc.h: * gst/gstqueue.c: (queue_leaky_get_type): correctly fix GEnumValues so that nick is the short lowercase dashed tag * tools/gst-inspect.c: (print_element_properties_info): also show the nick, since it's useful to use from parse_launch syntax Fixes #322139
2005-11-21check/gst/gstevent.c (create_custom_events): Check thatAndy Wingo1-4/+0
Original commit message from CVS: 2005-11-21 Andy Wingo <wingo@pobox.com> * check/gst/gstevent.c (create_custom_events): Check that FLUSH_STOP is serialized. * check/elements/identity.c (event_func): * check/elements/fakesrc.c (event_func): No stream lock, the core takes it. * gst/base/gstbasetransform.c (gst_base_transform_event): No more stream lock taking, yay. * gst/gstevent.h (GST_EVENT_FLUSH_STOP): Marked as serialized to ensure that core takes the stream lock. * gst/base/gstbasesrc.c (gst_base_src_do_seek): Update for stream lock name change. * gst/base/gstbasesink.c (gst_base_sink_event): No need to take the stream lock for EOS, NEWSEGMENT, or FLUSH_STOP, the core does it already. For the flush start we do take it though so we get the right preroll state change messages. * gst/gstqueue.c (gst_queue_sink_activate_push): No need to take the stream lock here, the core does it for us. * gst/gstpad.h (GST_PAD_GET_STREAM_LOCK): Renamed from GST_STREAM_GET_LOCK. (GST_PAD_STREAM_LOCK, GST_PAD_STREAM_TRYLOCK) (GST_PAD_STREAM_UNLOCK, GST_PAD_STREAM_UNLOCK_FULL) (GST_PAD_STREAM_LOCK_FULL): Renamed from GST_STREAM_*. (GST_PAD_GET_PREROLL_LOCK): Renamed from GST_PREROLL_GET_LOCK. (GST_PAD_PREROLL_LOCK, GST_PAD_PREROLL_TRYLOCK) (GST_PAD_PREROLL_UNLOCK): Renamed from GST_PREROLL_*. * gst/gstpad.c: Update for stream lock name change. * gst/base/gstbasesink.c: Update for preroll lock name change.
2005-11-16check/Makefile.am: Enable valgrind check that should work fine now.Wim Taymans1-6/+2
Original commit message from CVS: * check/Makefile.am: Enable valgrind check that should work fine now. * gst/elements/gsttypefindelement.c: (gst_type_find_element_init): * gst/gstqueue.c: (gst_queue_init): Fix memleaks in pad allocation.
2005-11-15Revert all these unrefs, they don't even pass make check !Thomas Vander Stichele1-2/+0
Original commit message from CVS: Revert all these unrefs, they don't even pass make check !
2005-11-15And gst_object_unref here tooJohan Dahlin1-2/+2
Original commit message from CVS: And gst_object_unref here too
2005-11-15gst/: Free pad templates, fixes a couple of leaks.Johan Dahlin1-6/+10
Original commit message from CVS: * gst/base/gstbasesrc.c: (gst_base_src_init): * gst/elements/gsttypefindelement.c: (gst_type_find_element_init): * gst/gstqueue.c: (gst_queue_init): Free pad templates, fixes a couple of leaks.
2005-11-03gst/gstbus.c: Fix some typos.Tim-Philipp Müller1-1/+4
Original commit message from CVS: * gst/gstbus.c: (gst_bus_class_init): Fix some typos. * gst/gstqueue.c: (gst_queue_loop): Don't assume a miniobject that isn't a buffer is an event (it could be that there is a refcounting problem somewhere and the pointer is stale and refers to an already destroyed miniobject).
2005-10-31Boo!Andy Wingo1-12/+8
Original commit message from CVS: 2005-10-31 Andy Wingo <wingo@pobox.com> * Boo! * gst/gstqueue.c (gst_queue_chain): Fix downstream leaky mode. * gst/gstobject.c (gst_object_dispatch_properties_changed): No need to serialize property notifications on GLib 2.8. GLib 2.6 has the possibility of deadlocks here if code calling notify() or set() has a lock that can be taken in another notify handler (ABBA with class lock and e.g. python GIL state lock).
2005-10-28gst/base/gstbasetransform.c: Don't leak class.Wim Taymans1-0/+11
Original commit message from CVS: * gst/base/gstbasetransform.c: (gst_base_transform_class_init), (gst_base_transform_init): Don't leak class. * gst/gstqueue.c: (gst_queue_handle_sink_event), (gst_queue_loop): An EOS event marks the queue as completely filled.
2005-10-24gst/gstbus.c: Doc fix.Wim Taymans1-14/+6
Original commit message from CVS: * gst/gstbus.c: Doc fix. * gst/gstqueue.c: (gst_queue_handle_sink_event), (gst_queue_chain), (gst_queue_loop): Fix potential deadlock when QUEUE_LOCK is taken before STREAM_LOCK.
2005-10-24Fix some minor documentation typosMichael Smith1-3/+3
Original commit message from CVS: Fix some minor documentation typos
2005-10-23remove prematurely added error category and clean up the instancesThomas Vander Stichele1-2/+3
Original commit message from CVS: remove prematurely added error category and clean up the instances
2005-10-20gst/base/gstbasesink.c: Speed up current position calculation.Wim Taymans1-5/+7
Original commit message from CVS: * gst/base/gstbasesink.c: (gst_base_sink_get_position), (gst_base_sink_query): Speed up current position calculation. * gst/base/gstbasesrc.c: (gst_base_src_query), (gst_base_src_default_newsegment): Correctly set stream position in newsegment. * gst/gstbin.c: (gst_bin_add_func), (add_to_queue), (update_degree), (gst_bin_sort_iterator_next), (gst_bin_sort_iterator_resync), (gst_bin_sort_iterator_free): * gst/gstmessage.c: (gst_message_new_custom): Clean up debugging info * gst/gstqueue.c: (gst_queue_link_src), (gst_queue_chain), (gst_queue_loop), (gst_queue_handle_src_query): Pause task faster.
2005-10-19gst/: API change fix.Wim Taymans1-6/+6
Original commit message from CVS: * gst/base/gstbasesink.c: (gst_base_sink_commit_state), (gst_base_sink_handle_object), (gst_base_sink_query), (do_playing): * gst/base/gstbasesrc.c: (gst_base_src_query): * gst/elements/gstfilesink.c: (gst_file_sink_query): * gst/elements/gsttypefindelement.c: (gst_type_find_handle_src_query), (find_element_get_length), (gst_type_find_element_activate): API change fix. * gst/gstquery.c: (gst_query_new_position), (gst_query_set_position), (gst_query_parse_position), (gst_query_new_duration), (gst_query_set_duration), (gst_query_parse_duration), (gst_query_set_segment), (gst_query_parse_segment): * gst/gstquery.h: Bundling query position/duration is not a good idea since duration does not change much and we don't want to recalculate it for every position query, so they are separated again.. Base value in segment query is not needed. * gst/gstqueue.c: (gst_queue_handle_src_query): * gst/gstutils.c: (gst_element_query_position), (gst_element_query_duration), (gst_pad_query_position), (gst_pad_query_duration): * gst/gstutils.h: Updates for query API change. Added some docs here and there.
2005-10-15various style fixesThomas Vander Stichele1-1/+1
Original commit message from CVS: various style fixes
2005-10-15whitespace fixesThomas Vander Stichele1-4/+4
Original commit message from CVS: whitespace fixes
2005-10-08gst/base/gstbasesink.c: Better log message.Wim Taymans1-26/+1
Original commit message from CVS: * gst/base/gstbasesink.c: (gst_base_sink_handle_object), (gst_base_sink_handle_buffer): Better log message. * gst/gstbus.h: * gst/gstelement.h: More docs. * gst/gstqueue.c: (gst_queue_class_init), (gst_queue_init), (gst_queue_set_property), (gst_queue_get_property): * gst/gstqueue.h: Remove old unused properties.
2005-09-02more docs inlinedStefan Kost1-0/+14
Original commit message from CVS: * docs/gst/gstreamer-docs.sgml: * docs/gst/tmpl/.cvsignore: * docs/gst/tmpl/gstghostpad.sgml: * docs/gst/tmpl/gstiterator.sgml: * docs/gst/tmpl/gstmacros.sgml: * docs/gst/tmpl/gstrealpad.sgml: * docs/gst/tmpl/gstregistry.sgml: * docs/gst/tmpl/gstregistrypool.sgml: * docs/gst/tmpl/gststructure.sgml: * docs/gst/tmpl/gstsystemclock.sgml: * docs/gst/tmpl/gsttrace.sgml: * gst/gstghostpad.c: * gst/gstmacros.h: * gst/gstmemchunk.c: * gst/gstmemchunk.h: * gst/gstqueue.c: * gst/gstregistry.c: * gst/gstregistrypool.c: * gst/gststructure.c: * gst/gstsystemclock.c: more docs inlined
2005-09-02gst/gstelement.h (GstState): Renamed from GstElementState, changed to be a ↵Andy Wingo1-13/+14
normal enum instead of flags. Original commit message from CVS: 2005-09-02 Andy Wingo <wingo@pobox.com> * gst/gstelement.h (GstState): Renamed from GstElementState, changed to be a normal enum instead of flags. (GstStateChangeReturn): Renamed from GstElementStateReturn, names munged to be GST_STATE_CHANGE_*. (GST_STATE_CHANGE): Renamed from GST_STATE_TRANSITION, updated to work with the new state representation. (GstStateChange): New enumeration of possible state transitions. Replaces GST_STATE_FOO_TO_BAR with GST_STATE_CHANGE_FOO_TO_BAR. (GstElementClass::change_state): Pass the GstStateChange along as an argument. Helps language bindings, so they don't have to use tricky lock-needing macros like GST_STATE_CHANGE (). * scripts/update-states (file): New script. Run it on a file to update it for state naming and API changes. Updates files in place. * All files updated for the new API.
2005-08-24check/generic/states.c: Make sure all tasks are stopped.Wim Taymans1-7/+10
Original commit message from CVS: * check/generic/states.c: (GST_START_TEST): Make sure all tasks are stopped. * check/gst/gstbin.c: (GST_START_TEST): Unref after usage for proper valgrinding. * gst/gstpad.c: (gst_pad_finalize), (gst_pad_stop_task): Really wait for the task to stop before destroying the mutex. * gst/gstqueue.c: (gst_queue_sink_activate_push), (gst_queue_src_activate_push): Small cleanups. Don't stop the task when we did not start it. * gst/gsttask.c: (gst_task_get_type), (gst_task_init), (gst_task_func), (gst_task_cleanup_all), (gst_task_set_lock), (gst_task_get_state), (gst_task_start), (gst_task_pause), (gst_task_join): * gst/gsttask.h: Protect the stream lock with the object lock. Disallow setting the stream lock when running. Add cleanup_all to wait for the threadpool to finish. Remove code to autoallocate a mutex if none was provided. Add _join() to wait for a task to stop. Protect the thread pool with a global lock.
2005-08-23gst/gstevent.*: Some more debugging output and doc cleanups.Wim Taymans1-1/+2
Original commit message from CVS: * gst/gstevent.c: (_gst_event_copy), (gst_event_new_custom), (gst_event_new_newsegment), (gst_event_parse_newsegment), (gst_event_new_tag), (gst_event_parse_tag), (gst_event_new_qos), (gst_event_parse_qos), (gst_event_new_seek), (gst_event_parse_seek): * gst/gstevent.h: Some more debugging output and doc cleanups. * gst/gstqueue.c: (gst_queue_handle_sink_event): Fix possible deadlock.
2005-08-22gst/base/gstbasesink.c: Remove extra parameter to debug outputJan Schmidt1-3/+7
Original commit message from CVS: * gst/base/gstbasesink.c: (gst_base_sink_handle_object): Remove extra parameter to debug output * gst/base/gstbasesrc.c: (gst_base_src_send_discont), (gst_base_src_do_seek), (gst_base_src_activate_push): Fix seek event handling. * gst/gstpipeline.c: (gst_pipeline_change_state): * gst/gstqueue.c: (gst_queue_handle_sink_event), (gst_queue_src_activate_push): Don't start the src pad task on FLUSH_STOP if the pad isn't linked. Debug changes.
2005-08-18check/: I wrote a test!Jan Schmidt1-3/+10
Original commit message from CVS: * check/Makefile.am: * check/gst/gstevents.c: (GST_START_TEST), (event_probe), (test_event), (timediff), (gstevents_suite), (main): I wrote a test! * docs/design/part-seeking.txt: Spelling correction * docs/gst/tmpl/gstevent.sgml: Docs updates. * gst/base/gstbasesink.c: (gst_base_sink_handle_object): Treat a buffer-without-newsegment the same as a receiving a newsegment not in time format, and disable syncing to the clock with a warning. * gst/gstbus.c: (gst_bus_set_sync_handler): Assert if anyone tries to replace the existing sync_handler for bus, as only the owner should be setting it. * gst/gstevent.h: Have a fixed set of custom event enums with events identified by their structure name (as in 0.8), rather than a free-for-all allowing collisions between enum values from different plugins. * gst/gstpad.c: (gst_pad_class_init): Docs change. * gst/gstqueue.c: (gst_queue_handle_sink_event): Handle out-of-band downstream events from the sending thread.
2005-08-15docs/gst/gstreamer-sections.txt: made some defines privateStefan Kost1-0/+26
Original commit message from CVS: * docs/gst/gstreamer-sections.txt: made some defines private * docs/gst/tmpl/gstconfig.sgml: * docs/gst/tmpl/gstqueue.sgml: * docs/gst/tmpl/gsttaglist.sgml: * docs/gst/tmpl/gsttypes.sgml: * docs/gst/tmpl/gstutils.sgml: * docs/pwg/appendix-porting.xml: * gst/base/gstbasesink.h: * gst/base/gstbasesrc.c: * gst/base/gstbasesrc.h: * gst/elements/gstfakesink.c: (gst_fake_sink_class_init): * gst/elements/gstfakesrc.c: (gst_fake_src_class_init): * gst/gstelement.c: (gst_element_class_init): * gst/gstpad.c: (gst_pad_class_init): * gst/gstqueue.c: (gst_queue_class_init): * gst/gstxml.c: (gst_xml_class_init): documented all undocumented signal inline * libs/gst/controller/gst-controller.h: added padding
2005-07-27Some docs updatesWim Taymans1-22/+28
Original commit message from CVS: * CHANGES-0.9: * docs/design/part-TODO.txt: * docs/design/part-events.txt: Some docs updates * gst/base/gstbasesink.c: (gst_base_sink_handle_object), (gst_base_sink_event), (gst_base_sink_do_sync), (gst_base_sink_activate_push), (gst_base_sink_activate_pull): * gst/base/gstbasesrc.c: (gst_base_src_send_discont), (gst_base_src_do_seek), (gst_base_src_event_handler), (gst_base_src_loop): * gst/base/gstbasetransform.c: (gst_base_transform_transform_caps), (gst_base_transform_configure_caps), (gst_base_transform_setcaps), (gst_base_transform_get_size), (gst_base_transform_buffer_alloc), (gst_base_transform_event), (gst_base_transform_handle_buffer), (gst_base_transform_set_passthrough), (gst_base_transform_is_passthrough): * gst/elements/gstfakesink.c: (gst_fake_sink_event): * gst/elements/gstfilesink.c: (gst_file_sink_event): Event updates. * gst/gstbuffer.h: Use faster casts. * gst/gstelement.c: (gst_element_seek): * gst/gstelement.h: Update gst_element_seek. * gst/gstevent.c: (gst_event_finalize), (_gst_event_copy), (gst_event_new), (gst_event_new_custom), (gst_event_get_structure), (gst_event_new_flush_start), (gst_event_new_flush_stop), (gst_event_new_eos), (gst_event_new_newsegment), (gst_event_parse_newsegment), (gst_event_new_tag), (gst_event_parse_tag), (gst_event_new_filler), (gst_event_new_qos), (gst_event_parse_qos), (gst_event_new_seek), (gst_event_parse_seek), (gst_event_new_navigation): * gst/gstevent.h: Make GstEvent use GstStructure. Add parsing code, make sure the API is sufficiently generic. Mark possible directions of events and serialization. * gst/gstmessage.c: (gst_message_init), (gst_message_finalize), (_gst_message_copy), (gst_message_new_segment_start), (gst_message_new_segment_done), (gst_message_new_custom), (gst_message_parse_segment_start), (gst_message_parse_segment_done): Small cleanups. * gst/gstpad.c: (gst_pad_get_caps_unlocked), (gst_pad_accept_caps), (gst_pad_set_caps), (gst_pad_send_event): Update for new events. Catch events sent in wrong directions. * gst/gstqueue.c: (gst_queue_link_src), (gst_queue_handle_sink_event), (gst_queue_chain), (gst_queue_loop), (gst_queue_handle_src_query): Event updates. * gst/gsttag.c: * gst/gsttag.h: Remove event code from this file. * libs/gst/dataprotocol/dataprotocol.c: (gst_dp_packet_from_event), (gst_dp_event_from_packet): Event updates.
2005-07-21docs/design/part-seeking.txt: Some small additions.Wim Taymans1-7/+41
Original commit message from CVS: * docs/design/part-seeking.txt: Some small additions. * gst/base/gstbasesink.c: (gst_base_sink_handle_object), (gst_base_sink_get_times), (gst_base_sink_do_sync), (gst_base_sink_activate_push), (gst_base_sink_activate_pull): * gst/base/gstbasesink.h: discont values are gint64, handle the math correctly. * gst/base/gstbasesrc.c: (gst_base_src_loop): Make the basesrc report error if the source pad is not linked. * gst/gstqueue.c: (gst_queue_link_src), (gst_queue_chain), (gst_queue_loop), (gst_queue_handle_src_query), (gst_queue_src_activate_push): Make queue collect data even if the srcpad is not linked. Start pushing out data as soon as it is linked. * gst/gstutils.c: (gst_element_unlink), (gst_flow_get_name): * gst/gstutils.h: Added gst_flow_get_name() to ease error reporting.
2005-07-20gst/base/gstbasesrc.*: Add a gboolean to decide when to push out a discont.Wim Taymans1-63/+51
Original commit message from CVS: * gst/base/gstbasesrc.c: (gst_base_src_init), (gst_base_src_do_seek), (gst_base_src_loop), (gst_base_src_start): * gst/base/gstbasesrc.h: Add a gboolean to decide when to push out a discont. * gst/gstqueue.c: (gst_queue_handle_sink_event), (gst_queue_chain), (gst_queue_loop), (gst_queue_handle_src_query), (gst_queue_sink_activate_push), (gst_queue_src_activate_push), (gst_queue_set_property), (gst_queue_get_property): Some cleanups. * tests/threadstate/threadstate1.c: (main): Make a thread test compile and run... very silly..
2005-07-19gst/gstqueue.*: Propagate GstFlowReturn more intelligently upstream and ↵Wim Taymans1-33/+76
output an ERROR/EOS when streaming stopped du... Original commit message from CVS: * gst/gstqueue.c: (gst_queue_init), (gst_queue_handle_sink_event), (gst_queue_chain), (gst_queue_loop), (gst_queue_handle_src_event), (gst_queue_handle_src_query), (gst_queue_sink_activate_push), (gst_queue_src_activate_push), (gst_queue_change_state), (gst_queue_get_property): * gst/gstqueue.h: Propagate GstFlowReturn more intelligently upstream and output an ERROR/EOS when streaming stopped due to fatal error.
2005-07-17gst/gstqueue.c: Fix nasty refcount bug.Wim Taymans1-3/+3
Original commit message from CVS: * gst/gstqueue.c: (gst_queue_handle_sink_event): Fix nasty refcount bug.
2005-07-14gst/gstcaps.c: Remove debug info.Wim Taymans1-9/+12
Original commit message from CVS: * gst/gstcaps.c: (gst_caps_do_simplify): Remove debug info. * gst/gsterror.h: Define error for stream stopped. * gst/gstghostpad.c: (gst_proxy_pad_do_bufferalloc), (gst_proxy_pad_do_chain), (gst_proxy_pad_do_getrange): Do proper return values. * gst/gstpad.c: (gst_pad_get_caps_unlocked), (gst_pad_accept_caps), (gst_pad_set_caps), (gst_pad_chain), (gst_pad_push), (gst_pad_get_range): Better return values. * gst/gstpad.h: Reorganise return values, add macro to check for fatal errors. * gst/gstqueue.c: (gst_queue_chain): Return proper GstFlowReturn values,
2005-07-13fix debug ifdefThomas Vander Stichele1-1/+1
Original commit message from CVS: fix debug ifdef
2005-06-30debug disable fixesThomas Vander Stichele1-1/+4
Original commit message from CVS: debug disable fixes
2005-06-28gst/: The deprecated pad loop function is removed now.Wim Taymans1-1/+0
Original commit message from CVS: * gst/base/gstbasesink.c: (gst_basesink_set_pad_functions), (gst_basesink_preroll_queue_flush): * gst/base/gstbasesrc.c: (gst_basesrc_set_dataflow_funcs): * gst/elements/gsttee.c: (gst_tee_update_pad_functions): * gst/gstghostpad.c: (gst_proxy_pad_do_bufferalloc), (gst_proxy_pad_do_acceptcaps), (gst_proxy_pad_do_fixatecaps), (gst_proxy_pad_set_property): * gst/gstpad.c: * gst/gstpad.h: * gst/gstqueue.c: (gst_queue_init): The deprecated pad loop function is removed now.
2005-06-27gst/base/gsttypefindhelper.c (gst_type_find_helper): Unref any remaining buffer.Andy Wingo1-45/+35
Original commit message from CVS: 2005-06-27 Andy Wingo <wingo@pobox.com> * gst/base/gsttypefindhelper.c (gst_type_find_helper): Unref any remaining buffer. * gst/gsttrace.c (gst_alloc_trace_list_sorted): New helper, returns a sorted copy of the trace list. (gst_alloc_trace_print_live): New API, only prints traces with live objects. Sort the list. (gst_alloc_trace_print_all): Sort the list. (gst_alloc_trace_print): Align columns. * gst/elements/gstttypefindelement.c: * gst/elements/gsttee.c: * gst/base/gstbasesrc.c: * gst/base/gstbasesink.c: * gst/base/gstbasetransform.c: * gst/gstqueue.c: Adapt for pad activation changes. * gst/gstpipeline.c (gst_pipeline_init): Unref after parenting sched. (gst_pipeline_dispose): Drop ref on sched. * gst/gstpad.c (gst_pad_init): Set the default activate func. (gst_pad_activate_default): Push mode by default. (pre_activate_switch, post_activate_switch): New stubs, things to do before and after switching activation modes on pads. (gst_pad_set_active): Take a boolean and not a mode, dispatch to the pad's activate function to choose which mode to activate. Shortcut on deactivation and call the right function directly. (gst_pad_activate_pull): New API, (de)activates a pad in pull mode. (gst_pad_activate_push): New API, same for push mode. (gst_pad_set_activate_function) (gst_pad_set_activatepull_function) (gst_pad_set_activatepush_function): Setters for new API. * gst/gstminiobject.c (gst_mini_object_new, gst_mini_object_free): Trace all miniobjects. (gst_mini_object_make_writable): Unref the arg if we copy, like gst_caps_make_writable. * gst/gstmessage.c (_gst_message_initialize): No trace init. * gst/gstghostpad.c (gst_proxy_pad_do_activate) (gst_proxy_pad_do_activatepull, gst_proxy_pad_do_activatepush): Adapt for new pad API. * gst/gstevent.c (_gst_event_initialize): Don't initialize trace. * gst/gstelement.h: * gst/gstelement.c (gst_element_iterate_src_pads) (gst_element_iterate_sink_pads): New API functions. * gst/gstelement.c (iterator_fold_with_resync): New utility, should fold into gstiterator.c in some form. (gst_element_pads_activate): Simplified via use of fold and delegation of decisions to gstpad->activate. * gst/gstbus.c (gst_bus_source_finalize): Set the bus to NULL, help in debugging. * gst/gstbuffer.c (_gst_buffer_initialize): Ref the buffer type class once in init, like gstmessage. Didn't run into this issue but it seems correct. Don't initialize a trace, gstminiobject does that. * check/pipelines/simple_launch_lines.c (test_stop_from_app): New test, runs fakesrc ! fakesink, stopping on ::handoff via a message to the bus. (assert_live_count): New util function, uses alloc traces to check cleanup. * check/gst/gstghostpad.c (test_ghost_pads): More refcount checks. To be modified when unlink drops the internal pad.
2005-06-23gst/: No unsafe task pausing please.Wim Taymans1-2/+2
Original commit message from CVS: * gst/gstpad.c: (gst_pad_event_default): * gst/gstqueue.c: (gst_queue_loop): No unsafe task pausing please.
2005-06-08gst/gstutils.c: RPAD fixes all around.Andy Wingo1-4/+4
Original commit message from CVS: 2005-06-08 Andy Wingo <wingo@pobox.com> * gst/gstutils.c: RPAD fixes all around. (gst_element_link_pads): Refcounting fixes. * tools/gst-inspect.c: * tools/gst-xmlinspect.c: * parse/grammar.y: * gst/base/gsttypefindhelper.c: * gst/base/gstbasesink.c: * gst/gstqueue.c: RPAD fixes. * gst/gstghostpad.h: * gst/gstghostpad.c: New ghost pad implementation as full proxy pads. The tricky thing is they provide both source and sink interfaces, since they proxy the internal pad for the external pad, and vice versa. Implement with lower-level ProxyPad objects, with the interior proxy pad as a child of the exterior ghost pad. Should write a doc on this. * gst/gstpad.h: s/RPAD/PAD/, s/RealPad/Pad/. (gst_pad_set_name, gst_pad_set_parent): Macros removed, use gst_object API. * gst/gstpad.c: Big changes. No more stub base GstPad, now all pads are real pads. No ghost pads in this file. Not documenting the myriad s/RPAD/PAD/ and REALIZE fixes. (gst_pad_class_init): Add properties for "direction" and "template". Both are construct-only, so they can't change during the life of the pad. Fixes properly deriving from GstPad. (gst_pad_custom_new, gst_pad_custom_new_from_template): Gone. For derived objects, just set properties when creating the objects via g_object_new. (gst_pad_get_parent): Implement as a function, return NULL if the parent is not an element. (gst_pad_get_real_parent, gst_pad_add_ghost_pad) (gst_pad_remove_ghost_pad, gst_pad_realize): Removed. * gst/gstobject.c (gst_object_class_init): Make name a construct property. Don't set it in the object init. * gst/gstelement.c (gst_element_add_pad): Don't allow adding pads with UNKNOWN direction. (gst_element_add_ghost_pad): Remove non-orthogonal API. Replace with gst_element_add_pad (e, gst_ghost_pad_new (name, pad)). (gst_element_remove_pad): Remove ghost-pad special cases. (gst_element_pads_activate): Remove rpad cruft. * gst/gstbin.c (gst_bin_change_state): Use gst_pad_get_parent to catch the pad's-parent-not-an-element case. * gst/gst.h: Include gstghostpad.h. * gst/gst.c (init_post): No more real, ghost pads. * gst/Makefile.am: Add gstghostpad.[ch]. * check/Makefile.am: * check/gst/gstbin.c: * check/gst/gstghostpad.c (test_ghost_pads): Check that linking into a bin creates ghost pads, and that the refcounts are right. Partly moved from gstbin.c.
2005-06-02gst/: Bufferalloc: return GstFlowReturn to more accuratly report why ↵Wim Taymans1-16/+7
allocation failed. Original commit message from CVS: * gst/base/gstbasesink.c: (gst_basesink_pad_buffer_alloc), (gst_base_sink_buffer_alloc), (gst_basesink_preroll_queue_push), (gst_basesink_activate): * gst/base/gstbasesink.h: * gst/gstpad.c: (gst_pad_set_active), (gst_pad_link_prepare), (gst_pad_link), (gst_pad_accept_caps), (gst_pad_alloc_buffer), (gst_pad_query), (gst_pad_start_task): * gst/gstpad.h: * gst/gstqueue.c: (gst_queue_bufferalloc), (gst_queue_handle_sink_event), (gst_queue_chain): Bufferalloc: return GstFlowReturn to more accuratly report why allocation failed.
2005-05-30gst/gstqueue.c: Remove old pieces of codeWim Taymans1-37/+1
Original commit message from CVS: * gst/gstqueue.c: (gst_queue_handle_sink_event), (gst_queue_chain), (gst_queue_loop), (gst_queue_handle_src_event): Remove old pieces of code Flushing the queue in an upstream event is a very bad idea.
2005-05-25gst/: Fix state changes for non sinks. We now change sinks, then elements ↵Wim Taymans1-26/+80
with unconnected srcpads, then the rest. Original commit message from CVS: * gst/gstbin.c: (bin_element_is_sink), (has_ancestor), (bin_element_is_semi_sink), (append_child), (gst_bin_change_state): * gst/gstpad.c: (gst_pad_set_active), (gst_pad_link_prepare), (gst_pad_link), (gst_pad_accept_caps), (gst_pad_query), (gst_pad_send_event), (gst_pad_start_task): * gst/gstqueue.c: (gst_queue_init), (gst_queue_locked_flush), (gst_queue_handle_sink_event), (gst_queue_chain), (gst_queue_loop), (gst_queue_sink_activate), (gst_queue_src_activate), (gst_queue_change_state): * gst/gstqueue.h: Fix state changes for non sinks. We now change sinks, then elements with unconnected srcpads, then the rest. More efficient queue unlocking in flush and state changes. Set the pad activate mode even if it does not have an activate function.
2005-05-25gst/: Implement gst_pad_pause/start/stop_task(), take STREAM lock in task ↵Wim Taymans1-35/+10
function. Original commit message from CVS: * gst/base/gstadapter.c: (gst_adapter_peek), (gst_adapter_flush): * gst/base/gstbasesink.c: (gst_basesink_preroll_queue_push), (gst_basesink_finish_preroll), (gst_basesink_chain), (gst_basesink_loop), (gst_basesink_activate), (gst_basesink_change_state): * gst/base/gstbasesrc.c: (gst_basesrc_do_seek), (gst_basesrc_get_range), (gst_basesrc_loop), (gst_basesrc_activate): * gst/elements/gsttee.c: (gst_tee_sink_activate): * gst/gstpad.c: (gst_pad_dispose), (gst_real_pad_class_init), (gst_real_pad_init), (gst_real_pad_set_property), (gst_real_pad_get_property), (gst_pad_set_active), (gst_pad_is_active), (gst_pad_get_query_types), (gst_pad_unlink), (gst_pad_link_prepare), (gst_pad_link), (gst_pad_get_real_parent), (gst_real_pad_get_caps_unlocked), (gst_pad_peer_get_caps), (gst_pad_accept_caps), (gst_pad_get_peer), (gst_pad_realize), (gst_pad_event_default_dispatch), (gst_pad_event_default), (gst_pad_dispatcher), (gst_pad_query), (gst_real_pad_dispose), (gst_pad_save_thyself), (handle_pad_block), (gst_pad_chain), (gst_pad_push), (gst_pad_get_range), (gst_pad_pull_range), (gst_pad_send_event), (gst_pad_start_task), (gst_pad_pause_task), (gst_pad_stop_task): * gst/gstpad.h: * gst/gstqueue.c: (gst_queue_handle_sink_event), (gst_queue_chain), (gst_queue_loop), (gst_queue_src_activate): * gst/gsttask.c: (gst_task_init), (gst_task_set_lock), (gst_task_get_state): * gst/gsttask.h: * gst/schedulers/threadscheduler.c: (gst_thread_scheduler_task_start), (gst_thread_scheduler_func): Implement gst_pad_pause/start/stop_task(), take STREAM lock in task function. Remove ACTIVE pad flag, use FLUSHING everywhere Added _pad_chain(), _pad_get_range() to call chain/getrange functions. Add locks around IS_FLUSHING when reading. Take STREAM lock in chain(), get_range() functions so plugins don't need to take it anymore.
2005-05-17gst/: Don't queue buffers in basesink when we are flushing.Wim Taymans1-2/+2
Original commit message from CVS: * gst/base/gstbasesink.c: (gst_basesink_finish_preroll), (gst_basesink_chain_unlocked), (gst_basesink_activate): * gst/gstminiobject.c: (gst_mini_object_get_type), (gst_mini_object_free): * gst/gstpad.c: (gst_pad_accept_caps), (gst_pad_query), (gst_pad_push), (gst_pad_push_event): * gst/gstqueue.c: (gst_queue_change_state): Don't queue buffers in basesink when we are flushing. Unref buffer when flushing in basesink. Flush queue when going to READY Unref buffer when _push() returns an error. Don't free MiniObject instance when refcount is incremented in _finalize() so that we can recover objects.
2005-05-16check/Makefile.am: remove GstData checksDavid Schleef1-6/+6
Original commit message from CVS: * check/Makefile.am: remove GstData checks * check/gst-libs/gdp.c: (START_TEST): fix for API changes * gst/Makefile.am: add miniobject, remove data * gst/gst.h: add miniobject, remove data * gst/gstdata.c: remove * gst/gstdata.h: remove * gst/gstdata_private.h: remove * gst/gsttypes.h: remove GstEvent and GstMessage * gst/gstelement.c: (gst_element_post_message): fix for API changes * gst/gstmarshal.list: change BOXED -> OBJECT Implement GstMiniObject. * gst/gstminiobject.c: * gst/gstminiobject.h: Modify to be subclasses of GstMiniObject. * gst/gstbuffer.c: (_gst_buffer_initialize), (gst_buffer_get_type), (gst_buffer_class_init), (gst_buffer_finalize), (_gst_buffer_copy), (gst_buffer_init), (gst_buffer_new), (gst_buffer_new_and_alloc), (gst_subbuffer_get_type), (gst_subbuffer_init), (gst_buffer_create_sub), (gst_buffer_is_span_fast), (gst_buffer_span): * gst/gstbuffer.h: * gst/gstevent.c: (_gst_event_initialize), (gst_event_get_type), (gst_event_class_init), (gst_event_init), (gst_event_finalize), (_gst_event_copy), (gst_event_new): * gst/gstevent.h: * gst/gstmessage.c: (_gst_message_initialize), (gst_message_get_type), (gst_message_class_init), (gst_message_init), (gst_message_finalize), (_gst_message_copy), (gst_message_new), (gst_message_new_error), (gst_message_new_warning), (gst_message_new_tag), (gst_message_new_state_changed), (gst_message_new_application): * gst/gstmessage.h: * gst/gstprobe.c: (gst_probe_perform), (gst_probe_dispatcher_dispatch): * gst/gstprobe.h: * gst/gstquery.c: (_gst_query_initialize), (gst_query_get_type), (gst_query_class_init), (gst_query_finalize), (gst_query_init), (_gst_query_copy), (gst_query_new): Update elements for GstData -> GstMiniObject changes * gst/gstquery.h: * gst/gstqueue.c: (gst_queue_finalize), (gst_queue_locked_flush), (gst_queue_chain), (gst_queue_loop): * gst/elements/gstbufferstore.c: (gst_buffer_store_add_buffer_func), (gst_buffer_store_cleared_func), (gst_buffer_store_get_buffer): * gst/elements/gstfakesink.c: (gst_fakesink_class_init), (gst_fakesink_render): * gst/elements/gstfakesrc.c: (gst_fakesrc_class_init): * gst/elements/gstfilesrc.c: (gst_mmap_buffer_get_type), (gst_mmap_buffer_class_init), (gst_mmap_buffer_init), (gst_mmap_buffer_finalize), (gst_filesrc_map_region), (gst_filesrc_create_read): * gst/elements/gstidentity.c: (gst_identity_class_init): * gst/elements/gsttypefindelement.c: (gst_type_find_element_src_event), (free_entry_buffers), (gst_type_find_element_handle_event): * libs/gst/dataprotocol/dataprotocol.c: (gst_dp_header_from_buffer): * libs/gst/dataprotocol/dataprotocol.h: * libs/gst/dataprotocol/dp-private.h:
2005-05-09Remove old query functions. Ported old code.Wim Taymans1-17/+29
Original commit message from CVS: Remove old query functions. Ported old code. Added position/convert helper functions to gstutils. Reordered gstpad.c code, grouping relevant things. Remove gst_message_new(), always need to speficy a specific message.
2005-05-06gst/: Fix gst_pad_peer_get_caps(), make it return NULL if no peer.Wim Taymans1-5/+8
Original commit message from CVS: * gst/base/gstbasetransform.c: (gst_base_transform_proxy_getcaps): * gst/elements/gstcapsfilter.c: (gst_capsfilter_getcaps): * gst/gstpad.c: (gst_pad_peer_get_caps): * gst/gstqueue.c: (gst_queue_init), (gst_queue_getcaps), (gst_queue_bufferalloc), (gst_queue_handle_sink_event), (gst_queue_src_activate), (gst_queue_change_state): * gst/gstqueue.h: * gst/gstutils.c: (gst_element_get_compatible_pad_template), (intersect_caps_func): Fix gst_pad_peer_get_caps(), make it return NULL if no peer. Always take QUEUE_LOCK after STREAM_LOCK or we might deadlock. Some fixes for the peer_get_caps() change.
2005-03-21Next big merge.Wim Taymans1-467/+298
Original commit message from CVS: Next big merge. Added GstBus for mainloop integration. Added GstMessage for sending notifications on the bus. Added GstTask as an abstraction for pipeline entry points. Removed GstThread. Removed Schedulers. Simplified GstQueue for multithreaded core. Made _link threadsafe, removed old capsnego. Added STREAM_LOCK and PREROLL_LOCK in GstPad. Added pad blocking functions. Reworked scheduling functions in GstPad to prepare for scheduling updates soon. Moved events out of data stream. Simplified GstEvent types. Added return values to push/pull. Removed clocking from GstElement. Added prototypes for state change function for next merge. Removed iterate from bins and state change management. Fixed some elements, disabled others for now. Fixed -inspect and -launch. Added check for GstBus.
2005-03-08Remove threadsafe properties. Fix elements because GObject complains when ↵Wim Taymans1-2/+3
installing a property before declaring a se... Original commit message from CVS: Remove threadsafe properties. Fix elements because GObject complains when installing a property before declaring a set/get_property handler. Rearrange gstelement.h file, use STATE macros for state locks. Free mutexes in the finalize method instead of dispose.
2005-03-07First THREADED backport attempt, focusing on adding locks and making sure ↵Wim Taymans1-1/+6
the API is threadsafe. Needs more work. Mor... Original commit message from CVS: First THREADED backport attempt, focusing on adding locks and making sure the API is threadsafe. Needs more work. More docs follow this week.