Assert спустя некоторое время без активности

[AlexYrkn]

Спустя некоторое время после запуска (минуты 2) валится assert:

Process terminated. Assertion Failed at QuikSharp.QuikService.<Start>b__53_2() in /Users/alexyrkn/personal/QUIKSharp/src/QuikSharp/QuikService.cs:line 308 at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state) at System.Runtime.CompilerServices.AsyncTaskMethodBuilder1.AsyncStateMachineBox1.MoveNext(Thread threadPoolThread) at System.Threading.Tasks.AwaitTaskContinuation.RunOrScheduleAction(IAsyncStateMachineBox box, Boolean allowInlining) at System.Threading.Tasks.Task.RunContinuations(Object continuationObject) at System.Threading.Tasks.Task.TwoTaskWhenAnyPromise1.Invoke(Task completingTask)
at System.Threading.Tasks.Task.RunContinuations(Object continuationObject)
at System.Threading.Tasks.Task.FinishSlow(Boolean userDelegateExecute)
at System.Threading.Tasks.Task.TrySetException(Object exceptionObject)
at System.Runtime.CompilerServices.AsyncTaskMethodBuilder1.SetException(Exception exception, Task1& taskField)
at System.IO.StreamReader.ReadLineAsyncInternal(CancellationToken cancellationToken)
at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state)
at System.Threading.Tasks.AwaitTaskContinuation.RunOrScheduleAction(IAsyncStateMachineBox box, Boolean allowInlining)
at System.Threading.Tasks.Task.RunContinuations(Object continuationObject)
at System.Threading.Tasks.Task.FinishSlow(Boolean userDelegateExecute)
at System.Threading.Tasks.Task.TrySetException(Object exceptionObject)
at System.Runtime.CompilerServices.AsyncTaskMethodBuilder1.SetException(Exception exception, Task1& taskField)
at System.IO.StreamReader.ReadBufferAsync(CancellationToken cancellationToken)
at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state)
at System.Runtime.CompilerServices.AsyncTaskMethodBuilder1.AsyncStateMachineBox1.MoveNext(Thread threadPoolThread)
at System.Net.Sockets.SocketAsyncEventArgs.TransferCompletionCallbackCore(Int32 bytesTransferred, Memory1 socketAddress, SocketFlags receivedFlags, SocketError socketError) at System.Net.Sockets.SocketAsyncEngine.System.Threading.IThreadPoolWorkItem.Execute() at System.Threading.ThreadPoolWorkQueue.Dispatch() at System.Threading.PortableThreadPool.WorkerThread.WorkerThreadStart() at System.Threading.Thread.StartCallback()

с чем может быть связано?
Если ассерт перехватывать, то после него любой метод висит в бесконечном ожидании.

Повторяется независимо от действий с квиком, даже просто если сделаю один запрос и потом будет висеть неактивно, то все равно ассерт.

[Pr0phet1c]

1. Слишком мало информации.
2. Я так понимаю, речь снова про работу на macOS. Я в этом не силен. Возможно проблемы в недостаточном уровне совместимости кода бибилиотеки с этой ОС.
3. Первичные признаки указывают на возможное наличие проблемы с соединением с терминалом. Вы смотрели как в это время ведет себя Lua-скрипт QuikSharp? Он у Вас случайно с ошибкой не отваливается?
4. Попробуйте помучать ИИ с этим вопросом. Может он Вам сможет посоветовать что-то...

[AlexYrkn]

Удалось победить: необходимо было установить при создании NetworkStream флаг ownsSocket: false, потому что по дефолту там стоит true и при окончании using, когда удаляется стрим, он в свою очередь убивает сокет, который вообще-то используют два стрима в requestTask и responseTask. И как раз в macos и Windows отличаются политиками закрытия стрима и макось его жестко сразу абортит и второму стриму тоже обрубается и вылетает assert.

Но закрытие подключения управляется в блоке finally для каждой таски и с учетом того, что его используют два стрима. Оно и логично, что подключение должно управляться таким образом, а не стримом, поэтому считаю, что данный фикс имеет места быть в основной версии.

Фиксы проверил с винды - все работает корректно.

Если нужно могу кинуть PR или уточнить конкретно, где произведены правки.

[AlexYrkn]

UPD: Assert, к сожалению, вернулся на маке.

С ИИ ни до чего путного не дошел. По информации: скрипт максимально упростил - подключаемся к квику, получаем торговые аккаунт и ждем в бесконечном цикле. Через минуту цикла падает от ассерта

В квике в момент ассерта просто QUIK# client disconnected

Если убирать ассерт, то не падает, а просто отключается, а через некоторое время сам реконнектится

[AlexYrkn]

UPD2: все работает, если регулярно слать запросы (например, пинг)

Но если соединение висит неактино более 1 минут, то все падает

[Pr0phet1c]

UPD2: все работает, если регулярно слать запросы (например, пинг)

вот что по этому поводу подсказывает ИИ:
Возможные исправления или обходные пути
Для диагностики/решения:

Добавление Heartbeats: Измените код, чтобы периодически отправлять "ping"-сообщения (например, фиктивный запрос каждые 30-60 секунд) для поддержания соединения. Реализуйте через фоновый таймер в QuikService.

private Timer _heartbeatTimer;

private void StartHeartbeat()
{
_heartbeatTimer = new Timer(state =>
{
if (!_cts.IsCancellationRequested)
{
var pingMessage = new Message { Command = "ping", Data = "heartbeat" };
EnvelopeQueue.Add(pingMessage);
}
}, null, TimeSpan.FromSeconds(30), TimeSpan.FromSeconds(30));
}

private void StopHeartbeat()
{
_heartbeatTimer?.Dispose();
}

Вызовите StartHeartbeat() в Start() и StopHeartbeat() в Stop().

Включение TCP Keep-Alive: В EnsureConnectedClient() после подключения:
if (readLineTask.Status == TaskStatus.Faulted) {
Trace.TraceError($"Read failed: {readLineTask.Exception}");
throw new IOException("Read failed", readLineTask.Exception);
} else {
Trace.Assert(readLineTask.Status == TaskStatus.RanToCompletion);
}

Аналогично для _callbackClient.

Обработка Faulted задач: Оберните утверждение в try-catch и проверяйте Faulted:

_responseClient.Client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.KeepAlive, true);
// Опционально: настройка интервалов (на macOS может потребоваться специфичный ioctl)

Это предотвратит зависание, передавая ошибку и запуская логику повторного подключения.

Увеличение тайм-аута или агрессивное переподключение: В EnsureConnectedClient() уменьшите интервалы Thread.Sleep или добавьте экспоненциальную задержку. Проверьте с увеличенным DefaultSendTimeout.
Тестирование окружения:

Запустите на Windows для изоляции проблем macOS.
Используйте netstat или tcpdump на macOS для мониторинга состояния сокета (например, проверка FIN/RST пакетов через 2 минуты).
Убедитесь, что Quik запущен и Lua-скрипт загружен (проверьте консоль скриптов Quik на ошибки).
При использовании Wine/VM убедитесь, что сеть настроена в режиме моста, а не NAT.

Отладка: Добавьте логирование вокруг reader.ReadLineAsync() (например, статус задачи и исключения). Соберите с дебаг-символами и подключите отладчик для перехвата внутреннего исключения.

/////////////////////

Однако, сразу скажу, что в текущую версию библиотеки я не пока планирую вносить эти изменения. Рекомендую Вам все эти эксперименты и заточку под macOS выполнять в своем форке.