equal
deleted
inserted
replaced
203 now = System.currentTimeMillis() - base; |
203 now = System.currentTimeMillis() - base; |
204 } |
204 } |
205 } |
205 } |
206 } |
206 } |
207 |
207 |
208 protected abstract void process() throws Exception; |
208 protected abstract void process() throws IOException; |
209 |
209 |
210 protected final void setClosed(boolean closed) { |
210 protected final void setClosed(boolean closed) { |
211 this.closed = closed; |
211 this.closed = closed; |
212 } |
212 } |
213 |
213 |
250 process(); |
250 process(); |
251 } catch (IOException ioe) { |
251 } catch (IOException ioe) { |
252 // This can happen if a chunk file is removed, or |
252 // This can happen if a chunk file is removed, or |
253 // a file is access that has been closed |
253 // a file is access that has been closed |
254 // This is "normal" behavior for streaming and the |
254 // This is "normal" behavior for streaming and the |
255 // stream will be closed when this happens |
255 // stream will be closed when this happens. |
256 } catch (Exception e) { |
|
257 // TODO: Remove before integrating |
|
258 e.printStackTrace(); |
|
259 } finally { |
256 } finally { |
260 Logger.log(LogTag.JFR_SYSTEM_STREAMING, LogLevel.DEBUG, "Execution of stream ended."); |
257 Logger.log(LogTag.JFR_SYSTEM_STREAMING, LogLevel.DEBUG, "Execution of stream ended."); |
261 try { |
258 try { |
262 close(); |
259 close(); |
263 } finally { |
260 } finally { |