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