equal
deleted
inserted
replaced
180 @Override |
180 @Override |
181 public void process() throws IOException { |
181 public void process() throws IOException { |
182 Path path = repositoryFiles.nextPath(startNanos); |
182 Path path = repositoryFiles.nextPath(startNanos); |
183 startNanos = repositoryFiles.getTimestamp(path) + 1; |
183 startNanos = repositoryFiles.getTimestamp(path) + 1; |
184 try (RecordingInput input = new RecordingInput(path.toFile())) { |
184 try (RecordingInput input = new RecordingInput(path.toFile())) { |
|
185 chunkParser = new ChunkParser(input, this.reuse); |
185 while (!isClosed()) { |
186 while (!isClosed()) { |
186 // chunkParser = chunkParser.nextChunkParser(); |
|
187 chunkParser = new ChunkParser(input, this.reuse); |
|
188 boolean awaitnewEvent = false; |
187 boolean awaitnewEvent = false; |
189 while (!isClosed() && !chunkParser.isChunkFinished()) { |
188 while (!isClosed() && !chunkParser.isChunkFinished()) { |
190 chunkParser.setReuse(this.reuse); |
189 chunkParser.setReuse(this.reuse); |
191 chunkParser.setOrdered(this.ordered); |
190 chunkParser.setOrdered(this.ordered); |
192 chunkParser.resetEventCache(); |
191 chunkParser.resetEventCache(); |
200 } |
199 } |
201 |
200 |
202 path = repositoryFiles.nextPath(startNanos); |
201 path = repositoryFiles.nextPath(startNanos); |
203 startNanos = repositoryFiles.getTimestamp(path) + 1; |
202 startNanos = repositoryFiles.getTimestamp(path) + 1; |
204 input.setFile(path); |
203 input.setFile(path); |
|
204 chunkParser = chunkParser.newChunkParser(); |
205 } |
205 } |
206 } |
206 } |
207 } |
207 } |
208 |
208 |
209 private boolean processOrdered(boolean awaitNewEvents) throws IOException { |
209 private boolean processOrdered(boolean awaitNewEvents) throws IOException { |