charleslemaux/Mirror
1
0
Fork 0
mirror of https://github.com/MirrorNetworking/Mirror.git synced 2024-11-18 02:50:32 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Simplify local message processing (#146)

Browse Source
This commit is contained in:
Paul Pacheco 2018-12-09 09:03:04 -06:00 committed by vis2k
parent e6f8cec658
commit eb9b7f556d
1 changed files with 9 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
Mirror/Runtime/LocalClient.cs
View File

@ -6,13 +6,8 @@ namespace Mirror
{
sealed class LocalClient : NetworkClient
{
struct InternalMsg
{
internal ushort msgType;
internal byte[] content;
}
List<InternalMsg> m_InternalMsgs = new List<InternalMsg>();
Queue<NetworkMessage> m_InternalMsgs = new Queue<NetworkMessage>();
bool m_Connected;
@ -68,10 +63,11 @@ internal void AddLocalPlayer(NetworkIdentity localPlayer)
private void PostInternalMessage(short msgType, byte[] content)
{
InternalMsg msg = new InternalMsg();
msg.msgType = (ushort)msgType;
msg.content = content;
m_InternalMsgs.Add(msg);
NetworkMessage msg = new NetworkMessage();
msg.msgType = msgType;
msg.reader = new NetworkReader(content);
msg.conn = connection;
m_InternalMsgs.Enqueue(msg);
}
private void PostInternalMessage(short msgType)
@ -83,29 +79,9 @@ private void PostInternalMessage(short msgType)
private void ProcessInternalMessages()
{
if (m_InternalMsgs.Count == 0)
while (m_InternalMsgs.Count > 0)
{
return;
}
// we will process all existing messages,
// but new messages might be added in the process because host mode
// local client messages don't go over the network. they are added
// here directly. (probably...)
// so we make a copy of the list first
List<InternalMsg> tmp = new List<InternalMsg>(m_InternalMsgs);
m_InternalMsgs.Clear();
// iterate through existing set
for (int i = 0; i < tmp.Count; i++)
{
InternalMsg msg = tmp[i];
NetworkMessage internalMessage = new NetworkMessage();
internalMessage.msgType = (short)msg.msgType;
internalMessage.reader = new NetworkReader(msg.content);
internalMessage.conn = connection;
NetworkMessage internalMessage = m_InternalMsgs.Dequeue();
m_Connection.InvokeHandler(internalMessage);
connection.lastMessageTime = Time.time;
}