426 TcpSocketLib/TcpSocketLib/TcpSocketLib/Compression/LZ4/LZ4Compressor32.cs
View file

Large diffs are not rendered by default.

426 TcpSocketLib/TcpSocketLib/TcpSocketLib/Compression/LZ4/LZ4Compressor64.cs
View file

Large diffs are not rendered by default.

17 TcpSocketLib/TcpSocketLib/TcpSocketLib/Compression/LZ4/LZ4CompressorFactory.cs
View file
@@ -0,0 +1,17 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace TcpSocketLib.Compression.LZ4
{
public static class LZ4CompressorFactory
{
public static ILZ4Compressor CreateNew()
{
if (IntPtr.Size == 4)
return new LZ4Compressor32();
return new LZ4Compressor64();
}
}
}
268 TcpSocketLib/TcpSocketLib/TcpSocketLib/Compression/LZ4/LZ4Decompressor32.cs
View file
@@ -0,0 +1,268 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Diagnostics;

namespace TcpSocketLib.Compression.LZ4
{





/// <summary>
/// Class for decompressing an LZ4 compressed byte array.
/// </summary>
public unsafe class LZ4Decompressor32 : ILZ4Decompressor
{
const int STEPSIZE = 4;





static byte[] DeBruijnBytePos = new byte[32] { 0, 0, 3, 0, 3, 1, 3, 0, 3, 2, 2, 1, 3, 2, 0, 1, 3, 3, 1, 2, 2, 2, 2, 0, 3, 1, 2, 0, 1, 0, 1, 1 };
//**************************************
// Macros
//**************************************
readonly sbyte[] m_DecArray = new sbyte[8] { 0, 3, 2, 3, 0, 0, 0, 0 };
// Note : The decoding functions LZ4_uncompress() and LZ4_uncompress_unknownOutputSize()
// are safe against "buffer overflow" attack type
// since they will *never* write outside of the provided output buffer :
// they both check this condition *before* writing anything.
// A corrupted packet however can make them *read* within the first 64K before the output buffer.
/// <summary>
/// Decompress.
/// </summary>
/// <param name="source">compressed array</param>
/// <param name="dest">This must be the exact length of the decompressed item</param>
public void DecompressKnownSize(byte[] compressed, byte[] decompressed)
{
int len = DecompressKnownSize(compressed, decompressed, decompressed.Length);
Debug.Assert(len == decompressed.Length);
}
public int DecompressKnownSize(byte[] compressed, byte[] decompressedBuffer, int decompressedSize)
{
fixed (byte* src = compressed)
fixed (byte* dst = decompressedBuffer)
return DecompressKnownSize(src, dst, decompressedSize);
}
public int DecompressKnownSize(byte* compressed, byte* decompressedBuffer, int decompressedSize)
{
fixed (sbyte* dec = m_DecArray)
{
// Local Variables
byte* ip = (byte*)compressed;
byte* r;

byte* op = (byte*)decompressedBuffer;
byte* oend = op + decompressedSize;
byte* cpy;

byte token;
int len, length;


// Main Loop
while (true)
{
// get runLength
token = *ip++;
if ((length = (token >> LZ4Util.ML_BITS)) == LZ4Util.RUN_MASK) { for (; (len = *ip++) == 255; length += 255) { } length += len; }


cpy = op + length;
if (cpy > oend - LZ4Util.COPYLENGTH)
{
if (cpy > oend) goto _output_error;
LZ4Util.CopyMemory(op, ip, length);
ip += length;
break;
}

do { *(uint*)op = *(uint*)ip; op += 4; ip += 4; ; *(uint*)op = *(uint*)ip; op += 4; ip += 4; ; } while (op < cpy); ; ip -= (op - cpy); op = cpy;


// get offset
{ r = (cpy) - *(ushort*)ip; }; ip += 2;
if (r < decompressedBuffer) goto _output_error;

// get matchLength
if ((length = (int)(token & LZ4Util.ML_MASK)) == LZ4Util.ML_MASK) { for (; *ip == 255; length += 255) { ip++; } length += *ip++; }

// copy repeated sequence
if (op - r < STEPSIZE)
{



const int dec2 = 0;



*op++ = *r++;
*op++ = *r++;
*op++ = *r++;
*op++ = *r++;
r -= dec[op - r];
*(uint*)op = *(uint*)r; op += STEPSIZE - 4;
r -= dec2;
}
else { *(uint*)op = *(uint*)r; op += 4; r += 4; ; }
cpy = op + length - (STEPSIZE - 4);
if (cpy > oend - LZ4Util.COPYLENGTH)
{
if (cpy > oend) goto _output_error;

do { *(uint*)op = *(uint*)r; op += 4; r += 4; ; *(uint*)op = *(uint*)r; op += 4; r += 4; ; } while (op < (oend - LZ4Util.COPYLENGTH)); ;
while (op < cpy) *op++ = *r++;
op = cpy;
if (op == oend) break;
continue;
}

do { *(uint*)op = *(uint*)r; op += 4; r += 4; ; *(uint*)op = *(uint*)r; op += 4; r += 4; ; } while (op < cpy); ;
op = cpy; // correction
}

// end of decoding
return (int)(((byte*)ip) - compressed);

// write overflow error detected
_output_error:
return (int)(-(((byte*)ip) - compressed));
}
}

public byte[] Decompress(byte[] compressed)
{
int length = compressed.Length;
int len;
byte[] dest;
const int Multiplier = 4; // Just a number. Determines how fast length should increase.
do
{
length *= Multiplier;
dest = new byte[length];
len = Decompress(compressed, dest, compressed.Length);
}
while (len < 0 || dest.Length < len);

byte[] d = new byte[len];
Buffer.BlockCopy(dest, 0, d, 0, d.Length);
return d;
}

public int Decompress(byte[] compressed, byte[] decompressedBuffer)
{
return Decompress(compressed, decompressedBuffer, compressed.Length);
}

public int Decompress(byte[] compressedBuffer, byte[] decompressedBuffer, int compressedSize)
{
fixed (byte* src = compressedBuffer)
fixed (byte* dst = decompressedBuffer)
return Decompress(src, dst, compressedSize, decompressedBuffer.Length);
}

public int Decompress(byte[] compressedBuffer, int compressedPosition, byte[] decompressedBuffer, int decompressedPosition, int compressedSize)
{
fixed (byte* src = &compressedBuffer[compressedPosition])
fixed (byte* dst = &decompressedBuffer[decompressedPosition])
return Decompress(src, dst, compressedSize, decompressedBuffer.Length);
}

public int Decompress(
byte* compressedBuffer,
byte* decompressedBuffer,
int compressedSize,
int maxDecompressedSize)
{
fixed (sbyte* dec = m_DecArray)
{
// Local Variables
byte* ip = (byte*)compressedBuffer;
byte* iend = ip + compressedSize;
byte* r;

byte* op = (byte*)decompressedBuffer;
byte* oend = op + maxDecompressedSize;
byte* cpy;

byte token;
int len, length;


// Main Loop
while (ip < iend)
{
// get runLength
token = *ip++;
if ((length = (token >> LZ4Util.ML_BITS)) == LZ4Util.RUN_MASK) { int s = 255; while ((ip < iend) && (s == 255)) { s = *ip++; length += s; } }

// copy literals
cpy = op + length;
if ((cpy > oend - LZ4Util.COPYLENGTH) || (ip + length > iend - LZ4Util.COPYLENGTH))
{
if (cpy > oend) goto _output_error; // Error : request to write beyond destination buffer
if (ip + length > iend) goto _output_error; // Error : request to read beyond source buffer
LZ4Util.CopyMemory(op, ip, length);
op += length;
ip += length;
if (ip < iend) goto _output_error; // Error : LZ4 format violation
break; //Necessarily EOF
}

do { *(uint*)op = *(uint*)ip; op += 4; ip += 4; ; *(uint*)op = *(uint*)ip; op += 4; ip += 4; ; } while (op < cpy); ; ip -= (op - cpy); op = cpy;

// get offset
{ r = (cpy) - *(ushort*)ip; }; ip += 2;
if (r < decompressedBuffer) goto _output_error;

// get matchlength
if ((length = (int)(token & LZ4Util.ML_MASK)) == LZ4Util.ML_MASK) { while (ip < iend) { int s = *ip++; length += s; if (s == 255) continue; break; } }

// copy repeated sequence
if (op - r < STEPSIZE)
{



const int dec2 = 0;


*op++ = *r++;
*op++ = *r++;
*op++ = *r++;
*op++ = *r++;
r -= dec[op - r];
*(uint*)op = *(uint*)r; op += STEPSIZE - 4;
r -= dec2;
}
else { *(uint*)op = *(uint*)r; op += 4; r += 4; ; }
cpy = op + length - (STEPSIZE - 4);
if (cpy > oend - LZ4Util.COPYLENGTH)
{
if (cpy > oend) goto _output_error;

do { *(uint*)op = *(uint*)r; op += 4; r += 4; ; *(uint*)op = *(uint*)r; op += 4; r += 4; ; } while (op < (oend - LZ4Util.COPYLENGTH)); ;
while (op < cpy) *op++ = *r++;
op = cpy;
if (op == oend) goto _output_error; // Check EOF (should never happen, since last 5 bytes are supposed to be literals)
continue;
}
do { *(uint*)op = *(uint*)r; op += 4; r += 4; ; *(uint*)op = *(uint*)r; op += 4; r += 4; ; } while (op < cpy); ;
op = cpy; // correction
}


return (int)(((byte*)op) - decompressedBuffer);


_output_error:
return (int)(-(((byte*)ip) - compressedBuffer));
}
}
}
}
271 TcpSocketLib/TcpSocketLib/TcpSocketLib/Compression/LZ4/LZ4Decompressor64.cs
View file
@@ -0,0 +1,271 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Diagnostics;

