input_stream: use "bool" instead of "int"
For boolean values and success flags, use bool instead of integer (1/0 for true/false, 0/-1 for success/failure).
This commit is contained in:
parent
464b611772
commit
5c19776f2f
@ -257,7 +257,7 @@ static float getAacFloatTotalTime(char *file)
|
|||||||
struct input_stream inStream;
|
struct input_stream inStream;
|
||||||
long bread;
|
long bread;
|
||||||
|
|
||||||
if (input_stream_open(&inStream, file) < 0)
|
if (!input_stream_open(&inStream, file))
|
||||||
return -1;
|
return -1;
|
||||||
|
|
||||||
initAacBuffer(&b, NULL, &inStream);
|
initAacBuffer(&b, NULL, &inStream);
|
||||||
@ -461,7 +461,7 @@ static int aac_decode(struct decoder * mpd_decoder, char *path)
|
|||||||
if ((totalTime = getAacFloatTotalTime(path)) < 0)
|
if ((totalTime = getAacFloatTotalTime(path)) < 0)
|
||||||
return -1;
|
return -1;
|
||||||
|
|
||||||
if (input_stream_open(&inStream, path) < 0)
|
if (!input_stream_open(&inStream, path))
|
||||||
return -1;
|
return -1;
|
||||||
|
|
||||||
initAacBuffer(&b, mpd_decoder, &inStream);
|
initAacBuffer(&b, mpd_decoder, &inStream);
|
||||||
|
@ -360,7 +360,7 @@ static struct tag *ffmpeg_tag(char *file)
|
|||||||
int ret;
|
int ret;
|
||||||
struct tag *tag = NULL;
|
struct tag *tag = NULL;
|
||||||
|
|
||||||
if (input_stream_open(&input, file) < 0) {
|
if (!input_stream_open(&input, file)) {
|
||||||
ERROR("failed to open %s\n", file);
|
ERROR("failed to open %s\n", file);
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
@ -52,9 +52,8 @@ static flac_seek_status flacSeek(mpd_unused const flac_decoder * flacDec,
|
|||||||
{
|
{
|
||||||
FlacData *data = (FlacData *) fdata;
|
FlacData *data = (FlacData *) fdata;
|
||||||
|
|
||||||
if (input_stream_seek(data->inStream, offset, SEEK_SET) < 0) {
|
if (!input_stream_seek(data->inStream, offset, SEEK_SET))
|
||||||
return flac_seek_status_error;
|
return flac_seek_status_error;
|
||||||
}
|
|
||||||
|
|
||||||
return flac_seek_status_ok;
|
return flac_seek_status_ok;
|
||||||
}
|
}
|
||||||
|
@ -158,9 +158,8 @@ static void initMp3DecodeData(mp3DecodeData * data, struct decoder *decoder,
|
|||||||
|
|
||||||
static int seekMp3InputBuffer(mp3DecodeData * data, long offset)
|
static int seekMp3InputBuffer(mp3DecodeData * data, long offset)
|
||||||
{
|
{
|
||||||
if (input_stream_seek(data->inStream, offset, SEEK_SET) < 0) {
|
if (!input_stream_seek(data->inStream, offset, SEEK_SET))
|
||||||
return -1;
|
return -1;
|
||||||
}
|
|
||||||
|
|
||||||
mad_stream_buffer(&data->stream, data->readBuffer, 0);
|
mad_stream_buffer(&data->stream, data->readBuffer, 0);
|
||||||
(data->stream).error = 0;
|
(data->stream).error = 0;
|
||||||
@ -757,7 +756,7 @@ static int getMp3TotalTime(char *file)
|
|||||||
mp3DecodeData data;
|
mp3DecodeData data;
|
||||||
int ret;
|
int ret;
|
||||||
|
|
||||||
if (input_stream_open(&inStream, file) < 0)
|
if (!input_stream_open(&inStream, file))
|
||||||
return -1;
|
return -1;
|
||||||
initMp3DecodeData(&data, NULL, &inStream);
|
initMp3DecodeData(&data, NULL, &inStream);
|
||||||
if (decodeFirstFrame(&data, NULL, NULL) < 0)
|
if (decodeFirstFrame(&data, NULL, NULL) < 0)
|
||||||
|
@ -75,7 +75,8 @@ static uint32_t mp4_inputStreamReadCallback(void *inStream, void *buffer,
|
|||||||
static uint32_t mp4_inputStreamSeekCallback(void *inStream, uint64_t position)
|
static uint32_t mp4_inputStreamSeekCallback(void *inStream, uint64_t position)
|
||||||
{
|
{
|
||||||
return input_stream_seek((struct input_stream *) inStream,
|
return input_stream_seek((struct input_stream *) inStream,
|
||||||
position, SEEK_SET);
|
position, SEEK_SET)
|
||||||
|
? 0 : -1;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int
|
static int
|
||||||
@ -317,7 +318,7 @@ static struct tag *mp4DataDup(char *file, int *mp4MetadataFound)
|
|||||||
|
|
||||||
*mp4MetadataFound = 0;
|
*mp4MetadataFound = 0;
|
||||||
|
|
||||||
if (input_stream_open(&inStream, file) < 0) {
|
if (!input_stream_open(&inStream, file)) {
|
||||||
DEBUG("mp4DataDup: Failed to open file: %s\n", file);
|
DEBUG("mp4DataDup: Failed to open file: %s\n", file);
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
@ -38,7 +38,7 @@ static mpc_bool_t mpc_seek_cb(void *vdata, mpc_int32_t offset)
|
|||||||
{
|
{
|
||||||
MpcCallbackData *data = (MpcCallbackData *) vdata;
|
MpcCallbackData *data = (MpcCallbackData *) vdata;
|
||||||
|
|
||||||
return input_stream_seek(data->inStream, offset, SEEK_SET) < 0 ? 0 : 1;
|
return input_stream_seek(data->inStream, offset, SEEK_SET) ? 0 : 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
static mpc_int32_t mpc_tell_cb(void *vdata)
|
static mpc_int32_t mpc_tell_cb(void *vdata)
|
||||||
@ -260,7 +260,7 @@ static float mpcGetTime(char *file)
|
|||||||
|
|
||||||
mpc_streaminfo_init(&info);
|
mpc_streaminfo_init(&info);
|
||||||
|
|
||||||
if (input_stream_open(&inStream, file) < 0) {
|
if (!input_stream_open(&inStream, file)) {
|
||||||
DEBUG("mpcGetTime: Failed to open file: %s\n", file);
|
DEBUG("mpcGetTime: Failed to open file: %s\n", file);
|
||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
@ -64,9 +64,8 @@ static OggFLAC__SeekableStreamDecoderSeekStatus of_seek_cb(mpd_unused const
|
|||||||
{
|
{
|
||||||
FlacData *data = (FlacData *) fdata;
|
FlacData *data = (FlacData *) fdata;
|
||||||
|
|
||||||
if (input_stream_seek(data->inStream, offset, SEEK_SET) < 0) {
|
if (!input_stream_seek(data->inStream, offset, SEEK_SET))
|
||||||
return OggFLAC__SEEKABLE_STREAM_DECODER_SEEK_STATUS_ERROR;
|
return OggFLAC__SEEKABLE_STREAM_DECODER_SEEK_STATUS_ERROR;
|
||||||
}
|
|
||||||
|
|
||||||
return OggFLAC__SEEKABLE_STREAM_DECODER_SEEK_STATUS_OK;
|
return OggFLAC__SEEKABLE_STREAM_DECODER_SEEK_STATUS_OK;
|
||||||
}
|
}
|
||||||
@ -261,7 +260,7 @@ static struct tag *oggflac_TagDup(char *file)
|
|||||||
OggFLAC__SeekableStreamDecoder *decoder;
|
OggFLAC__SeekableStreamDecoder *decoder;
|
||||||
FlacData data;
|
FlacData data;
|
||||||
|
|
||||||
if (input_stream_open(&inStream, file) < 0)
|
if (!input_stream_open(&inStream, file))
|
||||||
return NULL;
|
return NULL;
|
||||||
if (ogg_stream_type_detect(&inStream) != FLAC) {
|
if (ogg_stream_type_detect(&inStream) != FLAC) {
|
||||||
input_stream_close(&inStream);
|
input_stream_close(&inStream);
|
||||||
|
@ -66,7 +66,7 @@ static int ogg_seek_cb(void *vdata, ogg_int64_t offset, int whence)
|
|||||||
const OggCallbackData *data = (const OggCallbackData *) vdata;
|
const OggCallbackData *data = (const OggCallbackData *) vdata;
|
||||||
if(decoder_get_command(data->decoder) == DECODE_COMMAND_STOP)
|
if(decoder_get_command(data->decoder) == DECODE_COMMAND_STOP)
|
||||||
return -1;
|
return -1;
|
||||||
return input_stream_seek(data->inStream, offset, whence);
|
return input_stream_seek(data->inStream, offset, whence) ? 0 : -1;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* TODO: check Ogg libraries API and see if we can just not have this func */
|
/* TODO: check Ogg libraries API and see if we can just not have this func */
|
||||||
|
@ -366,12 +366,14 @@ static uint32_t get_pos(void *id)
|
|||||||
|
|
||||||
static int set_pos_abs(void *id, uint32_t pos)
|
static int set_pos_abs(void *id, uint32_t pos)
|
||||||
{
|
{
|
||||||
return input_stream_seek(((InputStreamPlus *)id)->is, pos, SEEK_SET);
|
return input_stream_seek(((InputStreamPlus *)id)->is, pos, SEEK_SET)
|
||||||
|
? 0 : -1;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int set_pos_rel(void *id, int32_t delta, int mode)
|
static int set_pos_rel(void *id, int32_t delta, int mode)
|
||||||
{
|
{
|
||||||
return input_stream_seek(((InputStreamPlus *)id)->is, delta, mode);
|
return input_stream_seek(((InputStreamPlus *)id)->is, delta, mode)
|
||||||
|
? 0 : -1;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int push_back_byte(void *id, int c)
|
static int push_back_byte(void *id, int c)
|
||||||
@ -439,7 +441,7 @@ static int wavpack_open_wvc(struct decoder *decoder,
|
|||||||
const char *utf8url;
|
const char *utf8url;
|
||||||
size_t len;
|
size_t len;
|
||||||
char *wvc_url = NULL;
|
char *wvc_url = NULL;
|
||||||
int ret;
|
bool ret;
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* As we use dc->utf8url, this function will be bad for
|
* As we use dc->utf8url, this function will be bad for
|
||||||
@ -464,7 +466,7 @@ static int wavpack_open_wvc(struct decoder *decoder,
|
|||||||
ret = input_stream_open(is_wvc, wvc_url);
|
ret = input_stream_open(is_wvc, wvc_url);
|
||||||
free(wvc_url);
|
free(wvc_url);
|
||||||
|
|
||||||
if (ret)
|
if (!ret)
|
||||||
return 0;
|
return 0;
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
@ -43,7 +43,7 @@ static void decodeStart(void)
|
|||||||
song_get_url(song, path_max_fs);
|
song_get_url(song, path_max_fs);
|
||||||
|
|
||||||
dc.current_song = dc.next_song; /* NEED LOCK */
|
dc.current_song = dc.next_song; /* NEED LOCK */
|
||||||
if (input_stream_open(&inStream, path_max_fs) < 0) {
|
if (!input_stream_open(&inStream, path_max_fs)) {
|
||||||
dc.error = DECODE_ERROR_FILE;
|
dc.error = DECODE_ERROR_FILE;
|
||||||
goto stop_no_close;
|
goto stop_no_close;
|
||||||
}
|
}
|
||||||
|
@ -241,7 +241,7 @@ input_curl_close(struct input_stream *is)
|
|||||||
input_curl_free(is);
|
input_curl_free(is);
|
||||||
}
|
}
|
||||||
|
|
||||||
static int
|
static bool
|
||||||
input_curl_eof(mpd_unused struct input_stream *is)
|
input_curl_eof(mpd_unused struct input_stream *is)
|
||||||
{
|
{
|
||||||
struct input_curl *c = is->data;
|
struct input_curl *c = is->data;
|
||||||
@ -397,7 +397,7 @@ input_curl_send_request(struct input_curl *c)
|
|||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int
|
static bool
|
||||||
input_curl_seek(struct input_stream *is, mpd_unused long offset,
|
input_curl_seek(struct input_stream *is, mpd_unused long offset,
|
||||||
mpd_unused int whence)
|
mpd_unused int whence)
|
||||||
{
|
{
|
||||||
@ -405,7 +405,7 @@ input_curl_seek(struct input_stream *is, mpd_unused long offset,
|
|||||||
bool ret;
|
bool ret;
|
||||||
|
|
||||||
if (!is->seekable)
|
if (!is->seekable)
|
||||||
return -1;
|
return false;
|
||||||
|
|
||||||
/* calculate the absolute offset */
|
/* calculate the absolute offset */
|
||||||
|
|
||||||
@ -423,11 +423,11 @@ input_curl_seek(struct input_stream *is, mpd_unused long offset,
|
|||||||
break;
|
break;
|
||||||
|
|
||||||
default:
|
default:
|
||||||
return -1;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (is->offset < 0)
|
if (is->offset < 0)
|
||||||
return -1;
|
return false;
|
||||||
|
|
||||||
/* close the old connection and open a new one */
|
/* close the old connection and open a new one */
|
||||||
|
|
||||||
@ -435,7 +435,7 @@ input_curl_seek(struct input_stream *is, mpd_unused long offset,
|
|||||||
|
|
||||||
ret = input_curl_easy_init(is);
|
ret = input_curl_easy_init(is);
|
||||||
if (!ret)
|
if (!ret)
|
||||||
return -1;
|
return false;
|
||||||
|
|
||||||
/* send the "Range" header */
|
/* send the "Range" header */
|
||||||
|
|
||||||
@ -446,9 +446,9 @@ input_curl_seek(struct input_stream *is, mpd_unused long offset,
|
|||||||
|
|
||||||
ret = input_curl_send_request(c);
|
ret = input_curl_send_request(c);
|
||||||
if (!ret)
|
if (!ret)
|
||||||
return -1;
|
return false;
|
||||||
|
|
||||||
return 0;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
static bool
|
static bool
|
||||||
|
@ -32,7 +32,7 @@ input_file_open(struct input_stream *is, const char *filename)
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
is->seekable = 1;
|
is->seekable = true;
|
||||||
|
|
||||||
fseek(fp, 0, SEEK_END);
|
fseek(fp, 0, SEEK_END);
|
||||||
is->size = ftell(fp);
|
is->size = ftell(fp);
|
||||||
@ -43,22 +43,22 @@ input_file_open(struct input_stream *is, const char *filename)
|
|||||||
#endif
|
#endif
|
||||||
|
|
||||||
is->data = fp;
|
is->data = fp;
|
||||||
is->ready = 1;
|
is->ready = true;
|
||||||
|
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int
|
static bool
|
||||||
input_file_seek(struct input_stream *is, long offset, int whence)
|
input_file_seek(struct input_stream *is, long offset, int whence)
|
||||||
{
|
{
|
||||||
if (fseek((FILE *) is->data, offset, whence) == 0) {
|
if (fseek((FILE *) is->data, offset, whence) == 0) {
|
||||||
is->offset = ftell((FILE *) is->data);
|
is->offset = ftell((FILE *) is->data);
|
||||||
} else {
|
} else {
|
||||||
is->error = errno;
|
is->error = errno;
|
||||||
return -1;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
return 0;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
static size_t
|
static size_t
|
||||||
@ -84,7 +84,7 @@ input_file_close(struct input_stream *is)
|
|||||||
fclose((FILE *) is->data);
|
fclose((FILE *) is->data);
|
||||||
}
|
}
|
||||||
|
|
||||||
static int
|
static bool
|
||||||
input_file_eof(struct input_stream *is)
|
input_file_eof(struct input_stream *is)
|
||||||
{
|
{
|
||||||
if (feof((FILE *) is->data))
|
if (feof((FILE *) is->data))
|
||||||
|
@ -51,14 +51,15 @@ void input_stream_global_finish(void)
|
|||||||
#endif
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
int input_stream_open(struct input_stream *is, char *url)
|
bool
|
||||||
|
input_stream_open(struct input_stream *is, char *url)
|
||||||
{
|
{
|
||||||
is->ready = 0;
|
is->seekable = false;
|
||||||
|
is->ready = false;
|
||||||
is->offset = 0;
|
is->offset = 0;
|
||||||
is->size = 0;
|
is->size = 0;
|
||||||
is->error = 0;
|
is->error = 0;
|
||||||
is->mime = NULL;
|
is->mime = NULL;
|
||||||
is->seekable = 0;
|
|
||||||
is->meta_name = NULL;
|
is->meta_name = NULL;
|
||||||
is->meta_title = NULL;
|
is->meta_title = NULL;
|
||||||
|
|
||||||
@ -67,14 +68,15 @@ int input_stream_open(struct input_stream *is, char *url)
|
|||||||
|
|
||||||
if (plugin->open(is, url)) {
|
if (plugin->open(is, url)) {
|
||||||
is->plugin = plugin;
|
is->plugin = plugin;
|
||||||
return 0;
|
return true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return -1;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
int input_stream_seek(struct input_stream *is, long offset, int whence)
|
bool
|
||||||
|
input_stream_seek(struct input_stream *is, long offset, int whence)
|
||||||
{
|
{
|
||||||
return is->plugin->seek(is, offset, whence);
|
return is->plugin->seek(is, offset, whence);
|
||||||
}
|
}
|
||||||
@ -97,7 +99,7 @@ void input_stream_close(struct input_stream *is)
|
|||||||
is->plugin->close(is);
|
is->plugin->close(is);
|
||||||
}
|
}
|
||||||
|
|
||||||
int input_stream_eof(struct input_stream *is)
|
bool input_stream_eof(struct input_stream *is)
|
||||||
{
|
{
|
||||||
return is->plugin->eof(is);
|
return is->plugin->eof(is);
|
||||||
}
|
}
|
||||||
|
@ -30,20 +30,20 @@ struct input_plugin {
|
|||||||
|
|
||||||
int (*buffer)(struct input_stream *is);
|
int (*buffer)(struct input_stream *is);
|
||||||
size_t (*read)(struct input_stream *is, void *ptr, size_t size);
|
size_t (*read)(struct input_stream *is, void *ptr, size_t size);
|
||||||
int (*eof)(struct input_stream *is);
|
bool (*eof)(struct input_stream *is);
|
||||||
int (*seek)(struct input_stream *is, long offset, int whence);
|
bool (*seek)(struct input_stream *is, long offset, int whence);
|
||||||
};
|
};
|
||||||
|
|
||||||
struct input_stream {
|
struct input_stream {
|
||||||
const struct input_plugin *plugin;
|
const struct input_plugin *plugin;
|
||||||
|
|
||||||
int ready;
|
bool seekable;
|
||||||
|
bool ready;
|
||||||
|
|
||||||
int error;
|
int error;
|
||||||
long offset;
|
long offset;
|
||||||
size_t size;
|
size_t size;
|
||||||
char *mime;
|
char *mime;
|
||||||
int seekable;
|
|
||||||
|
|
||||||
void *data;
|
void *data;
|
||||||
char *meta_name;
|
char *meta_name;
|
||||||
@ -56,10 +56,14 @@ void input_stream_global_finish(void);
|
|||||||
|
|
||||||
/* if an error occurs for these 3 functions, then -1 is returned and errno
|
/* if an error occurs for these 3 functions, then -1 is returned and errno
|
||||||
for the input stream is set */
|
for the input stream is set */
|
||||||
int input_stream_open(struct input_stream *is, char *url);
|
bool
|
||||||
int input_stream_seek(struct input_stream *is, long offset, int whence);
|
input_stream_open(struct input_stream *is, char *url);
|
||||||
|
|
||||||
|
bool
|
||||||
|
input_stream_seek(struct input_stream *is, long offset, int whence);
|
||||||
|
|
||||||
void input_stream_close(struct input_stream *is);
|
void input_stream_close(struct input_stream *is);
|
||||||
int input_stream_eof(struct input_stream *is);
|
bool input_stream_eof(struct input_stream *is);
|
||||||
|
|
||||||
/* return value: -1 is error, 1 inidicates stuff was buffered, 0 means nothing
|
/* return value: -1 is error, 1 inidicates stuff was buffered, 0 means nothing
|
||||||
was buffered */
|
was buffered */
|
||||||
|
Loading…
Reference in New Issue
Block a user