aboutsummaryrefslogtreecommitdiff
path: root/Tools/Hazel-Networking/Hazel/Udp/UdpClientConnection.cs
diff options
context:
space:
mode:
Diffstat (limited to 'Tools/Hazel-Networking/Hazel/Udp/UdpClientConnection.cs')
-rw-r--r--Tools/Hazel-Networking/Hazel/Udp/UdpClientConnection.cs6
1 files changed, 4 insertions, 2 deletions
diff --git a/Tools/Hazel-Networking/Hazel/Udp/UdpClientConnection.cs b/Tools/Hazel-Networking/Hazel/Udp/UdpClientConnection.cs
index f6da329..90aeb0d 100644
--- a/Tools/Hazel-Networking/Hazel/Udp/UdpClientConnection.cs
+++ b/Tools/Hazel-Networking/Hazel/Udp/UdpClientConnection.cs
@@ -205,9 +205,10 @@ namespace Hazel.Udp
}
#endif
- var msg = MessageReader.GetSized(this.ReceiveBufferSize);
+ var msg = MessageReader.GetSized(this.ReceiveBufferSize);//一个父message
try
{
+ // Buffer包含MessageWriter的整个内容,包括header
socket.BeginReceive(msg.Buffer, 0, msg.Buffer.Length, SocketFlags.None, ReadCallback, msg);
}
catch
@@ -282,7 +283,7 @@ namespace Hazel.Udp
//Begin receiving again
try
{
- StartListeningForData();
+ StartListeningForData(); //继续接受消息。它这里没有用async await在一个while里轮询,所以需要嵌套调用
}
catch (SocketException e)
{
@@ -305,6 +306,7 @@ namespace Hazel.Udp
DataReceivedRaw?.Invoke(msg.Buffer, msg.Length);
#endif
+ //c //! 重点看这里面长什么样
HandleReceive(msg, msg.Length);
}