blob: 256ed41b6f718fb766d4b416af557c687c44ded3 [file] [log] [blame]
// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License. You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied. See the License for the
// specific language governing permissions and limitations
// under the License.
use crate::error::Error;
use crate::resolver::context::ReadContext;
use crate::resolver::context::WriteContext;
use crate::resolver::type_resolver::TypeResolver;
use crate::serializer::util::read_basic_type_info;
use crate::serializer::{ForyDefault, Serializer};
use crate::types::TypeId;
use std::mem;
#[allow(dead_code)]
enum StrEncoding {
Latin1 = 0,
Utf16 = 1,
Utf8 = 2,
}
impl Serializer for String {
#[inline(always)]
fn fory_write_data(&self, context: &mut WriteContext) -> Result<(), Error> {
let bitor = (self.len() as i32 as u64) << 2 | StrEncoding::Utf8 as u64;
context.writer.write_varuint36_small(bitor);
context.writer.write_utf8_string(self);
Ok(())
}
#[inline(always)]
fn fory_read_data(context: &mut ReadContext) -> Result<Self, Error> {
// xlang mode: read encoding header and decode accordingly
let bitor = context.reader.read_varuint36small()?;
let len = bitor >> 2;
let encoding = bitor & 0b11;
let s = match encoding {
0 => context.reader.read_latin1_string(len as usize),
1 => context.reader.read_utf16_string(len as usize),
2 => context.reader.read_utf8_string(len as usize),
_ => {
return Err(Error::encoding_error(format!(
"wrong encoding value: {}",
encoding
)))
}
}?;
Ok(s)
}
#[inline(always)]
fn fory_reserved_space() -> usize {
mem::size_of::<i32>()
}
#[inline(always)]
fn fory_get_type_id(_: &TypeResolver) -> Result<u32, Error> {
Ok(TypeId::STRING as u32)
}
#[inline(always)]
fn fory_type_id_dyn(&self, _: &TypeResolver) -> Result<u32, Error> {
Ok(TypeId::STRING as u32)
}
#[inline(always)]
fn fory_static_type_id() -> TypeId
where
Self: Sized,
{
TypeId::STRING
}
#[inline(always)]
fn as_any(&self) -> &dyn std::any::Any {
self
}
#[inline(always)]
fn fory_write_type_info(context: &mut WriteContext) -> Result<(), Error> {
context.writer.write_varuint32(TypeId::STRING as u32);
Ok(())
}
#[inline(always)]
fn fory_read_type_info(context: &mut ReadContext) -> Result<(), Error> {
read_basic_type_info::<Self>(context)
}
}
impl ForyDefault for String {
#[inline(always)]
fn fory_default() -> Self {
String::new()
}
}