oysteikt/mpd
0
0
Fork 0
Code Issues Pull Requests Releases Activity

decoder_control: added decoder_control.thread

Browse Source 
decoder_control.thread contains the handle of the decoder thread, or
NULL if the decoder thread isn't running.
This commit is contained in:
Max Kellermann 2009-01-25 13:44:27 +01:00
parent 2c45224be7
commit ac0e799965
4 changed files with 17 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/decoder_control.c
View File

@ -102,8 +102,13 @@ dc_seek(struct notify *notify, double where)
}
void
dc_quit(struct notify *notify)
dc_quit(void)
{
assert(dc.thread != NULL);
dc.quit = true;
dc_command(notify, DECODE_COMMAND_STOP);
dc_command_async(DECODE_COMMAND_STOP);
g_thread_join(dc.thread);
dc.thread = NULL;
}

6
src/decoder_control.h
View File

@ -45,6 +45,10 @@ enum decoder_state {
};
struct decoder_control {
/** the handle of the decoder thread, or NULL if the decoder
thread isn't running */
GThread *thread;
struct notify notify;
volatile enum decoder_state state;
@ -124,6 +128,6 @@ bool
dc_seek(struct notify *notify, double where);
void
dc_quit(struct notify *notify);
dc_quit(void);
#endif

6
src/decoder_thread.c
View File

@ -258,8 +258,10 @@ static gpointer decoder_task(G_GNUC_UNUSED gpointer arg)
void decoder_thread_start(void)
{
GError *e = NULL;
GThread *t;
if (!(t = g_thread_create(decoder_task, NULL, FALSE, &e)))
assert(dc.thread == NULL);
dc.thread = g_thread_create(decoder_task, NULL, true, &e);
if (dc.thread == NULL)
FATAL("Failed to spawn decoder task: %s\n", e->message);
}

2
src/player_thread.c
View File

@ -526,7 +526,7 @@ static gpointer player_task(G_GNUC_UNUSED gpointer arg)
break;
case PLAYER_COMMAND_EXIT:
dc_quit(&pc.notify);
dc_quit();
closeAudioDevice();
player_command_finished();
g_thread_exit(NULL);