FurinaImpact/FurinaImpact.Gameserver/Network/Kcp/KcpSession.cs
2023-12-09 06:45:08 +03:00

48 lines
1.6 KiB
C#

using FurinaImpact.Common.Security;
using FurinaImpact.Gameserver.Controllers.Dispatching;
using FurinaImpact.Gameserver.Network.Session;
using Microsoft.Extensions.Logging;
namespace FurinaImpact.Gameserver.Network.Kcp;
internal class KcpSession : NetSession
{
private const int MaxPacketSize = 32768;
private const int ReadTimeout = 30;
private const int WriteTimeout = 30;
private readonly byte[] _recvBuffer;
private readonly byte[] _sendBuffer;
public KcpSession(ILogger<NetSession> logger, NetSessionManager sessionManager, NetCommandDispatcher commandDispatcher) : base(logger, sessionManager, commandDispatcher)
{
_recvBuffer = GC.AllocateUninitializedArray<byte>(MaxPacketSize);
_sendBuffer = GC.AllocateUninitializedArray<byte>(MaxPacketSize);
}
public override async ValueTask RunAsync()
{
Memory<byte> buffer = _recvBuffer.AsMemory();
while (true)
{
int readAmount = await ReadWithTimeoutAsync(buffer, ReadTimeout);
if (readAmount <= 0)
break;
MhySecurity.Xor(buffer[..readAmount].Span, EncryptionKey);
int consumedBytes = await ConsumePacketsAsync(buffer[..readAmount]);
if (consumedBytes == -1)
break;
}
}
public override async ValueTask SendAsync(NetPacket packet)
{
Memory<byte> buffer = _sendBuffer.AsMemory();
int length = packet.EncodeTo(buffer);
MhySecurity.Xor(buffer[..length].Span, EncryptionKey);
await WriteWithTimeoutAsync(buffer[..length], WriteTimeout);
}
}