equal
deleted
inserted
replaced
75 close(); |
75 close(); |
76 return; |
76 return; |
77 } |
77 } |
78 StreamConfiguration c2 = configuration; |
78 StreamConfiguration c2 = configuration; |
79 boolean ordered = c2.getOrdered(); |
79 boolean ordered = c2.getOrdered(); |
|
80 chunkParser.setFlushOperation(flushOperation); |
80 chunkParser.setFirstNanos(start); |
81 chunkParser.setFirstNanos(start); |
81 chunkParser.setLastNanos(end); |
82 chunkParser.setLastNanos(end); |
82 chunkParser.setReuse(c2.getReuse()); |
83 chunkParser.setReuse(c2.getReuse()); |
83 chunkParser.setOrdered(ordered); |
84 chunkParser.setOrdered(ordered); |
84 chunkParser.resetEventCache(); |
85 chunkParser.resetEventCache(); |
88 if (ordered) { |
89 if (ordered) { |
89 processOrdered(); |
90 processOrdered(); |
90 } else { |
91 } else { |
91 processUnordered(); |
92 processUnordered(); |
92 } |
93 } |
93 runFlushActions(); |
|
94 if (chunkParser.isLastChunk()) { |
94 if (chunkParser.isLastChunk()) { |
95 return; |
95 return; |
96 } |
96 } |
97 chunkParser = chunkParser.nextChunkParser(); |
97 chunkParser = chunkParser.nextChunkParser(); |
98 } |
98 } |