/* * Copyright (c) Atmosphère-NX * * This program is free software; you can redistribute it and/or modify it * under the terms and conditions of the GNU General Public License, * version 2, as published by the Free Software Foundation. * * This program is distributed in the hope it will be useful, but WITHOUT * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for * more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see <http://www.gnu.org/licenses/>. */ #include <mesosphere.hpp> namespace ams::kern { void KServerPort::Initialize(KPort *parent) { /* Set member variables. */ m_parent = parent; } bool KServerPort::IsLight() const { return this->GetParent()->IsLight(); } void KServerPort::CleanupSessions() { /* Ensure our preconditions are met. */ if (this->IsLight()) { MESOSPHERE_ASSERT(m_session_list.empty()); } else { MESOSPHERE_ASSERT(m_light_session_list.empty()); } /* Cleanup the session list. */ while (true) { /* Get the last session in the list. */ KServerSession *session = nullptr; { KScopedSchedulerLock sl; if (!m_session_list.empty()) { session = std::addressof(m_session_list.front()); m_session_list.pop_front(); } } /* Close the session. */ if (session != nullptr) { session->Close(); } else { break; } } /* Cleanup the light session list. */ while (true) { /* Get the last session in the list. */ KLightServerSession *session = nullptr; { KScopedSchedulerLock sl; if (!m_light_session_list.empty()) { session = std::addressof(m_light_session_list.front()); m_light_session_list.pop_front(); } } /* Close the session. */ if (session != nullptr) { session->Close(); } else { break; } } } void KServerPort::Destroy() { /* Note with our parent that we're closed. */ m_parent->OnServerClosed(); /* Perform necessary cleanup of our session lists. */ this->CleanupSessions(); /* Close our reference to our parent. */ m_parent->Close(); } bool KServerPort::IsSignaled() const { MESOSPHERE_ASSERT_THIS(); if (this->IsLight()) { return !m_light_session_list.empty(); } else { return !m_session_list.empty(); } } void KServerPort::EnqueueSession(KServerSession *session) { MESOSPHERE_ASSERT_THIS(); MESOSPHERE_ASSERT(!this->IsLight()); KScopedSchedulerLock sl; /* Add the session to our queue. */ m_session_list.push_back(*session); if (m_session_list.size() == 1) { this->NotifyAvailable(); } } void KServerPort::EnqueueSession(KLightServerSession *session) { MESOSPHERE_ASSERT_THIS(); MESOSPHERE_ASSERT(this->IsLight()); KScopedSchedulerLock sl; /* Add the session to our queue. */ m_light_session_list.push_back(*session); if (m_light_session_list.size() == 1) { this->NotifyAvailable(); } } KServerSession *KServerPort::AcceptSession() { MESOSPHERE_ASSERT_THIS(); MESOSPHERE_ASSERT(!this->IsLight()); KScopedSchedulerLock sl; /* Return the first session in the list. */ if (m_session_list.empty()) { return nullptr; } KServerSession *session = std::addressof(m_session_list.front()); m_session_list.pop_front(); return session; } KLightServerSession *KServerPort::AcceptLightSession() { MESOSPHERE_ASSERT_THIS(); MESOSPHERE_ASSERT(this->IsLight()); KScopedSchedulerLock sl; /* Return the first session in the list. */ if (m_light_session_list.empty()) { return nullptr; } KLightServerSession *session = std::addressof(m_light_session_list.front()); m_light_session_list.pop_front(); return session; } }