|
|
@ -36,14 +36,14 @@ public:
|
|
|
|
|
|
|
|
|
|
|
|
private:
|
|
|
|
private:
|
|
|
|
KernelCore& kernel;
|
|
|
|
KernelCore& kernel;
|
|
|
|
|
|
|
|
|
|
|
|
std::jthread m_host_thread;
|
|
|
|
|
|
|
|
std::mutex m_session_mutex;
|
|
|
|
|
|
|
|
std::map<KServerSession*, std::shared_ptr<SessionRequestManager>> m_sessions;
|
|
|
|
|
|
|
|
KEvent* m_wakeup_event;
|
|
|
|
|
|
|
|
KThread* m_thread;
|
|
|
|
|
|
|
|
std::atomic<bool> m_shutdown_requested;
|
|
|
|
|
|
|
|
const std::string m_service_name;
|
|
|
|
const std::string m_service_name;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
std::jthread m_host_thread{};
|
|
|
|
|
|
|
|
std::mutex m_session_mutex{};
|
|
|
|
|
|
|
|
std::map<KServerSession*, std::shared_ptr<SessionRequestManager>> m_sessions{};
|
|
|
|
|
|
|
|
KEvent* m_wakeup_event{};
|
|
|
|
|
|
|
|
KThread* m_thread{};
|
|
|
|
|
|
|
|
std::atomic<bool> m_shutdown_requested{};
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
void ServiceThread::Impl::WaitAndProcessImpl() {
|
|
|
|
void ServiceThread::Impl::WaitAndProcessImpl() {
|
|
|
|