summaryrefslogtreecommitdiff
path: root/src/sessionManager.cpp
diff options
context:
space:
mode:
authorlittleblack111 <littleblack11111@gmail.com>2025-05-20 19:00:37 +0800
committerlittleblack111 <littleblack11111@gmail.com>2025-05-20 19:00:37 +0800
commit9e3a7d5238d1b1c7a00e457f67a8108108909f01 (patch)
tree713628aff287107182d1bd2a0f23f0327618b3c1 /src/sessionManager.cpp
parent092965b583bd0c377ed5d9f2af0e0f4bb0548354 (diff)
Revert "internal: use smart pointer for everything, no more naked pointer"
This reverts commit 72cf95bc9b1eb338457a0815eb1fe4f70b42ebb3. segfault/IOT instruct on client exit...
Diffstat (limited to 'src/sessionManager.cpp')
-rw-r--r--src/sessionManager.cpp29
1 files changed, 15 insertions, 14 deletions
diff --git a/src/sessionManager.cpp b/src/sessionManager.cpp
index 6d9df28..b81aeaf 100644
--- a/src/sessionManager.cpp
+++ b/src/sessionManager.cpp
@@ -12,7 +12,7 @@ void CSessionManager::shutdownSessions() {
return;
for (auto &session : m_vSessions)
- kick(std::unique_ptr<std::pair<std::jthread, std::shared_ptr<CSession>>>(&session), false, "Server shutting down");
+ kick(&session, false, "Server shutting down");
}
CSessionManager::CSessionManager() {
@@ -35,10 +35,11 @@ CSessionManager::~CSessionManager() {
log(SYS, "SessionManager: bye");
}
-void CSessionManager::newSession() {
+std::pair<std::jthread, std::shared_ptr<CSession>> *CSessionManager::newSession() {
std::shared_ptr session = std::make_shared<CSession>();
- auto instance = std::unique_ptr<std::pair<std::jthread, std::shared_ptr<CSession>>>(&m_vSessions.emplace_back(std::jthread(&CSession::run, session.get()), session));
- instance->second->setSelf(std::move(instance));
+ const auto instance = &m_vSessions.emplace_back(std::jthread(&CSession::run, session.get()), session);
+ instance->second->setSelf(instance);
+ return instance;
}
void CSessionManager::run() {
@@ -65,7 +66,7 @@ bool CSessionManager::nameExists(const std::string &name) {
if (it != m_vSessions.end()) {
if (!it->second->isValid()) {
- kick(it->second, true, "Connection lost");
+ kick(it->second.get(), true, "Connection lost");
return false;
}
return true;
@@ -73,28 +74,28 @@ bool CSessionManager::nameExists(const std::string &name) {
return false;
}
-std::shared_ptr<CSession> CSessionManager::getByName(const std::string &name) const {
+CSession *CSessionManager::getByName(const std::string &name) const {
auto it = std::ranges::find_if(m_vSessions, [&name](const auto &s) { return s.second->getName() == name; });
- return it != m_vSessions.end() ? it->second : nullptr;
+ return it != m_vSessions.end() ? it->second.get() : nullptr;
}
-std::shared_ptr<CSession> CSessionManager::getByIp(const std::string &ip) const {
+CSession *CSessionManager::getByIp(const std::string &ip) const {
auto it = std::ranges::find_if(m_vSessions, [&ip](const auto &s) { log(LOG, s.second->m_ip); return s.second->m_ip == ip; });
- return it != m_vSessions.end() ? it->second : nullptr;
+ return it != m_vSessions.end() ? it->second.get() : nullptr;
}
std::vector<std::shared_ptr<CSession>> CSessionManager::getSessions() const {
return m_vSessions | std::views::transform([](const auto &s) { return s.second; }) | std::ranges::to<std::vector>();
}
-void CSessionManager::kick(std::shared_ptr<CSession> session, const bool kill, const std::string &reason) {
+void CSessionManager::kick(CSession *session, const bool kill, const std::string &reason) {
for (auto &_session : m_vSessions)
- if (_session.second == session)
- kick(std::unique_ptr<std::pair<std::jthread, std::shared_ptr<CSession>>>(&_session), kill, reason);
+ if (_session.second.get() == session)
+ kick(&_session, kill, reason);
}
-void CSessionManager::kick(std::unique_ptr<std::pair<std::jthread, std::shared_ptr<CSession>>> session, const bool kill, const std::string &reason) {
- auto it = std::ranges::find_if(m_vSessions, [&session](const auto &s) { return s.second.get() == session->second.get(); });
+void CSessionManager::kick(std::pair<std::jthread, std::shared_ptr<CSession>> *session, const bool kill, const std::string &reason) {
+ auto it = std::ranges::find_if(m_vSessions, [session](const auto &s) { return s.second.get() == session->second.get(); });
if (it != m_vSessions.end()) {
if (!reason.empty()) {