MyFavMirrors
/
owntone-server
mirror of https://github.com/owntone/owntone-server.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[player/transcode/httpd] Pass path, data_kind and song_length to 

transcode_decode_setup/transcode_setup
This commit is contained in:
chme 2016-10-26 19:52:30 +02:00
parent 477088a36c
commit 6690ba32eb
4 changed files with 18 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/httpd.c
View File

@ -491,7 +491,7 @@ httpd_stream_file(struct evhttp_request *req, int id)
stream_cb = stream_chunk_xcode_cb; stream_cb = stream_chunk_xcode_cb;
st->xcode = transcode_setup(mfi, XCODE_PCM16_HEADER, &st->size); st->xcode = transcode_setup(mfi->data_kind, mfi->path, mfi->song_length, XCODE_PCM16_HEADER, &st->size);
if (!st->xcode) if (!st->xcode)
{ {
DPRINTF(E_WARN, L_HTTPD, "Transcoding setup failed, aborting streaming\n"); DPRINTF(E_WARN, L_HTTPD, "Transcoding setup failed, aborting streaming\n");

4
src/player.c
View File

@ -666,7 +666,7 @@ stream_setup(struct player_source *ps, struct media_file_info *mfi)
switch (ps->data_kind) switch (ps->data_kind)
{ {
case DATA_KIND_FILE: case DATA_KIND_FILE:
ps->xcode = transcode_setup(mfi, XCODE_PCM16_NOHEADER, NULL); ps->xcode = transcode_setup(mfi->data_kind, mfi->path, mfi->song_length, XCODE_PCM16_NOHEADER, NULL);
ret = ps->xcode ? 0 : -1; ret = ps->xcode ? 0 : -1;
break; break;
@ -678,7 +678,7 @@ stream_setup(struct player_source *ps, struct media_file_info *mfi)
free(mfi->path); free(mfi->path);
mfi->path = url; mfi->path = url;
ps->xcode = transcode_setup(mfi, XCODE_PCM16_NOHEADER, NULL); ps->xcode = transcode_setup(mfi->data_kind, mfi->path, mfi->song_length, XCODE_PCM16_NOHEADER, NULL);
ret = ps->xcode ? 0 : -1; ret = ps->xcode ? 0 : -1;
break; break;

26
src/transcode.c
View File

@ -580,7 +580,7 @@ flush_encoder(struct encode_ctx *ctx, unsigned int stream_index)
/* --------------------------- INPUT/OUTPUT INIT --------------------------- */ /* --------------------------- INPUT/OUTPUT INIT --------------------------- */
static int static int
open_input(struct decode_ctx *ctx, struct media_file_info *mfi, int decode_video) open_input(struct decode_ctx *ctx, enum data_kind data_kind, const char *path, int decode_video)
{ {
AVDictionary *options; AVDictionary *options;
AVCodec *decoder; AVCodec *decoder;
@ -597,10 +597,10 @@ open_input(struct decode_ctx *ctx, struct media_file_info *mfi, int decode_video
# ifndef HAVE_FFMPEG # ifndef HAVE_FFMPEG
// Without this, libav is slow to probe some internet streams, which leads to RAOP timeouts // Without this, libav is slow to probe some internet streams, which leads to RAOP timeouts
if (mfi->data_kind == DATA_KIND_HTTP) if (data_kind == DATA_KIND_HTTP)
ctx->ifmt_ctx->probesize = 64000; ctx->ifmt_ctx->probesize = 64000;
# endif # endif
if (mfi->data_kind == DATA_KIND_HTTP) if (data_kind == DATA_KIND_HTTP)
av_dict_set(&options, "icy", "1", 0); av_dict_set(&options, "icy", "1", 0);
// TODO Newest versions of ffmpeg have timeout and reconnect options we should use // TODO Newest versions of ffmpeg have timeout and reconnect options we should use
@ -608,14 +608,14 @@ open_input(struct decode_ctx *ctx, struct media_file_info *mfi, int decode_video
ctx->ifmt_ctx->interrupt_callback.opaque = ctx; ctx->ifmt_ctx->interrupt_callback.opaque = ctx;
ctx->timestamp = av_gettime(); ctx->timestamp = av_gettime();
ret = avformat_open_input(&ctx->ifmt_ctx, mfi->path, NULL, &options); ret = avformat_open_input(&ctx->ifmt_ctx, path, NULL, &options);
if (options) if (options)
av_dict_free(&options); av_dict_free(&options);
if (ret < 0) if (ret < 0)
{ {
DPRINTF(E_LOG, L_XCODE, "Cannot open '%s': %s\n", mfi->path, err2str(ret)); DPRINTF(E_LOG, L_XCODE, "Cannot open '%s': %s\n", path, err2str(ret));
return -1; return -1;
} }
@ -628,7 +628,7 @@ open_input(struct decode_ctx *ctx, struct media_file_info *mfi, int decode_video
if (ctx->ifmt_ctx->nb_streams > MAX_STREAMS) if (ctx->ifmt_ctx->nb_streams > MAX_STREAMS)
{ {
DPRINTF(E_LOG, L_XCODE, "File '%s' has too many streams (%u)\n", mfi->path, ctx->ifmt_ctx->nb_streams); DPRINTF(E_LOG, L_XCODE, "File '%s' has too many streams (%u)\n", path, ctx->ifmt_ctx->nb_streams);
goto out_fail; goto out_fail;
} }
@ -636,7 +636,7 @@ open_input(struct decode_ctx *ctx, struct media_file_info *mfi, int decode_video
stream_index = av_find_best_stream(ctx->ifmt_ctx, AVMEDIA_TYPE_AUDIO, -1, -1, &decoder, 0); stream_index = av_find_best_stream(ctx->ifmt_ctx, AVMEDIA_TYPE_AUDIO, -1, -1, &decoder, 0);
if ((stream_index < 0) || (!decoder)) if ((stream_index < 0) || (!decoder))
{ {
DPRINTF(E_LOG, L_XCODE, "Did not find audio stream or suitable decoder for %s\n", mfi->path); DPRINTF(E_LOG, L_XCODE, "Did not find audio stream or suitable decoder for %s\n", path);
goto out_fail; goto out_fail;
} }
@ -664,7 +664,7 @@ open_input(struct decode_ctx *ctx, struct media_file_info *mfi, int decode_video
stream_index = av_find_best_stream(ctx->ifmt_ctx, AVMEDIA_TYPE_VIDEO, -1, -1, &decoder, 0); stream_index = av_find_best_stream(ctx->ifmt_ctx, AVMEDIA_TYPE_VIDEO, -1, -1, &decoder, 0);
if ((stream_index < 0) || (!decoder)) if ((stream_index < 0) || (!decoder))
{ {
DPRINTF(E_LOG, L_XCODE, "Did not find video stream or suitable decoder for '%s': %s\n", mfi->path, err2str(ret)); DPRINTF(E_LOG, L_XCODE, "Did not find video stream or suitable decoder for '%s': %s\n", path, err2str(ret));
return 0; return 0;
} }
@ -1232,7 +1232,7 @@ close_filters(struct encode_ctx *ctx)
/* Setup */ /* Setup */
struct decode_ctx * struct decode_ctx *
transcode_decode_setup(struct media_file_info *mfi, int decode_video) transcode_decode_setup(enum data_kind data_kind, const char *path, uint32_t song_length, int decode_video)
{ {
struct decode_ctx *ctx; struct decode_ctx *ctx;
@ -1243,13 +1243,13 @@ transcode_decode_setup(struct media_file_info *mfi, int decode_video)
return NULL; return NULL;
} }
if (open_input(ctx, mfi, decode_video) < 0) if (open_input(ctx, data_kind, path, decode_video) < 0)
{ {
free(ctx); free(ctx);
return NULL; return NULL;
} }
ctx->duration = mfi->song_length; ctx->duration = song_length;
av_init_packet(&ctx->packet); av_init_packet(&ctx->packet);
@ -1293,7 +1293,7 @@ transcode_encode_setup(struct decode_ctx *src_ctx, enum transcode_profile profil
} }
struct transcode_ctx * struct transcode_ctx *
transcode_setup(struct media_file_info *mfi, enum transcode_profile profile, off_t *est_size) transcode_setup(enum data_kind data_kind, const char *path, uint32_t song_length, enum transcode_profile profile, off_t *est_size)
{ {
struct transcode_ctx *ctx; struct transcode_ctx *ctx;
@ -1304,7 +1304,7 @@ transcode_setup(struct media_file_info *mfi, enum transcode_profile profile, off
return NULL; return NULL;
} }
ctx->decode_ctx = transcode_decode_setup(mfi, profile & XCODE_HAS_VIDEO); ctx->decode_ctx = transcode_decode_setup(data_kind, path, song_length, profile & XCODE_HAS_VIDEO);
if (!ctx->decode_ctx) if (!ctx->decode_ctx)
{ {
free(ctx); free(ctx);

4
src/transcode.h
View File

@ -28,13 +28,13 @@ struct decoded_frame;
// Setting up // Setting up
struct decode_ctx * struct decode_ctx *
transcode_decode_setup(struct media_file_info *mfi, int decode_video); transcode_decode_setup(enum data_kind data_kind, const char *path, uint32_t song_length, int decode_video);
struct encode_ctx * struct encode_ctx *
transcode_encode_setup(struct decode_ctx *src_ctx, enum transcode_profile profile, off_t *est_size); transcode_encode_setup(struct decode_ctx *src_ctx, enum transcode_profile profile, off_t *est_size);
struct transcode_ctx * struct transcode_ctx *
transcode_setup(struct media_file_info *mfi, enum transcode_profile profile, off_t *est_size); transcode_setup(enum data_kind data_kind, const char *path, uint32_t song_length, enum transcode_profile profile, off_t *est_size);
struct decode_ctx * struct decode_ctx *
transcode_decode_setup_raw(void); transcode_decode_setup_raw(void);