Сокет .NET 8 ReadAsync: почему последний ответ сообщается точно в момент отмены? ⇐ C#

[Anonymous]

Мне нужно дождаться ответов на широковещательную рассылку UDP с тайм-аутом, поэтому я пробую ReadAsync с токеном отмены и Threading.Timer для подачи сигнала об отмене. Есть еще два компьютера, которые отвечают на трансляцию. Если я использую просто «Чтение», я вижу, что ответы приходят через 0,05 и 0,27 секунды после передачи. При использовании ReadAsync и отмене во время T после широковещательной рассылки ответы сообщаются в T и T-0,22 для T 0,5, 1 и 1,5 с.
Другими словами, ответ от Comp1 всегда сообщается как прибывший во время отмена, а ответ от Comp2 всегда сообщается примерно на 22 мс раньше.
Очень странно, что время получения ответа зависит от таймаута, есть идеи, почему и как получать ответы, как как можно скорее, независимо от таймаута?
Я использую приложение .NET 8 для Windows, просто форму с кнопкой:
private async void button_Click(object sender, EventArgs e) {
udp2 u = new udp2(local);
List rs = await u.Broadcast_as("hPC",TimeSpan.FromSeconds(waittime_sec));
}
public class udp2
{
public readonly struct Reply {
public readonly EndPoint From;
public readonly DateTime When;
public readonly string ReplyString;
public Reply(EndPoint rrom, DateTime when, string reply) {
From = rrom;
When = when;
ReplyString = reply;
}
}

private readonly Socket m_socket;
private readonly List m_replies;
public IList Replies => m_replies;

public udp2(IPEndPoint local) {
m_socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
m_socket.Bind(local);
m_socket.EnableBroadcast = true;
m_replies = new List();
}
public void Shutdown() { if (m_socket.IsBound) m_socket.Shutdown(SocketShutdown.Both); m_socket.Dispose();}
public async Task Broadcast_as(string command, TimeSpan timeout) {
List replies = [];
byte[] dg = Encoding.ASCII.GetBytes(command);
IPEndPoint dst = new(IPAddress.Broadcast, 4321);

m_socket.SendTo(dg,dst);// m_client.Send(dg,"255.255.255.255",4321);
byte[] rq = new byte[1024];
t_bs x = new t_bs();
CancellationToken ct = x.GetToken();
bool cancelled = false;
Stopwatch sw = Stopwatch.StartNew();
using (Timer t = new Timer(t_b,x,(int)timeout.TotalMilliseconds,Timeout.Infinite)) {
do {
IPEndPoint remote = new IPEndPoint(IPAddress.Any,0);
EndPoint epremote = (EndPoint)remote;
try {
SocketReceiveFromResult rres = await m_socket.ReceiveFromAsync(rq,epremote, ct);

if (rres.ReceivedBytes>0) {
Reply re = new Reply(rres.RemoteEndPoint,DateTime.Now,Encoding.ASCII.GetString(rq,0,rres.ReceivedBytes));
replies.Add(re);
}
}
catch (OperationCanceledException) { cancelled = true; sw.Stop();}

} while (!cancelled);
}
Debug.WriteLine("cancelled after "+sw.ElapsedMilliseconds+" ms");
return replies;
}
public List Broadcast_syn(string command, TimeSpan timeout) {
List replies = new List();
byte[] dg = Encoding.ASCII.GetBytes(command);
IPEndPoint dst = new IPEndPoint(IPAddress.Broadcast,4321);

m_socket.SendTo(dg,dst);// m_client.Send(dg,"255.255.255.255",4321);
byte[] rq = new byte[1024];
Closocket x = new Closocket(m_socket);
bool cancelled = false;
using (Timer t = new Timer(t_clo,x,(int)timeout.TotalMilliseconds,System.Threading.Timeout.Infinite)) {
do {
IPEndPoint remote = new IPEndPoint(IPAddress.Any,0);
EndPoint epremote = (EndPoint)remote;
try {
int recount = m_socket.ReceiveFrom(rq,ref epremote);

if (recount>0) {
Reply re = new Reply(epremote,DateTime.Now,Encoding.ASCII.GetString(rq,0,recount));
replies.Add(re);
}
}
catch (OperationCanceledException) { cancelled = true; }
catch (Exception ex) { Debug.WriteLine(ex.Message); cancelled = true;}

} while (!cancelled);
}

return replies;
}
private class t_bs {
private int m_cnt;
private CancellationTokenSource m_cts;
public t_bs() {
m_cts = new CancellationTokenSource();
m_cnt = 0;
}
public CancellationToken GetToken() { return m_cts.Token; }
public void ReqCancellation() { if (m_cnt==0) m_cts.Cancel(); m_cnt=1;}
};
private void t_b(Object? o) {
if (o is t_bs tbs)
tbs.ReqCancellation();
}
}


Подробнее здесь: https://stackoverflow.com/questions/792 ... -time-of-c