324 lines
12 KiB
C#
324 lines
12 KiB
C#
#region Copyright notice and license
|
|
// Protocol Buffers - Google's data interchange format
|
|
// Copyright 2008 Google Inc. All rights reserved.
|
|
//
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file or at
|
|
// https://developers.google.com/open-source/licenses/bsd
|
|
#endregion
|
|
|
|
using System;
|
|
using System.Security;
|
|
|
|
namespace Google.Protobuf
|
|
{
|
|
/// <summary>
|
|
/// Fast parsing primitives for wrapper types
|
|
/// </summary>
|
|
[SecuritySafeCritical]
|
|
internal static class ParsingPrimitivesWrappers
|
|
{
|
|
internal static float? ReadFloatWrapperLittleEndian(ref ReadOnlySpan<byte> buffer, ref ParserInternalState state)
|
|
{
|
|
// length:1 + tag:1 + value:4 = 6 bytes
|
|
if (state.bufferPos + 6 <= state.bufferSize)
|
|
{
|
|
// The entire wrapper message is already contained in `buffer`.
|
|
int length = buffer[state.bufferPos];
|
|
if (length == 0)
|
|
{
|
|
state.bufferPos++;
|
|
return 0F;
|
|
}
|
|
// tag:1 + value:4 = length of 5 bytes
|
|
// field=1, type=32-bit = tag of 13
|
|
if (length != 5 || buffer[state.bufferPos + 1] != 13)
|
|
{
|
|
return ReadFloatWrapperSlow(ref buffer, ref state);
|
|
}
|
|
state.bufferPos += 2;
|
|
return ParsingPrimitives.ParseFloat(ref buffer, ref state);
|
|
}
|
|
else
|
|
{
|
|
return ReadFloatWrapperSlow(ref buffer, ref state);
|
|
}
|
|
}
|
|
|
|
internal static float? ReadFloatWrapperSlow(ref ReadOnlySpan<byte> buffer, ref ParserInternalState state)
|
|
{
|
|
int length = ParsingPrimitives.ParseLength(ref buffer, ref state);
|
|
if (length == 0)
|
|
{
|
|
return 0F;
|
|
}
|
|
int finalBufferPos = state.totalBytesRetired + state.bufferPos + length;
|
|
float result = 0F;
|
|
do
|
|
{
|
|
// field=1, type=32-bit = tag of 13
|
|
if (ParsingPrimitives.ParseTag(ref buffer, ref state) == 13)
|
|
{
|
|
result = ParsingPrimitives.ParseFloat(ref buffer, ref state);
|
|
}
|
|
else
|
|
{
|
|
ParsingPrimitivesMessages.SkipLastField(ref buffer, ref state);
|
|
}
|
|
}
|
|
while (state.totalBytesRetired + state.bufferPos < finalBufferPos);
|
|
return result;
|
|
}
|
|
|
|
internal static double? ReadDoubleWrapperLittleEndian(ref ReadOnlySpan<byte> buffer, ref ParserInternalState state)
|
|
{
|
|
// length:1 + tag:1 + value:8 = 10 bytes
|
|
if (state.bufferPos + 10 <= state.bufferSize)
|
|
{
|
|
// The entire wrapper message is already contained in `buffer`.
|
|
int length = buffer[state.bufferPos];
|
|
if (length == 0)
|
|
{
|
|
state.bufferPos++;
|
|
return 0D;
|
|
}
|
|
// tag:1 + value:8 = length of 9 bytes
|
|
// field=1, type=64-bit = tag of 9
|
|
if (length != 9 || buffer[state.bufferPos + 1] != 9)
|
|
{
|
|
return ReadDoubleWrapperSlow(ref buffer, ref state);
|
|
}
|
|
state.bufferPos += 2;
|
|
return ParsingPrimitives.ParseDouble(ref buffer, ref state);
|
|
}
|
|
else
|
|
{
|
|
return ReadDoubleWrapperSlow(ref buffer, ref state);
|
|
}
|
|
}
|
|
|
|
internal static double? ReadDoubleWrapperSlow(ref ReadOnlySpan<byte> buffer, ref ParserInternalState state)
|
|
{
|
|
int length = ParsingPrimitives.ParseLength(ref buffer, ref state);
|
|
if (length == 0)
|
|
{
|
|
return 0D;
|
|
}
|
|
int finalBufferPos = state.totalBytesRetired + state.bufferPos + length;
|
|
double result = 0D;
|
|
do
|
|
{
|
|
// field=1, type=64-bit = tag of 9
|
|
if (ParsingPrimitives.ParseTag(ref buffer, ref state) == 9)
|
|
{
|
|
result = ParsingPrimitives.ParseDouble(ref buffer, ref state);
|
|
}
|
|
else
|
|
{
|
|
ParsingPrimitivesMessages.SkipLastField(ref buffer, ref state);
|
|
}
|
|
}
|
|
while (state.totalBytesRetired + state.bufferPos < finalBufferPos);
|
|
return result;
|
|
}
|
|
|
|
internal static bool? ReadBoolWrapper(ref ReadOnlySpan<byte> buffer, ref ParserInternalState state)
|
|
{
|
|
return ReadUInt64Wrapper(ref buffer, ref state) != 0;
|
|
}
|
|
|
|
internal static uint? ReadUInt32Wrapper(ref ReadOnlySpan<byte> buffer, ref ParserInternalState state)
|
|
{
|
|
// field=1, type=varint = tag of 8
|
|
const int expectedTag = 8;
|
|
// length:1 + tag:1 + value:10(varint64-max) = 12 bytes
|
|
// Value can be 64 bits for negative integers
|
|
if (state.bufferPos + 12 <= state.bufferSize)
|
|
{
|
|
// The entire wrapper message is already contained in `buffer`.
|
|
int pos0 = state.bufferPos;
|
|
int length = buffer[state.bufferPos++];
|
|
if (length == 0)
|
|
{
|
|
return 0;
|
|
}
|
|
// Length will always fit in a single byte.
|
|
if (length >= 128)
|
|
{
|
|
state.bufferPos = pos0;
|
|
return ReadUInt32WrapperSlow(ref buffer, ref state);
|
|
}
|
|
int finalBufferPos = state.bufferPos + length;
|
|
if (buffer[state.bufferPos++] != expectedTag)
|
|
{
|
|
state.bufferPos = pos0;
|
|
return ReadUInt32WrapperSlow(ref buffer, ref state);
|
|
}
|
|
var result = ParsingPrimitives.ParseRawVarint32(ref buffer, ref state);
|
|
// Verify this message only contained a single field.
|
|
if (state.bufferPos != finalBufferPos)
|
|
{
|
|
state.bufferPos = pos0;
|
|
return ReadUInt32WrapperSlow(ref buffer, ref state);
|
|
}
|
|
return result;
|
|
}
|
|
else
|
|
{
|
|
return ReadUInt32WrapperSlow(ref buffer, ref state);
|
|
}
|
|
}
|
|
|
|
internal static uint? ReadUInt32WrapperSlow(ref ReadOnlySpan<byte> buffer, ref ParserInternalState state)
|
|
{
|
|
int length = ParsingPrimitives.ParseLength(ref buffer, ref state);
|
|
if (length == 0)
|
|
{
|
|
return 0;
|
|
}
|
|
int finalBufferPos = state.totalBytesRetired + state.bufferPos + length;
|
|
uint result = 0;
|
|
do
|
|
{
|
|
// field=1, type=varint = tag of 8
|
|
if (ParsingPrimitives.ParseTag(ref buffer, ref state) == 8)
|
|
{
|
|
result = ParsingPrimitives.ParseRawVarint32(ref buffer, ref state);
|
|
}
|
|
else
|
|
{
|
|
ParsingPrimitivesMessages.SkipLastField(ref buffer, ref state);
|
|
}
|
|
}
|
|
while (state.totalBytesRetired + state.bufferPos < finalBufferPos);
|
|
return result;
|
|
}
|
|
|
|
internal static int? ReadInt32Wrapper(ref ReadOnlySpan<byte> buffer, ref ParserInternalState state)
|
|
{
|
|
return (int?)ReadUInt32Wrapper(ref buffer, ref state);
|
|
}
|
|
|
|
internal static ulong? ReadUInt64Wrapper(ref ReadOnlySpan<byte> buffer, ref ParserInternalState state)
|
|
{
|
|
// field=1, type=varint = tag of 8
|
|
const int expectedTag = 8;
|
|
// length:1 + tag:1 + value:10(varint64-max) = 12 bytes
|
|
if (state.bufferPos + 12 <= state.bufferSize)
|
|
{
|
|
// The entire wrapper message is already contained in `buffer`.
|
|
int pos0 = state.bufferPos;
|
|
int length = buffer[state.bufferPos++];
|
|
if (length == 0)
|
|
{
|
|
return 0L;
|
|
}
|
|
// Length will always fit in a single byte.
|
|
if (length >= 128)
|
|
{
|
|
state.bufferPos = pos0;
|
|
return ReadUInt64WrapperSlow(ref buffer, ref state);
|
|
}
|
|
int finalBufferPos = state.bufferPos + length;
|
|
if (buffer[state.bufferPos++] != expectedTag)
|
|
{
|
|
state.bufferPos = pos0;
|
|
return ReadUInt64WrapperSlow(ref buffer, ref state);
|
|
}
|
|
var result = ParsingPrimitives.ParseRawVarint64(ref buffer, ref state);
|
|
// Verify this message only contained a single field.
|
|
if (state.bufferPos != finalBufferPos)
|
|
{
|
|
state.bufferPos = pos0;
|
|
return ReadUInt64WrapperSlow(ref buffer, ref state);
|
|
}
|
|
return result;
|
|
}
|
|
else
|
|
{
|
|
return ReadUInt64WrapperSlow(ref buffer, ref state);
|
|
}
|
|
}
|
|
|
|
internal static ulong? ReadUInt64WrapperSlow(ref ReadOnlySpan<byte> buffer, ref ParserInternalState state)
|
|
{
|
|
// field=1, type=varint = tag of 8
|
|
const int expectedTag = 8;
|
|
int length = ParsingPrimitives.ParseLength(ref buffer, ref state);
|
|
if (length == 0)
|
|
{
|
|
return 0L;
|
|
}
|
|
int finalBufferPos = state.totalBytesRetired + state.bufferPos + length;
|
|
ulong result = 0L;
|
|
do
|
|
{
|
|
if (ParsingPrimitives.ParseTag(ref buffer, ref state) == expectedTag)
|
|
{
|
|
result = ParsingPrimitives.ParseRawVarint64(ref buffer, ref state);
|
|
}
|
|
else
|
|
{
|
|
ParsingPrimitivesMessages.SkipLastField(ref buffer, ref state);
|
|
}
|
|
}
|
|
while (state.totalBytesRetired + state.bufferPos < finalBufferPos);
|
|
return result;
|
|
}
|
|
|
|
internal static long? ReadInt64Wrapper(ref ReadOnlySpan<byte> buffer, ref ParserInternalState state)
|
|
{
|
|
return (long?)ReadUInt64Wrapper(ref buffer, ref state);
|
|
}
|
|
|
|
internal static float? ReadFloatWrapperLittleEndian(ref ParseContext ctx)
|
|
{
|
|
return ParsingPrimitivesWrappers.ReadFloatWrapperLittleEndian(ref ctx.buffer, ref ctx.state);
|
|
}
|
|
|
|
internal static float? ReadFloatWrapperSlow(ref ParseContext ctx)
|
|
{
|
|
return ParsingPrimitivesWrappers.ReadFloatWrapperSlow(ref ctx.buffer, ref ctx.state);
|
|
}
|
|
|
|
internal static double? ReadDoubleWrapperLittleEndian(ref ParseContext ctx)
|
|
{
|
|
return ParsingPrimitivesWrappers.ReadDoubleWrapperLittleEndian(ref ctx.buffer, ref ctx.state);
|
|
}
|
|
|
|
internal static double? ReadDoubleWrapperSlow(ref ParseContext ctx)
|
|
{
|
|
return ParsingPrimitivesWrappers.ReadDoubleWrapperSlow(ref ctx.buffer, ref ctx.state);
|
|
}
|
|
|
|
internal static bool? ReadBoolWrapper(ref ParseContext ctx)
|
|
{
|
|
return ParsingPrimitivesWrappers.ReadBoolWrapper(ref ctx.buffer, ref ctx.state);
|
|
}
|
|
|
|
internal static uint? ReadUInt32Wrapper(ref ParseContext ctx)
|
|
{
|
|
return ParsingPrimitivesWrappers.ReadUInt32Wrapper(ref ctx.buffer, ref ctx.state);
|
|
}
|
|
|
|
internal static int? ReadInt32Wrapper(ref ParseContext ctx)
|
|
{
|
|
return ParsingPrimitivesWrappers.ReadInt32Wrapper(ref ctx.buffer, ref ctx.state);
|
|
}
|
|
|
|
internal static ulong? ReadUInt64Wrapper(ref ParseContext ctx)
|
|
{
|
|
return ParsingPrimitivesWrappers.ReadUInt64Wrapper(ref ctx.buffer, ref ctx.state);
|
|
}
|
|
|
|
internal static ulong? ReadUInt64WrapperSlow(ref ParseContext ctx)
|
|
{
|
|
return ParsingPrimitivesWrappers.ReadUInt64WrapperSlow(ref ctx.buffer, ref ctx.state);
|
|
}
|
|
|
|
internal static long? ReadInt64Wrapper(ref ParseContext ctx)
|
|
{
|
|
return ParsingPrimitivesWrappers.ReadInt64Wrapper(ref ctx.buffer, ref ctx.state);
|
|
}
|
|
}
|
|
} |