namespace TcpSocketLib.Compression.LZ4
{





/// <summary>
/// Class for decompressing an LZ4 compressed byte array.
/// </summary>
public unsafe class LZ4Decompressor64 : ILZ4Decompressor
{
const int STEPSIZE = 8;
static byte[] DeBruijnBytePos = new byte[64] { 0, 0, 0, 0, 0, 1, 1, 2, 0, 3, 1, 3, 1, 4, 2, 7, 0, 2, 3, 6, 1, 5, 3, 5, 1, 3, 4, 4, 2, 5, 6, 7, 7, 0, 1, 2, 3, 3, 4, 6, 2, 6, 5, 5, 3, 4, 5, 6, 7, 1, 2, 4, 6, 4, 4, 5, 7, 2, 6, 5, 7, 6, 7, 7 };
//**************************************
// Macros
//**************************************
readonly sbyte[] m_DecArray = new sbyte[8] { 0, 3, 2, 3, 0, 0, 0, 0 };
readonly sbyte[] m_Dec2table = new sbyte[8] { 0, 0, 0, -1, 0, 1, 2, 3 };
// Note : The decoding functions LZ4_uncompress() and LZ4_uncompress_unknownOutputSize()
// are safe against "buffer overflow" attack type
// since they will *never* write outside of the provided output buffer :
// they both check this condition *before* writing anything.
// A corrupted packet however can make them *read* within the first 64K before the output buffer.

/// <summary>
/// Decompress.
/// </summary>
/// <param name="source">compressed array</param>
/// <param name="dest">This must be the exact length of the decompressed item</param>
public void DecompressKnownSize(byte[] compressed, byte[] decompressed)
{
int len = DecompressKnownSize(compressed, decompressed, decompressed.Length);
Debug.Assert(len == decompressed.Length);
}

public int DecompressKnownSize(byte[] compressed, byte[] decompressedBuffer, int decompressedSize)
{
fixed (byte* src = compressed)
fixed (byte* dst = decompressedBuffer)
return DecompressKnownSize(src, dst, decompressedSize);
}

public int DecompressKnownSize(byte* compressed, byte* decompressedBuffer, int decompressedSize)
{
fixed (sbyte* dec = m_DecArray)

fixed (sbyte* dec2Ptr = m_Dec2table)
{
// Local Variables
byte* ip = (byte*)compressed;
byte* r;

byte* op = (byte*)decompressedBuffer;
byte* oend = op + decompressedSize;
byte* cpy;

byte token;
int len, length;


// Main Loop
while (true)
{
// get runLength
token = *ip++;
if ((length = (token >> LZ4Util.ML_BITS)) == LZ4Util.RUN_MASK) { for (; (len = *ip++) == 255; length += 255) { } length += len; }


cpy = op + length;
if (cpy > oend - LZ4Util.COPYLENGTH)
{
if (cpy > oend) goto _output_error;
LZ4Util.CopyMemory(op, ip, length);
ip += length;
break;
}

do { *(ulong*)op = *(ulong*)ip; op += 8; ip += 8; } while (op < cpy); ; ip -= (op - cpy); op = cpy;


// get offset
{ r = (cpy) - *(ushort*)ip; }; ip += 2;
if (r < decompressedBuffer) goto _output_error;

// get matchLength
if ((length = (int)(token & LZ4Util.ML_MASK)) == LZ4Util.ML_MASK) { for (; *ip == 255; length += 255) { ip++; } length += *ip++; }

// copy repeated sequence
if (op - r < STEPSIZE)
{

var dec2 = dec2Ptr[(int)(op - r)];





*op++ = *r++;
*op++ = *r++;
*op++ = *r++;
*op++ = *r++;
r -= dec[op - r];
*(uint*)op = *(uint*)r; op += STEPSIZE - 4;
r -= dec2;
}
else { *(ulong*)op = *(ulong*)r; op += 8; r += 8; ; }
cpy = op + length - (STEPSIZE - 4);
if (cpy > oend - LZ4Util.COPYLENGTH)
{
if (cpy > oend) goto _output_error;

if (op < (oend - LZ4Util.COPYLENGTH)) do { *(ulong*)op = *(ulong*)r; op += 8; r += 8; } while (op < (oend - LZ4Util.COPYLENGTH)); ;
while (op < cpy) *op++ = *r++;
op = cpy;
if (op == oend) break;
continue;
}

if (op < cpy) do { *(ulong*)op = *(ulong*)r; op += 8; r += 8; } while (op < cpy); ;
op = cpy; // correction
}

// end of decoding
return (int)(((byte*)ip) - compressed);

// write overflow error detected
_output_error:
return (int)(-(((byte*)ip) - compressed));
}
}

public byte[] Decompress(byte[] compressed)
{
int length = compressed.Length;
int len;
byte[] dest;
const int Multiplier = 4; // Just a number. Determines how fast length should increase.
do
{
length *= Multiplier;
dest = new byte[length];
len = Decompress(compressed, dest, compressed.Length);
}
while (len < 0 || dest.Length < len);

byte[] d = new byte[len];
Buffer.BlockCopy(dest, 0, d, 0, d.Length);
return d;
}

public int Decompress(byte[] compressed, byte[] decompressedBuffer)
{
return Decompress(compressed, decompressedBuffer, compressed.Length);
}

public int Decompress(byte[] compressedBuffer, byte[] decompressedBuffer, int compressedSize)
{
fixed (byte* src = compressedBuffer)
fixed (byte* dst = decompressedBuffer)
return Decompress(src, dst, compressedSize, decompressedBuffer.Length);
}

public int Decompress(byte[] compressedBuffer, int compressedPosition, byte[] decompressedBuffer, int decompressedPosition, int compressedSize)
{
fixed (byte* src = &compressedBuffer[compressedPosition])
fixed (byte* dst = &decompressedBuffer[decompressedPosition])
return Decompress(src, dst, compressedSize, decompressedBuffer.Length);
}

public int Decompress(
byte* compressedBuffer,
byte* decompressedBuffer,
int compressedSize,
int maxDecompressedSize)
{
fixed (sbyte* dec = m_DecArray)

fixed (sbyte* dec2Ptr = m_Dec2table)
{
// Local Variables
byte* ip = (byte*)compressedBuffer;
byte* iend = ip + compressedSize;
byte* r;

byte* op = (byte*)decompressedBuffer;
byte* oend = op + maxDecompressedSize;
byte* cpy;

byte token;
int len, length;


// Main Loop
while (ip < iend)
{
// get runLength
token = *ip++;
if ((length = (token >> LZ4Util.ML_BITS)) == LZ4Util.RUN_MASK) { int s = 255; while ((ip < iend) && (s == 255)) { s = *ip++; length += s; } }

// copy literals
cpy = op + length;
if ((cpy > oend - LZ4Util.COPYLENGTH) || (ip + length > iend - LZ4Util.COPYLENGTH))
{
if (cpy > oend) goto _output_error; // Error : request to write beyond destination buffer
if (ip + length > iend) goto _output_error; // Error : request to read beyond source buffer
LZ4Util.CopyMemory(op, ip, length);
op += length;
ip += length;
if (ip < iend) goto _output_error; // Error : LZ4 format violation
break; //Necessarily EOF
}

do { *(ulong*)op = *(ulong*)ip; op += 8; ip += 8; } while (op < cpy); ; ip -= (op - cpy); op = cpy;

// get offset
{ r = (cpy) - *(ushort*)ip; }; ip += 2;
if (r < decompressedBuffer) goto _output_error;

// get matchlength
if ((length = (int)(token & LZ4Util.ML_MASK)) == LZ4Util.ML_MASK) { while (ip < iend) { int s = *ip++; length += s; if (s == 255) continue; break; } }

// copy repeated sequence
if (op - r < STEPSIZE)
{

var dec2 = dec2Ptr[op - r];




*op++ = *r++;
*op++ = *r++;
*op++ = *r++;
*op++ = *r++;
r -= dec[op - r];
*(uint*)op = *(uint*)r; op += STEPSIZE - 4;
r -= dec2;
}
else { *(ulong*)op = *(ulong*)r; op += 8; r += 8; ; }
cpy = op + length - (STEPSIZE - 4);
if (cpy > oend - LZ4Util.COPYLENGTH)
{
if (cpy > oend) goto _output_error;

if (op < (oend - LZ4Util.COPYLENGTH)) do { *(ulong*)op = *(ulong*)r; op += 8; r += 8; } while (op < (oend - LZ4Util.COPYLENGTH)); ;
while (op < cpy) *op++ = *r++;
op = cpy;
if (op == oend) goto _output_error; // Check EOF (should never happen, since last 5 bytes are supposed to be literals)
continue;
}
if (op < cpy) do { *(ulong*)op = *(ulong*)r; op += 8; r += 8; } while (op < cpy); ;
op = cpy; // correction
}


return (int)(((byte*)op) - decompressedBuffer);


_output_error:
return (int)(-(((byte*)ip) - compressedBuffer));
}
}
}
}
17 TcpSocketLib/TcpSocketLib/TcpSocketLib/Compression/LZ4/LZ4DecompressorFactory.cs
View file
@@ -0,0 +1,17 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace TcpSocketLib.Compression.LZ4
{
public static class LZ4DecompressorFactory
{
public static ILZ4Decompressor CreateNew()
{
if (IntPtr.Size == 4)
return new LZ4Decompressor32();
return new LZ4Decompressor64();
}
}
}
53 TcpSocketLib/TcpSocketLib/TcpSocketLib/Compression/LZ4/LZ4Util.cs
View file
@@ -0,0 +1,53 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace TcpSocketLib.Compression.LZ4
{
/// <summary>
/// Constants and methods shared by LZ4Compressor and LZ4Decompressor
/// </summary>
internal class LZ4Util
{
//**************************************
// Constants
//**************************************
public const int COPYLENGTH = 8;
public const int ML_BITS = 4;
public const uint ML_MASK = ((1U << ML_BITS) - 1);
public const int RUN_BITS = (8 - ML_BITS);
public const uint RUN_MASK = ((1U << RUN_BITS) - 1);

public static unsafe void CopyMemory(byte* dst, byte* src, long length)
{
while (length >= 16)
{
*(ulong*)dst = *(ulong*)src; dst += 8; src += 8;
*(ulong*)dst = *(ulong*)src; dst += 8; src += 8;
length -= 16;
}

if (length >= 8)
{
*(ulong*)dst = *(ulong*)src; dst += 8; src += 8;
length -= 8;
}

if (length >= 4)
{
*(uint*)dst = *(uint*)src; dst += 4; src += 4;
length -= 4;
}

if (length >= 2)
{
*(ushort*)dst = *(ushort*)src; dst += 2; src += 2;
length -= 2;
}

if (length != 0)
*dst = *src;
}
}
}
25 TcpSocketLib/TcpSocketLib/TcpSocketLib/Extensions/ListExtensions.cs
View file
@@ -0,0 +1,25 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace TcpSocketLib.Extensions
{
public static class ListExtensions
{
public static void Shuffle<T>(this IList<T> list)
{
Random rng = new Random();
int n = list.Count;
while (n > 1)
{
n--;
int k = rng.Next(n + 1);
T value = list[k];
list[k] = list[n];
list[n] = value;
}
}
}
}
2 ...pSocketLib/TcpSocketLib/PluginResolver.cs → ...tLib/TcpSocketLib/Extra/PluginResolver.cs
View file
@@ -2,7 +2,7 @@
using System.IO;
using System.Reflection;

