--- a/src/jdk.jfr/share/classes/jdk/jfr/consumer/StreamConfiguration.java Fri Sep 13 18:46:07 2019 +0200
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,102 +0,0 @@
-package jdk.jfr.consumer;
-
-import java.time.Instant;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.function.Consumer;
-
-import jdk.jfr.consumer.Dispatcher.EventDispatcher;
-import jdk.jfr.internal.Utils;
-
-final class StreamConfiguration {
- final List<Runnable> closeActions = new ArrayList<>();
- final List<Runnable> flushActions = new ArrayList<>();
- final List<EventDispatcher> eventActions = new ArrayList<>();
- final List<Consumer<Throwable>> errorActions = new ArrayList<>();
-
- boolean reuse = true;
- boolean ordered = true;
- Instant startTime = null;
- Instant endTime = null;
- boolean started = false;
- long startNanos = 0;
- long endNanos = Long.MAX_VALUE;
-
- volatile boolean changed = true;
-
- public synchronized boolean remove(Object action) {
- boolean removed = false;
- removed |= flushActions.removeIf(e -> e == action);
- removed |= closeActions.removeIf(e -> e == action);
- removed |= errorActions.removeIf(e -> e == action);
- removed |= eventActions.removeIf(e -> e.action == action);
- if (removed) {
- changed = true;
- }
- return removed;
- }
-
- public synchronized void addEventAction(String name, Consumer<RecordedEvent> consumer) {
- eventActions.add(new EventDispatcher(name, consumer));
- changed = true;
- }
-
- public void addEventAction(Consumer<RecordedEvent> action) {
- addEventAction(null, action);
- }
-
- public synchronized void addFlushAction(Runnable action) {
- flushActions.add(action);
- changed = true;
- }
-
- public synchronized void addCloseAction(Runnable action) {
- closeActions.add(action);
- changed = true;
- }
-
- public synchronized void addErrorAction(Consumer<Throwable> action) {
- errorActions.add(action);
- changed = true;
- }
-
- public synchronized void setReuse(boolean reuse) {
- this.reuse = reuse;
- changed = true;
- }
-
- public synchronized void setOrdered(boolean ordered) {
- this.ordered = ordered;
- changed = true;
- }
-
- public synchronized void setEndTime(Instant endTime) {
- this.endTime = endTime;
- this.endNanos = Utils.timeToNanos(endTime);
- changed = true;
- }
-
- public synchronized void setStartTime(Instant startTime) {
- this.startTime = startTime;
- this.startNanos = Utils.timeToNanos(startTime);
- changed = true;
- }
-
- public synchronized void setStartNanos(long startNanos) {
- this.startNanos = startNanos;
- changed = true;
- }
-
- public synchronized void setStarted(boolean started) {
- this.started = started;
- changed = true;
- }
-
- public boolean hasChanged() {
- return changed;
- }
-
- public synchronized void clearChanged() {
- changed = false;
- }
-}
\ No newline at end of file