src/jdk.jfr/share/classes/jdk/jfr/internal/SettingsManager.java
author mgronlun
Wed, 30 Oct 2019 19:43:52 +0100
changeset 58863 c16ac7a2eba4
parent 52413 6372f5af9612
permissions -rw-r--r--
8226511: Implement JFR Event Streaming Reviewed-by: egahlin, mseledtsov, mgronlun Contributed-by: erik.gahlin@oracle.com, mikhailo.seledtsov@oracle.com, markus.gronlund@oracle.com
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     1
/*
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 52413
diff changeset
     2
 * Copyright (c) 2016, 2019, Oracle and/or its affiliates. All rights reserved.
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     3
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     4
 *
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     5
 * This code is free software; you can redistribute it and/or modify it
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     6
 * under the terms of the GNU General Public License version 2 only, as
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     7
 * published by the Free Software Foundation.  Oracle designates this
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     8
 * particular file as subject to the "Classpath" exception as provided
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     9
 * by Oracle in the LICENSE file that accompanied this code.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    10
 *
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    11
 * This code is distributed in the hope that it will be useful, but WITHOUT
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    12
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    13
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    14
 * version 2 for more details (a copy is included in the LICENSE file that
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    15
 * accompanied this code).
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    16
 *
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    17
 * You should have received a copy of the GNU General Public License version
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    18
 * 2 along with this work; if not, write to the Free Software Foundation,
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    19
 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    20
 *
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    21
 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    22
 * or visit www.oracle.com if you need additional information or have any
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    23
 * questions.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    24
 */
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    25
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    26
package jdk.jfr.internal;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    27
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    28
import java.util.ArrayList;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    29
import java.util.Collection;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    30
import java.util.Collections;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    31
import java.util.HashMap;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    32
import java.util.HashSet;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    33
import java.util.LinkedHashMap;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    34
import java.util.List;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    35
import java.util.Map;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    36
import java.util.Set;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    37
import java.util.StringJoiner;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    38
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 52413
diff changeset
    39
