Код: Выделить всё
public async Task SendDataAsync(bytes[] data, CancellationToken ct)
{
//Send to wire
await TcpClient.GetStream().WriteAsync(bytes, ct);
//read the reply
var buffer = new byte[256];
var bytesRead = await TcpClient.GetStream().ReadAsync(buffer, ct);
if (bytesRead == 0)
{
Disconnect();
//Shit went down
throw new ModbusExceptions.ConnectionException("Recevied 0 bytes read, socket was closed");
}
}
Однако сейчас у нас есть случай, где находится TCP-клиент, из которого мы пытаемся прочитать данные. В определенном сценарии он не отвечает (поэтому он получит наши данные, т.е. запись работает), но он не ответит.
В этом случае я бы сидел и ждал вечно на своей линии приема.
Поэтому я теперь добавил тайм-аут с использованием токена отмены на 5 секунд.
Код: Выделить всё
using (var ct = new CancellationTokenSource(5000))
{
await SendDataAsync(bytes, ct.Token);
}
Поэтому, если я попытаюсь вызвать await SendDataAsync(bytes, ct.Token); во второй раз. Я получаю исключение, в котором говорится, что вы не можете выполнить эту операцию с неоткрытым сокетом.
Я что-то здесь упускаю?
Конечно, если мой поток запись отменяется, но токен, мне не нужно заново устанавливать новый TCP-сокет с клиентом?
В моем случае я просто хочу подождать 5000 мс, а затем попробовать отправить следующее сообщение снова?
Подробнее здесь: https://stackoverflow.com/questions/790 ... tcp-socket