OpenCodeBox/fishbait
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Update RelayHandler.cs

Browse source
This commit is contained in:
cxxpxr 2021-08-19 15:51:35 -04:00
parent 83096a908a
commit 6d25fc0022
1 changed files with 4 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
ServerProject-DONT-IMPORT-INTO-UNITY/LRM/RelayHandler/RelayHandler.cs
View file

@ -85,11 +85,7 @@ namespace LightReflectiveMirror
private void SendData(byte[] clientData, int channel, int sendTo, int senderId) private void SendData(byte[] clientData, int channel, int sendTo, int senderId)
{ {
// 1 byte for opcode if (clientData.Length > _maxPacketSize)
var headerLength = 1;
var payloadLength = headerLength + clientData.Length;
if (payloadLength > _maxPacketSize)
{ {
Program.transport.ServerDisconnect(senderId); Program.transport.ServerDisconnect(senderId);
Program.WriteLogMessage($"Client {senderId} tried to send more than max packet size! Disconnecting..."); Program.WriteLogMessage($"Client {senderId} tried to send more than max packet size! Disconnecting...");
@ -97,7 +93,7 @@ namespace LightReflectiveMirror
} }
int pos = 0; int pos = 0;
byte[] sendBuffer = _sendBuffers.Rent(payloadLength); byte[] sendBuffer = _sendBuffers.Rent(_maxPacketSize);
sendBuffer.WriteByte(ref pos, (byte)OpCodes.GetData); sendBuffer.WriteByte(ref pos, (byte)OpCodes.GetData);
sendBuffer.WriteBytes(ref pos, clientData); sendBuffer.WriteBytes(ref pos, clientData);
@ -108,11 +104,7 @@ namespace LightReflectiveMirror
private void SendDataToRoomHost(int senderId, byte[] clientData, int channel, Room room) private void SendDataToRoomHost(int senderId, byte[] clientData, int channel, Room room)
{ {
// 1 byte - opcode, 4 bytes for sizeof(int) client id if(clientData.Length > _maxPacketSize)
var headerLength = 5;
var payloadLength = headerLength + clientData.Length;
if(payloadLength > _maxPacketSize)
{ {
Program.transport.ServerDisconnect(senderId); Program.transport.ServerDisconnect(senderId);
Program.WriteLogMessage($"Client {senderId} tried to send more than max packet size! Disconnecting..."); Program.WriteLogMessage($"Client {senderId} tried to send more than max packet size! Disconnecting...");
@ -121,7 +113,7 @@ namespace LightReflectiveMirror
// We are not the host, so send the data to the host. // We are not the host, so send the data to the host.
int pos = 0; int pos = 0;
byte[] sendBuffer = _sendBuffers.Rent(payloadLength); byte[] sendBuffer = _sendBuffers.Rent(_maxPacketSize);
sendBuffer.WriteByte(ref pos, (byte)OpCodes.GetData); sendBuffer.WriteByte(ref pos, (byte)OpCodes.GetData);
sendBuffer.WriteBytes(ref pos, clientData); sendBuffer.WriteBytes(ref pos, clientData);