namespace TcpSocketLib
namespace TcpSocketLib.Extra
{
public class PluginResolver<PluginInterface>
{
3 ...cketLib/TcpSocketLib/TcpSocketLib/UUID.cs → ...b/TcpSocketLib/TcpSocketLib/Extra/UUID.cs
View file
@@ -1,7 +1,8 @@
using System;
using System.Collections.Generic;
using TcpSocketLib.Extensions;

namespace TcpSocketLib
namespace TcpSocketLib.Extra
{
public static class UUID
{
0 ...Lib/TcpSocketLib/TcpSocketLibEventArgs.cs → ...ketLib/TcpSocketLib/PacketReceivedArgs.cs
View file
File renamed without changes.
24 TcpSocketLib/TcpSocketLib/TcpSocketLib/PacketWriter.cs
View file

This file was deleted.

13 ...TcpSocketLib/TcpSocketLib/PacketReader.cs → ...cpSocketLib/Serialization/PacketReader.cs
View file
@@ -1,16 +1,27 @@
using System.IO;
using System.Runtime.Serialization.Formatters.Binary;

namespace TcpSocketLib
namespace TcpSocketLib.Serialization
{
public class PacketReader : BinaryReader
{
private BinaryFormatter _bf;

public PacketReader(byte[] data)
: base(new MemoryStream(data)) {
_bf = new BinaryFormatter();
}

public Stream ReadStream()
{
int streamSize = ReadInt32();
byte[] streamData = ReadBytes(streamSize);
using(MemoryStream ms = new MemoryStream(streamData))
{
return ms;
}
}

public T ReadObject<T>() {
return (T)_bf.Deserialize(BaseStream);
}
41 TcpSocketLib/TcpSocketLib/TcpSocketLib/Serialization/PacketWriter.cs
View file
@@ -0,0 +1,41 @@
using System.IO;
using System.Runtime.Serialization.Formatters.Binary;

namespace TcpSocketLib.Serialization
{
public class PacketWriter : BinaryWriter
{
private MemoryStream _ms;
private BinaryFormatter _bf;

public PacketWriter()
: base() {
_ms = new MemoryStream();
_bf = new BinaryFormatter();
OutStream = _ms;
}

public void WriteObject<T>(T obj) {
_bf.Serialize(_ms, obj);
}

public void Write(Stream stream)
{
byte[] buffer = new byte[16 * 1024];
using (MemoryStream ms = new MemoryStream())
{
int read;
while ((read = stream.Read(buffer, 0, buffer.Length)) > 0)
{
ms.Write(buffer, 0, read);
}
byte[] streamData = ms.ToArray();
int sizeData = streamData.Length;
Write(sizeData);
Write(streamData);
}
}

public byte[] Data => _ms.ToArray();
}
}
27 TcpSocketLib/TcpSocketLib/TcpSocketLib/TcpSocket.cs
View file
@@ -12,13 +12,15 @@ public class TcpSocket
public delegate void FloodDetectedEventHandler(TcpSocket sender);
public delegate void ClientConnectedEventHandler(TcpSocket sender);
public delegate void ClientDisconnectedEventHandler(TcpSocket sender);
public delegate void ReceiveProgressChangedHandler(TcpSocket sender, int Received, int BytesToReceive);
public delegate void ReceiveProgressChangedEventHandler(TcpSocket sender, int Received, int BytesToReceive);
public delegate void SendProgressChangedEventHandler(TcpSocket sender, int Send);

public event ReceiveProgressChangedHandler ReceiveProgressChanged;
public event ReceiveProgressChangedEventHandler ReceiveProgressChanged;
public event PacketReceivedEventHandler PacketReceived;
public event ClientConnectedEventHandler ClientConnected;
public event ClientDisconnectedEventHandler ClientDisconnected;
public event FloodDetectedEventHandler FloodDetected;
public event SendProgressChangedEventHandler SendProgressChanged;

private const int SIZE_PAYLOAD_LENGTH = sizeof(int);

@@ -151,7 +153,7 @@ public void Connect(string IP, int Port)
PacketReceived?.Invoke(this, new PacketReceivedArgs(new byte[0]));
}
else
HandleDisconnect(new Exception("zero length packets wasn't set to be allowed"));
HandleDisconnect(new Exception("Zero length packets wasn't set to be allowed"));
}
}
}
@@ -199,7 +201,7 @@ public void Connect(string IP, int Port)

_totalRead += read;
//Report progress about receiving.
ReceiveProgressChanged?.Invoke(this, _totalRead, _buffer.Length);
ReceiveProgressChanged?.Invoke(this, _totalRead + SIZE_PAYLOAD_LENGTH, _buffer.Length);

if (FloodDetector != null)
CheckFlood();
@@ -212,19 +214,26 @@ public void Connect(string IP, int Port)
AllocateBuffer(SIZE_PAYLOAD_LENGTH);
BeginReadSize();
}
}
}
catch (Exception ex) {
HandleDisconnect(ex);
}
}

