SikongJueluo/FPGA_WebLab
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: 修改异步接受为同步接受

Browse Source
This commit is contained in:
SikongJueluo
2025-07-16 14:06:29 +08:00
parent b08b86dbbe
commit 57cf82b48f
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
server/src/UdpServer.cs
View File

@@ -491,9 +491,9 @@ public class UDPServer : IDisposable
recvData = Encoding.ASCII.GetString(bytes, 0, bytes.Length);
}
// logger.Debug($"Receive Data from {data.Address}:{data.Port} at {data.DateTime.ToString()}:");
// logger.Debug($" Original Data : {BitConverter.ToString(bytes).Replace("-", " ")}");
// if (recvData.Length != 0) logger.Debug($" Decoded Data : {recvData}");
logger.Debug($"Receive Data from {data.Address}:{data.Port} at {data.DateTime.ToString()}:");
logger.Debug($" Original Data : {BitConverter.ToString(bytes).Replace("-", " ")}");
if (recvData.Length != 0) logger.Debug($" Decoded Data : {recvData}");
return $@"
Receive Data from {data.Address}:{data.Port} at {data.DateTime.ToString()}:
Original Data : {BitConverter.ToString(bytes).Replace("-", " ")}
@@ -811,14 +811,15 @@ public class UDPServer : IDisposable
{
foreach (var client in listeners)
{
Task.Run(async () =>
Task.Run(() =>
{
while (this.isRunning)
{
try
{
var result = await client.ReceiveAsync();
_ = ReceiveHandler(result.Buffer, result.RemoteEndPoint, DateTime.Now);
var ep = new IPEndPoint(IPAddress.Any, listenPort);
var result = client.Receive(ref ep);
_ = ReceiveHandler(result, ep, DateTime.Now);
}
catch (Exception ex)
{