/**
* 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.
*/
using System;
using System.Collections.Generic;
using System.IO;
namespace Avro.IO
{
///
/// Write leaf values.
///
public class BinaryEncoder : Encoder
{
private readonly Stream Stream;
public BinaryEncoder() : this(null)
{
}
public BinaryEncoder(Stream stream)
{
this.Stream = stream;
}
///
/// null is written as zero bytes
///
public void WriteNull()
{
}
///
/// true is written as 1 and false 0.
///
/// Boolean value to write
public void WriteBoolean(bool b)
{
writeByte((byte)(b ? 1 : 0));
}
///
/// int and long values are written using variable-length, zig-zag coding.
///
///
public void WriteInt(int value)
{
WriteLong(value);
}
///
/// int and long values are written using variable-length, zig-zag coding.
///
///
public void WriteLong(long value)
{
ulong n = (ulong)((value << 1) ^ (value >> 63));
while ((n & ~0x7FUL) != 0)
{
writeByte((byte)((n & 0x7f) | 0x80));
n >>= 7;
}
writeByte((byte)n);
}
///
/// A float is written as 4 bytes.
/// The float is converted into a 32-bit integer using a method equivalent to
/// Java's floatToIntBits and then encoded in little-endian format.
///
///
public void WriteFloat(float value)
{
byte[] buffer = BitConverter.GetBytes(value);
if (!BitConverter.IsLittleEndian) Array.Reverse(buffer);
writeBytes(buffer);
}
///
///A double is written as 8 bytes.
///The double is converted into a 64-bit integer using a method equivalent to
///Java's doubleToLongBits and then encoded in little-endian format.
///
///
public void WriteDouble(double value)
{
long bits = BitConverter.DoubleToInt64Bits(value);
writeByte((byte)((bits) & 0xFF));
writeByte((byte)((bits >> 8) & 0xFF));
writeByte((byte)((bits >> 16) & 0xFF));
writeByte((byte)((bits >> 24) & 0xFF));
writeByte((byte)((bits >> 32) & 0xFF));
writeByte((byte)((bits >> 40) & 0xFF));
writeByte((byte)((bits >> 48) & 0xFF));
writeByte((byte)((bits >> 56) & 0xFF));
}
///
/// Bytes are encoded as a long followed by that many bytes of data.
///
///
///
public void WriteBytes(byte[] value)
{
WriteLong(value.Length);
writeBytes(value);
}
///
/// A string is encoded as a long followed by
/// that many bytes of UTF-8 encoded character data.
///
///
public void WriteString(string value)
{
WriteBytes(System.Text.Encoding.UTF8.GetBytes(value));
}
public void WriteEnum(int value)
{
WriteLong(value);
}
public void StartItem()
{
}
public void SetItemCount(long value)
{
if (value > 0) WriteLong(value);
}
public void WriteArrayStart()
{
}
public void WriteArrayEnd()
{
WriteLong(0);
}
public void WriteMapStart()
{
}
public void WriteMapEnd()
{
WriteLong(0);
}
public void WriteUnionIndex(int value)
{
WriteLong(value);
}
public void WriteFixed(byte[] data)
{
WriteFixed(data, 0, data.Length);
}
public void WriteFixed(byte[] data, int start, int len)
{
Stream.Write(data, start, len);
}
private void writeBytes(byte[] bytes)
{
Stream.Write(bytes, 0, bytes.Length);
}
private void writeByte(byte b)
{
Stream.WriteByte(b);
}
public void Flush()
{
Stream.Flush();
}
}
}