Serial port кидает таймауты хотя их нет
30.01.2026, 13:37. Показов 341. Ответов 1
maui проект, net10, по serial port обмен с устройством
устройство стабильно всегда отвечает за 50мс
у меня же, как бы я не пробовал и через BaseStream, и через DataReceived, и EndRead - я получаю таймауты.
уже и вынес за тред пул, в новый поток
и не важно таймаут 200мс или 16сек он все равно периодически выскакивает
уже сдался сделал консольное приложение просто ради теста
| C# | 1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
| class Program
{
static void Main()
{
var portName = "COM5";
var baudRate = 9600;
using var port = new SerialPort(portName, baudRate)
{
Parity = Parity.None,
DataBits = 8,
StopBits = StopBits.One,
Handshake = Handshake.None,
ReadTimeout = 500,
WriteTimeout = 500,
DtrEnable = true,
RtsEnable = true
};
port.Open();
Console.WriteLine("PORT OPENED");
byte[] request = new byte[] { 0xFA, 0xCE, 0x01, 0x01, 0x00, 0x00, 0x00, 0xDE, 0xAD, 0xBE, 0xEF };
while (true)
{
try
{
// Отправка запроса
port.Write(request, 0, request.Length);
Console.WriteLine($"Sent: {BitConverter.ToString(request)}");
// Чтение всех байтов, которые пришли
Thread.Sleep(50); // даём контроллеру время
while (port.BytesToRead > 0)
{
int count = port.BytesToRead;
byte[] buffer = new byte[count];
port.Read(buffer, 0, count);
Console.WriteLine($"Received: {BitConverter.ToString(buffer)}");
}
Thread.Sleep(200); // пауза перед следующим запросом
}
catch (TimeoutException)
{
Console.WriteLine("Timeout");
}
catch (Exception ex)
{
Console.WriteLine("Error: " + ex.Message);
}
}
}
} |
|
все стабильно таймаутов нет
дальше ради интереса сделал тоже самое в maui
| C# | 1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
| private void TestWorkerLoop(CancellationToken ct)
{
byte[] buffer = new byte[1024];
_eventBus.RaiseLoging($"Тестовый worker запущен в потоке ID: {Thread.CurrentThread.ManagedThreadId}");
while (!ct.IsCancellationRequested && _serialPort != null && _serialPort.IsOpen)
{
try
{
// Отправка тестового запроса
_serialPort.Write(TestRequest, 0, TestRequest.Length);
_eventBus.RaiseLoging($"[{DateTime.UtcNow:HH:mm:ss.fff}] Отправлено: {BitConverter.ToString(TestRequest)}");
// Даём время контроллеру ответить
Thread.Sleep(50);
// Чтение всех байтов
while (_serialPort.BytesToRead > 0)
{
int count = _serialPort.BytesToRead;
int read = _serialPort.Read(buffer, 0, Math.Min(count, buffer.Length));
if (read > 0)
{
byte[] received = buffer.AsSpan(0, read).ToArray();
_eventBus.RaiseLoging($"[{DateTime.UtcNow:HH:mm:ss.fff}] Получено: {BitConverter.ToString(received)}");
_eventBus.RaiseDeviceRead(received); // если нужно событие
}
}
Thread.Sleep(100); // пауза перед следующим запросом
}
catch (Exception ex)
{
_eventBus.RaiseLoging($"Ошибка в тестовом worker: {ex.Message}");
Thread.Sleep(1000);
}
}
_eventBus.RaiseLoging("Тестовый worker завершён");
}
} |
|
все работает нет никаких таймаутов
но как только запросы приходят из вне и появляется хоть какая то логика поиска пакетов, то я начинаю получать периодически, рандомно эти таймауты
вот последняя версия класса, который пробую сделать, временно воткнул ретраи иногда доходит до 2 штук, 3 пока не наблюдал
| C# | 1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
| public sealed class WindowsSerialPortService : ISerialPortService, IAsyncDisposable
{
private static readonly byte[] PacketStart = { 0xFA, 0xCE };
private static readonly byte[] PacketEnd = { 0xDE, 0xAD, 0xBE, 0xEF };
private readonly AppEventBus _eventBus;
private SerialPort? _serialPort;
private CancellationTokenSource? _cts;
private Task? _rxTask;
private readonly ConcurrentQueue<PendingRequest> _queue = new();
private PendingRequest? _currentRequest;
private readonly List<byte> _rxBuffer = new(4096);
private readonly object _lock = new();
public bool IsConnected => _serialPort?.IsOpen == true;
public SerialPortDeviceInfo? CurrentSerialPortDevice { get; private set; }
public WindowsSerialPortService(AppEventBus eventBus)
{
_eventBus = eventBus ?? throw new ArgumentNullException(nameof(eventBus));
}
public IReadOnlyList<SerialPortDeviceInfo> GetAvailablePorts()
{
var result = new List<SerialPortDeviceInfo>();
using var searcher = new ManagementObjectSearcher(
"SELECT Name FROM Win32_PnPEntity WHERE Name LIKE '%(COM%[0-9]%)' AND ConfigManagerErrorCode = 0");
foreach (var obj in searcher.Get())
{
using (obj)
{
var name = obj["Name"]?.ToString();
if (string.IsNullOrEmpty(name)) continue;
var port = ExtractPortName(name);
if (port != null)
result.Add(new SerialPortDeviceInfo { PortName = port, Description = name });
}
}
return result;
}
private static string? ExtractPortName(string name)
{
var start = name.LastIndexOf("(COM", StringComparison.OrdinalIgnoreCase);
if (start < 0) return null;
var end = name.IndexOf(')', start);
if (end < 0) return null;
return name.Substring(start + 1, end - start - 1);
}
public void SetCurrentSerialPortDevice(SerialPortDeviceInfo device)
{
if (IsConnected)
throw new InvalidOperationException("Cannot change device while connected");
CurrentSerialPortDevice = device ?? throw new ArgumentNullException(nameof(device));
}
public Task<bool> ConnectAsync(CancellationToken ct = default)
{
if (CurrentSerialPortDevice == null)
throw new InvalidOperationException("Serial port device not selected");
_serialPort = new SerialPort(
CurrentSerialPortDevice.PortName,
9600,
Parity.None,
8,
StopBits.One)
{
ReadTimeout = 100,
WriteTimeout = 500,
DtrEnable = true,
RtsEnable = true
};
_serialPort.Open();
_cts = CancellationTokenSource.CreateLinkedTokenSource(ct);
_rxTask = Task.Run(() => RxLoopAsync(_cts.Token));
_eventBus.RaiseLoging($"Serial connected: {_serialPort.PortName}");
return Task.FromResult(true);
}
public async Task DisconnectAsync(CancellationToken ct = default)
{
_cts?.Cancel();
if (_rxTask != null)
{
try { await _rxTask; } catch { }
_rxTask = null;
}
if (_serialPort != null)
{
try { _serialPort.Close(); } catch { }
_serialPort.Dispose();
_serialPort = null;
}
_cts?.Dispose();
_cts = null;
_currentRequest = null;
}
public Task<byte[]> SendAsync(byte[] request, CancellationToken ct = default)
{
if (!IsConnected)
throw new InvalidOperationException("Serial port not connected");
var pending = new PendingRequest(request, ct);
_queue.Enqueue(pending);
TrySendNext();
return pending.Tcs.Task;
}
public async ValueTask DisposeAsync()
{
await DisconnectAsync();
GC.SuppressFinalize(this);
}
private async Task RxLoopAsync(CancellationToken ct)
{
var buffer = new byte[512];
while (!ct.IsCancellationRequested && _serialPort?.IsOpen == true)
{
try
{
// Чтение с таймаутом
int bytesRead = 0;
try
{
bytesRead = await _serialPort.BaseStream.ReadAsync(buffer, 0, buffer.Length, ct);
}
catch (OperationCanceledException) { break; }
catch (TimeoutException) { bytesRead = 0; }
if (bytesRead > 0)
{
lock (_lock)
{
_rxBuffer.AddRange(buffer.AsSpan(0, bytesRead).ToArray());
}
}
// Парсинг пакетов
while (TryExtractPacket(out var packet))
{
_eventBus.RaiseDeviceRead(packet);
if (_currentRequest != null)
{
_currentRequest.Tcs.TrySetResult(packet);
_currentRequest = null;
TrySendNext();
}
}
await Task.Delay(10, ct); // CPU relief
}
catch (Exception ex)
{
_eventBus.RaiseLoging($"RX loop error: {ex.Message}");
}
}
_eventBus.RaiseLoging("RX loop finished");
}
private void TrySendNext()
{
if (_currentRequest != null) return;
if (!_queue.TryDequeue(out var next)) return;
_currentRequest = next;
_currentRequest.SentAtUtc = DateTime.UtcNow;
Task.Run(async () =>
{
int attempt = 0;
while (attempt <= 2 && !_cts?.IsCancellationRequested == true)
{
try
{
// Отправка запроса
_serialPort!.Write(next.Request, 0, next.Request.Length);
_eventBus.RaiseDeviceWritten(next.Request);
// Ждём завершения с таймаутом
var delayTask = Task.Delay(300);
var completedTask = await Task.WhenAny(next.Tcs.Task, delayTask);
if (completedTask == next.Tcs.Task)
{
// Успех
break;
}
else
{
attempt++;
_eventBus.RaiseLoging($"Request timeout, retry {attempt}/2");
if (attempt > 2)
{
next.Tcs.TrySetException(new TimeoutException("Serial response timeout after retries"));
break;
}
}
}
catch (Exception ex)
{
_currentRequest = null;
next.Tcs.TrySetException(ex);
break;
}
}
_currentRequest = null;
TrySendNext();
});
}
private bool TryExtractPacket(out byte[] packet)
{
packet = Array.Empty<byte>();
lock (_lock)
{
if (_rxBuffer.Count < PacketStart.Length + PacketEnd.Length)
return false;
var span = CollectionsMarshal.AsSpan(_rxBuffer);
int start = span.IndexOf(PacketStart);
if (start < 0)
{
_rxBuffer.Clear();
return false;
}
var afterStart = span.Slice(start + PacketStart.Length);
int end = afterStart.IndexOf(PacketEnd);
if (end < 0)
return false;
int packetLength = PacketStart.Length + end + PacketEnd.Length;
packet = span.Slice(start, packetLength).ToArray();
_rxBuffer.RemoveRange(0, start + packetLength);
return true;
}
}
private sealed class PendingRequest
{
public byte[] Request { get; }
public TaskCompletionSource<byte[]> Tcs { get; }
public CancellationToken Token { get; }
public DateTime SentAtUtc { get; set; }
public PendingRequest(byte[] request, CancellationToken token)
{
Request = request;
Token = token;
Tcs = new TaskCompletionSource<byte[]>(TaskCreationOptions.RunContinuationsAsynchronously);
}
}
} |
|
есть идеи откуда берутся таймауты эти( ? DataReceived вообще как бдуто бы иногда не приходит, в не maui не встречал таких проблем раньше
0
|
(
