2009-03-13 18:43:16 +01:00
|
|
|
/*
|
2013-01-04 08:41:16 +01:00
|
|
|
* Copyright (C) 2003-2013 The Music Player Daemon Project
|
2009-03-13 18:43:16 +01:00
|
|
|
* http://www.musicpd.org
|
2004-02-24 00:41:20 +01:00
|
|
|
*
|
|
|
|
* This program is free software; you can redistribute it and/or modify
|
|
|
|
* it under the terms of the GNU General Public License as published by
|
|
|
|
* the Free Software Foundation; either version 2 of the License, or
|
|
|
|
* (at your option) any later version.
|
|
|
|
*
|
|
|
|
* This program is distributed in the hope that it will be useful,
|
|
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
|
|
* GNU General Public License for more details.
|
2009-03-13 18:43:16 +01:00
|
|
|
*
|
|
|
|
* You should have received a copy of the GNU General Public License along
|
|
|
|
* with this program; if not, write to the Free Software Foundation, Inc.,
|
|
|
|
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
|
2004-02-24 00:41:20 +01:00
|
|
|
*/
|
|
|
|
|
2013-01-04 08:41:16 +01:00
|
|
|
#ifndef MPD_DECODER_CONTROL_HXX
|
|
|
|
#define MPD_DECODER_CONTROL_HXX
|
2004-02-24 00:41:20 +01:00
|
|
|
|
2013-07-28 13:18:48 +02:00
|
|
|
#include "DecoderCommand.hxx"
|
2013-08-03 21:00:50 +02:00
|
|
|
#include "AudioFormat.hxx"
|
2013-01-27 17:20:50 +01:00
|
|
|
#include "thread/Mutex.hxx"
|
|
|
|
#include "thread/Cond.hxx"
|
2009-08-13 23:33:46 +02:00
|
|
|
|
|
|
|
#include <glib.h>
|
2004-03-22 03:44:22 +01:00
|
|
|
|
2008-11-08 15:48:00 +01:00
|
|
|
#include <assert.h>
|
|
|
|
|
2013-07-28 13:25:12 +02:00
|
|
|
struct Song;
|
|
|
|
|
2008-06-02 00:25:00 +02:00
|
|
|
enum decoder_state {
|
|
|
|
DECODE_STATE_STOP = 0,
|
|
|
|
DECODE_STATE_START,
|
2008-11-08 15:48:00 +01:00
|
|
|
DECODE_STATE_DECODE,
|
|
|
|
|
|
|
|
/**
|
|
|
|
* The last "START" command failed, because there was an I/O
|
|
|
|
* error or because no decoder was able to decode the file.
|
|
|
|
* This state will only come after START; once the state has
|
|
|
|
* turned to DECODE, by definition no such error can occur.
|
|
|
|
*/
|
|
|
|
DECODE_STATE_ERROR,
|
2008-11-03 21:48:17 +01:00
|
|
|
};
|
2004-05-18 15:13:55 +02:00
|
|
|
|
2008-08-26 08:40:47 +02:00
|
|
|
struct decoder_control {
|
2009-01-25 13:44:27 +01:00
|
|
|
/** the handle of the decoder thread, or NULL if the decoder
|
|
|
|
thread isn't running */
|
|
|
|
GThread *thread;
|
|
|
|
|
2009-08-13 23:33:46 +02:00
|
|
|
/**
|
|
|
|
* This lock protects #state and #command.
|
|
|
|
*/
|
2013-01-27 17:20:50 +01:00
|
|
|
mutable Mutex mutex;
|
2009-08-13 23:33:46 +02:00
|
|
|
|
|
|
|
/**
|
|
|
|
* Trigger this object after you have modified #command. This
|
|
|
|
* is also used by the decoder thread to notify the caller
|
|
|
|
* when it has finished a command.
|
|
|
|
*/
|
2013-01-27 17:20:50 +01:00
|
|
|
Cond cond;
|
2009-08-13 23:33:46 +02:00
|
|
|
|
2011-01-10 21:27:43 +01:00
|
|
|
/**
|
|
|
|
* The trigger of this object's client. It is signalled
|
|
|
|
* whenever an event occurs.
|
|
|
|
*/
|
2013-01-27 17:20:50 +01:00
|
|
|
Cond client_cond;
|
2011-01-10 21:27:43 +01:00
|
|
|
|
2009-08-13 23:33:46 +02:00
|
|
|
enum decoder_state state;
|
|
|
|
enum decoder_command command;
|
2008-04-12 06:14:32 +02:00
|
|
|
|
2012-08-08 21:54:54 +02:00
|
|
|
/**
|
|
|
|
* The error that occurred in the decoder thread. This
|
|
|
|
* attribute is only valid if #state is #DECODE_STATE_ERROR.
|
|
|
|
* The object must be freed when this object transitions to
|
|
|
|
* any other state (usually #DECODE_STATE_START).
|
|
|
|
*/
|
|
|
|
GError *error;
|
|
|
|
|
2008-12-28 19:48:53 +01:00
|
|
|
bool quit;
|
2008-11-03 21:43:02 +01:00
|
|
|
bool seek_error;
|
2008-10-30 08:38:54 +01:00
|
|
|
bool seekable;
|
2009-08-13 23:33:46 +02:00
|
|
|
double seek_where;
|
2008-11-02 16:55:43 +01:00
|
|
|
|
|
|
|
/** the format of the song file */
|
2013-08-03 21:00:50 +02:00
|
|
|
AudioFormat in_audio_format;
|
2008-11-02 16:55:43 +01:00
|
|
|
|
|
|
|
/** the format being sent to the music pipe */
|
2013-08-03 21:00:50 +02:00
|
|
|
AudioFormat out_audio_format;
|
2008-11-02 16:55:43 +01:00
|
|
|
|
2009-11-03 20:02:19 +01:00
|
|
|
/**
|
|
|
|
* The song currently being decoded. This attribute is set by
|
|
|
|
* the player thread, when it sends the #DECODE_COMMAND_START
|
|
|
|
* command.
|
2012-08-09 20:55:18 +02:00
|
|
|
*
|
|
|
|
* This is a duplicate, and must be freed when this attribute
|
|
|
|
* is cleared.
|
2009-11-03 20:02:19 +01:00
|
|
|
*/
|
2013-07-28 13:25:12 +02:00
|
|
|
Song *song;
|
2009-11-03 20:02:19 +01:00
|
|
|
|
2011-10-05 22:37:59 +02:00
|
|
|
/**
|
|
|
|
* The initial seek position (in milliseconds), e.g. to the
|
|
|
|
* start of a sub-track described by a CUE file.
|
|
|
|
*
|
|
|
|
* This attribute is set by dc_start().
|
|
|
|
*/
|
|
|
|
unsigned start_ms;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* The decoder will stop when it reaches this position (in
|
|
|
|
* milliseconds). 0 means don't stop before the end of the
|
|
|
|
* file.
|
|
|
|
*
|
|
|
|
* This attribute is set by dc_start().
|
|
|
|
*/
|
|
|
|
unsigned end_ms;
|
|
|
|
|
2008-11-03 21:44:12 +01:00
|
|
|
float total_time;
|
2009-03-06 00:42:03 +01:00
|
|
|
|
|
|
|
/** the #music_chunk allocator */
|
|
|
|
struct music_buffer *buffer;
|
|
|
|
|
2009-11-03 21:18:22 +01:00
|
|
|
/**
|
|
|
|
* The destination pipe for decoded chunks. The caller thread
|
|
|
|
* owns this object, and is responsible for freeing it.
|
|
|
|
*/
|
2009-03-06 00:42:03 +01:00
|
|
|
struct music_pipe *pipe;
|
2010-03-21 18:21:47 +01:00
|
|
|
|
2010-05-08 09:19:44 +02:00
|
|
|
float replay_gain_db;
|
|
|
|
float replay_gain_prev_db;
|
2010-03-21 18:21:47 +01:00
|
|
|
char *mixramp_start;
|
|
|
|
char *mixramp_end;
|
|
|
|
char *mixramp_prev_end;
|
2013-01-20 17:48:23 +01:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
decoder_control();
|
|
|
|
~decoder_control();
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Locks the object.
|
|
|
|
*/
|
|
|
|
void Lock() const {
|
2013-01-27 17:20:50 +01:00
|
|
|
mutex.lock();
|
2013-01-21 10:13:29 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Unlocks the object.
|
|
|
|
*/
|
|
|
|
void Unlock() const {
|
2013-01-27 17:20:50 +01:00
|
|
|
mutex.unlock();
|
2013-01-21 10:13:29 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Signals the object. This function is only valid in the
|
|
|
|
* player thread. The object should be locked prior to
|
|
|
|
* calling this function.
|
|
|
|
*/
|
|
|
|
void Signal() {
|
2013-01-27 17:20:50 +01:00
|
|
|
cond.signal();
|
2013-01-21 10:13:29 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Waits for a signal on the #decoder_control object. This function
|
|
|
|
* is only valid in the decoder thread. The object must be locked
|
|
|
|
* prior to calling this function.
|
|
|
|
*/
|
|
|
|
void Wait() {
|
2013-01-27 17:20:50 +01:00
|
|
|
cond.wait(mutex);
|
2013-01-21 10:13:29 +01:00
|
|
|
}
|
|
|
|
|
2013-01-20 17:48:23 +01:00
|
|
|
/**
|
|
|
|
* Waits for a signal from the decoder thread. This object
|
|
|
|
* must be locked prior to calling this function. This method
|
|
|
|
* is only valid in the player thread.
|
|
|
|
*/
|
|
|
|
void WaitForDecoder() {
|
2013-01-27 17:20:50 +01:00
|
|
|
client_cond.wait(mutex);
|
2013-01-20 17:48:23 +01:00
|
|
|
}
|
2008-08-26 08:45:14 +02:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
bool IsIdle() const {
|
|
|
|
return state == DECODE_STATE_STOP ||
|
|
|
|
state == DECODE_STATE_ERROR;
|
2012-08-08 21:54:54 +02:00
|
|
|
}
|
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
gcc_pure
|
|
|
|
bool LockIsIdle() const {
|
|
|
|
Lock();
|
|
|
|
bool result = IsIdle();
|
|
|
|
Unlock();
|
|
|
|
return result;
|
|
|
|
}
|
2009-08-13 23:33:46 +02:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
bool IsStarting() const {
|
|
|
|
return state == DECODE_STATE_START;
|
|
|
|
}
|
2009-08-13 23:33:46 +02:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
gcc_pure
|
|
|
|
bool LockIsStarting() const {
|
|
|
|
Lock();
|
|
|
|
bool result = IsStarting();
|
|
|
|
Unlock();
|
|
|
|
return result;
|
|
|
|
}
|
2009-08-13 23:33:46 +02:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
bool HasFailed() const {
|
|
|
|
assert(command == DECODE_COMMAND_NONE);
|
2009-08-13 23:33:46 +02:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
return state == DECODE_STATE_ERROR;
|
|
|
|
}
|
2009-08-13 23:33:46 +02:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
gcc_pure
|
|
|
|
bool LockHasFailed() const {
|
|
|
|
Lock();
|
|
|
|
bool result = HasFailed();
|
|
|
|
Unlock();
|
|
|
|
return result;
|
|
|
|
}
|
2009-08-13 23:33:46 +02:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
/**
|
|
|
|
* Checks whether an error has occurred, and if so, returns a newly
|
|
|
|
* allocated copy of the #GError object.
|
|
|
|
*
|
|
|
|
* Caller must lock the object.
|
|
|
|
*/
|
|
|
|
GError *GetError() const {
|
|
|
|
assert(command == DECODE_COMMAND_NONE);
|
|
|
|
assert(state != DECODE_STATE_ERROR || error != nullptr);
|
2009-08-13 23:33:46 +02:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
return state == DECODE_STATE_ERROR
|
|
|
|
? g_error_copy(error)
|
|
|
|
: nullptr;
|
|
|
|
}
|
2009-08-13 23:33:46 +02:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
/**
|
|
|
|
* Like dc_get_error(), but locks and unlocks the object.
|
|
|
|
*/
|
|
|
|
GError *LockGetError() const {
|
|
|
|
Lock();
|
|
|
|
GError *result = GetError();
|
|
|
|
Unlock();
|
|
|
|
return result;
|
|
|
|
}
|
2009-08-13 23:33:46 +02:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
/**
|
|
|
|
* Clear the error condition and free the #GError object (if any).
|
|
|
|
*
|
|
|
|
* Caller must lock the object.
|
|
|
|
*/
|
|
|
|
void ClearError() {
|
|
|
|
if (state == DECODE_STATE_ERROR) {
|
|
|
|
g_error_free(error);
|
|
|
|
state = DECODE_STATE_STOP;
|
|
|
|
}
|
|
|
|
}
|
2008-08-26 08:27:18 +02:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
/**
|
|
|
|
* Check if the specified song is currently being decoded. If the
|
|
|
|
* decoder is not running currently (or being started), then this
|
|
|
|
* function returns false in any case.
|
|
|
|
*
|
|
|
|
* Caller must lock the object.
|
|
|
|
*/
|
|
|
|
gcc_pure
|
2013-07-28 13:25:12 +02:00
|
|
|
bool IsCurrentSong(const Song *_song) const;
|
2013-01-21 10:13:29 +01:00
|
|
|
|
|
|
|
gcc_pure
|
2013-07-28 13:25:12 +02:00
|
|
|
bool LockIsCurrentSong(const Song *_song) const {
|
2013-01-21 10:13:29 +01:00
|
|
|
Lock();
|
|
|
|
const bool result = IsCurrentSong(_song);
|
|
|
|
Unlock();
|
|
|
|
return result;
|
|
|
|
}
|
2008-08-26 08:27:18 +02:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
/**
|
|
|
|
* Start the decoder.
|
|
|
|
*
|
|
|
|
* @param song the song to be decoded; the given instance will be
|
|
|
|
* owned and freed by the decoder
|
|
|
|
* @param start_ms see #decoder_control
|
|
|
|
* @param end_ms see #decoder_control
|
|
|
|
* @param pipe the pipe which receives the decoded chunks (owned by
|
|
|
|
* the caller)
|
|
|
|
*/
|
2013-07-28 13:25:12 +02:00
|
|
|
void Start(Song *song, unsigned start_ms, unsigned end_ms,
|
2013-01-21 10:13:29 +01:00
|
|
|
music_buffer *buffer, music_pipe *pipe);
|
2008-08-26 08:27:18 +02:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
void Stop();
|
2008-12-28 19:48:53 +01:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
bool Seek(double where);
|
2010-03-21 18:21:47 +01:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
void Quit();
|
2010-03-21 18:21:47 +01:00
|
|
|
|
2013-01-21 10:13:29 +01:00
|
|
|
void MixRampStart(char *_mixramp_start);
|
|
|
|
void MixRampEnd(char *_mixramp_end);
|
|
|
|
void MixRampPrevEnd(char *_mixramp_prev_end);
|
|
|
|
};
|
2010-03-21 18:21:47 +01:00
|
|
|
|
2004-02-24 00:41:20 +01:00
|
|
|
#endif
|