Serraniel/SweetLib
1
0
Fork 0
Code Issues Pull requests 2 Packages Projects Releases 2 Wiki Activity

Added most other streaming implementations

Browse source
This commit is contained in:
Serraniel 2018-04-06 17:37:54 +02:00
parent d393bd184d
commit c419fa2757
1 changed files with 106 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

123
SweetLib.IO/Classes/Streaming/StreamManager.cs
View file

@ -1,4 +1,6 @@
using System.IO; using System;
using System.IO;
using System.Runtime.InteropServices.ComTypes;
using SweetLib.Utils.Extensions; using SweetLib.Utils.Extensions;
namespace SweetLib.IO.Classes.Streaming namespace SweetLib.IO.Classes.Streaming
@ -17,13 +19,12 @@ namespace SweetLib.IO.Classes.Streaming
DoubleValue = 0x1600, DoubleValue = 0x1600,
DateTimeValue = 0x1700, DateTimeValue = 0x1700,
StreamValue = 0x1800, StreamValue = 0x1800,
ObjectValue = 0x1900,
} }
private static bool SaveMetaToStream(Stream stream, StreamedObjectType type, long length) private static bool SaveMetaToStream(Stream stream, StreamedObjectType type, long length)
{ {
stream.Write(((ushort)type).ToBytes(), 0, sizeof(ushort)); stream.Write(((ushort)type).AsBytes(), 0, sizeof(ushort));
stream.Write(length.ToBytes(), 0, sizeof(long)); stream.Write(length.AsBytes(), 0, sizeof(long));
return true; return true;
} }
@ -36,36 +37,124 @@ namespace SweetLib.IO.Classes.Streaming
// read object type // read object type
var buffer = new byte[sizeof(ushort)]; var buffer = new byte[sizeof(ushort)];
stream.Read(buffer, 0, buffer.Length); stream.Read(buffer, 0, buffer.Length);
type = (StreamedObjectType) buffer.ToUInt16(); type = (StreamedObjectType)buffer.AsUInt16();
// read data length // read data length
buffer = new byte[sizeof(long)]; buffer = new byte[sizeof(long)];
stream.Read(buffer, 0, buffer.Length); stream.Read(buffer, 0, buffer.Length);
length = buffer.ToInt64(); length = buffer.AsInt64();
return true; return true;
} }
private static void SaveToStream(Stream stream, StreamedObjectType type, byte[] buffer)
{
SaveMetaToStream(stream, type, buffer.Length);
stream.Write(buffer, 0, buffer.Length);
}
private static byte[] LoadFromStream(Stream stream, StreamedObjectType type)
{
StreamedObjectType foundType;
long length;
LoadMetaDataFromStream(stream, out foundType, out length);
if (foundType != type)
throw new StreamTypeException($"Expected {type} but found {foundType} instead.");
var buffer = new byte[length];
stream.Read(buffer, 0, buffer.Length);
return buffer;
}
public static void SaveToStream(Stream stream, string value)
{
SaveToStream(stream, StreamedObjectType.StringValue, value.AsBytes());
}
public static void SaveToStream(Stream stream, bool value)
{
SaveToStream(stream, StreamedObjectType.BoolValue, value.AsBytes());
}
public static void SaveToStream(Stream stream, char value)
{
SaveToStream(stream, StreamedObjectType.CharValue, value.AsBytes());
}
public static void SaveToStream(Stream stream, int value) public static void SaveToStream(Stream stream, int value)
{ {
SaveMetaToStream(stream, StreamedObjectType.IntValue, sizeof(int)); SaveToStream(stream, StreamedObjectType.IntValue, value.AsBytes());
}
stream.Write(value.ToBytes(), 0, sizeof(int)); public static void SaveToStream(Stream stream, long value)
{
SaveToStream(stream, StreamedObjectType.LongValue, value.AsBytes());
}
public static void SaveToStream(Stream stream, float value)
{
SaveToStream(stream, StreamedObjectType.FloatValue, value.AsBytes());
}
public static void SaveToStream(Stream stream, double value)
{
SaveToStream(stream, StreamedObjectType.DoubleValue, value.AsBytes());
}
public static void SaveToStream(Stream stream, DateTime value)
{
SaveToStream(stream, StreamedObjectType.DateTimeValue, value.AsBytes());
}
public static void SaveToStream(Stream stream, Stream value, bool resetSourceStream = false)
{
if (resetSourceStream)
value.Position = 0;
var buffer = new byte[value.Length - value.Position];
value.Read(buffer, 0, buffer.Length);
SaveToStream(stream, StreamedObjectType.StreamValue, buffer);
}
public static void LoadFromStream(Stream stream, out string value)
{
value = LoadFromStream(stream, StreamedObjectType.StringValue).AsString();
}
public static void LoadFromStream(Stream stream, out bool value)
{
value = LoadFromStream(stream, StreamedObjectType.BoolValue).AsBool();
}
public static void LoadFromStream(Stream stream, out char value)
{
value = LoadFromStream(stream, StreamedObjectType.CharValue).AsChar();
} }
public static void LoadFromStream(Stream stream, out int value) public static void LoadFromStream(Stream stream, out int value)
{ {
StreamedObjectType type; value = LoadFromStream(stream, StreamedObjectType.IntValue).AsInt32();
long length; }
LoadMetaDataFromStream(stream, out type, out length); public static void LoadFromStream(Stream stream, out long value)
{
value = LoadFromStream(stream, StreamedObjectType.LongValue).AsInt64();
}
if(type!=StreamedObjectType.IntValue) public static void LoadFromStream(Stream stream, out float value)
throw new StreamTypeException($"Expected {StreamedObjectType.IntValue} but found {type} instead."); {
value = LoadFromStream(stream, StreamedObjectType.FloatValue).AsSingle();
}
var buffer = new byte[length]; public static void LoadFromStream(Stream stream, out double value)
stream.Read(buffer, 0, buffer.Length); {
value = buffer.ToInt32(); value = LoadFromStream(stream, StreamedObjectType.DoubleValue).AsDouble();
}
public static void LoadFromStream(Stream stream, out DateTime value)
{
value = LoadFromStream(stream, StreamedObjectType.DateTimeValue).AsDateTime();
}
public static void LoadFromStream(Stream stream, out Stream value)
{
var buffer = LoadFromStream(stream, StreamedObjectType.StreamValue);
value = new MemoryStream();
value.Read(buffer, 0, buffer.Length);
} }
} }
} }