soarqin/DSP_Mods
1
0
Fork 0
mirror of https://github.com/soarqin/DSP_Mods.git synced 2025-12-09 06:53:31 +08:00
Code Activity

try to resolve #4

Browse Source
This commit is contained in:
Soar Qin
2023-04-02 21:21:17 +08:00
parent 7a095a9f61
commit 4347083769
1 changed files with 10 additions and 45 deletions
Download Patch File Download Diff File Expand all files Collapse all files

55
CompressSave/Wrapper/BufferWriter.cs
View File

@@ -13,7 +13,7 @@ public unsafe class BufferWriter : BinaryWriter
private Encoding _encoding; private Encoding _encoding;
private Encoder encoder; private int maxBytesPerChar;
byte[] Buffer => currentBuffer.Buffer; byte[] Buffer => currentBuffer.Buffer;
@@ -53,7 +53,7 @@ public unsafe class BufferWriter : BinaryWriter
doubleBuffer = buffer; doubleBuffer = buffer;
RefreshStatus(); RefreshStatus();
_encoding = encoding; _encoding = encoding;
encoder = _encoding.GetEncoder(); maxBytesPerChar = _encoding.GetMaxByteCount(1);
} }
void SwapBuffer() void SwapBuffer()
@@ -149,9 +149,9 @@ public unsafe class BufferWriter : BinaryWriter
throw new ArgumentException("Arg_SurrogatesNotAllowedAsSingleChar"); throw new ArgumentException("Arg_SurrogatesNotAllowedAsSingleChar");
} }
CheckCapacityAndSwap(4); CheckCapacityAndSwap(maxBytesPerChar);
curPos += encoder.GetBytes(&ch, 1, curPos, (int)SuplusCapacity, flush: true); curPos += _encoding.GetBytes(&ch, 1, curPos, (int)SuplusCapacity);
} }
//slow //slow
@@ -257,10 +257,7 @@ public unsafe class BufferWriter : BinaryWriter
public unsafe override void Write(float value) public unsafe override void Write(float value)
{ {
if (SuplusCapacity < 4) CheckCapacityAndSwap(4);
{
SwapBuffer();
}
uint num = *(uint*)(&value); uint num = *(uint*)(&value);
*(curPos++) = (byte)num; *(curPos++) = (byte)num;
*(curPos++) = (byte)(num >> 8); *(curPos++) = (byte)(num >> 8);
@@ -269,51 +266,19 @@ public unsafe class BufferWriter : BinaryWriter
} }
//slow // Just use same mechanisum from `Write(char[] chars, int index, int count)`
public unsafe override void Write(string value) public override void Write(string value)
{ {
if (value == null) if (value == null)
{ {
throw new ArgumentNullException("value"); throw new ArgumentNullException("value");
} }
int byteCount = _encoding.GetByteCount(value); byte[] bytes = _encoding.GetBytes(value);
Write7BitEncodedInt(byteCount); Write7BitEncodedInt(bytes.Length);
{ Write(bytes);
var dstSuplus = (int)SuplusCapacity;
if (byteCount <= dstSuplus)
{
fixed (char* start = value)
{
int Wcount = _encoding.GetBytes(start, value.Length, curPos, dstSuplus);
curPos += Wcount;
//Console.WriteLine($"Using quick write!");
return;
}
}
}
int charIndex = 0;
bool completed;
fixed (char* chars = value)
{
do
{
encoder.Convert(chars + charIndex, value.Length - charIndex,
curPos, (int)SuplusCapacity, true,
out int charsConsumed, out int bytesWritten, out completed);
charIndex += charsConsumed;
curPos += bytesWritten;
//Console.WriteLine($"charsConsumed{charsConsumed} charIndex{charIndex} bytesWritten{bytesWritten} position{position} suplusCapacity{suplusCapacity}");
if (SuplusCapacity <= 0)
SwapBuffer();
} while (!completed);
}
encoder.Reset(); //flush
} }
protected new void Write7BitEncodedInt(int value) protected new void Write7BitEncodedInt(int value)
{ {
uint num; uint num;