--- a/src/jdk.jfr/share/classes/jdk/jfr/consumer/StringParser.java Fri Sep 13 18:46:07 2019 +0200
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,202 +0,0 @@
-/*
- * Copyright (c) 2019, Oracle and/or its affiliates. All rights reserved.
- * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
- *
- * This code is free software; you can redistribute it and/or modify it
- * under the terms of the GNU General Public License version 2 only, as
- * published by the Free Software Foundation. Oracle designates this
- * particular file as subject to the "Classpath" exception as provided
- * by Oracle in the LICENSE file that accompanied this code.
- *
- * This code is distributed in the hope that it will be useful, but WITHOUT
- * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
- * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
- * version 2 for more details (a copy is included in the LICENSE file that
- * accompanied this code).
- *
- * You should have received a copy of the GNU General Public License version
- * 2 along with this work; if not, write to the Free Software Foundation,
- * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
- *
- * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
- * or visit www.oracle.com if you need additional information or have any
- * questions.
- */
-
-package jdk.jfr.consumer;
-
-import java.io.IOException;
-import java.nio.charset.Charset;
-
-import jdk.jfr.internal.consumer.Parser;
-import jdk.jfr.internal.consumer.RecordingInput;
-import jdk.jfr.internal.consumer.StringEncoding;
-
-final class StringParser extends Parser {
- private final static Charset UTF8 = Charset.forName("UTF-8");
- private final static Charset LATIN1 = Charset.forName("ISO-8859-1");
-
- final static class CharsetParser extends Parser {
- private final Charset charset;
- private int lastSize;
- private byte[] buffer = new byte[16];
- private String lastString;
-
- CharsetParser(Charset charset) {
- this.charset = charset;
- }
-
- @Override
- public Object parse(RecordingInput input) throws IOException {
- int size = input.readInt();
- ensureSize(size);
- if (lastSize == size) {
- boolean equalsLastString = true;
- for (int i = 0; i < size; i++) {
- // TODO: No need to read byte per byte
- byte b = input.readByte();
- if (buffer[i] != b) {
- equalsLastString = false;
- buffer[i] = b;
- }
- }
- if (equalsLastString) {
- return lastString;
- }
- } else {
- for (int i = 0; i < size; i++) {
- buffer[i] = input.readByte();
- }
- }
- lastString = new String(buffer, 0, size, charset);
- lastSize = size;
- return lastString;
- }
-
- @Override
- public void skip(RecordingInput input) throws IOException {
- int size = input.readInt();
- input.skipBytes(size);
- }
-
- private void ensureSize(int size) {
- if (buffer.length < size) {
- buffer = new byte[size];
- }
- }
- }
-
- final static class CharArrayParser extends Parser {
- private char[] buffer = new char[16];
- private int lastSize = -1;
- private String lastString = null;
-
- @Override
- public Object parse(RecordingInput input) throws IOException {
- int size = input.readInt();
- ensureSize(size);
- if (lastSize == size) {
- boolean equalsLastString = true;
- for (int i = 0; i < size; i++) {
- char c = input.readChar();
- if (buffer[i] != c) {
- equalsLastString = false;
- buffer[i] = c;
- }
- }
- if (equalsLastString) {
- return lastString;
- }
- } else {
- for (int i = 0; i < size; i++) {
- buffer[i] = input.readChar();
- }
- }
- lastString = new String(buffer, 0, size);
- lastSize = size;
- return lastString;
- }
-
- @Override
- public void skip(RecordingInput input) throws IOException {
- int size = input.readInt();
- for (int i = 0; i < size; i++) {
- input.readChar();
- }
- }
-
- private void ensureSize(int size) {
- if (buffer.length < size) {
- buffer = new char[size];
- }
- }
- }
-
- private final ConstantLookup stringLookup;
- private final CharArrayParser charArrayParser = new CharArrayParser();
- private final CharsetParser utf8parser = new CharsetParser(UTF8);
- private final CharsetParser latin1parser = new CharsetParser(LATIN1);
- private final boolean event;
-
- public StringParser(ConstantLookup stringLookup, boolean event) {
- this.stringLookup = stringLookup;
- this.event = event;
- }
-
- @Override
- public Object parse(RecordingInput input) throws IOException {
- byte encoding = input.readByte();
- if (encoding == StringEncoding.STRING_ENCODING_CONSTANT_POOL) {
- long key = input.readLong();
- if (event) {
- return stringLookup.getCurrentResolved(key);
- } else {
- return stringLookup.getCurrent(key);
- }
- }
- if (encoding == StringEncoding.STRING_ENCODING_NULL) {
- return null;
- }
- if (encoding == StringEncoding.STRING_ENCODING_EMPTY_STRING) {
- return "";
- }
- if (encoding == StringEncoding.STRING_ENCODING_CHAR_ARRAY) {
- return charArrayParser.parse(input);
- }
- if (encoding == StringEncoding.STRING_ENCODING_UTF8_BYTE_ARRAY) {
- return utf8parser.parse(input);
- }
- if (encoding == StringEncoding.STRING_ENCODING_LATIN1_BYTE_ARRAY) {
- return latin1parser.parse(input);
- }
- throw new IOException("Unknown string encoding " + encoding);
- }
-
- @Override
- public void skip(RecordingInput input) throws IOException {
- byte encoding = input.readByte();
- if (encoding == StringEncoding.STRING_ENCODING_CONSTANT_POOL) {
- input.readLong();
- return;
- }
- if (encoding == StringEncoding.STRING_ENCODING_EMPTY_STRING) {
- return;
- }
- if (encoding == StringEncoding.STRING_ENCODING_NULL) {
- return;
- }
- if (encoding == StringEncoding.STRING_ENCODING_CHAR_ARRAY) {
- charArrayParser.skip(input);
- return;
- }
- if (encoding == StringEncoding.STRING_ENCODING_UTF8_BYTE_ARRAY) {
- utf8parser.skip(input);
- return;
- }
- if (encoding == StringEncoding.STRING_ENCODING_LATIN1_BYTE_ARRAY) {
- latin1parser.skip(input);
- return;
- }
- throw new IOException("Unknown string encoding " + encoding);
- }
-}
\ No newline at end of file