if (render->subtitle_flushing) {
gst_buffer_unref (buffer);
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
timestamp = GST_BUFFER_TIMESTAMP (buffer);
GST_DEBUG_OBJECT (render, "Text pad flushing");
gst_buffer_unref (buffer);
g_mutex_unlock (&render->subtitle_mutex);
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
GST_DEBUG_OBJECT (render,
"Too early text buffer, waiting (%" GST_TIME_FORMAT " > %"
not_ready:
{
GST_ELEMENT_ERROR (b, LIBRARY, FAILED, (NULL), ("Decompressor not ready."));
- flow = GST_FLOW_WRONG_STATE;
+ flow = GST_FLOW_FLUSHING;
goto done;
}
}
not_ready:
{
GST_ELEMENT_ERROR (b, LIBRARY, FAILED, (NULL), ("Compressor not ready."));
- flow = GST_FLOW_WRONG_STATE;
+ flow = GST_FLOW_FLUSHING;
goto done;
}
compress_error:
if (fs->cancel) {
g_mutex_unlock (fs->lock);
gst_object_unref (fs);
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
}
if (fs->cancel) {
g_mutex_unlock (fs->lock);
gst_object_unref (fs);
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
}
GST_KATE_TIGER_MUTEX_UNLOCK (tiger);
gst_object_unref (tiger);
gst_buffer_unref (buf);
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
if (G_LIKELY (GST_BUFFER_TIMESTAMP_IS_VALID (buf))) {
/* can only end the encoding loop by forcing eos */
GST_MPEG2ENC_MUTEX_LOCK (enc);
enc->eos = TRUE;
- enc->srcresult = GST_FLOW_WRONG_STATE;
+ enc->srcresult = GST_FLOW_FLUSHING;
GST_MPEG2ENC_SIGNAL (enc);
GST_MPEG2ENC_MUTEX_UNLOCK (enc);
/* now unblock the chain function */
GST_MPLEX_MUTEX_LOCK (mplex);
- mplex->srcresult = GST_FLOW_WRONG_STATE;
+ mplex->srcresult = GST_FLOW_FLUSHING;
GST_MPLEX_SIGNAL (mplex, mpad);
GST_MPLEX_MUTEX_UNLOCK (mplex);
/* no way to pause/restart loop task */
/* end the muxing loop by forcing eos and unblock chains */
GST_MPLEX_MUTEX_LOCK (mplex);
mplex->eos = TRUE;
- mplex->srcresult = GST_FLOW_WRONG_STATE;
+ mplex->srcresult = GST_FLOW_FLUSHING;
GST_MPLEX_SIGNAL_ALL (mplex);
GST_MPLEX_MUTEX_UNLOCK (mplex);
branching:
{
g_mutex_unlock (src->branch_lock);
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
}
error:
{
if (ret != GST_FLOW_OK && ret != GST_FLOW_NOT_LINKED
- && ret != GST_FLOW_WRONG_STATE) {
+ && ret != GST_FLOW_FLUSHING) {
GST_ELEMENT_ERROR (teletext, STREAM, FAILED,
("Internal data stream error."), ("stream stopped, reason %s",
gst_flow_get_name (ret)));
{
GST_DEBUG_OBJECT (ringbuffer, "ringbuffer is flushing");
GST_OBJECT_UNLOCK (ringbuffer);
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
}
GST_DEBUG_OBJECT (ringbuffer, "we are flushing");
GST_OBJECT_UNLOCK (ringbuffer);
gst_object_unref (ringbuffer);
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
wrong_size:
{
GST_DEBUG_OBJECT (pad, "We are flushing, discard buffer %p", buf);
GST_INPUT_SELECTOR_UNLOCK (sel);
gst_buffer_unref (buf);
- res = GST_FLOW_WRONG_STATE;
+ res = GST_FLOW_FLUSHING;
goto done;
}
}
dtmfsrc->last_event = NULL;
}
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
dtmfsrc->redundancy_count = dtmfsrc->packet_redundancy;
goto send_last;
} else {
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
no_clock:
if (freeze->on_flush) {
g_object_unref (freeze);
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
/* If it is working in push mode this function will be called by "_chain"
GST_OBJECT_LOCK (adder);
/* mark ourselves as flushing */
- adder->srcresult = GST_FLOW_WRONG_STATE;
+ adder->srcresult = GST_FLOW_FLUSHING;
/* Empty the queue */
g_queue_foreach (adder->buffers, (GFunc) gst_mini_object_unref, NULL);
demux = GST_FLUPS_DEMUX (gst_pad_get_parent (pad));
if (G_UNLIKELY (demux->flushing)) {
- ret = GST_FLOW_WRONG_STATE;
+ ret = GST_FLOW_FLUSHING;
goto pause;
}
while (gst_flups_demux_resync (demux, save)) {
gboolean ps_sync = TRUE;
if (G_UNLIKELY (demux->flushing)) {
- ret = GST_FLOW_WRONG_STATE;
+ ret = GST_FLOW_FLUSHING;
goto done;
}
sink = GST_MULTI_FD_SINK (bsink);
g_return_val_if_fail (GST_OBJECT_FLAG_IS_SET (sink, GST_MULTI_FD_SINK_OPEN),
- GST_FLOW_WRONG_STATE);
+ GST_FLOW_FLUSHING);
#if 0
/* since we check every buffer for streamheader caps, we need to make
for (i = 0; i < demux->preface->content_storage->n_packages; i++) {
if (demux->preface->content_storage->packages[i] &&
- MXF_IS_METADATA_MATERIAL_PACKAGE (demux->preface->
- content_storage->packages[i])) {
+ MXF_IS_METADATA_MATERIAL_PACKAGE (demux->preface->content_storage->
+ packages[i])) {
ret =
- MXF_METADATA_GENERIC_PACKAGE (demux->preface->
- content_storage->packages[i]);
+ MXF_METADATA_GENERIC_PACKAGE (demux->preface->content_storage->
+ packages[i]);
break;
}
}
essence_container);
if (track->parent.type == MXF_METADATA_TRACK_PICTURE_ESSENCE) {
- if (MXF_IS_METADATA_GENERIC_PICTURE_ESSENCE_DESCRIPTOR (track->
- parent.descriptor[0]))
+ if (MXF_IS_METADATA_GENERIC_PICTURE_ESSENCE_DESCRIPTOR (track->parent.
+ descriptor[0]))
mxf_ul_to_string (&MXF_METADATA_GENERIC_PICTURE_ESSENCE_DESCRIPTOR
(track->parent.descriptor[0])->picture_essence_coding,
essence_compression);
g_strdup_printf ("video/x-mxf-%s-%s", essence_container,
essence_compression);
} else if (track->parent.type == MXF_METADATA_TRACK_SOUND_ESSENCE) {
- if (MXF_IS_METADATA_GENERIC_SOUND_ESSENCE_DESCRIPTOR (track->
- parent.descriptor[0]))
+ if (MXF_IS_METADATA_GENERIC_SOUND_ESSENCE_DESCRIPTOR (track->parent.
+ descriptor[0]))
mxf_ul_to_string (&MXF_METADATA_GENERIC_SOUND_ESSENCE_DESCRIPTOR
(track->parent.descriptor[0])->sound_essence_compression,
essence_compression);
g_strdup_printf ("audio/x-mxf-%s-%s", essence_container,
essence_compression);
} else if (track->parent.type == MXF_METADATA_TRACK_DATA_ESSENCE) {
- if (MXF_IS_METADATA_GENERIC_DATA_ESSENCE_DESCRIPTOR (track->
- parent.descriptor[0]))
+ if (MXF_IS_METADATA_GENERIC_DATA_ESSENCE_DESCRIPTOR (track->parent.
+ descriptor[0]))
mxf_ul_to_string (&MXF_METADATA_GENERIC_DATA_ESSENCE_DESCRIPTOR
(track->parent.descriptor[0])->data_essence_coding,
essence_compression);
pad->current_component_index);
pad->current_component =
- MXF_METADATA_SOURCE_CLIP (sequence->
- structural_components[pad->current_component_index]);
+ MXF_METADATA_SOURCE_CLIP (sequence->structural_components[pad->
+ current_component_index]);
if (pad->current_component == NULL) {
GST_ERROR_OBJECT (demux, "No such structural component");
return GST_FLOW_ERROR;
if (!pad->current_component->source_package
|| !pad->current_component->source_package->top_level
- || !MXF_METADATA_GENERIC_PACKAGE (pad->
- current_component->source_package)->tracks) {
+ || !MXF_METADATA_GENERIC_PACKAGE (pad->current_component->
+ source_package)->tracks) {
GST_ERROR_OBJECT (demux, "Invalid component");
return GST_FLOW_ERROR;
}
while (ret == GST_FLOW_OK) {
if (G_UNLIKELY (demux->flushing)) {
GST_DEBUG_OBJECT (demux, "we are now flushing, exiting parser loop");
- ret = GST_FLOW_WRONG_STATE;
+ ret = GST_FLOW_FLUSHING;
break;
}
for (i = 0; i < p->material_track->parent.sequence->n_structural_components;
i++) {
clip =
- MXF_METADATA_SOURCE_CLIP (p->material_track->parent.
- sequence->structural_components[i]);
+ MXF_METADATA_SOURCE_CLIP (p->material_track->parent.sequence->
+ structural_components[i]);
if (clip->parent.duration <= 0)
break;
if (format != GST_FORMAT_TIME)
goto wrong_format;
- flush = !!(flags & GST_SEEK_FLAG_FLUSH);
- keyframe = !!(flags & GST_SEEK_FLAG_KEY_UNIT);
+ flush = ! !(flags & GST_SEEK_FLAG_FLUSH);
+ keyframe = ! !(flags & GST_SEEK_FLAG_KEY_UNIT);
/* Work on a copy until we are sure the seek succeeded. */
memcpy (&seeksegment, &demux->segment, sizeof (GstSegment));
if (rate <= 0.0)
goto wrong_rate;
- flush = !!(flags & GST_SEEK_FLAG_FLUSH);
- keyframe = !!(flags & GST_SEEK_FLAG_KEY_UNIT);
+ flush = ! !(flags & GST_SEEK_FLAG_FLUSH);
+ keyframe = ! !(flags & GST_SEEK_FLAG_KEY_UNIT);
if (flush) {
GstEvent *e;
/* got eos */
} else if (ret == GST_FLOW_UNEXPECTED) {
gst_nuv_demux_send_eos (nuv);
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
} else {
if (gst_adapter_available (nuv->adapter) < size)
{
GST_DEBUG ("found EOS");
gst_pad_push_event (ttaparse->srcpad, gst_event_new_eos ());
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
pull_error:
{
[bufQueueLock lockWhenCondition:HAS_BUFFER_OR_STOP_REQUEST];
if (stopRequest) {
[bufQueueLock unlock];
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
sbuf = (CMSampleBufferRef) [bufQueue lastObject];
shutting_down:
{
cm->FigSampleBufferRelease (sbuf);
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
}
*buf = NULL;
}
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
unexpected_format:
{
[queueLock lockWhenCondition:HAS_FRAME_OR_STOP_REQUEST];
if (stopRequest) {
[queueLock unlock];
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
frame = (CVPixelBufferRef) [queue lastObject];
if (avcsrc->unlock) {
if (buffer)
gst_buffer_unref (buffer);
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
gst_buffer_set_caps (buffer, GST_PAD_CAPS (avcsrc->srcpad));
GST_D3DVIDEOSINK_SHARED_D3D_DEV_UNLOCK return GST_FLOW_OK;
wrong_state:
GST_D3DVIDEOSINK_SWAP_CHAIN_UNLOCK (sink);
- GST_D3DVIDEOSINK_SHARED_D3D_DEV_UNLOCK return GST_FLOW_WRONG_STATE;
+ GST_D3DVIDEOSINK_SHARED_D3D_DEV_UNLOCK return GST_FLOW_FLUSHING;
/*unexpected:*/
/* GST_D3DVIDEOSINK_SWAP_CHAIN_UNLOCK(sink); */
/* GST_D3DVIDEOSINK_SHARED_D3D_DEV_UNLOCK */
ret = GST_FLOW_OK;
} else {
- ret = GST_FLOW_WRONG_STATE;
+ ret = GST_FLOW_FLUSHING;
}
frame->Release ();
if (!adec->setup) {
/* we are not set up */
GST_WARNING_OBJECT (adec, "Decoder not set up, failing");
- adec->last_ret = GST_FLOW_WRONG_STATE;
+ adec->last_ret = GST_FLOW_FLUSHING;
goto beach;
}
if (!vdec->setup) {
/* we are not setup */
GST_WARNING_OBJECT (vdec, "Decoder not set up, failing");
- vdec->last_ret = GST_FLOW_WRONG_STATE;
+ vdec->last_ret = GST_FLOW_FLUSHING;
goto beach;
}
gst_buffer_unref (*buf);
*buf = NULL;
}
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
GST_DEBUG ("dshowvideosrc_create => pts %" GST_TIME_FORMAT " duration %"
if (!sink->graph_running){
retst = gst_dshowvideosink_start_graph(sink);
if (retst == GST_STATE_CHANGE_FAILURE)
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
ret = sink->fakesrc->GetOutputPin()->PushBuffer (buffer);
if (!sink->graph_running){
retst = gst_dshowvideosink_pause_graph(sink);
if (retst == GST_STATE_CHANGE_FAILURE)
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
GST_DSHOWVIDEOSINK_GRAPH_UNLOCK(sink);
GST_DEBUG_OBJECT (sink, "Done pushing buffer through fakesrc->renderer: %s", gst_flow_get_name(ret));
guint8 *data = linsyssdisrc->tmpdata;
if (linsyssdisrc->fd < 0)
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
if (linsyssdisrc->is_625) {
sdi_width = 864;
g_cond_wait (self->cond, GST_OBJECT_GET_LOCK (self));
if (self->unlock) {
GST_OBJECT_UNLOCK (self);
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
}
g_cond_wait (self->cond, GST_OBJECT_GET_LOCK (self));
if (self->unlock) {
GST_OBJECT_UNLOCK (self);
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
}
g_cond_wait (self->cond, GST_OBJECT_GET_LOCK (self));
if (self->unlock) {
GST_OBJECT_UNLOCK (self);
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
}
while (self->wait_for_connection && !self->clients) {
if (self->unlock) {
sp_writer_free_block (block);
GST_OBJECT_UNLOCK (self);
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
}
do {
if (gst_poll_wait (self->poll, GST_CLOCK_TIME_NONE) < 0) {
if (errno == EBUSY)
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
GST_ELEMENT_ERROR (self, RESOURCE, READ, ("Failed to read from shmsrc"),
("Poll failed on fd: %s", strerror (errno)));
return GST_FLOW_ERROR;
}
if (self->unlocked)
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
if (gst_poll_fd_has_closed (self->poll, &self->pollfd)) {
GST_ELEMENT_ERROR (self, RESOURCE, READ, ("Failed to read from shmsrc"),
if (error_str != NULL)
*error_str = NULL;
- return GST_FLOW_WRONG_STATE;
+ return GST_FLOW_FLUSHING;
}
error_get_result:
{