davebluke
/
ctbrec
forked from j62/ctbrec
1
0
Fork 0
Code Pull Requests Activity

faster shutdown, adjust download reschedule time 

(cherry picked from commit ef818843185eba80fbe58786c91e2bc52994f9da)
This commit is contained in:
reusedname 2025-01-19 11:35:56 +05:00
parent 74852692d0
commit af38886f97
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
common/src/main/java/ctbrec/recorder/SimplifiedLocalRecorder.java
View File

@ -728,7 +728,7 @@ public class SimplifiedLocalRecorder implements Recorder {
} }
private void tryRestartRecording(Model model) { private void tryRestartRecording(Model model) {
if (!running) { if (!running || shuttingDown) {
// recorder is not in recording state // recorder is not in recording state
return; return;
} }

4
common/src/main/java/ctbrec/recorder/download/hls/AbstractHlsDownload.java
View File

@ -154,7 +154,7 @@ public abstract class AbstractHlsDownload extends AbstractDownload {
model.delay(); model.delay();
stop(); stop();
} else { } else {
rescheduleTime = beforeLastPlaylistRequest; // try again as fast as possible rescheduleTime = Instant.now(); // try again as fast as possible
} }
} catch (EOFException e) { } catch (EOFException e) {
// end of playlist reached // end of playlist reached
@ -422,6 +422,8 @@ public abstract class AbstractHlsDownload extends AbstractDownload {
private void calculateRescheduleTime() { private void calculateRescheduleTime() {
rescheduleTime = beforeLastPlaylistRequest.plusMillis(1000); rescheduleTime = beforeLastPlaylistRequest.plusMillis(1000);
if (Instant.now().isAfter(rescheduleTime))
rescheduleTime = Instant.now();
recordingEvents.add(RecordingEvent.of("next playlist download scheduled for " + rescheduleTime.toString())); recordingEvents.add(RecordingEvent.of("next playlist download scheduled for " + rescheduleTime.toString()));
} }