import jdk.jfr.internal.EventControl.NamedControl;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    40
import jdk.jfr.internal.handlers.EventHandler;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    41
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    42
final class SettingsManager {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    43
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    44
    private static class InternalSetting {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    45
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    46
        private final String identifier;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    47
        private Map<String, Set<String>> enabledMap = new LinkedHashMap<>(5);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    48
        private Map<String, Set<String>> allMap = new LinkedHashMap<>(5);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    49
        private boolean enabled;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    50
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    51
        /**
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    52
         * Settings identifier, for example "com.example.HelloWorld" or "56"
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    53
         * (id of event)
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    54
         *
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    55
         * @param settingsId
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    56
         */
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    57
        public InternalSetting(String settingsId) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    58
            this.identifier = settingsId;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    59
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    60
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    61
        public Set<String> getValues(String key) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    62
            if (enabled) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    63
                return enabledMap.get(key);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    64
            } else {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    65
                return allMap.get(key);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    66
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    67
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    68
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    69
        public void add(String attribute, String value) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    70
            if ("enabled".equals(attribute) && "true".equals(value)) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    71
                enabled = true;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    72
                allMap = null; // no need to keep these around
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    73
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    74
            addToMap(enabledMap, attribute, value);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    75
            if (allMap != null) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    76
                addToMap(allMap, attribute, value);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    77
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    78
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    79
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    80
        private void addToMap(Map<String, Set<String>> map, String attribute, String value) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    81
            Set<String> values = map.get(attribute);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    82
            if (values == null) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    83
                values = new HashSet<String>(5);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    84
                map.put(attribute, values);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    85
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    86
            values.add(value);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    87
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    88
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    89
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    90
        public String getSettingsId() {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    91
            return identifier;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    92
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    93
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    94
        public void add(InternalSetting enabled) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    95
            for (Map.Entry<String, Set<String>> entry : enabled.enabledMap.entrySet()) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    96
                for (String value : entry.getValue()) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    97
                    add(entry.getKey(), value);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    98
                }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    99
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   100
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   101
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   102
        public boolean isEnabled() {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   103
            return enabled;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   104
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   105
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   106
        @Override
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   107
        public String toString() {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   108
            StringBuilder sb = new StringBuilder();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   109
            sb.append(identifier);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   110
            sb.append(": ");
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   111
            sb.append(enabledMap.toString());
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   112
            return sb.toString();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   113
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   114
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   115
        public void finish() {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   116
            if (!enabled) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   117
                // settings from disabled
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   118
                // events should not impact results, but
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   119
                // we can't clear enabledMap since enabled=false
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   120
                // needs be there, so events that are enabled
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   121
                // by default are turned off
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   122
                Map<String, Set<String>> disabledMap = new HashMap<>(2);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   123
                Set<String> values = new HashSet<>(2);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   124
                values.add("false");
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   125
                disabledMap.put("enabled", values);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   126
                enabledMap = disabledMap;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   127
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   128
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   129
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   130
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   131
   private Map<String, InternalSetting> availableSettings = new LinkedHashMap<>();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   132
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   133
    void setSettings(List<Map<String, String>> activeSettings) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   134
        // store settings so they are available if a new event class is loaded
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   135
        availableSettings = createSettingsMap(activeSettings);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   136
        List<EventControl> eventControls = MetadataRepository.getInstance().getEventControls();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   137
        if (!JVM.getJVM().isRecording()) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   138
            for (EventControl ec : eventControls) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   139
                ec.disable();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   140
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   141
        } else {
52413
6372f5af9612 8209960: -Xlog:jfr* doesn't work with the JFR
egahlin
parents: 52334
diff changeset
   142
            if (Logger.shouldLog(LogTag.JFR_SETTING, LogLevel.INFO)) {
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   143
                Collections.sort(eventControls, (x,y) -> x.getEventType().getName().compareTo(y.getEventType().getName()));
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   144
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   145
            for (EventControl ec : eventControls) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   146
                setEventControl(ec);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   147
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   148
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   149
        if (JVM.getJVM().getAllowedToDoEventRetransforms()) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   150
            updateRetransform(JVM.getJVM().getAllEventClasses());
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   151
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   152
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   153
52334
a181612f0715 8203629: Produce events in the JDK without a dependency on jdk.jfr
egahlin
parents: 50113
diff changeset
   154
    public void updateRetransform(List<Class<? extends jdk.internal.event.Event>> eventClasses) {
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   155
        List<Class<?>> classes = new ArrayList<>();
52334
a181612f0715 8203629: Produce events in the JDK without a dependency on jdk.jfr
egahlin
parents: 50113
diff changeset
   156
        for(Class<? extends jdk.internal.event.Event> eventClass: eventClasses) {
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   157
            EventHandler eh = Utils.getHandler(eventClass);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   158
            if (eh != null ) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   159
                PlatformEventType eventType = eh.getPlatformEventType();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   160
                if (eventType.isMarkedForInstrumentation()) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   161
                    classes.add(eventClass);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   162
                    eventType.markForInstrumentation(false);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   163
                    // A bit premature to set it here, but hard to check
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   164
                    // after call to retransformClasses.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   165
                    eventType.setInstrumented();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   166
                }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   167
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   168
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   169
        if (!classes.isEmpty()) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   170
            JVM.getJVM().retransformClasses(classes.toArray(new Class<?>[0]));
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   171
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   172
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   173
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   174
    private Map<String, InternalSetting> createSettingsMap(List<Map<String,String>> activeSettings) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   175
        Map<String, InternalSetting> map = new LinkedHashMap<>(activeSettings.size());
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   176
        for (Map<String, String> rec : activeSettings) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   177
            for (InternalSetting internal : makeInternalSettings(rec)) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   178
                InternalSetting is = map.get(internal.getSettingsId());
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   179
                if (is == null) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   180
                    map.put(internal.getSettingsId(), internal);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   181
                } else {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   182
                    is.add(internal);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   183
                }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   184
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   185
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   186
        return map;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   187
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   188
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   189
    private Collection<InternalSetting> makeInternalSettings(Map<String, String> rec) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   190
        Map<String, InternalSetting> internals = new LinkedHashMap<>();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   191
        for (Map.Entry<String, String> entry : rec.entrySet()) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   192
            String key = entry.getKey();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   193
            String value = entry.getValue();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   194
            int index = key.indexOf("#");
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   195
            if (index > 1 && index < key.length() - 2) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   196
                String eventName = key.substring(0, index);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   197
                eventName = Utils.upgradeLegacyJDKEvent(eventName);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   198
                InternalSetting s = internals.get(eventName);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   199
                String settingName = key.substring(index + 1).trim();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   200
                if (s == null) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   201
                    s = new InternalSetting(eventName);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   202
                    internals.put(eventName, s);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   203
                }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   204
                s.add(settingName, value);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   205
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   206
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   207
      for (InternalSetting s : internals.values()) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   208
         s.finish();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   209
      }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   210
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   211
      return internals.values();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   212
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   213
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   214
    void setEventControl(EventControl ec) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   215
        InternalSetting is = getInternalSetting(ec);
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 52413
diff changeset
   216
        boolean shouldLog = Logger.shouldLog(LogTag.JFR_SETTING, LogLevel.INFO);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 52413
diff changeset
   217
        if (shouldLog) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 52413
diff changeset
   218
            Logger.log(LogTag.JFR_SETTING, LogLevel.INFO, "Applied settings for " + ec.getEventType().getLogName() + " {");
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 52413
diff changeset
   219
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 52413
diff changeset
   220
        for (NamedControl nc: ec.getNamedControls()) {
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   221
            Set<String> values = null;
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 52413
diff changeset
   222
            String settingName = nc.name;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   223
            if (is != null) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   224
                values = is.getValues(settingName);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   225
            }
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 52413
diff changeset
   226
            Control control = nc.control;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   227
            if (values != null) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   228
                control.apply(values);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   229
                String after = control.getLastValue();
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 52413
diff changeset
   230
                if (shouldLog) {
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   231
                    if (Utils.isSettingVisible(control, ec.getEventType().hasEventHook())) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   232
                        if (values.size() > 1) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   233
                            StringJoiner sj = new StringJoiner(", ", "{", "}");
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   234
                            for (String s : values) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   235
                                sj.add("\"" + s + "\"");
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   236
                            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   237
                            String message = "  " + settingName + "= " + sj.toString() + " => \"" + after + "\"";
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   238
                            Logger.log(LogTag.JFR_SETTING, LogLevel.INFO, message);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   239
                        } else {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   240
                            String message = "  " + settingName + "=\"" + control.getLastValue() + "\"";
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   241
                            Logger.log(LogTag.JFR_SETTING, LogLevel.INFO, message);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   242
                        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   243
                    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   244
                }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   245
            } else {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   246
                control.setDefault();
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 52413
diff changeset
   247
                if (shouldLog) {
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   248
                    String message = "  " + settingName + "=\"" + control.getLastValue() + "\"";
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   249
                    Logger.log(LogTag.JFR_SETTING, LogLevel.INFO, message);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   250
                }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   251
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   252
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   253
        ec.writeActiveSettingEvent();
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 52413
diff changeset
   254
        if (shouldLog) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 52413
diff changeset
   255
            Logger.log(LogTag.JFR_SETTING, LogLevel.INFO, "}");
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 52413
diff changeset
   256
        }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   257
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   258
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   259
    private InternalSetting getInternalSetting(EventControl ec) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   260
        String name = ec.getEventType().getName();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   261
        InternalSetting nameBased = availableSettings.get(name);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   262
        InternalSetting idBased = availableSettings.get(ec.getSettingsId());
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   263
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   264
        if (nameBased == null && idBased == null) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   265
            return null;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   266
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   267
        if (idBased == null) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   268
            return nameBased;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   269
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   270
        if (nameBased == null) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   271
            return idBased;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   272
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   273
        InternalSetting mixed = new InternalSetting(nameBased.getSettingsId());
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   274
        mixed.add(nameBased);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   275
        mixed.add(idBased);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   276
        return mixed;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   277
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   278
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   279
    @Override
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   280
    public String toString() {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   281
        StringBuilder sb = new StringBuilder();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   282
        for (InternalSetting enabled : availableSettings.values()) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   283
            sb.append(enabled.toString());
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   284
            sb.append("\n");
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   285
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   286
        return sb.toString();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   287
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   288
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   289
    boolean isEnabled(String eventName) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   290
        InternalSetting is = availableSettings.get(eventName);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   291
        if (is == null) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   292
            return false;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   293
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   294
        return is.isEnabled();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   295
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   296
}