src/jdk.jfr/share/classes/jdk/jfr/consumer/ConstantMap.java
author egahlin
Fri, 24 May 2019 20:30:12 +0200
branchJEP-349-branch
changeset 57373 400db63e4937
parent 57360 5d043a159d5c
child 57467 de154169948b
permissions -rw-r--r--
Move LongMap to util. Update use cases
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     1
/*
57360
5d043a159d5c Preview
egahlin
parents: 50113
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.consumer;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    27
57373
400db63e4937 Move LongMap to util. Update use cases
egahlin
parents: 57360
diff changeset
    28
import jdk.jfr.internal.LongMap;
400db63e4937 Move LongMap to util. Update use cases
egahlin
parents: 57360
diff changeset
    29
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    30
/**
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    31
 * Holds mapping between a set of keys and their corresponding object.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    32
 *
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    33
 * If the type is a known type, i.e. {@link RecordedThread}, an
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    34
 * {@link ObjectFactory} can be supplied which will instantiate a typed object.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    35
 */
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    36
final class ConstantMap {
57360
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    37
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    38
    private static final int RESOLUTION_FINISHED = 0;
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    39
    private static final int RESOLUTION_STARTED = 1;
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    40
    public static final ConstantMap EMPTY = new ConstantMap();
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    41
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    42
    // A temporary placeholder, so objects can
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    43
    // reference themselves (directly, or indirectly),
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    44
    // when making a transition from numeric id references
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    45
    // to normal Java references.
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    46
    private final static class Reference {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    47
        private final long key;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    48
        private final ConstantMap pool;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    49
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    50
        Reference(ConstantMap pool, long key) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    51
            this.pool = pool;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    52
            this.key = key;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    53
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    54
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    55
        Object resolve() {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    56
            return pool.get(key);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    57
        }
57360
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    58
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    59
        public String toString() {
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    60
            return "ref: " + pool.name + "[" + key + "]";
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    61
        }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    62
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    63
57360
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    64
    final ObjectFactory<?> factory;
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    65
    final String name;
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    66
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    67
    private final LongMap<Object> objects;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    68
57360
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    69
    private boolean resolving;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    70
    private boolean allResolved;
57360
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    71
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    72
    private ConstantMap() {
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    73
        this(null, "<empty>");
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    74
        allResolved = true;
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    75
    }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    76
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    77
    ConstantMap(ObjectFactory<?> factory, String name) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    78
        this.name = name;
57360
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    79
        this.objects = new LongMap<>(2);
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    80
        this.factory = factory;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    81
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    82
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    83
    Object get(long id) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    84
        // fast path, all objects in pool resolved
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    85
        if (allResolved) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    86
            return objects.get(id);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    87
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    88
        // referenced from a pool, deal with this later
57360
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    89
        if (!resolving) {
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    90
            return new Reference(this, id);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    91
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    92
57360
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    93
        // should always have a value
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    94
        Object value = objects.get(id);
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    95
        if (value == null) {
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    96
            // unless is 0 which is used to represent null
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    97
            if (id == 0) {
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    98
                return null;
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
    99
            }
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   100
            throw new InternalError("Missing object id=" + id + " in pool " + name + ". All ids should reference object");
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   101
        }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   102
57360
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   103
        // id is resolved (but not the whole pool)
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   104
        if (objects.isSetId(id, RESOLUTION_FINISHED)) {
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   105
            return value;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   106
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   107
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   108
        // resolving ourself, abort to avoid infinite recursion
57360
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   109
        if (objects.isSetId(id, RESOLUTION_STARTED)) {
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   110
            return null;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   111
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   112
57360
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   113
        // mark id as STARTED if we should
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   114
        // come back during object resolution
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   115
        objects.setId(id, RESOLUTION_STARTED);
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   116
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   117
        // resolve object!
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   118
        Object resolved = resolve(value);
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   119
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   120
        // mark id as FINISHED
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   121
        objects.setId(id, RESOLUTION_FINISHED);
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   122
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   123
        // if a factory exists, convert to RecordedThread.
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   124
        // RecordedClass etc. and store back results
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   125
        if (factory != null) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   126
            Object factorized = factory.createObject(id, resolved);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   127
            objects.put(id, factorized);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   128
            return factorized;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   129
        } else {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   130
            objects.put(id, resolved);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   131
            return resolved;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   132
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   133
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   134
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   135
    private static Object resolve(Object o) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   136
        if (o instanceof Reference) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   137
            return resolve(((Reference) o).resolve());
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   138
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   139
        if (o != null && o.getClass().isArray()) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   140
            final Object[] array = (Object[]) o;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   141
            for (int i = 0; i < array.length; i++) {
57360
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   142
                Object element = array[i];
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   143
                array[i] = resolve(element);
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   144
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   145
            return array;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   146
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   147
        return o;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   148
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   149
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   150
    public void resolve() {
57360
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   151
        objects.forEachKey(k -> get(k));
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   152
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   153
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   154
    public void put(long key, Object value) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   155
        objects.put(key, value);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   156
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   157
57360
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   158
    public void setResolving() {
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   159
        resolving = true;
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   160
        allResolved = false;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   161
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   162
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   163
    public void setResolved() {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   164
        allResolved = true;
57360
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   165
        resolving = false;
50113
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
    public String getName() {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   169
        return name;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   170
    }
57360
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   171
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   172
    public Object getResolved(long id) {
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   173
        return objects.get(id);
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   174
    }
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   175
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   176
    public void putResolved(long id, Object object) {
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   177
        objects.setId(id, RESOLUTION_FINISHED);
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   178
        objects.put(id, object);
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   179
    }
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   180
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   181
    public void setAllResolved(boolean allResolved) {
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   182
        this.allResolved = allResolved;
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   183
    }
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   184
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   185
    public boolean isResolved(long id) {
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   186
        if (objects.hasKey(id)) {
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   187
            return objects.isSetId(id, RESOLUTION_FINISHED);
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   188
        }
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   189
        return false;
5d043a159d5c Preview
egahlin
parents: 50113
diff changeset
   190
    }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   191
}