progtime/DangerousD
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

nf

Browse source
This commit is contained in:
AnloGames 2023-08-18 18:11:17 +03:00
parent dcb7eaa960
commit 77aacb86f0
2 changed files with 19 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
DangerousD/GameCore/Managers/GameManager.cs
View file

@ -134,7 +134,7 @@ namespace DangerousD.GameCore
{
if (AppManager.Instance.NetworkTasks.Count > 0)
{
if (gameTime.TotalGameTime.Milliseconds - _lastUpdate > 1000)
if (gameTime.TotalGameTime.Milliseconds - _lastUpdate > 800)
{
AppManager.Instance.DebugHUD.Log("sending");
AppManager.Instance.NetworkManager.SendMsg(AppManager.Instance.NetworkTasks.ToList());

22
DangerousD/GameCore/Network/NetworkManager.cs
View file

@ -44,9 +44,16 @@ namespace DangerousD.GameCore.Network
{
byte[] bytesCount = new byte[4];
clientSocket.Receive(bytesCount);
byte[] Data = new byte[BitConverter.ToInt32(bytesCount)];
int length = BitConverter.ToInt32(bytesCount);
byte[] Data = new byte[length];
StateObject so = new StateObject(clientSocket, Data);
IAsyncResult count = clientSocket.BeginReceive(so.buffer, 0, so.bufferSize, SocketFlags.None, AsyncReceiveCallback, so);
while (so.UploadedBytesCount < length)
{
int count = socket.Receive(so.buffer, so.UploadedBytesCount, length - so.UploadedBytesCount, SocketFlags.None);
so.UploadedBytesCount += count;
}
List<NetworkTask> tasks = JsonConvert.DeserializeObject<List<NetworkTask>>(so.sb.ToString());
GetReceivingMessages(tasks);
}
}
public void HostInit(string IpAddress)
@ -98,9 +105,16 @@ namespace DangerousD.GameCore.Network
{
byte[] bytesCount = new byte[4];
socket.Receive(bytesCount);
byte[] Data = new byte[BitConverter.ToInt32(bytesCount)];
int length = BitConverter.ToInt32(bytesCount);
byte[] Data = new byte[length];
StateObject so = new StateObject(socket, Data);
IAsyncResult count = socket.BeginReceive(so.buffer, 0, so.bufferSize, SocketFlags.None, AsyncReceiveCallback, so);
while (so.UploadedBytesCount < length)
{
int count = socket.Receive(so.buffer, so.UploadedBytesCount, length-so.UploadedBytesCount, SocketFlags.None);
so.UploadedBytesCount += count;
}
List<NetworkTask> tasks = JsonConvert.DeserializeObject<List<NetworkTask>>(so.sb.ToString());
GetReceivingMessages(tasks);
}
}