in src/main/java/com/aws/iot/edgeconnectorforkvs/videouploader/visitors/MergeFragmentVisitor.java [469:489]
private void emitCluster(MkvCluster cluster) throws MkvElementVisitException {
if (cluster != null) {
boolean isMissingFrameForTrack = false;
for (long trackNumber : trackNumbers) {
if (cluster.getSimpleBlockCountInTrack(trackNumber) == 0) {
isMissingFrameForTrack = true;
}
}
if (isMissingFrameForTrack) {
log.trace("Skip cluster for missing frame for track: " + cluster);
} else {
log.trace("Wrote cluster to channel: " + cluster);
cluster.sort();
try {
cluster.writeToChannel(outputChannel);
} catch (IOException exception) {
wrapIOException(exception);
}
}
}
}