summaryrefslogtreecommitdiffstats
path: root/libhb/sync.c
diff options
context:
space:
mode:
authorJohn Stebbins <[email protected]>2016-06-10 10:56:50 -0600
committerJohn Stebbins <[email protected]>2016-06-10 11:15:09 -0600
commitf4f3e9c40299e63adae24a5b85316f0771739c9b (patch)
treec1501acd71ac5f9066577ae63b09b411ccf4197a /libhb/sync.c
parent191529edf883680213f46b4cfaaf16a93c3b2201 (diff)
sync: when p-to-p end reached return HB_WORK_DONE asap
Diffstat (limited to 'libhb/sync.c')
-rw-r--r--libhb/sync.c12
1 files changed, 12 insertions, 0 deletions
diff --git a/libhb/sync.c b/libhb/sync.c
index 284663492..6f33e978a 100644
--- a/libhb/sync.c
+++ b/libhb/sync.c
@@ -2647,6 +2647,10 @@ static int syncVideoWork( hb_work_object_t * w, hb_buffer_t ** buf_in,
QueueBuffer(pv->stream, in);
Synchronize(pv->stream);
+ if (pv->stream->done)
+ {
+ return HB_WORK_DONE;
+ }
return HB_WORK_OK;
}
@@ -2723,6 +2727,10 @@ static int syncAudioWork( hb_work_object_t * w, hb_buffer_t ** buf_in,
QueueBuffer(pv->stream, in);
Synchronize(pv->stream);
+ if (pv->stream->done)
+ {
+ return HB_WORK_DONE;
+ }
return HB_WORK_OK;
}
@@ -3034,6 +3042,10 @@ static int syncSubtitleWork( hb_work_object_t * w, hb_buffer_t ** buf_in,
QueueBuffer(pv->stream, in);
Synchronize(pv->stream);
+ if (pv->stream->done)
+ {
+ return HB_WORK_DONE;
+ }
return HB_WORK_OK;
}