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

winegstreamer: Factor out get_stream_event(). 

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-01-23 12:43:45 -06:00 committed by Alexandre Julliard
parent 54e012b5b7
commit 13ea906985
1 changed files with 26 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
dlls/winegstreamer/gstdemux.c
View File

@ -1023,6 +1023,31 @@ static void send_buffer(struct parser_source *pin, GstBuffer *buf)
gst_buffer_unref(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);
pthread_mutex_lock(&filter->mutex);
while (!filter->flushing && pin->event.type == PARSER_EVENT_NONE)
pthread_cond_wait(&pin->event_cond, &filter->mutex);
if (filter->flushing)
{
pthread_mutex_unlock(&filter->mutex);
TRACE("Filter is flushing.\n");
return false;
}
*event = pin->event;
pin->event.type = PARSER_EVENT_NONE;
pthread_mutex_unlock(&filter->mutex);
pthread_cond_signal(&pin->event_empty_cond);
return true;
}
static DWORD CALLBACK stream_thread(void *arg)
{
struct parser_source *pin = arg;
@ -1035,32 +1060,13 @@ static DWORD CALLBACK stream_thread(void *arg)
struct parser_event event;
EnterCriticalSection(&pin->flushing_cs);
pthread_mutex_lock(&filter->mutex);
while (!filter->flushing && pin->event.type == PARSER_EVENT_NONE)
pthread_cond_wait(&pin->event_cond, &filter->mutex);
if (filter->flushing)
if (!get_stream_event(pin, &event))
{
pthread_mutex_unlock(&filter->mutex);
LeaveCriticalSection(&pin->flushing_cs);
TRACE("Filter is flushing.\n");
continue;
}
if (!pin->event.type)
{
pthread_mutex_unlock(&filter->mutex);
LeaveCriticalSection(&pin->flushing_cs);
continue;
}
event = pin->event;
pin->event.type = PARSER_EVENT_NONE;
pthread_cond_signal(&pin->event_empty_cond);
pthread_mutex_unlock(&filter->mutex);
TRACE("Got event of type %#x.\n", event.type);
switch (event.type)