equal
deleted
inserted
replaced
142 |
142 |
143 if (isClosed()) { |
143 if (isClosed()) { |
144 return; |
144 return; |
145 } |
145 } |
146 long durationNanos = currentParser.getChunkDuration(); |
146 long durationNanos = currentParser.getChunkDuration(); |
|
147 if (durationNanos == 0) { |
|
148 // Avoid reading the same chunk again and again if |
|
149 // duration is 0 ns |
|
150 durationNanos++; |
|
151 } |
147 path = repositoryFiles.nextPath(currentChunkStartNanos + durationNanos); |
152 path = repositoryFiles.nextPath(currentChunkStartNanos + durationNanos); |
148 if (path == null) { |
153 if (path == null) { |
149 return; // stream closed |
154 return; // stream closed |
150 } |
155 } |
151 currentChunkStartNanos = repositoryFiles.getTimestamp(path); |
156 currentChunkStartNanos = repositoryFiles.getTimestamp(path); |