Protocol Buffers - Google's data interchange format (grpc依赖) https://developers.google.com/protocol-buffers/
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 
 
 
 

1021 lines
34 KiB

/*
* Copyright (c) 2009-2022, Google LLC
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
* * Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* * Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* * Neither the name of Google LLC nor the
* names of its contributors may be used to endorse or promote products
* derived from this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
* ARE DISCLAIMED. IN NO EVENT SHALL Google LLC BE LIABLE FOR ANY DIRECT,
* INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/
#include "upb/io/tokenizer.h"
#include <stdio.h>
#include "upb/internal/unicode.h"
#include "upb/io/string.h"
#include "upb/io/strtod.h"
// Must be included last.
#include "upb/port_def.inc"
typedef enum {
// Started a line comment.
kUpb_CommentType_Line,
// Started a block comment.
kUpb_CommentType_Block,
// Consumed a slash, then realized it wasn't a comment. current_ has
// been filled in with a slash token. The caller should return it.
kUpb_CommentType_SlashNot,
// We do not appear to be starting a comment here.
kUpb_CommentType_None,
} upb_CommentType;
static bool upb_Tokenizer_IsUnprintable(char c) { return '\0' < c && c < ' '; }
// Since we count columns we need to interpret tabs somehow. We'll take
// the standard 8-character definition for lack of any way to do better.
static const int kUpb_Tokenizer_TabWidth = 8;
// Given a char, interpret it as a numeric digit and return its value.
// This supports any number base up to 36.
// Represents integer values of digits.
// Uses 36 to indicate an invalid character since we support
// bases up to 36.
static const int8_t kUpb_Tokenizer_AsciiToInt[256] = {
36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, // 00-0F
36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, // 10-1F
36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, // ' '-'/'
0, 1, 2, 3, 4, 5, 6, 7, 8, 9, // '0'-'9'
36, 36, 36, 36, 36, 36, 36, // ':'-'@'
10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, // 'A'-'P'
26, 27, 28, 29, 30, 31, 32, 33, 34, 35, // 'Q'-'Z'
36, 36, 36, 36, 36, 36, // '['-'`'
10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, // 'a'-'p'
26, 27, 28, 29, 30, 31, 32, 33, 34, 35, // 'q'-'z'
36, 36, 36, 36, 36, // '{'-DEL
36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, // 80-8F
36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, // 90-9F
36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, // A0-AF
36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, // B0-BF
36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, // C0-CF
36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, // D0-DF
36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, // E0-EF
36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, 36, // F0-FF
};
static int DigitValue(char digit) {
return kUpb_Tokenizer_AsciiToInt[digit & 0xFF];
}
static bool upb_Tokenizer_IsLetter(char c) {
return ('a' <= c && c <= 'z') || ('A' <= c && c <= 'Z') || (c == '_');
}
static bool upb_Tokenizer_IsDigit(char c) { return '0' <= c && c <= '9'; }
static bool upb_Tokenizer_IsOctalDigit(char c) { return '0' <= c && c <= '7'; }
static bool upb_Tokenizer_IsHexDigit(char c) {
return ('0' <= c && c <= '9') || ('a' <= c && c <= 'f') ||
('A' <= c && c <= 'F');
}
static bool upb_Tokenizer_IsAlphanumeric(char c) {
return upb_Tokenizer_IsLetter(c) || upb_Tokenizer_IsDigit(c);
}
static bool upb_Tokenizer_IsWhitespaceNoNewline(char c) {
return c == ' ' || c == '\t' || c == '\r' || c == '\v' || c == '\f';
}
static bool upb_Tokenizer_IsWhitespace(char c) {
return c == '\n' || upb_Tokenizer_IsWhitespaceNoNewline(c);
}
static bool upb_Tokenizer_IsEscape(char c) {
return c == 'a' || c == 'b' || c == 'f' || c == 'n' || c == 'r' || c == 't' ||
c == 'v' || c == '\\' || c == '?' || c == '\'' || c == '\"';
}
static char TranslateEscape(char c) {
switch (c) {
case 'a':
return '\a';
case 'b':
return '\b';
case 'f':
return '\f';
case 'n':
return '\n';
case 'r':
return '\r';
case 't':
return '\t';
case 'v':
return '\v';
case '\\':
return '\\';
case '?':
return '\?'; // Trigraphs = :(
case '\'':
return '\'';
case '"':
return '\"';
// We expect escape sequences to have been validated separately.
default:
return '?';
}
}
// ===================================================================
struct upb_Tokenizer {
upb_TokenType token_type; // The type of the current token.
// The exact text of the current token as it appeared in the input.
// e.g. tokens of TYPE_STRING will still be escaped and in quotes.
upb_String token_text;
// "line" and "column" specify the position of the first character of
// the token within the input stream. They are zero-based.
int token_line;
int token_column;
int token_end_column;
upb_ZeroCopyInputStream* input;
upb_Arena* arena;
upb_Status* status;
char current_char; // == buffer_[buffer_pos_], updated by NextChar().
const char* buffer; // Current buffer returned from input_.
size_t buffer_size; // Size of buffer_.
size_t buffer_pos; // Current position within the buffer.
bool read_error; // Did we previously encounter a read error?
// Line and column number of current_char_ within the whole input stream.
int line;
// By "column number", the proto compiler refers to a count of the number
// of bytes before a given byte, except that a tab character advances to
// the next multiple of 8 bytes. Note in particular that column numbers
// are zero-based, while many user interfaces use one-based column numbers.
int column;
// Cached values from before the most recent call to Next()
upb_TokenType previous_type;
int previous_line;
int previous_column;
int previous_end_column;
// String to which text should be appended as we advance through it.
// Call RecordTo(&str) to start recording and StopRecording() to stop.
// E.g. StartToken() calls RecordTo(&current_.text). record_start_ is the
// position within the current buffer where recording started.
upb_String* record_target;
int record_start;
int options;
jmp_buf err;
};
// Convenience methods to return an error at the current line and column.
UPB_NORETURN static void ReportError(upb_Tokenizer* t, const char* msg) {
upb_Status_SetErrorFormat(t->status, "%d:%d: %s", t->line, t->column, msg);
UPB_LONGJMP(t->err, 1);
}
UPB_NORETURN UPB_PRINTF(2, 3) static void ReportErrorFormat(upb_Tokenizer* t,
const char* fmt,
...) {
va_list args;
va_start(args, fmt);
char msg[128];
vsnprintf(msg, sizeof(msg), fmt, args);
ReportError(t, msg);
}
// Read a new buffer from the input.
static void Refresh(upb_Tokenizer* t) {
if (t->read_error) {
t->current_char = '\0';
return;
}
// If we're in a token, append the rest of the buffer to it.
if (t->record_target != NULL && t->record_start < t->buffer_size) {
upb_String_Append(t->record_target, t->buffer + t->record_start,
t->buffer_size - t->record_start);
t->record_start = 0;
}
t->buffer = NULL;
t->buffer_pos = 0;
upb_Status status;
const void* data =
upb_ZeroCopyInputStream_Next(t->input, &t->buffer_size, &status);
if (t->buffer_size > 0) {
t->buffer = data;
t->current_char = t->buffer[0];
} else {
// end of stream (or read error)
t->buffer_size = 0;
t->read_error = true;
t->current_char = '\0';
}
}
// Consume this character and advance to the next one.
static void NextChar(upb_Tokenizer* t) {
// Update our line and column counters based on the character being
// consumed.
if (t->current_char == '\n') {
t->line++;
t->column = 0;
} else if (t->current_char == '\t') {
t->column += kUpb_Tokenizer_TabWidth - t->column % kUpb_Tokenizer_TabWidth;
} else {
t->column++;
}
// Advance to the next character.
t->buffer_pos++;
if (t->buffer_pos < t->buffer_size) {
t->current_char = t->buffer[t->buffer_pos];
} else {
Refresh(t);
}
}
static void RecordTo(upb_Tokenizer* t, upb_String* target) {
t->record_target = target;
t->record_start = t->buffer_pos;
}
static void StopRecording(upb_Tokenizer* t) {
if (t->buffer_pos > t->record_start) {
upb_String_Append(t->record_target, t->buffer + t->record_start,
t->buffer_pos - t->record_start);
}
t->record_target = NULL;
t->record_start = -1;
}
// Called when the current character is the first character of a new
// token (not including whitespace or comments).
static void StartToken(upb_Tokenizer* t) {
t->token_type = kUpb_TokenType_Start;
upb_String_Clear(&t->token_text);
t->token_line = t->line;
t->token_column = t->column;
RecordTo(t, &t->token_text);
}
// Called when the current character is the first character after the
// end of the last token. After this returns, current_.text will
// contain all text consumed since StartToken() was called.
static void EndToken(upb_Tokenizer* t) {
StopRecording(t);
t->token_end_column = t->column;
}
// -----------------------------------------------------------------
// These helper methods make the parsing code more readable.
// The "character classes" referred to are defined at the top of the file.
// The method returns true if c is a member of this "class", like "Letter"
// or "Digit".
// Returns true if the current character is of the given character
// class, but does not consume anything.
static bool LookingAt(const upb_Tokenizer* t, bool (*f)(char)) {
return f(t->current_char);
}
// If the current character is in the given class, consume it and return true.
// Otherwise return false.
static bool TryConsumeOne(upb_Tokenizer* t, bool (*f)(char)) {
if (f(t->current_char)) {
NextChar(t);
return true;
} else {
return false;
}
}
// Like above, but try to consume the specific character indicated.
static bool TryConsume(upb_Tokenizer* t, char c) {
if (t->current_char == c) {
NextChar(t);
return true;
} else {
return false;
}
}
// Consume zero or more of the given character class.
static void ConsumeZeroOrMore(upb_Tokenizer* t, bool (*f)(char)) {
while (f(t->current_char)) {
NextChar(t);
}
}
// Consume one or more of the given character class or log the given
// error message.
static void ConsumeOneOrMore(upb_Tokenizer* t, bool (*f)(char),
const char* err_msg) {
if (!f(t->current_char)) {
ReportError(t, err_msg);
}
do {
NextChar(t);
} while (f(t->current_char));
}
// -----------------------------------------------------------------
// The following four methods are used to consume tokens of specific
// types. They are actually used to consume all characters *after*
// the first, since the calling function consumes the first character
// in order to decide what kind of token is being read.
// Read and consume a string, ending when the given delimiter is consumed.
static void ConsumeString(upb_Tokenizer* t, char delimiter) {
while (true) {
switch (t->current_char) {
case '\0':
ReportError(t, "Unexpected end of string.");
case '\n':
ReportError(t, "String literals cannot cross line boundaries.");
case '\\': {
// An escape sequence.
NextChar(t);
if (TryConsumeOne(t, upb_Tokenizer_IsEscape)) {
// Valid escape sequence.
} else if (TryConsumeOne(t, upb_Tokenizer_IsOctalDigit)) {
// Possibly followed by two more octal digits, but these will
// just be consumed by the main loop anyway so we don't need
// to do so explicitly here.
} else if (TryConsume(t, 'x')) {
if (!TryConsumeOne(t, upb_Tokenizer_IsHexDigit)) {
ReportError(t, "Expected hex digits for escape sequence.");
}
// Possibly followed by another hex digit, but again we don't care.
} else if (TryConsume(t, 'u')) {
if (!TryConsumeOne(t, upb_Tokenizer_IsHexDigit) ||
!TryConsumeOne(t, upb_Tokenizer_IsHexDigit) ||
!TryConsumeOne(t, upb_Tokenizer_IsHexDigit) ||
!TryConsumeOne(t, upb_Tokenizer_IsHexDigit)) {
ReportError(t, "Expected four hex digits for \\u escape sequence.");
}
} else if (TryConsume(t, 'U')) {
// We expect 8 hex digits; but only the range up to 0x10ffff is
// legal.
if (!TryConsume(t, '0') || !TryConsume(t, '0') ||
!(TryConsume(t, '0') || TryConsume(t, '1')) ||
!TryConsumeOne(t, upb_Tokenizer_IsHexDigit) ||
!TryConsumeOne(t, upb_Tokenizer_IsHexDigit) ||
!TryConsumeOne(t, upb_Tokenizer_IsHexDigit) ||
!TryConsumeOne(t, upb_Tokenizer_IsHexDigit) ||
!TryConsumeOne(t, upb_Tokenizer_IsHexDigit)) {
ReportError(t,
"Expected eight hex digits up to 10ffff for \\U escape "
"sequence");
}
} else {
ReportError(t, "Invalid escape sequence in string literal.");
}
break;
}
default: {
if (t->current_char == delimiter) {
NextChar(t);
return;
}
NextChar(t);
break;
}
}
}
}
// Read and consume a number, returning TYPE_FLOAT or TYPE_INTEGER depending
// on what was read. This needs to know if the first characer was a zero in
// order to correctly recognize hex and octal numbers. It also needs to know
// whether the first character was a '.' to parse floating point correctly.
static upb_TokenType ConsumeNumber(upb_Tokenizer* t, bool started_with_zero,
bool started_with_dot) {
bool is_float = false;
if (started_with_zero && (TryConsume(t, 'x') || TryConsume(t, 'X'))) {
// A hex number (started with "0x").
ConsumeOneOrMore(t, upb_Tokenizer_IsHexDigit,
"\"0x\" must be followed by hex digits.");
} else if (started_with_zero && LookingAt(t, upb_Tokenizer_IsDigit)) {
// An octal number (had a leading zero).
ConsumeZeroOrMore(t, upb_Tokenizer_IsOctalDigit);
if (LookingAt(t, upb_Tokenizer_IsDigit)) {
ReportError(t, "Numbers starting with leading zero must be in octal.");
}
} else {
// A decimal number.
if (started_with_dot) {
is_float = true;
ConsumeZeroOrMore(t, upb_Tokenizer_IsDigit);
} else {
ConsumeZeroOrMore(t, upb_Tokenizer_IsDigit);
if (TryConsume(t, '.')) {
is_float = true;
ConsumeZeroOrMore(t, upb_Tokenizer_IsDigit);
}
}
if (TryConsume(t, 'e') || TryConsume(t, 'E')) {
is_float = true;
if (!TryConsume(t, '-')) TryConsume(t, '+');
ConsumeOneOrMore(t, upb_Tokenizer_IsDigit,
"\"e\" must be followed by exponent.");
}
if (t->options & kUpb_TokenizerOption_AllowFAfterFloat) {
if (TryConsume(t, 'f') || TryConsume(t, 'F')) is_float = true;
}
}
if (LookingAt(t, upb_Tokenizer_IsLetter)) {
ReportError(t, "Need space between number and identifier.");
}
if (t->current_char == '.') {
if (is_float) {
ReportError(
t, "Already saw decimal point or exponent; can't have another one.");
} else {
ReportError(t, "Hex and octal numbers must be integers.");
}
}
return is_float ? kUpb_TokenType_Float : kUpb_TokenType_Integer;
}
// Consume the rest of a line.
static void ConsumeLineComment(upb_Tokenizer* t, upb_String* content) {
if (content != NULL) RecordTo(t, content);
while (t->current_char != '\0' && t->current_char != '\n') {
NextChar(t);
}
TryConsume(t, '\n');
if (content != NULL) StopRecording(t);
}
static void ConsumeBlockComment(upb_Tokenizer* t, upb_String* content) {
const int start_line = t->line;
const int start_column = t->column - 2;
if (content != NULL) RecordTo(t, content);
while (true) {
while (t->current_char != '\0' && t->current_char != '*' &&
t->current_char != '/' && t->current_char != '\n') {
NextChar(t);
}
if (TryConsume(t, '\n')) {
if (content != NULL) StopRecording(t);
// Consume leading whitespace and asterisk;
ConsumeZeroOrMore(t, upb_Tokenizer_IsWhitespaceNoNewline);
if (TryConsume(t, '*')) {
if (TryConsume(t, '/')) {
// End of comment.
break;
}
}
if (content != NULL) RecordTo(t, content);
} else if (TryConsume(t, '*') && TryConsume(t, '/')) {
// End of comment.
if (content != NULL) {
StopRecording(t);
// Strip trailing "*/".
upb_String_Erase(content, upb_String_Size(content) - 2, 2);
}
break;
} else if (TryConsume(t, '/') && t->current_char == '*') {
// Note: We didn't consume the '*' because if there is a '/' after it
// we want to interpret that as the end of the comment.
ReportError(
t, "\"/*\" inside block comment. Block comments cannot be nested.");
} else if (t->current_char == '\0') {
ReportErrorFormat(
t, "End-of-file inside block comment.\n%d:%d: Comment started here.",
start_line, start_column);
}
}
}
// If we're at the start of a new comment, consume it and return what kind
// of comment it is.
static upb_CommentType TryConsumeCommentStart(upb_Tokenizer* t) {
const bool style_sh = t->options & kUpb_TokenizerOption_CommentStyleShell;
const bool style_cpp = !style_sh;
if (style_cpp && TryConsume(t, '/')) {
if (TryConsume(t, '/')) {
return kUpb_CommentType_Line;
} else if (TryConsume(t, '*')) {
return kUpb_CommentType_Block;
} else {
// Oops, it was just a slash. Return it.
t->token_type = kUpb_TokenType_Symbol;
upb_String_Assign(&t->token_text, "/", 1);
t->token_line = t->line;
t->token_column = t->column - 1;
t->token_end_column = t->column;
return kUpb_CommentType_SlashNot;
}
} else if (style_sh && TryConsume(t, '#')) {
return kUpb_CommentType_Line;
} else {
return kUpb_CommentType_None;
}
}
// If we're looking at a TYPE_WHITESPACE token and `report_whitespace` is true,
// consume it and return true.
static bool TryConsumeWhitespace(upb_Tokenizer* t) {
if (t->options & kUpb_TokenizerOption_ReportNewlines) {
if (TryConsumeOne(t, upb_Tokenizer_IsWhitespaceNoNewline)) {
ConsumeZeroOrMore(t, upb_Tokenizer_IsWhitespaceNoNewline);
t->token_type = kUpb_TokenType_Whitespace;
return true;
}
return false;
}
if (TryConsumeOne(t, upb_Tokenizer_IsWhitespace)) {
ConsumeZeroOrMore(t, upb_Tokenizer_IsWhitespace);
t->token_type = kUpb_TokenType_Whitespace;
return (t->options & kUpb_TokenizerOption_ReportWhitespace) != 0;
}
return false;
}
// If we're looking at a TYPE_NEWLINE token and `report_newlines` is true,
// consume it and return true.
static bool TryConsumeNewline(upb_Tokenizer* t) {
if (t->options & kUpb_TokenizerOption_ReportNewlines) {
if (TryConsume(t, '\n')) {
t->token_type = kUpb_TokenType_Newline;
return true;
}
}
return false;
}
// -------------------------------------------------------------------
int upb_Tokenizer_Column(const upb_Tokenizer* t) { return t->token_column; }
int upb_Tokenizer_EndColumn(const upb_Tokenizer* t) {
return t->token_end_column;
}
int upb_Tokenizer_Line(const upb_Tokenizer* t) { return t->token_line; }
int upb_Tokenizer_TextSize(const upb_Tokenizer* t) {
return t->token_text.size_;
}
const char* upb_Tokenizer_TextData(const upb_Tokenizer* t) {
return t->token_text.data_;
}
upb_TokenType upb_Tokenizer_Type(const upb_Tokenizer* t) {
return t->token_type;
}
bool upb_Tokenizer_Next(upb_Tokenizer* t, upb_Status* status) {
t->status = status;
t->previous_type = t->token_type;
t->previous_line = t->token_line;
t->previous_column = t->token_column;
t->previous_end_column = t->token_end_column;
if (UPB_SETJMP(t->err)) return false;
while (!t->read_error) {
StartToken(t);
bool report_token = TryConsumeWhitespace(t) || TryConsumeNewline(t);
EndToken(t);
if (report_token) return true;
switch (TryConsumeCommentStart(t)) {
case kUpb_CommentType_Line:
ConsumeLineComment(t, NULL);
continue;
case kUpb_CommentType_Block:
ConsumeBlockComment(t, NULL);
continue;
case kUpb_CommentType_SlashNot:
return true;
case kUpb_CommentType_None:
break;
}
// Check for EOF before continuing.
if (t->read_error) break;
if (LookingAt(t, upb_Tokenizer_IsUnprintable) || t->current_char == '\0') {
ReportError(t, "Invalid control characters encountered in text.");
}
// Reading some sort of token.
StartToken(t);
if (TryConsumeOne(t, upb_Tokenizer_IsLetter)) {
ConsumeZeroOrMore(t, upb_Tokenizer_IsAlphanumeric);
t->token_type = kUpb_TokenType_Identifier;
} else if (TryConsume(t, '0')) {
t->token_type = ConsumeNumber(t, true, false);
} else if (TryConsume(t, '.')) {
// This could be the beginning of a floating-point number, or it could
// just be a '.' symbol.
if (TryConsumeOne(t, upb_Tokenizer_IsDigit)) {
// It's a floating-point number.
if (t->previous_type == kUpb_TokenType_Identifier &&
t->token_line == t->previous_line &&
t->token_column == t->previous_end_column) {
// We don't accept syntax like "blah.123".
t->column -= 2;
ReportError(t, "Need space between identifier and decimal point.");
}
t->token_type = ConsumeNumber(t, false, true);
} else {
t->token_type = kUpb_TokenType_Symbol;
}
} else if (TryConsumeOne(t, upb_Tokenizer_IsDigit)) {
t->token_type = ConsumeNumber(t, false, false);
} else if (TryConsume(t, '\"')) {
ConsumeString(t, '\"');
t->token_type = kUpb_TokenType_String;
} else if (TryConsume(t, '\'')) {
ConsumeString(t, '\'');
t->token_type = kUpb_TokenType_String;
} else {
// Check if the high order bit is set.
if (t->current_char & 0x80) {
ReportErrorFormat(t, "Interpreting non ascii codepoint %d.",
(uint8_t)t->current_char);
}
NextChar(t);
t->token_type = kUpb_TokenType_Symbol;
}
EndToken(t);
return true;
}
// EOF
t->token_type = kUpb_TokenType_End;
upb_String_Clear(&t->token_text);
t->token_line = t->line;
t->token_column = t->column;
t->token_end_column = t->column;
upb_Status_Clear(status);
return false;
}
// -------------------------------------------------------------------
// Token-parsing helpers. Remember that these don't need to report
// errors since any errors should already have been reported while
// tokenizing. Also, these can assume that whatever text they
// are given is text that the tokenizer actually parsed as a token
// of the given type.
bool upb_Parse_Integer(const char* text, uint64_t max_value, uint64_t* output) {
// We can't just use strtoull() because (a) it accepts negative numbers,
// (b) We want additional range checks, (c) it reports overflows via errno.
const char* ptr = text;
int base = 10;
uint64_t overflow_if_mul_base = (UINT64_MAX / 10) + 1;
if (ptr[0] == '0') {
if (ptr[1] == 'x' || ptr[1] == 'X') {
// This is hex.
base = 16;
overflow_if_mul_base = (UINT64_MAX / 16) + 1;
ptr += 2;
} else {
// This is octal.
base = 8;
overflow_if_mul_base = (UINT64_MAX / 8) + 1;
}
}
uint64_t result = 0;
// For all the leading '0's, and also the first non-zero character, we
// don't need to multiply.
while (*ptr != '\0') {
int digit = DigitValue(*ptr++);
if (digit >= base) {
// The token provided by Tokenizer is invalid. i.e., 099 is an invalid
// token, but Tokenizer still think it's integer.
return false;
}
if (digit != 0) {
result = digit;
break;
}
}
for (; *ptr != '\0'; ptr++) {
int digit = DigitValue(*ptr);
if (digit < 0 || digit >= base) {
// The token provided by Tokenizer is invalid. i.e., 099 is an invalid
// token, but Tokenizer still think it's integer.
return false;
}
if (result >= overflow_if_mul_base) {
// We know the multiply we're about to do will overflow, so exit now.
return false;
}
// We know that result * base won't overflow, but adding digit might...
result = result * base + digit;
// C++ guarantees defined "wrap" semantics when unsigned integer
// operations overflow, making this a fast way to check if adding
// digit made result overflow, and thus, wrap around.
if (result < (uint64_t)base) return false;
}
if (result > max_value) return false;
*output = result;
return true;
}
double upb_Parse_Float(const char* text) {
char* end;
double result = NoLocaleStrtod(text, &end);
// "1e" is not a valid float, but if the tokenizer reads it, it will
// report an error but still return it as a valid token. We need to
// accept anything the tokenizer could possibly return, error or not.
if (*end == 'e' || *end == 'E') {
++end;
if (*end == '-' || *end == '+') ++end;
}
// If the Tokenizer had allow_f_after_float_ enabled, the float may be
// suffixed with the letter 'f'.
if (*end == 'f' || *end == 'F') {
++end;
}
if ((end - text) != strlen(text) || *text == '-') {
fprintf(stderr,
"upb_Parse_Float() passed text that could not have"
" been tokenized as a float: %s\n",
text);
UPB_ASSERT(0);
}
return result;
}
// Append a Unicode code point to a string as UTF8.
static void AppendUTF8(uint32_t code_point, upb_String* output) {
char temp[24];
int len = upb_Unicode_ToUTF8(code_point, temp);
if (len == 0) {
// ConsumeString permits hex values up to 0x1FFFFF,
// and FetchUnicodePoint doesn't perform a range check.
// Unicode code points end at 0x10FFFF, so this is out-of-range.
len = snprintf(temp, sizeof temp, "\\U%08x", code_point);
}
upb_String_Append(output, temp, len);
}
// Try to read <len> hex digits from ptr, and stuff the numeric result into
// *result. Returns true if that many digits were successfully consumed.
static bool ReadHexDigits(const char* ptr, int len, uint32_t* result) {
*result = 0;
if (len == 0) return false;
for (const char* end = ptr + len; ptr < end; ++ptr) {
if (*ptr == '\0') return false;
*result = (*result << 4) + DigitValue(*ptr);
}
return true;
}
// Convert the escape sequence parameter to a number of expected hex digits.
static int UnicodeLength(char key) {
if (key == 'u') return 4;
if (key == 'U') return 8;
return 0;
}
// Given a pointer to the 'u' or 'U' starting a Unicode escape sequence, attempt
// to parse that sequence. On success, returns a pointer to the first char
// beyond that sequence, and fills in *code_point. On failure, returns ptr
// itself.
static const char* FetchUnicodePoint(const char* ptr, uint32_t* code_point) {
const char* p = ptr;
// Fetch the code point.
const int len = UnicodeLength(*p++);
if (!ReadHexDigits(p, len, code_point)) return ptr;
p += len;
// Check if the code point we read is a "head surrogate." If so, then we
// expect it to be immediately followed by another code point which is a valid
// "trail surrogate," and together they form a UTF-16 pair which decodes into
// a single Unicode point. Trail surrogates may only use \u, not \U.
if (upb_Unicode_IsHigh(*code_point) && *p == '\\' && *(p + 1) == 'u') {
uint32_t trail_surrogate;
if (ReadHexDigits(p + 2, 4, &trail_surrogate) &&
upb_Unicode_IsLow(trail_surrogate)) {
*code_point = upb_Unicode_FromPair(*code_point, trail_surrogate);
p += 6;
}
// If this failed, then we just emit the head surrogate as a code point.
// It's bogus, but so is the string.
}
return p;
}
// The text string must begin and end with single or double quote characters.
upb_StringView upb_Parse_String(const char* text, upb_Arena* arena) {
const size_t size = strlen(text);
upb_String output;
upb_String_Init(&output, arena);
// Reminder: text[0] is always a quote character.
// (If text is empty, it's invalid, so we'll just return).
if (size == 0) {
fprintf(stderr,
"Tokenizer::ParseStringAppend() passed text that could not"
" have been tokenized as a string: %s",
text);
UPB_ASSERT(0);
}
// Reserve room for new string.
const size_t new_len = size + upb_String_Size(&output);
upb_String_Reserve(&output, new_len);
// Loop through the string copying characters to "output" and
// interpreting escape sequences. Note that any invalid escape
// sequences or other errors were already reported while tokenizing.
// In this case we do not need to produce valid results.
for (const char* ptr = text + 1; *ptr != '\0'; ptr++) {
if (*ptr == '\\' && ptr[1] != '\0') {
// An escape sequence.
++ptr;
if (upb_Tokenizer_IsOctalDigit(*ptr)) {
// An octal escape. May one, two, or three digits.
int code = DigitValue(*ptr);
if (upb_Tokenizer_IsOctalDigit(ptr[1])) {
++ptr;
code = code * 8 + DigitValue(*ptr);
}
if (upb_Tokenizer_IsOctalDigit(ptr[1])) {
++ptr;
code = code * 8 + DigitValue(*ptr);
}
upb_String_PushBack(&output, (char)code);
} else if (*ptr == 'x') {
// A hex escape. May zero, one, or two digits. (The zero case
// will have been caught as an error earlier.)
int code = 0;
if (upb_Tokenizer_IsHexDigit(ptr[1])) {
++ptr;
code = DigitValue(*ptr);
}
if (upb_Tokenizer_IsHexDigit(ptr[1])) {
++ptr;
code = code * 16 + DigitValue(*ptr);
}
upb_String_PushBack(&output, (char)code);
} else if (*ptr == 'u' || *ptr == 'U') {
uint32_t unicode;
const char* end = FetchUnicodePoint(ptr, &unicode);
if (end == ptr) {
// Failure: Just dump out what we saw, don't try to parse it.
upb_String_PushBack(&output, *ptr);
} else {
AppendUTF8(unicode, &output);
ptr = end - 1; // Because we're about to ++ptr.
}
} else {
// Some other escape code.
upb_String_PushBack(&output, TranslateEscape(*ptr));
}
} else if (*ptr == text[0] && ptr[1] == '\0') {
// Ignore final quote matching the starting quote.
} else {
upb_String_PushBack(&output, *ptr);
}
}
return upb_StringView_FromDataAndSize(upb_String_Data(&output),
upb_String_Size(&output));
}
static bool AllInClass(bool (*f)(char), const char* text, int size) {
for (int i = 0; i < size; i++) {
if (!f(text[i])) return false;
}
return true;
}
bool upb_Tokenizer_IsIdentifier(const char* data, int size) {
// Mirrors IDENTIFIER definition in Tokenizer::Next() above.
if (size == 0) return false;
if (!upb_Tokenizer_IsLetter(data[0])) return false;
if (!AllInClass(upb_Tokenizer_IsAlphanumeric, data + 1, size - 1))
return false;
return true;
}
upb_Tokenizer* upb_Tokenizer_New(const void* data, size_t size,
upb_ZeroCopyInputStream* input, int options,
upb_Arena* arena) {
upb_Tokenizer* t = upb_Arena_Malloc(arena, sizeof(upb_Tokenizer));
if (!t) return NULL;
t->input = input;
t->arena = arena;
t->buffer = data;
t->buffer_size = size;
t->buffer_pos = 0;
t->read_error = false;
t->line = 0;
t->column = 0;
t->record_target = NULL;
t->record_start = -1;
// ReportNewlines implies ReportWhitespace.
if (options & kUpb_TokenizerOption_ReportNewlines) {
options |= kUpb_TokenizerOption_ReportWhitespace;
}
t->options = options;
upb_String_Init(&t->token_text, arena);
t->token_type = kUpb_TokenType_Start;
t->token_line = 0;
t->token_column = 0;
t->token_end_column = 0;
t->previous_type = kUpb_TokenType_Start;
t->previous_line = 0;
t->previous_column = 0;
t->previous_end_column = 0;
if (size) {
t->current_char = t->buffer[0];
} else {
Refresh(t);
}
return t;
}
void upb_Tokenizer_Fini(upb_Tokenizer* t) {
// If we had any buffer left unread, return it to the underlying stream
// so that someone else can read it.
if (t->buffer_size > t->buffer_pos) {
upb_ZeroCopyInputStream_BackUp(t->input, t->buffer_size - t->buffer_pos);
}
}