ReceiveTempSMS
/
Sweden-Number
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

winegstreamer: Move the "flushing" field to struct wg_parser. 

Signed-off-by: Zebediah Figura <z.figura12@gmail.com>
Signed-off-by: Alexandre Julliard <julliard@winehq.org>
This commit is contained in:
Zebediah Figura 2021-02-01 18:36:59 -06:00 committed by Alexandre Julliard
parent 6e5af4fc7d
commit 5736cb23ac
1 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
dlls/winegstreamer/gstdemux.c
View File

@ -68,6 +68,8 @@ struct wg_parser
bool done;
GstFlowReturn ret;
} read_request;
bool flushing;
};
struct parser
@ -89,7 +91,7 @@ struct parser
/* FIXME: It would be nice to avoid duplicating these with strmbase.
* However, synchronization is tricky; we need access to be protected by a
* separate lock. */
bool streaming, flushing, sink_connected;
bool streaming, sink_connected;
uint64_t next_pull_offset;
@ -1037,13 +1039,14 @@ static void send_buffer(struct parser_source *pin, GstBuffer *buf)
static bool get_stream_event(struct parser_source *pin, struct parser_event *event)
{
struct parser *filter = impl_from_strmbase_filter(pin->pin.pin.filter);
struct wg_parser *parser = filter->wg_parser;
pthread_mutex_lock(&filter->mutex);
while (!filter->flushing && pin->event.type == PARSER_EVENT_NONE)
while (!parser->flushing && pin->event.type == PARSER_EVENT_NONE)
pthread_cond_wait(&pin->event_cond, &filter->mutex);
if (filter->flushing)
if (parser->flushing)
{
pthread_mutex_unlock(&filter->mutex);
TRACE("Filter is flushing.\n");
@ -1720,7 +1723,7 @@ static HRESULT parser_init_stream(struct strmbase_filter *iface)
filter->streaming = true;
pthread_mutex_lock(&filter->mutex);
filter->flushing = false;
parser->flushing = false;
pthread_mutex_unlock(&filter->mutex);
/* DirectShow retains the old seek positions, but resets to them every time
@ -1761,7 +1764,7 @@ static HRESULT parser_cleanup_stream(struct strmbase_filter *iface)
filter->streaming = false;
pthread_mutex_lock(&filter->mutex);
filter->flushing = true;
parser->flushing = true;
pthread_mutex_unlock(&filter->mutex);
for (i = 0; i < filter->source_count; ++i)
@ -1997,7 +2000,6 @@ static BOOL parser_init_gstreamer(void)
static void parser_init_common(struct parser *object)
{
pthread_mutex_init(&object->mutex, NULL);
object->flushing = true;
}
static struct wg_parser *wg_parser_create(void)
@ -2010,6 +2012,7 @@ static struct wg_parser *wg_parser_create(void)
pthread_cond_init(&parser->init_cond, NULL);
pthread_cond_init(&parser->read_cond, NULL);
pthread_cond_init(&parser->read_done_cond, NULL);
parser->flushing = true;
TRACE("Created winegstreamer parser %p.\n", parser);
return parser;
@ -2149,6 +2152,7 @@ static HRESULT WINAPI GST_Seeking_SetPositions(IMediaSeeking *iface,
GstSeekType current_type = GST_SEEK_TYPE_SET, stop_type = GST_SEEK_TYPE_SET;
struct parser_source *pin = impl_from_IMediaSeeking(iface);
struct parser *filter = impl_from_strmbase_filter(pin->pin.pin.filter);
struct wg_parser *parser = filter->wg_parser;
GstSeekFlags flags = 0;
HRESULT hr = S_OK;
int i;
@ -2168,7 +2172,7 @@ static HRESULT WINAPI GST_Seeking_SetPositions(IMediaSeeking *iface,
if (!(current_flags & AM_SEEKING_NoFlush))
{
pthread_mutex_lock(&filter->mutex);
filter->flushing = true;
parser->flushing = true;
pthread_mutex_unlock(&filter->mutex);
for (i = 0; i < filter->source_count; ++i)
@ -2217,7 +2221,7 @@ static HRESULT WINAPI GST_Seeking_SetPositions(IMediaSeeking *iface,
if (!(current_flags & AM_SEEKING_NoFlush))
{
pthread_mutex_lock(&filter->mutex);
filter->flushing = false;
parser->flushing = false;
pthread_mutex_unlock(&filter->mutex);
for (i = 0; i < filter->source_count; ++i)