equal
deleted
inserted
replaced
80 runFlushActions(); |
80 runFlushActions(); |
81 chunkParser = chunkParser.nextChunkParser(); |
81 chunkParser = chunkParser.nextChunkParser(); |
82 } |
82 } |
83 } |
83 } |
84 |
84 |
85 |
|
86 private void processOrdered() throws IOException { |
85 private void processOrdered() throws IOException { |
87 if (sortedList == null) { |
86 if (sortedList == null) { |
88 sortedList = new RecordedEvent[DEFAULT_ARRAY_SIZE]; |
87 sortedList = new RecordedEvent[DEFAULT_ARRAY_SIZE]; |
89 } |
88 } |
90 RecordedEvent event; |
89 RecordedEvent event; |
186 @Override |
185 @Override |
187 public void start() { |
186 public void start() { |
188 eventConsumer.start(0); |
187 eventConsumer.start(0); |
189 } |
188 } |
190 |
189 |
|
190 @Override |
191 public void setReuse(boolean reuse) { |
191 public void setReuse(boolean reuse) { |
192 eventConsumer.setReuse(reuse); |
192 eventConsumer.setReuse(reuse); |
193 } |
193 } |
194 |
194 |
195 @Override |
195 @Override |