j62
/
ctbrec
2
2
Fork 2
Code Issues 3 Pull Requests Packages Projects Releases 3 Wiki Activity

debug statistics 

(cherry picked from commit d03c16f68be3f55893b7908bc094e6a32043563e)
This commit is contained in:
reusedname 2025-02-09 15:55:24 +05:00
parent 9a3dc4c02d
commit a90fb87b09
3 changed files with 27 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -10,6 +10,8 @@ public class Statistics {
public ReadWriteLock statsLock = new ReentrantReadWriteLock(); public ReadWriteLock statsLock = new ReentrantReadWriteLock();
public CircularFifoBuffer stats = new CircularFifoBuffer(100); public CircularFifoBuffer stats = new CircularFifoBuffer(100);
public long errorCount = 0;
public void add(Object val) { public void add(Object val) {
statsLock.writeLock().lock(); statsLock.writeLock().lock();
try { try {

23
common/src/main/java/ctbrec/recorder/download/hls/MergedFfmpegHlsDownload.java
View File

@ -6,8 +6,11 @@ import ctbrec.OS;
import ctbrec.Recording; import ctbrec.Recording;
import ctbrec.io.HttpClient; import ctbrec.io.HttpClient;
import ctbrec.recorder.FFmpeg; import ctbrec.recorder.FFmpeg;
import ctbrec.recorder.SimplifiedLocalRecorder;
import ctbrec.recorder.download.ProcessExitedUncleanException; import ctbrec.recorder.download.ProcessExitedUncleanException;
import ctbrec.recorder.download.hls.SegmentPlaylist.Segment; import ctbrec.recorder.download.hls.SegmentPlaylist.Segment;
import lombok.Getter;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@ -16,6 +19,7 @@ import java.io.File;
import java.io.IOException; import java.io.IOException;
import java.io.OutputStream; import java.io.OutputStream;
import java.nio.file.Files; import java.nio.file.Files;
import java.time.Duration;
import java.time.Instant; import java.time.Instant;
import java.util.concurrent.*; import java.util.concurrent.*;
import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.Lock;
@ -25,7 +29,7 @@ import java.util.regex.Pattern;
public class MergedFfmpegHlsDownload extends AbstractHlsDownload { public class MergedFfmpegHlsDownload extends AbstractHlsDownload {
private static final Logger LOG = LoggerFactory.getLogger(MergedFfmpegHlsDownload.class); private static final Logger LOG = LoggerFactory.getLogger(MergedFfmpegHlsDownload.class);
protected File targetFile; protected File targetFile;
protected FFmpeg ffmpeg; protected FFmpeg ffmpeg;
protected Process ffmpegProcess; protected Process ffmpegProcess;
@ -34,7 +38,15 @@ public class MergedFfmpegHlsDownload extends AbstractHlsDownload {
protected Lock ffmpegStreamLock = new ReentrantLock(); protected Lock ffmpegStreamLock = new ReentrantLock();
public String getStats() { public String getStats() {
String text = (running ? "RUN" : "stp") + String.format(" %d: ", queue.size()); // check if lock is held
var locked = ffmpegStreamLock.tryLock();
if (locked) ffmpegStreamLock.unlock();
String text = (running ? "RUN" : "stp")
+ String.format(" lag=%6dms lock=%b %d: ",
Duration.between(lastSegmentDownload, Instant.now()).toMillis(),
!locked,
queue.size());
for (var elem : queue) { for (var elem : queue) {
text += elem.isDone() ? "|" : "-"; text += elem.isDone() ? "|" : "-";
} }
@ -148,7 +160,12 @@ public class MergedFfmpegHlsDownload extends AbstractHlsDownload {
@Override @Override
protected void execute(SegmentDownload segmentDownload) { protected void execute(SegmentDownload segmentDownload) {
queue.add(segmentDownloadService.submit(segmentDownload)); try {
queue.add(segmentDownloadService.submit(segmentDownload));
} catch (Exception e) {
SimplifiedLocalRecorder.STATS.errorCount++;
throw e;
}
LOG.trace("Enqueuing segment for file {}", targetFile); LOG.trace("Enqueuing segment for file {}", targetFile);
} }

7
server/src/main/java/ctbrec/recorder/server/DebugServlet.java
View File

@ -69,15 +69,18 @@ public class DebugServlet extends AbstractCtbrecServlet {
resp.setContentType("text/plain"); resp.setContentType("text/plain");
sendResponse(resp, SC_OK, box.text); sendResponse(resp, SC_OK, box.text);
} else if ((m = URL_PATTERN_DEBUG_STATS.matcher(requestURI)).matches()) { } else if ((m = URL_PATTERN_DEBUG_STATS.matcher(requestURI)).matches()) {
String text = "<html><body style=\"body { font-family: Monospace; }\">"; // <meta http-equiv=\"refresh\" content=\"1\">
String text = "<html><body style=\"font-family: &quot;Noto Sans Mono&quot;, monospace;\">";
text += String.format("GLOBAL_HTTP_CONN_POOL: connectionCount=%d, idleConnectionCount=%d\n", text += String.format("GLOBAL_HTTP_CONN_POOL: connectionCount=%d, idleConnectionCount=%d\n",
HttpClient.getGLOBAL_HTTP_CONN_POOL().connectionCount(), HttpClient.getGLOBAL_HTTP_CONN_POOL().connectionCount(),
HttpClient.getGLOBAL_HTTP_CONN_POOL().idleConnectionCount()); HttpClient.getGLOBAL_HTTP_CONN_POOL().idleConnectionCount());
var rlock = SimplifiedLocalRecorder.STATS.statsLock.readLock(); var rlock = SimplifiedLocalRecorder.STATS.statsLock.readLock();
rlock.lock(); rlock.lock();
try { try {
text += String.format("Time between download iterations = %s\n", SimplifiedLocalRecorder.STATS.stats.toString()); text += String.format("Time between download iterations = %s\n", SimplifiedLocalRecorder.STATS.stats.toString());
text += String.format("Error count: %d\n", SimplifiedLocalRecorder.STATS.errorCount);
} finally { } finally {
rlock.unlock(); rlock.unlock();
} }
@ -88,7 +91,7 @@ public class DebugServlet extends AbstractCtbrecServlet {
for (var rec : recorder.getRecordings()) { for (var rec : recorder.getRecordings()) {
var proc = rec.getRecordingProcess(); var proc = rec.getRecordingProcess();
if (proc == null) continue; if (proc == null) continue;
text += String.format("<tr><td>%s</td><td>%s</td></tr>\n", proc.getModel().getDisplayName(), proc.getStats()); text += String.format("<tr><td>%s</td><td>%s</td></tr>\n", proc.getModel().getDisplayName(), proc.getStats().replace(" ", "&nbsp;"));
} }
text += "</table>"; text += "</table>";