aboutsummaryrefslogtreecommitdiff
path: root/src/decoder/decoder_control.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/decoder/decoder_control.c')
-rw-r--r--src/decoder/decoder_control.c158
1 files changed, 79 insertions, 79 deletions
diff --git a/src/decoder/decoder_control.c b/src/decoder/decoder_control.c
index 5c952d9d..4c7d59da 100644
--- a/src/decoder/decoder_control.c
+++ b/src/decoder/decoder_control.c
@@ -29,163 +29,163 @@
struct decoder_control *
dc_new(GCond *client_cond)
{
- struct decoder_control *dc = g_new(struct decoder_control, 1);
+ struct decoder_control *dc = g_new(struct decoder_control, 1);
- dc->thread = NULL;
+ dc->thread = NULL;
- dc->mutex = g_mutex_new();
- dc->cond = g_cond_new();
- dc->client_cond = client_cond;
+ dc->mutex = g_mutex_new();
+ dc->cond = g_cond_new();
+ dc->client_cond = client_cond;
- dc->state = DECODE_STATE_STOP;
- dc->command = DECODE_COMMAND_NONE;
+ dc->state = DECODE_STATE_STOP;
+ dc->command = DECODE_COMMAND_NONE;
- dc->replay_gain_db = 0;
- dc->replay_gain_prev_db = 0;
- dc->mixramp_start = NULL;
- dc->mixramp_end = NULL;
- dc->mixramp_prev_end = NULL;
+ dc->replay_gain_db = 0;
+ dc->replay_gain_prev_db = 0;
+ dc->mixramp_start = NULL;
+ dc->mixramp_end = NULL;
+ dc->mixramp_prev_end = NULL;
- return dc;
+ return dc;
}
void
dc_free(struct decoder_control *dc)
{
- g_cond_free(dc->cond);
- g_mutex_free(dc->mutex);
- g_free(dc->mixramp_start);
- g_free(dc->mixramp_end);
- g_free(dc->mixramp_prev_end);
- g_free(dc);
+ g_cond_free(dc->cond);
+ g_mutex_free(dc->mutex);
+ g_free(dc->mixramp_start);
+ g_free(dc->mixramp_end);
+ g_free(dc->mixramp_prev_end);
+ g_free(dc);
}
static void
dc_command_wait_locked(struct decoder_control *dc)
{
- while (dc->command != DECODE_COMMAND_NONE)
- g_cond_wait(dc->client_cond, dc->mutex);
+ while (dc->command != DECODE_COMMAND_NONE)
+ g_cond_wait(dc->client_cond, dc->mutex);
}
static void
dc_command_locked(struct decoder_control *dc, enum decoder_command cmd)
{
- dc->command = cmd;
- decoder_signal(dc);
- dc_command_wait_locked(dc);
+ dc->command = cmd;
+ decoder_signal(dc);
+ dc_command_wait_locked(dc);
}
static void
dc_command(struct decoder_control *dc, enum decoder_command cmd)
{
- decoder_lock(dc);
- dc_command_locked(dc, cmd);
- decoder_unlock(dc);
+ decoder_lock(dc);
+ dc_command_locked(dc, cmd);
+ decoder_unlock(dc);
}
static void
dc_command_async(struct decoder_control *dc, enum decoder_command cmd)
{
- decoder_lock(dc);
+ decoder_lock(dc);
- dc->command = cmd;
- decoder_signal(dc);
+ dc->command = cmd;
+ decoder_signal(dc);
- decoder_unlock(dc);
+ decoder_unlock(dc);
}
void dc_start(struct decoder_control *dc, struct song *song,
unsigned start_ms, unsigned end_ms,
int buffer_samples, struct music_pipe *pipe)
{
- assert(song != NULL);
- assert(pipe != NULL);
- assert(music_pipe_empty(pipe));
-
- dc->song = song;
- dc->start_ms = start_ms;
- dc->end_ms = end_ms;
- dc->buffer_samples = buffer_samples;
- dc->pipe = pipe;
- dc_command(dc, DECODE_COMMAND_START);
+ assert(song != NULL);
+ assert(pipe != NULL);
+ assert(music_pipe_empty(pipe));
+
+ dc->song = song;
+ dc->start_ms = start_ms;
+ dc->end_ms = end_ms;
+ dc->buffer_samples = buffer_samples;
+ dc->pipe = pipe;
+ dc_command(dc, DECODE_COMMAND_START);
}
void
dc_stop(struct decoder_control *dc)
{
- decoder_lock(dc);
+ decoder_lock(dc);
- if (dc->command != DECODE_COMMAND_NONE)
- /* Attempt to cancel the current command. If it's too
- late and the decoder thread is already executing
- the old command, we'll call STOP again in this
- function (see below). */
- dc_command_locked(dc, DECODE_COMMAND_STOP);
+ if (dc->command != DECODE_COMMAND_NONE)
+ /* Attempt to cancel the current command. If it's too
+ late and the decoder thread is already executing
+ the old command, we'll call STOP again in this
+ function (see below). */
+ dc_command_locked(dc, DECODE_COMMAND_STOP);
- if (dc->state != DECODE_STATE_STOP && dc->state != DECODE_STATE_ERROR)
- dc_command_locked(dc, DECODE_COMMAND_STOP);
+ if (dc->state != DECODE_STATE_STOP && dc->state != DECODE_STATE_ERROR)
+ dc_command_locked(dc, DECODE_COMMAND_STOP);
- decoder_unlock(dc);
+ decoder_unlock(dc);
}
bool
dc_seek(struct decoder_control *dc, double where)
{
- assert(dc->state != DECODE_STATE_START);
- assert(where >= 0.0);
+ assert(dc->state != DECODE_STATE_START);
+ assert(where >= 0.0);
- if (dc->state == DECODE_STATE_STOP ||
- dc->state == DECODE_STATE_ERROR || !dc->seekable)
- return false;
+ if (dc->state == DECODE_STATE_STOP ||
+ dc->state == DECODE_STATE_ERROR || !dc->seekable)
+ return false;
- dc->seek_where = where;
- dc->seek_error = false;
- dc_command(dc, DECODE_COMMAND_SEEK);
+ dc->seek_where = where;
+ dc->seek_error = false;
+ dc_command(dc, DECODE_COMMAND_SEEK);
- if (dc->seek_error)
- return false;
+ if (dc->seek_error)
+ return false;
- return true;
+ return true;
}
void
dc_quit(struct decoder_control *dc)
{
- assert(dc->thread != NULL);
+ assert(dc->thread != NULL);
- dc->quit = true;
- dc_command_async(dc, DECODE_COMMAND_STOP);
+ dc->quit = true;
+ dc_command_async(dc, DECODE_COMMAND_STOP);
- g_thread_join(dc->thread);
- dc->thread = NULL;
+ g_thread_join(dc->thread);
+ dc->thread = NULL;
}
void
dc_mixramp_start(struct decoder_control *dc, char *mixramp_start)
{
- assert(dc != NULL);
+ assert(dc != NULL);
- g_free(dc->mixramp_start);
- dc->mixramp_start = mixramp_start;
- g_debug("mixramp_start = %s", mixramp_start ? mixramp_start : "NULL");
+ g_free(dc->mixramp_start);
+ dc->mixramp_start = mixramp_start;
+ g_debug("mixramp_start = %s", mixramp_start ? mixramp_start : "NULL");
}
void
dc_mixramp_end(struct decoder_control *dc, char *mixramp_end)
{
- assert(dc != NULL);
+ assert(dc != NULL);
- g_free(dc->mixramp_end);
- dc->mixramp_end = mixramp_end;
- g_debug("mixramp_end = %s", mixramp_end ? mixramp_end : "NULL");
+ g_free(dc->mixramp_end);
+ dc->mixramp_end = mixramp_end;
+ g_debug("mixramp_end = %s", mixramp_end ? mixramp_end : "NULL");
}
void
dc_mixramp_prev_end(struct decoder_control *dc, char *mixramp_prev_end)
{
- assert(dc != NULL);
+ assert(dc != NULL);
- g_free(dc->mixramp_prev_end);
- dc->mixramp_prev_end = mixramp_prev_end;
- g_debug("mixramp_prev_end = %s", mixramp_prev_end ? mixramp_prev_end : "NULL");
+ g_free(dc->mixramp_prev_end);
+ dc->mixramp_prev_end = mixramp_prev_end;
+ g_debug("mixramp_prev_end = %s", mixramp_prev_end ? mixramp_prev_end : "NULL");
}
generated by cgit v1.2.3 (git 2.39.1) at 2024-05-18 08:46:44 +0000