timur/ADC
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

...

Browse Source
This commit is contained in:
Timur A. Fatkhullin 2024-06-16 22:18:15 +03:00
parent 3e8a113c3a
commit 143f54b989
1 changed files with 22 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
net/adc_netserver.h
View File

@ -7,6 +7,7 @@ ABSTRACT DEVICE COMPONENTS LIBRARY
*/ */
#include <filesystem> #include <filesystem>
#include <functional>
#include <set> #include <set>
#include <unordered_map> #include <unordered_map>
@ -262,12 +263,30 @@ protected:
// started sessions waek pointers // started sessions waek pointers
template <traits::adc_netserver_session_c SessionT> template <traits::adc_netserver_session_c SessionT>
static std::unordered_map<const AdcNetServer*, std::set<typename SessionT::weak_ptr_t>> _serverSessions; static std::unordered_map<const AdcNetServer*, std::set<typename SessionT::weak_ptr_t>> _serverSessions;
std::vector<std::function<void()>> _stopSessionFunc;
template <traits::adc_netserver_session_c SessionT> template <traits::adc_netserver_session_c SessionT>
void startAsyncSession(const typename SessionT::shared_ptr_t& sess_ptr) void startSession(const typename SessionT::shared_ptr_t& sess_ptr)
{ {
_serverSessions<SessionT>[this].insert(sess_ptr); auto res = _serverSessions<SessionT>[this].emplace(sess_ptr);
if (res.second) {
sess_ptr.start(); sess_ptr.start();
_stopSessionFunc.emplace_back([res]() {
if (!res.first.expired()) { // session is still existing
auto sess = res.first.lock();
sess->stop();
}
});
}
}
void stopAllSessions()
{
for (auto& func : _stopSessionFunc) {
func();
}
} }
virtual void daemonizePrepare() virtual void daemonizePrepare()