src/jdk.jfr/share/classes/jdk/jfr/consumer/ConstantMap.java
author egahlin
Tue, 15 May 2018 20:24:34 +0200
changeset 50113 caf115bb98ad
child 57360 5d043a159d5c
permissions -rw-r--r--
8199712: Flight Recorder Reviewed-by: coleenp, ihse, erikj, dsamersoff, mseledtsov, egahlin, mgronlun Contributed-by: erik.gahlin@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
/*
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     2
 * Copyright (c) 2016, 2018, Oracle and/or its affiliates. All rights reserved.
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
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.List;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    30
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    31
/**
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    32
 * Holds mapping between a set of keys and their corresponding object.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    33
 *
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    34
 * If the type is a known type, i.e. {@link RecordedThread}, an
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    35
 * {@link ObjectFactory} can be supplied which will instantiate a typed object.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    36
 */
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    37
final class ConstantMap {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    38
    private final static class Reference {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    39
        private final long key;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    40
        private final ConstantMap pool;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    41
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    42
        Reference(ConstantMap pool, long key) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    43
            this.pool = pool;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    44
            this.key = key;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    45
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    46
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    47
        Object resolve() {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    48
            return pool.get(key);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    49
        }
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
    private final ObjectFactory<?> factory;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    53
    private final LongMap<Object> objects;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    54
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    55
    private LongMap<Boolean> isResolving;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    56
    private boolean allResolved;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    57
    private String name;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    58
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    59
    ConstantMap(ObjectFactory<?> factory, String name) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    60
        this.name = name;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    61
        this.objects = new LongMap<>();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    62
        this.factory = factory;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    63
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    64
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    65
    Object get(long id) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    66
        // fast path, all objects in pool resolved
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    67
        if (allResolved) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    68
            return objects.get(id);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    69
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    70
        // referenced from a pool, deal with this later
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    71
        if (isResolving == null) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    72
            return new Reference(this, id);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    73
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    74
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    75
        Boolean beingResolved = isResolving.get(id);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    76
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    77
        // we are resolved (but not the whole pool)
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    78
        if (Boolean.FALSE.equals(beingResolved)) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    79
            return objects.get(id);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    80
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    81
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    82
        // resolving ourself, abort to avoid infinite recursion
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    83
        if (Boolean.TRUE.equals(beingResolved)) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    84
            return null;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    85
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    86
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    87
        // resolve me!
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    88
        isResolving.put(id, Boolean.TRUE);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    89
        Object resolved = resolve(objects.get(id));
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    90
        isResolving.put(id, Boolean.FALSE);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    91
        if (factory != null) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    92
            Object factorized = factory.createObject(id, resolved);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    93
            objects.put(id, factorized);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    94
            return factorized;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    95
        } else {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    96
            objects.put(id, resolved);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    97
            return resolved;
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
    private static Object resolve(Object o) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   102
        if (o instanceof Reference) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   103
            return resolve(((Reference) o).resolve());
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   104
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   105
        if (o != null && o.getClass().isArray()) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   106
            final Object[] array = (Object[]) o;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   107
            for (int i = 0; i < array.length; i++) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   108
                array[i] = resolve(array[i]);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   109
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   110
            return array;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   111
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   112
        return o;
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 resolve() {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   116
        List<Long> keyList = new ArrayList<>();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   117
        objects.keys().forEachRemaining(keyList::add);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   118
        for (Long l : keyList) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   119
            get(l);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   120
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   121
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   122
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   123
    public void put(long key, Object value) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   124
        objects.put(key, value);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   125
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   126
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   127
    public void setIsResolving() {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   128
        isResolving = new LongMap<>();
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
    public void setResolved() {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   132
        allResolved = true;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   133
        isResolving = null; // pool finished, release memory
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   134
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   135
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   136
    public String getName() {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   137
        return name;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   138
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   139
}