src/jdk.jfr/share/classes/jdk/jfr/internal/consumer/ParserFactory.java
author mgronlun
Wed, 30 Oct 2019 19:43:52 +0100
changeset 58863 c16ac7a2eba4
parent 50113 src/jdk.jfr/share/classes/jdk/jfr/consumer/ParserFactory.java@caf115bb98ad
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: 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
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    26
package jdk.jfr.internal.consumer;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    27
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    28
import java.io.IOException;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    29
import java.util.ArrayList;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    30
import java.util.List;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    31
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    32
import jdk.jfr.EventType;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    33
import jdk.jfr.ValueDescriptor;
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    34
import jdk.jfr.internal.LongMap;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    35
import jdk.jfr.internal.MetadataDescriptor;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    36
import jdk.jfr.internal.PrivateAccess;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    37
import jdk.jfr.internal.Type;
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    38
import jdk.jfr.internal.consumer.Parser;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    39
import jdk.jfr.internal.consumer.RecordingInput;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    40
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    41
/**
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    42
 * Class that create parsers suitable for reading events and constant pools
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    43
 */
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    44
final class ParserFactory {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    45
    private final LongMap<Parser> parsers = new LongMap<>();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    46
    private final TimeConverter timeConverter;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    47
    private final LongMap<Type> types = new LongMap<>();
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    48
    private final LongMap<ConstantLookup> constantLookups;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    49
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    50
    public ParserFactory(MetadataDescriptor metadata, LongMap<ConstantLookup> constantLookups, TimeConverter timeConverter) throws IOException {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    51
        this.constantLookups = constantLookups;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    52
        this.timeConverter = timeConverter;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    53
        for (Type t : metadata.getTypes()) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    54
            types.put(t.getId(), t);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    55
        }
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    56
        // Add to separate list
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    57
        // so createCompositeParser can throw
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    58
        // IOException outside lambda
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    59
        List<Type> typeList = new ArrayList<>();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    60
        types.forEach(typeList::add);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    61
        for (Type t : typeList) {
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    62
            if (!t.getFields().isEmpty()) { // Avoid primitives
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    63
                CompositeParser cp = createCompositeParser(t, false);
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    64
                if (t.isSimpleType()) { // Reduce to nested parser
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    65
                    parsers.put(t.getId(), cp.parsers[0]);
50113
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
        // Override event types with event parsers
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    70
        for (EventType t : metadata.getEventTypes()) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    71
            parsers.put(t.getId(), createEventParser(t));
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    72
        }
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
    public LongMap<Parser> getParsers() {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    76
        return parsers;
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
    public LongMap<Type> getTypeMap() {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    80
        return types;
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
    private EventParser createEventParser(EventType eventType) throws IOException {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    84
        List<Parser> parsers = new ArrayList<Parser>();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    85
        for (ValueDescriptor f : eventType.getFields()) {
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    86
            parsers.add(createParser(f, true));
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    87
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    88
        return new EventParser(timeConverter, eventType, parsers.toArray(new Parser[0]));
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    89
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    90
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    91
    private Parser createParser(ValueDescriptor v, boolean event) throws IOException {
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    92
        boolean constantPool = PrivateAccess.getInstance().isConstantPool(v);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    93
        if (v.isArray()) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    94
            Type valueType = PrivateAccess.getInstance().getType(v);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    95
            ValueDescriptor element = PrivateAccess.getInstance().newValueDescriptor(v.getName(), valueType, v.getAnnotationElements(), 0, constantPool, null);
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    96
            return new ArrayParser(createParser(element, event));
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    97
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    98
        long id = v.getTypeId();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    99
        Type type = types.get(id);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   100
        if (type == null) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   101
            throw new IOException("Type '" + v.getTypeName() + "' is not defined");
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   102
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   103
        if (constantPool) {
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   104
            ConstantLookup lookup = constantLookups.get(id);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   105
            if (lookup == null) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   106
                ConstantMap pool = new ConstantMap(ObjectFactory.create(type, timeConverter), type.getName());
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   107
                lookup = new ConstantLookup(pool, type);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   108
                constantLookups.put(id, lookup);
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   109
            }
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   110
            if (event) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   111
                return new EventValueConstantParser(lookup);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   112
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   113
            return new ConstantValueParser(lookup);
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   114
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   115
        Parser parser = parsers.get(id);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   116
        if (parser == null) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   117
            if (!v.getFields().isEmpty()) {
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   118
                return createCompositeParser(type, event);
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   119
            } else {
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   120
                return registerParserType(type, createPrimitiveParser(type, constantPool));
50113
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
        return parser;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   124
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   125
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   126
    private Parser createPrimitiveParser(Type type, boolean event) throws IOException {
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   127
        switch (type.getName()) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   128
        case "int":
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   129
            return new IntegerParser();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   130
        case "long":
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   131
            return new LongParser();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   132
        case "float":
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   133
            return new FloatParser();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   134
        case "double":
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   135
            return new DoubleParser();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   136
        case "char":
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   137
            return new CharacterParser();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   138
        case "boolean":
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   139
            return new BooleanParser();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   140
        case "short":
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   141
            return new ShortParser();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   142
        case "byte":
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   143
            return new ByteParser();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   144
        case "java.lang.String":
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   145
            ConstantMap pool = new ConstantMap(ObjectFactory.create(type, timeConverter), type.getName());
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   146
            ConstantLookup lookup = new ConstantLookup(pool, type);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   147
            constantLookups.put(type.getId(), lookup);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   148
            return new StringParser(lookup, event);
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   149
        default:
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   150
            throw new IOException("Unknown primitive type " + type.getName());
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
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   154
    private Parser registerParserType(Type t, Parser parser) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   155
        Parser p = parsers.get(t.getId());
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   156
        // check if parser exists (known type)
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   157
        if (p != null) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   158
            return p;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   159
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   160
        parsers.put(t.getId(), parser);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   161
        return parser;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   162
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   163
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   164
    private CompositeParser createCompositeParser(Type type, boolean event) throws IOException {
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   165
        List<ValueDescriptor> vds = type.getFields();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   166
        Parser[] parsers = new Parser[vds.size()];
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   167
        CompositeParser composite = new CompositeParser(parsers);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   168
        // need to pre-register so recursive types can be handled
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   169
        registerParserType(type, composite);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   170
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   171
        int index = 0;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   172
        for (ValueDescriptor vd : vds) {
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   173
            parsers[index++] = createParser(vd, event);
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   174
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   175
        return composite;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   176
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   177
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   178
    private static final class BooleanParser extends Parser {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   179
        @Override
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   180
        public Object parse(RecordingInput input) throws IOException {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   181
            return input.readBoolean() ? Boolean.TRUE : Boolean.FALSE;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   182
        }
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   183
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   184
        @Override
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   185
        public void skip(RecordingInput input) throws IOException {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   186
            input.skipBytes(1);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   187
        }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   188
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   189
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   190
    private static final class ByteParser extends Parser {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   191
        @Override
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   192
        public Object parse(RecordingInput input) throws IOException {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   193
            return Byte.valueOf(input.readByte());
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   194
        }
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   195
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   196
        @Override
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   197
        public void skip(RecordingInput input) throws IOException {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   198
            input.skipBytes(1);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   199
        }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   200
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   201
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   202
    private static final class LongParser extends Parser {
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   203
        private Object lastLongObject = Long.valueOf(0);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   204
        private long last = 0;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   205
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   206
        @Override
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   207
        public Object parse(RecordingInput input) throws IOException {
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   208
            long l = input.readLong();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   209
            if (l == last) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   210
                return lastLongObject;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   211
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   212
            last = l;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   213
            lastLongObject = Long.valueOf(l);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   214
            return lastLongObject;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   215
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   216
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   217
        @Override
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   218
        public void skip(RecordingInput input) throws IOException {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   219
            input.readLong();
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   220
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   221
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   222
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   223
    private static final class IntegerParser extends Parser {
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   224
        private Integer lastIntegergObject = Integer.valueOf(0);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   225
        private int last = 0;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   226
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   227
        @Override
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   228
        public Object parse(RecordingInput input) throws IOException {
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   229
            int i = input.readInt();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   230
            if (i != last) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   231
                last = i;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   232
                lastIntegergObject = Integer.valueOf(i);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   233
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   234
            return lastIntegergObject;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   235
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   236
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   237
        @Override
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   238
        public void skip(RecordingInput input) throws IOException {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   239
            input.readInt();
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   240
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   241
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   242
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   243
    private static final class ShortParser extends Parser {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   244
        @Override
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   245
        public Object parse(RecordingInput input) throws IOException {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   246
            return Short.valueOf(input.readShort());
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   247
        }
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   248
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   249
        @Override
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   250
        public void skip(RecordingInput input) throws IOException {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   251
            input.readShort();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   252
        }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   253
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   254
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   255
    private static final class CharacterParser extends Parser {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   256
        @Override
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   257
        public Object parse(RecordingInput input) throws IOException {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   258
            return Character.valueOf(input.readChar());
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   259
        }
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   260
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   261
        @Override
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   262
        public void skip(RecordingInput input) throws IOException {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   263
            input.readChar();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   264
        }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   265
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   266
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   267
    private static final class FloatParser extends Parser {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   268
        @Override
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   269
        public Object parse(RecordingInput input) throws IOException {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   270
            return Float.valueOf(input.readFloat());
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   271
        }
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   272
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   273
        @Override
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   274
        public void skip(RecordingInput input) throws IOException {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   275
            input.skipBytes(Float.SIZE);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   276
        }
50113
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
    private static final class DoubleParser extends Parser {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   280
        @Override
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   281
        public Object parse(RecordingInput input) throws IOException {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   282
            return Double.valueOf(input.readDouble());
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   283
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   284
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   285
        @Override
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   286
        public void skip(RecordingInput input) throws IOException {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   287
            input.skipBytes(Double.SIZE);
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   288
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   289
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   290
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   291
    private final static class ArrayParser extends Parser {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   292
        private final Parser elementParser;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   293
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   294
        public ArrayParser(Parser elementParser) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   295
            this.elementParser = elementParser;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   296
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   297
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   298
        @Override
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   299
        public Object parse(RecordingInput input) throws IOException {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   300
            final int size = input.readInt();
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   301
            final Object[] array = new Object[size];
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   302
            for (int i = 0; i < size; i++) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   303
                array[i] = elementParser.parse(input);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   304
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   305
            return array;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   306
        }
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   307
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   308
        @Override
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   309
        public void skip(RecordingInput input) throws IOException {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   310
            final int size = input.readInt();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   311
            for (int i = 0; i < size; i++) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   312
                elementParser.skip(input);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   313
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   314
        }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   315
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   316
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   317
    private final static class CompositeParser extends Parser {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   318
        private final Parser[] parsers;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   319
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   320
        public CompositeParser(Parser[] valueParsers) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   321
            this.parsers = valueParsers;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   322
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   323
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   324
        @Override
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   325
        public Object parse(RecordingInput input) throws IOException {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   326
            final Object[] values = new Object[parsers.length];
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   327
            for (int i = 0; i < values.length; i++) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   328
                values[i] = parsers[i].parse(input);
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   329
            }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   330
            return values;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   331
        }
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   332
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   333
        @Override
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   334
        public void skip(RecordingInput input) throws IOException {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   335
            for (int i = 0; i < parsers.length; i++) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   336
                parsers[i].skip(input);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   337
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   338
        }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   339
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   340
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   341
    private static final class EventValueConstantParser extends Parser {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   342
        private final ConstantLookup lookup;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   343
        private Object lastValue = 0;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   344
        private long lastKey = -1;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   345
        EventValueConstantParser(ConstantLookup lookup) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   346
            this.lookup = lookup;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   347
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   348
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   349
        @Override
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   350
        public Object parse(RecordingInput input) throws IOException {
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   351
            long key = input.readLong();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   352
            if (key == lastKey) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   353
                return lastValue;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   354
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   355
            lastKey = key;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   356
            lastValue = lookup.getCurrentResolved(key);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   357
            return lastValue;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   358
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   359
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   360
        @Override
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   361
        public void skip(RecordingInput input) throws IOException {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   362
            input.readLong();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   363
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   364
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   365
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   366
    private static final class ConstantValueParser extends Parser {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   367
        private final ConstantLookup lookup;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   368
        ConstantValueParser(ConstantLookup lookup) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   369
            this.lookup = lookup;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   370
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   371
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   372
        @Override
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   373
        public Object parse(RecordingInput input) throws IOException {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   374
            return lookup.getCurrent(input.readLong());
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   375
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   376
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   377
        @Override
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   378
        public void skip(RecordingInput input) throws IOException {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   379
            input.readLong();
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   380
        }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   381
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   382
}