public void Send(byte[] bytes) {
lock (_syncLock) {
this._socket.Send(BitConverter.GetBytes(bytes.Length));
this._socket.Send(bytes);
private void SendData(byte[] data)
{
lock (_syncLock)
{
this._socket.Send(BitConverter.GetBytes(data.Length));
this._socket.Send(data);
this.SendProgressChanged?.Invoke(this, data.Length);
}
}

public void Send(byte[] bytes) {
SendData(bytes);
}

public void Dispose() {
Disconnect();
_buffer = null;
29 TcpSocketLib/TcpSocketLib/TcpSocketLib/TcpSocketLib.csproj
View file
@@ -15,11 +15,13 @@
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
<DebugSymbols>true</DebugSymbols>
<DebugType>full</DebugType>
<Optimize>false</Optimize>
<Optimize>true</Optimize>
<OutputPath>bin\Debug\</OutputPath>
<DefineConstants>DEBUG;TRACE</DefineConstants>
<ErrorReport>prompt</ErrorReport>
<WarningLevel>4</WarningLevel>
<AllowUnsafeBlocks>true</AllowUnsafeBlocks>
<GenerateSerializationAssemblies>On</GenerateSerializationAssemblies>
</PropertyGroup>
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
<DebugType>pdbonly</DebugType>
@@ -30,7 +32,7 @@
<WarningLevel>3</WarningLevel>
<GenerateSerializationAssemblies>On</GenerateSerializationAssemblies>
<PlatformTarget>AnyCPU</PlatformTarget>
<AllowUnsafeBlocks>false</AllowUnsafeBlocks>
<AllowUnsafeBlocks>true</AllowUnsafeBlocks>
</PropertyGroup>
<ItemGroup>
<Reference Include="System" />
@@ -44,20 +46,31 @@
<Reference Include="System.Xml" />
</ItemGroup>
<ItemGroup>
<Compile Include="Compression\LZ4\ILZ4Compressor.cs" />
<Compile Include="Compression\LZ4\ILZ4Decompressor.cs" />
<Compile Include="Compression\LZ4\LZ4.cs" />
<Compile Include="Compression\LZ4\LZ4Compressor32.cs" />
<Compile Include="Compression\LZ4\LZ4Compressor64.cs" />
<Compile Include="Compression\LZ4\LZ4CompressorFactory.cs" />
<Compile Include="Compression\LZ4\LZ4Decompressor32.cs" />
<Compile Include="Compression\LZ4\LZ4Decompressor64.cs" />
<Compile Include="Compression\LZ4\LZ4DecompressorFactory.cs" />
<Compile Include="Compression\LZ4\LZ4Util.cs" />
<Compile Include="Extensions\ListExtensions.cs" />
<Compile Include="FloodDetector.cs" />
<Compile Include="PacketReader.cs" />
<Compile Include="PacketWriter.cs" />
<Compile Include="PluginResolver.cs" />
<Compile Include="Serialization\PacketReader.cs" />
<Compile Include="Serialization\PacketWriter.cs" />
<Compile Include="Extra\PluginResolver.cs" />
<Compile Include="Properties\AssemblyInfo.cs" />
<Compile Include="TcpSocket.cs" />
<Compile Include="TcpSocketLibEventArgs.cs" />
<Compile Include="PacketReceivedArgs.cs" />
<Compile Include="TcpSocketListener.cs" />
<Compile Include="Utils.cs" />
<Compile Include="UUID.cs" />
<Compile Include="Extra\UUID.cs" />
</ItemGroup>
<ItemGroup>
<Content Include="Protocol.txt" />
</ItemGroup>
<ItemGroup />
<Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
<!-- To modify your build process, add your task inside one of the targets below and uncomment it.
Other similar extension points exist, see Microsoft.Common.targets.
14 TcpSocketLib/TcpSocketLib/TcpSocketLib/TcpSocketListener.cs
View file
@@ -12,13 +12,15 @@ public class TcpSocketListener
public delegate void FloodDetectedEventHandler(TcpSocket sender);
public delegate void ClientConnectedEventHandler(TcpSocket sender);
public delegate void ClientDisconnectedEventHandler(TcpSocket sender);
public delegate void ReceiveProgressChangedHandler(TcpSocket sender, int Received, int BytesToReceive);
public delegate void ReceiveProgressChangedEventHandler(TcpSocket sender, int Received, int BytesToReceive);
public delegate void SendProgressChangedEventHandler(TcpSocket sender, int Send);

public event ReceiveProgressChangedHandler ReceiveProgressChanged;
public event ReceiveProgressChangedEventHandler ReceiveProgressChanged;
public event PacketReceivedEventHandler PacketReceived;
public event ClientConnectedEventHandler ClientConnected;
public event ClientDisconnectedEventHandler ClientDisconnected;
public event FloodDetectedEventHandler FloodDetected;
public event SendProgressChangedEventHandler SendProgressChanged;

public List<TcpSocket> ConnectedClients {
get {
@@ -84,15 +86,21 @@ public class TcpSocketListener
tcpSocket.ClientDisconnected += TcpSocket_ClientDisconnected;
tcpSocket.PacketReceived += TcpSocket_PacketReceived;
tcpSocket.ReceiveProgressChanged += TcpSocket_ReceiveProgressChanged;
tcpSocket.SendProgressChanged += TcpSocket_SendProgressChanged;
tcpSocket.FloodDetected += TcpSocket_FloodDetected;

tcpSocket.Start();
this._listener.BeginAccept(AcceptCallBack, null);
} catch (Exception ex) {
} catch {
//MessageBox.Show(ex.Message + " \n\n [" + ex.StackTrace + "]");
}
}

private void TcpSocket_SendProgressChanged(TcpSocket sender, int Send)
{
SendProgressChanged?.Invoke(sender, Send);
}

private void TcpSocket_FloodDetected(TcpSocket sender) {
FloodDetected?.Invoke(sender);
}
20 TcpSocketLib/TcpSocketLib/TcpSocketLib/Utils.cs
View file

This file was deleted.

BIN +20 KB (230%) TcpSocketLib/TcpSocketLib/TcpSocketLib/bin/Debug/TcpSocketLib.dll
View file
Binary file not shown.
BIN +50 KB (230%) TcpSocketLib/TcpSocketLib/TcpSocketLib/bin/Debug/TcpSocketLib.pdb
View file
Binary file not shown.
BIN +0 Bytes (100%) TcpSocketLib/TcpSocketLib/TcpSocketLib/bin/Release/TcpSocketLib.dll
View file
Binary file not shown.
BIN +0 Bytes (100%) TcpSocketLib/TcpSocketLib/TcpSocketLib/bin/Release/TcpSocketLib.pdb
View file
Binary file not shown.
5 TcpSocketLib/TcpSocketLib/TcpSocketLib/obj/Debug/TcpSocketLib.csproj.FileListAbsolute.txt
View file
@@ -3,3 +3,8 @@ C:\Users\Alex\Documents\GitHub\TcpSocketLib\TcpSocketLib\TcpSocketLib\TcpSocketL
C:\Users\Alex\Documents\GitHub\TcpSocketLib\TcpSocketLib\TcpSocketLib\TcpSocketLib\obj\Debug\TcpSocketLib.csprojResolveAssemblyReference.cache
C:\Users\Alex\Documents\GitHub\TcpSocketLib\TcpSocketLib\TcpSocketLib\TcpSocketLib\obj\Debug\TcpSocketLib.dll
C:\Users\Alex\Documents\GitHub\TcpSocketLib\TcpSocketLib\TcpSocketLib\TcpSocketLib\obj\Debug\TcpSocketLib.pdb
C:\Users\Alex\Desktop\TcpSocketLib\TcpSocketLib\TcpSocketLib\TcpSocketLib\obj\Debug\TcpSocketLib.csprojResolveAssemblyReference.cache
C:\Users\Alex\Desktop\TcpSocketLib\TcpSocketLib\TcpSocketLib\TcpSocketLib\obj\Debug\TcpSocketLib.dll
C:\Users\Alex\Desktop\TcpSocketLib\TcpSocketLib\TcpSocketLib\TcpSocketLib\obj\Debug\TcpSocketLib.pdb
C:\Users\Alex\Desktop\TcpSocketLib\TcpSocketLib\TcpSocketLib\TcpSocketLib\bin\Debug\TcpSocketLib.dll
C:\Users\Alex\Desktop\TcpSocketLib\TcpSocketLib\TcpSocketLib\TcpSocketLib\bin\Debug\TcpSocketLib.pdb
BIN +157 Bytes (110%) ...Lib/TcpSocketLib/TcpSocketLib/obj/Debug/TcpSocketLib.csprojResolveAssemblyReference.cache
View file
Binary file not shown.
BIN +20 KB (230%) TcpSocketLib/TcpSocketLib/TcpSocketLib/obj/Debug/TcpSocketLib.dll
View file
Binary file not shown.
BIN +50 KB (230%) TcpSocketLib/TcpSocketLib/TcpSocketLib/obj/Debug/TcpSocketLib.pdb
View file
Binary file not shown.