src/jdk.jfr/share/classes/jdk/jfr/consumer/StreamConfiguration.java
branchJEP-349-branch
changeset 58145 bc54ed8d908a
parent 58129 7b751fe181a5
child 58146 9f3aadcaa430
--- 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