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

Improve logging messages

This commit is contained in:
0xboobface 2018-09-07 16:46:49 +02:00
parent 85618289d5
commit b91888f2ae
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/ctbrec/recorder/download/MergedHlsDownload.java
View File

@ -88,9 +88,7 @@ public class MergedHlsDownload extends AbstractHlsDownload {
int seq = lsp.seq; int seq = lsp.seq;
for (int i = nextSegment; i < lsp.seq; i++) { for (int i = nextSegment; i < lsp.seq; i++) {
URL segmentUrl = new URL(first.replaceAll(Integer.toString(seq), Integer.toString(i))); URL segmentUrl = new URL(first.replaceAll(Integer.toString(seq), Integer.toString(i)));
LOG.debug("Reloading segment {} for model {}", i, model.getName()); LOG.debug("Loading missed segment {} for model {}", i, model.getName());
// FIXME this does not work with the current mechanism, since the InputStreams for these segments would be added
// to the mergeQueue in the wrong spot (after successors of these segments -> wrong order)
Future<InputStream> downloadFuture = downloadThreadPool.submit(new SegmentDownload(segmentUrl, client)); Future<InputStream> downloadFuture = downloadThreadPool.submit(new SegmentDownload(segmentUrl, client));
mergeQueue.add(downloadFuture); mergeQueue.add(downloadFuture);
} }
@ -157,7 +155,7 @@ public class MergedHlsDownload extends AbstractHlsDownload {
multiSource.addSource(source); multiSource.addSource(source);
} catch (InterruptedException e) { } catch (InterruptedException e) {
if(running) { if(running) {
LOG.error("Error while waiting for a download future", e); LOG.error("Interrupted while waiting for a download future", e);
} }
} catch (ExecutionException e) { } catch (ExecutionException e) {
LOG.error("Error while executing download", e); LOG.error("Error while executing download", e);