Merge pull request #32 from Ravenwolfe/master
Add persistence mechanism for serialization to files. *Requires Core Recompile*
This commit is contained in:
commit
5e7de85760
2 changed files with 118 additions and 0 deletions
117
Server/Persistence/Persistence.cs
Normal file
117
Server/Persistence/Persistence.cs
Normal file
|
|
@ -0,0 +1,117 @@
|
||||||
|
#region References
|
||||||
|
using System;
|
||||||
|
using System.IO;
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
namespace Server
|
||||||
|
{
|
||||||
|
public static class Persistence
|
||||||
|
{
|
||||||
|
public static void Serialize(string path, Action<GenericWriter> serializer)
|
||||||
|
{
|
||||||
|
Serialize(new FileInfo(path), serializer);
|
||||||
|
}
|
||||||
|
|
||||||
|
public static void Serialize(FileInfo file, Action<GenericWriter> serializer)
|
||||||
|
{
|
||||||
|
file.Refresh();
|
||||||
|
|
||||||
|
if (file.Directory != null && !file.Directory.Exists)
|
||||||
|
{
|
||||||
|
file.Directory.Create();
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!file.Exists)
|
||||||
|
{
|
||||||
|
file.Create().Close();
|
||||||
|
}
|
||||||
|
|
||||||
|
file.Refresh();
|
||||||
|
|
||||||
|
using (var fs = file.OpenWrite())
|
||||||
|
{
|
||||||
|
var writer = new BinaryFileWriter(fs, true);
|
||||||
|
|
||||||
|
try
|
||||||
|
{
|
||||||
|
serializer(writer);
|
||||||
|
}
|
||||||
|
finally
|
||||||
|
{
|
||||||
|
writer.Flush();
|
||||||
|
writer.Close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public static void Deserialize(string path, Action<GenericReader> deserializer)
|
||||||
|
{
|
||||||
|
Deserialize(path, deserializer, true);
|
||||||
|
}
|
||||||
|
|
||||||
|
public static void Deserialize(FileInfo file, Action<GenericReader> deserializer)
|
||||||
|
{
|
||||||
|
Deserialize(file, deserializer, true);
|
||||||
|
}
|
||||||
|
|
||||||
|
public static void Deserialize(string path, Action<GenericReader> deserializer, bool ensure)
|
||||||
|
{
|
||||||
|
Deserialize(new FileInfo(path), deserializer, ensure);
|
||||||
|
}
|
||||||
|
|
||||||
|
public static void Deserialize(FileInfo file, Action<GenericReader> deserializer, bool ensure)
|
||||||
|
{
|
||||||
|
file.Refresh();
|
||||||
|
|
||||||
|
if (file.Directory != null && !file.Directory.Exists)
|
||||||
|
{
|
||||||
|
if (!ensure)
|
||||||
|
{
|
||||||
|
throw new DirectoryNotFoundException();
|
||||||
|
}
|
||||||
|
|
||||||
|
file.Directory.Create();
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!file.Exists)
|
||||||
|
{
|
||||||
|
if (!ensure)
|
||||||
|
{
|
||||||
|
throw new FileNotFoundException
|
||||||
|
{
|
||||||
|
Source = file.FullName
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
file.Create().Close();
|
||||||
|
}
|
||||||
|
|
||||||
|
file.Refresh();
|
||||||
|
|
||||||
|
using (var fs = file.OpenRead())
|
||||||
|
{
|
||||||
|
var reader = new BinaryFileReader(new BinaryReader(fs));
|
||||||
|
|
||||||
|
try
|
||||||
|
{
|
||||||
|
deserializer(reader);
|
||||||
|
}
|
||||||
|
catch (EndOfStreamException eos)
|
||||||
|
{
|
||||||
|
if (file.Length > 0)
|
||||||
|
{
|
||||||
|
Console.WriteLine("[Persistence]: {0}", eos);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
catch (Exception e)
|
||||||
|
{
|
||||||
|
Console.WriteLine("[Persistence]: {0}", e);
|
||||||
|
}
|
||||||
|
finally
|
||||||
|
{
|
||||||
|
reader.Close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -182,6 +182,7 @@
|
||||||
<Compile Include="Persistence\FileOperations.cs" />
|
<Compile Include="Persistence\FileOperations.cs" />
|
||||||
<Compile Include="Persistence\FileQueue.cs" />
|
<Compile Include="Persistence\FileQueue.cs" />
|
||||||
<Compile Include="Persistence\ParallelSaveStrategy.cs" />
|
<Compile Include="Persistence\ParallelSaveStrategy.cs" />
|
||||||
|
<Compile Include="Persistence\Persistence.cs" />
|
||||||
<Compile Include="Persistence\QueuedMemoryWriter.cs" />
|
<Compile Include="Persistence\QueuedMemoryWriter.cs" />
|
||||||
<Compile Include="Persistence\SaveMetrics.cs" />
|
<Compile Include="Persistence\SaveMetrics.cs" />
|
||||||
<Compile Include="Persistence\SaveStrategy.cs" />
|
<Compile Include="Persistence\SaveStrategy.cs" />
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue