Shikong/gb28181-docking-platform-proxy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

调整 录制时长 和 超时控制

Browse Source
This commit is contained in:
shikong 2023-09-07 10:35:00 +08:00
parent 310ec451fb
commit 67a891ada8
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/video/RecordService.java
View File

@ -69,11 +69,15 @@ public class RecordService {
scheduledExecutorService.schedule(() -> { scheduledExecutorService.schedule(() -> {
log.info("到达超时时间, 结束录制"); log.info("到达超时时间, 结束录制");
record.set(false); record.set(false);
}, timeout, TimeUnit.SECONDS); }, timeout * 2, TimeUnit.SECONDS);
long maxTime = TimeUnit.SECONDS.toMicros(timeout);
try { try {
Frame frame; Frame frame;
while (record.get() && (frame = grabber.grab()) != null) { while (!recorder.isCloseOutputStream() && record.get() && (frame = grabber.grab()) != null) {
long micros = TimeUnit.MICROSECONDS.toMicros(recorder.getTimestamp());
if(micros >= maxTime){
break;
}
recorder.record(frame); recorder.record(frame);
} }
grabber.close(); grabber.close();