Removed references to reliable sender

Now the game is broken, progress is being made :)
This commit is contained in:
juanjp600
2016-08-25 18:55:32 -03:00
parent 6e456bcee2
commit 12f849be01
7 changed files with 1442 additions and 1522 deletions
Binary file not shown.
+1434 -1435
View File
File diff suppressed because it is too large Load Diff
@@ -1,5 +1,4 @@
using Barotrauma.Items.Components; using Barotrauma.Items.Components;
using Barotrauma.Networking.ReliableMessages;
using Lidgren.Network; using Lidgren.Network;
using Microsoft.Xna.Framework; using Microsoft.Xna.Framework;
using System; using System;
+2 -5
View File
@@ -1,5 +1,4 @@
using Barotrauma.Networking.ReliableMessages; using Lidgren.Network;
using Lidgren.Network;
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.ComponentModel; using System.ComponentModel;
@@ -40,8 +39,6 @@ namespace Barotrauma.Networking
public JobPrefab assignedJob; public JobPrefab assignedJob;
public FileStreamSender FileStreamSender; public FileStreamSender FileStreamSender;
public ReliableChannel ReliableChannel;
public float deleteDisconnectedTimer; public float deleteDisconnectedTimer;
@@ -55,7 +52,7 @@ namespace Barotrauma.Networking
public Client(NetPeer server, string name, byte ID) public Client(NetPeer server, string name, byte ID)
: this(name, ID) : this(name, ID)
{ {
ReliableChannel = new ReliableChannel(server);
} }
public Client(string name, byte ID) public Client(string name, byte ID)
+1 -31
View File
@@ -2,7 +2,6 @@
using Lidgren.Network; using Lidgren.Network;
using Microsoft.Xna.Framework; using Microsoft.Xna.Framework;
using System.Collections.Generic; using System.Collections.Generic;
using Barotrauma.Networking.ReliableMessages;
using FarseerPhysics; using FarseerPhysics;
using System.IO; using System.IO;
using System.Linq; using System.Linq;
@@ -17,8 +16,6 @@ namespace Barotrauma.Networking
private GUIMessageBox reconnectBox; private GUIMessageBox reconnectBox;
private ReliableChannel reliableChannel;
private FileStreamReceiver fileStreamReceiver; private FileStreamReceiver fileStreamReceiver;
private Queue<Pair<string, FileTransferMessageType>> requestFileQueue; private Queue<Pair<string, FileTransferMessageType>> requestFileQueue;
@@ -128,7 +125,6 @@ namespace Barotrauma.Networking
client = new NetClient(config); client = new NetClient(config);
netPeer = client; netPeer = client;
reliableChannel = new ReliableChannel(client);
client.Start(); client.Start();
NetOutgoingMessage outmsg = client.CreateMessage(); NetOutgoingMessage outmsg = client.CreateMessage();
@@ -429,8 +425,6 @@ namespace Barotrauma.Networking
DebugConsole.ThrowError("Error while receiving message from server", e); DebugConsole.ThrowError("Error while receiving message from server", e);
#endif #endif
} }
reliableChannel.Update(deltaTime);
if (gameStarted && respawnManager != null) if (gameStarted && respawnManager != null)
{ {
@@ -452,17 +446,7 @@ namespace Barotrauma.Networking
} }
} }
var message = ComposeNetworkEventMessage(NetworkEventDeliveryMethod.ReliableChannel); var message = ComposeNetworkEventMessage(NetworkEventDeliveryMethod.Unreliable);
if (message != null)
{
ReliableMessage reliableMessage = reliableChannel.CreateMessage();
message.Position = 0;
reliableMessage.InnerMessage.Write(message.ReadBytes(message.LengthBytes));
reliableChannel.SendMessage(reliableMessage, client.ServerConnection);
}
message = ComposeNetworkEventMessage(NetworkEventDeliveryMethod.Unreliable);
if (message != null) client.SendMessage(message, NetDeliveryMethod.Unreliable); if (message != null) client.SendMessage(message, NetDeliveryMethod.Unreliable);
message = ComposeNetworkEventMessage(NetworkEventDeliveryMethod.ReliableLidgren); message = ComposeNetworkEventMessage(NetworkEventDeliveryMethod.ReliableLidgren);
@@ -525,12 +509,6 @@ namespace Barotrauma.Networking
byte packetType = inc.ReadByte(); byte packetType = inc.ReadByte();
if (packetType == (byte)PacketTypes.ReliableMessage)
{
if (!reliableChannel.CheckMessage(inc)) continue;
packetType = inc.ReadByte();
}
switch (packetType) switch (packetType)
{ {
case (byte)PacketTypes.CanStartGame: case (byte)PacketTypes.CanStartGame:
@@ -685,10 +663,8 @@ namespace Barotrauma.Networking
break; break;
case (byte)PacketTypes.ResendRequest: case (byte)PacketTypes.ResendRequest:
reliableChannel.HandleResendRequest(inc);
break; break;
case (byte)PacketTypes.LatestMessageID: case (byte)PacketTypes.LatestMessageID:
reliableChannel.HandleLatestMessageID(inc);
break; break;
case (byte)PacketTypes.VoteStatus: case (byte)PacketTypes.VoteStatus:
Voting.ReadData(inc); Voting.ReadData(inc);
@@ -1226,12 +1202,6 @@ namespace Barotrauma.Networking
var chatMessage = ChatMessage.Create( var chatMessage = ChatMessage.Create(
gameStarted && myCharacter != null ? myCharacter.Name : name, gameStarted && myCharacter != null ? myCharacter.Name : name,
message, (ChatMessageType)type, gameStarted ? myCharacter : null); message, (ChatMessageType)type, gameStarted ? myCharacter : null);
ReliableMessage msg = reliableChannel.CreateMessage();
msg.InnerMessage.Write((byte)PacketTypes.Chatmessage);
chatMessage.WriteNetworkMessage(msg.InnerMessage);
reliableChannel.SendMessage(msg, client.ServerConnection);
} }
/// <summary> /// <summary>
+4 -47
View File
@@ -6,7 +6,6 @@ using System.Linq;
using Lidgren.Network; using Lidgren.Network;
using Microsoft.Xna.Framework; using Microsoft.Xna.Framework;
using RestSharp; using RestSharp;
using Barotrauma.Networking.ReliableMessages;
using Barotrauma.Items.Components; using Barotrauma.Items.Components;
namespace Barotrauma.Networking namespace Barotrauma.Networking
@@ -343,9 +342,7 @@ namespace Barotrauma.Networking
foreach (Client c in connectedClients) foreach (Client c in connectedClients)
{ {
if (c.FileStreamSender != null) UpdateFileTransfer(c, deltaTime); if (c.FileStreamSender != null) UpdateFileTransfer(c, deltaTime);
c.ReliableChannel.Update(deltaTime);
} }
NetIncomingMessage inc = null; NetIncomingMessage inc = null;
@@ -482,12 +479,6 @@ namespace Barotrauma.Networking
return; return;
} }
if (packetType == (byte)PacketTypes.ReliableMessage)
{
if (!sender.ReliableChannel.CheckMessage(inc)) return;
packetType = inc.ReadByte();
}
switch (packetType) switch (packetType)
{ {
case (byte)PacketTypes.NetworkEvent: case (byte)PacketTypes.NetworkEvent:
@@ -581,10 +572,8 @@ namespace Barotrauma.Networking
break; break;
case (byte)PacketTypes.ResendRequest: case (byte)PacketTypes.ResendRequest:
sender.ReliableChannel.HandleResendRequest(inc);
break; break;
case (byte)PacketTypes.LatestMessageID: case (byte)PacketTypes.LatestMessageID:
sender.ReliableChannel.HandleLatestMessageID(inc);
break; break;
case (byte)PacketTypes.Vote: case (byte)PacketTypes.Vote:
Voting.RegisterVote(inc, connectedClients); Voting.RegisterVote(inc, connectedClients);
@@ -653,17 +642,7 @@ namespace Barotrauma.Networking
foreach (Client c in recipients) foreach (Client c in recipients)
{ {
var message = ComposeNetworkEventMessage(NetworkEventDeliveryMethod.ReliableChannel, c.Connection); var message = ComposeNetworkEventMessage(NetworkEventDeliveryMethod.ReliableLidgren, c.Connection);
if (message != null)
{
ReliableMessage reliableMessage = c.ReliableChannel.CreateMessage();
message.Position = 0;
reliableMessage.InnerMessage.Write(message.ReadBytes(message.LengthBytes));
c.ReliableChannel.SendMessage(reliableMessage, c.Connection);
}
message = ComposeNetworkEventMessage(NetworkEventDeliveryMethod.ReliableLidgren, c.Connection);
if (message!=null) if (message!=null)
{ {
server.SendMessage(message, c.Connection, NetDeliveryMethod.ReliableUnordered); server.SendMessage(message, c.Connection, NetDeliveryMethod.ReliableUnordered);
@@ -1483,19 +1462,7 @@ namespace Barotrauma.Networking
recipients.Add(c); recipients.Add(c);
} }
AddChatMessage(message); AddChatMessage(message);
foreach (Client c in recipients)
{
ReliableMessage msg = c.ReliableChannel.CreateMessage();
msg.InnerMessage.Write((byte)PacketTypes.Chatmessage);
//msg.InnerMessage.Write((byte)type);
//msg.InnerMessage.Write(message);
message.WriteNetworkMessage(msg.InnerMessage);
c.ReliableChannel.SendMessage(msg, c.Connection);
}
} }
public override void SendChatMessage(string message, ChatMessageType? type = null) public override void SendChatMessage(string message, ChatMessageType? type = null)
@@ -1556,17 +1523,7 @@ namespace Barotrauma.Networking
public void SendChatMessage(ChatMessage chatMessage, List<Client> recipients) public void SendChatMessage(ChatMessage chatMessage, List<Client> recipients)
{ {
foreach (Client c in recipients)
{
ReliableMessage msg = c.ReliableChannel.CreateMessage();
msg.InnerMessage.Write((byte)PacketTypes.Chatmessage);
//msg.InnerMessage.Write((byte)type);
//msg.InnerMessage.Write(message);
chatMessage.WriteNetworkMessage(msg.InnerMessage);
c.ReliableChannel.SendMessage(msg, c.Connection);
}
} }
private void ReadCharacterData(NetIncomingMessage message) private void ReadCharacterData(NetIncomingMessage message)
@@ -1,5 +1,4 @@
using Barotrauma.Networking.ReliableMessages; using Lidgren.Network;
using Lidgren.Network;
using Microsoft.Xna.Framework; using Microsoft.Xna.Framework;
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
@@ -161,7 +160,6 @@ namespace Barotrauma.Networking
if (existingClient != null) if (existingClient != null)
{ {
existingClient.Connection = inc.SenderConnection; existingClient.Connection = inc.SenderConnection;
existingClient.ReliableChannel = new ReliableChannel(server);
LogClientIn(inc); LogClientIn(inc);
return; return;
} }