summaryrefslogtreecommitdiffstats
path: root/player
diff options
context:
space:
mode:
authorwm4 <wm4@nowhere>2014-07-18 15:10:28 +0200
committerwm4 <wm4@nowhere>2014-07-18 15:10:28 +0200
commit7083f88ca8b98aa74dbc9e34d5c5cf6e150cfe0b (patch)
tree8835b9e68ef6738203cfae798fb0df5122fdae08 /player
parent848546f2de52b54f78077cb4ca968e089e3e010a (diff)
downloadmpv-7083f88ca8b98aa74dbc9e34d5c5cf6e150cfe0b.tar.bz2
mpv-7083f88ca8b98aa74dbc9e34d5c5cf6e150cfe0b.tar.xz
video: don't block when reading video packets
Instead of blocking on the demuxer when reading a packet, let packets be read asynchronously. Basically, it polls whether a packet is available, and if not, the playloop goes to sleep until the demuxer thread wakes it up. Note that the player will still block for I/O, because audio is still read synchronously. It's much harder to do the same change for audio (because of the design of the audio decoding path and especially initialization), so audio will have to be done later.
Diffstat (limited to 'player')
-rw-r--r--player/loadfile.c21
-rw-r--r--player/playloop.c9
-rw-r--r--player/video.c18
3 files changed, 35 insertions, 13 deletions
diff --git a/player/loadfile.c b/player/loadfile.c
index e1ffa5d783..9816dbf4cc 100644
--- a/player/loadfile.c
+++ b/player/loadfile.c
@@ -312,6 +312,21 @@ static struct sh_stream *select_fallback_stream(struct demuxer *d,
return best_stream;
}
+// Called from the demuxer thread if a new packet is available.
+static void wakeup_demux(void *pctx)
+{
+ struct MPContext *mpctx = pctx;
+ mp_input_wakeup(mpctx->input);
+}
+
+static void enable_demux_thread(struct MPContext *mpctx)
+{
+ if (mpctx->demuxer && mpctx->opts->demuxer_thread) {
+ demux_set_wakeup_cb(mpctx->demuxer, wakeup_demux, mpctx);
+ demux_start_thread(mpctx->demuxer);
+ }
+}
+
bool timeline_set_part(struct MPContext *mpctx, int i, bool force)
{
struct timeline_part *p = mpctx->timeline + mpctx->timeline_part;
@@ -353,8 +368,7 @@ bool timeline_set_part(struct MPContext *mpctx, int i, bool force)
}
reselect_demux_streams(mpctx);
- if (mpctx->demuxer && mpctx->opts->demuxer_thread)
- demux_start_thread(mpctx->demuxer);
+ enable_demux_thread(mpctx);
return true;
}
@@ -1188,8 +1202,7 @@ goto_reopen_demuxer: ;
update_demuxer_properties(mpctx);
- if (mpctx->demuxer && opts->demuxer_thread)
- demux_start_thread(mpctx->demuxer);
+ enable_demux_thread(mpctx);
if (mpctx->current_track[0][STREAM_VIDEO] &&
mpctx->current_track[0][STREAM_VIDEO]->attached_picture)
diff --git a/player/playloop.c b/player/playloop.c
index 2392fd32a4..a3fcf133e3 100644
--- a/player/playloop.c
+++ b/player/playloop.c
@@ -985,6 +985,12 @@ void run_playloop(struct MPContext *mpctx)
video_left = r > 0;
+ if (r == 3)
+ break;
+
+ if (mpctx->restart_playback)
+ mpctx->sleeptime = 0;
+
if (r == 2)
MP_TRACE(mpctx, "frametime=%5.3f\n", frame_time);
@@ -1243,9 +1249,6 @@ void run_playloop(struct MPContext *mpctx)
if (mpctx->stop_play)
mpctx->sleeptime = 0;
- if (mpctx->restart_playback)
- mpctx->sleeptime = 0;
-
if (mpctx->sleeptime > 0 && handle_osd_redraw(mpctx))
mpctx->sleeptime = 0;
diff --git a/player/video.c b/player/video.c
index 3d742c0081..45cf04e92b 100644
--- a/player/video.c
+++ b/player/video.c
@@ -300,6 +300,8 @@ static int check_framedrop(struct MPContext *mpctx, double frame_time)
// Read a packet, store decoded image into d_video->waiting_decoded_mpi
// Return 0 if EOF was reached (though the decoder still can have frames buffered)
+// Return 1 if a packet was read (i.e. progress made)
+// Return 3 if the demuxer will wake us up once a new packet is available.
static int decode_image(struct MPContext *mpctx)
{
struct dec_video *d_video = mpctx->d_video;
@@ -310,7 +312,9 @@ static int decode_image(struct MPContext *mpctx)
return 0;
}
- struct demux_packet *pkt = demux_read_packet(d_video->header);
+ struct demux_packet *pkt;
+ if (demux_read_packet_async(d_video->header, &pkt) == 0)
+ return 3;
if (pkt && pkt->pts != MP_NOPTS_VALUE)
pkt->pts += mpctx->video_offset;
if ((pkt && pkt->pts >= mpctx->hrseek_pts - .005) ||
@@ -326,7 +330,7 @@ static int decode_image(struct MPContext *mpctx)
bool had_packet = !!pkt;
talloc_free(pkt);
- return had_packet;
+ return had_packet ? 1 : 0;
}
@@ -345,7 +349,7 @@ static void init_filter_params(struct MPContext *mpctx)
}
// Make sure at least 1 filtered image is available.
-// Returns: -1: error, 0: EOF, 1: ok or progress was made
+// Returns: -1: error, 0: EOF, 1: ok or progress was made, 3: ok but wait
// A return value of 1 doesn't necessarily output a frame, but makes the promise
// that calling this function again will eventually do something.
static int video_decode_and_filter(struct MPContext *mpctx)
@@ -387,9 +391,11 @@ static int video_decode_and_filter(struct MPContext *mpctx)
return 1;
}
+ int r = 1;
+
if (!d_video->waiting_decoded_mpi) {
// Decode a new image, or at least feed the decoder a packet.
- int r = decode_image(mpctx);
+ r = decode_image(mpctx);
if (d_video->waiting_decoded_mpi)
d_video->decoder_output = d_video->waiting_decoded_mpi->params;
if (!d_video->waiting_decoded_mpi && r < 1)
@@ -397,7 +403,7 @@ static int video_decode_and_filter(struct MPContext *mpctx)
}
// Image will be filtered on the next iteration.
- return 1;
+ return r;
}
static void init_vo(struct MPContext *mpctx)
@@ -518,7 +524,7 @@ int update_video(struct MPContext *mpctx, double endpts, bool reconfig_ok,
}
int r = video_output_image(mpctx, endpts, reconfig_ok);
- if (r < 0)
+ if (r < 0 || r == 3)
return r;
// On EOF (r==0), we always drain the VO; otherwise we must ensure that