Method StartUpdatingInSeparateThread

Src/Core/DeviceBridge.cpp:104–149

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

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
void FSecure::C3::Core::DeviceBridge::StartUpdatingInSeparateThread()
{
	std::thread{
		[this, self = shared_from_this()]()
		{
			WinTools::StructuredExceptionHandling::SehWrapper([&]()
			{
				while (m_IsAlive)
					try
					{
						std::this_thread::sleep_for(GetDevice()->GetUpdateDelay());
						
						OnReceive();

						// Give the other end some time to respond to the receive if a fast comms mechanism.
						std::this_thread::sleep_for(std::chrono::milliseconds(50));

						// Previous bug occurred where we only received when sendqueue was empty
						// But if sendqueue fills faster than the update delay then we never receive a message
						if (!m_SendQueue.empty())
						{
							ByteVector msg;
							{
								auto lock = std::lock_guard<std::mutex>{ m_ProtectWriteInConcurrentThreads };
								msg = std::move(m_SendQueue.front());
								m_SendQueue.pop_front();
							}
							OnSend(msg);
						}
					}
					catch (std::exception const& exception)
					{
						Log({ OBF_SEC("std::exception while updating: ") + exception.what(), LogMessage::Severity::Error });
					}
					catch (...)
					{
						Log({ OBF_SEC("Unknown exception while updating."), LogMessage::Severity::Error });
					}
			}, [this]()
			{
#				if defined _DEBUG
						Log({ "Signal captured, ending thread execution.", LogMessage::Severity::Error });
#				endif
			});
		}}.detach();
}

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
void FSecure::C3::Core::DeviceBridge::SetUpdateDelay(std::chrono::milliseconds minUpdateDelayInMs, std::chrono::milliseconds maxUpdateDelayInMs)