开云体育

Let me provide more details about my setup.

I have a USBService class that manages communication with a device using a serial connection. Here’s how I create the USB connection:

To send and receive commands, I use the following method:

public async Task<string> SendCommandAsync(string command)
{
? ? await _sendCommandSemaphore.WaitAsync();
? ? try
? ? {
? ? ? ? using (var serialPortStream = CreateSerialPort(PortName, BaudRate))
? ? ? ? {
? ? ? ? ? ? if (!serialPortStream.IsOpen)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? serialPortStream.Open();
? ? ? ? ? ? }
? ? ? ? ? ??
? ? ? ? ? ? command += "\r";
? ? ? ? ? ? byte[] commandBytes = Encoding.ASCII.GetBytes(command); ? ? ? ? ? ? ? ? ? ?
? ? ? ??
? ? ? ? ? ? serialPortStream.Write(commandBytes, 0, commandBytes.Length);
? ? ? ? ? ? string echoResponse = ReadUntil(serialPortStream, "\r");
? ? ? ? ? ??
? ? ? ? ? ? if (echoResponse.Trim() == command.Trim())
? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ?
? ? ? ? ? ? ? ? string data = ReadUntil(serialPortStream, "ch>");
? ? ? ? ? ? ? ? data = data.TrimEnd("\r\nch>".ToCharArray());
? ? ? ? ? ? ? ? return data;
? ? ? ? ? ? }
? ? ? ? ? ? else
? ? ? ? ? ? {
? ? ? ? ? ? ? ? string errorStr = $"Unexpected echo response: {echoResponse}";
? ? ? ? ? ? ? ? Logger.Log(errorStr);
? ? ? ? ? ? ? ? return errorStr; ? ? ? ? ? ? ? ? ? ? ? ?
? ? ? ? ? ? } ? ? ? ? ? ? ? ? ? ?
? ? ? ? }
? ? }
? ? finally
? ? {
? ? ? ? _sendCommandSemaphore.Release();
? ? }
}

?

Here’s the ReadUntil method used for reading data:

private string ReadUntil(SerialPortStream serialPort, string terminator)
{
? ? byte[] buffer = new byte[1]; ? ? ? ? ? ?
? ?
? ? StringBuilder responseBuilder = new StringBuilder();
? ? while (true)
? ? {
? ? ? ? int bytesRead = serialPort.Read(buffer, 0, buffer.Length);
? ? ? ? if (bytesRead > 0)
? ? ? ? {
? ? ? ? ? ? char currentChar = (char)buffer[0];
? ? ? ? ? ? responseBuilder.Append(currentChar);
? ? ? ? ? ? if (responseBuilder.ToString().EndsWith(terminator))
? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? ? ?
? ? ? ? ? ? ? ? return responseBuilder.ToString();
? ? ? ? ? ? }
? ? ? ? }
? ? ? ? else
? ? ? ? {
? ? ? ? ? ? throw new TimeoutException("Read operation timed out.");
? ? ? ? }
? ? }
}

In my application, I run the following loop to receive data continuously:

private async void Loop()
{
? ? while (_isRunning)
? ? { ? ? ? ? ? ? ? ?
? ? ? ? try
? ? ? ? {
? ? ? ? ? ? var frequenciesString = await UsbService.SendCommandAsync("frequencies");
? ? ? ? ? ? var dataList1 = UsbService.SendCommandAsync("data 1");
? ? ? ? ? ? var dataList2 = UsbService.SendCommandAsync("data 2");
? ? ? ? ? ? var marker = await UsbService.SendCommandAsync("marker 1");
? ? ? ? }
? ? ? ? catch (Exception ex)
? ? ? ? {
? ? ? ? ? ? Logger.Log($"Error: {ex.Message}");
? ? ? ? }
? ? ? ??
? ? ? ? await Task.Delay(500);?
? ? }
}

The Issue:
After running this loop for a few thousand iterations, the program stops receiving data and only returns timeout exceptions.