mirror of https://github.com/PCSX2/pcsx2.git
112 lines
3.0 KiB
C++
112 lines
3.0 KiB
C++
/* PCSX2 - PS2 Emulator for PCs
|
|
* Copyright (C) 2002-2010 PCSX2 Dev Team
|
|
*
|
|
* PCSX2 is free software: you can redistribute it and/or modify it under the terms
|
|
* of the GNU Lesser General Public License as published by the Free Software Found-
|
|
* ation, either version 3 of the License, or (at your option) any later version.
|
|
*
|
|
* PCSX2 is distributed in the hope that 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 PCSX2.
|
|
* If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
#include "common/Threading.h"
|
|
|
|
using Threading::ScopedLock;
|
|
|
|
template <typename ListenerType>
|
|
typename EventSource<ListenerType>::ListenerIterator EventSource<ListenerType>::Add(ListenerType& listener)
|
|
{
|
|
ScopedLock locker(m_listeners_lock);
|
|
|
|
// Check for duplicates before adding the event.
|
|
if (IsDebugBuild)
|
|
{
|
|
ListenerIterator iter = m_listeners.begin();
|
|
while (iter != m_listeners.end())
|
|
{
|
|
if ((*iter) == &listener)
|
|
return iter;
|
|
++iter;
|
|
}
|
|
}
|
|
return _AddFast_without_lock(listener);
|
|
}
|
|
|
|
template <typename ListenerType>
|
|
void EventSource<ListenerType>::Remove(ListenerType& listener)
|
|
{
|
|
ScopedLock locker(m_listeners_lock);
|
|
m_cache_valid = false;
|
|
m_listeners.remove(&listener);
|
|
}
|
|
|
|
template <typename ListenerType>
|
|
void EventSource<ListenerType>::Remove(const ListenerIterator& listenerHandle)
|
|
{
|
|
ScopedLock locker(m_listeners_lock);
|
|
m_cache_valid = false;
|
|
m_listeners.erase(listenerHandle);
|
|
}
|
|
|
|
template <typename ListenerType>
|
|
typename EventSource<ListenerType>::ListenerIterator EventSource<ListenerType>::_AddFast_without_lock(ListenerType& listener)
|
|
{
|
|
m_cache_valid = false;
|
|
m_listeners.push_front(&listener);
|
|
return m_listeners.begin();
|
|
}
|
|
|
|
|
|
template <typename ListenerType>
|
|
__fi void EventSource<ListenerType>::_DispatchRaw(ListenerIterator iter, const ListenerIterator& iend, const EvtParams& evtparams)
|
|
{
|
|
while (iter != iend)
|
|
{
|
|
try
|
|
{
|
|
(*iter)->DispatchEvent(evtparams);
|
|
}
|
|
catch (Exception::RuntimeError& ex)
|
|
{
|
|
if (IsDevBuild)
|
|
{
|
|
pxFailDev(L"Ignoring runtime error thrown from event listener (event listeners should not throw exceptions!): " + ex.FormatDiagnosticMessage());
|
|
}
|
|
else
|
|
{
|
|
Console.Error(L"Ignoring runtime error thrown from event listener: " + ex.FormatDiagnosticMessage());
|
|
}
|
|
}
|
|
catch (BaseException& ex)
|
|
{
|
|
if (IsDevBuild)
|
|
{
|
|
ex.DiagMsg() = L"Non-runtime BaseException thrown from event listener .. " + ex.DiagMsg();
|
|
throw;
|
|
}
|
|
Console.Error(L"Ignoring non-runtime BaseException thrown from event listener: " + ex.FormatDiagnosticMessage());
|
|
}
|
|
++iter;
|
|
}
|
|
}
|
|
|
|
template <typename ListenerType>
|
|
void EventSource<ListenerType>::Dispatch(const EvtParams& evtparams)
|
|
{
|
|
if (!m_cache_valid)
|
|
{
|
|
m_cache_copy = m_listeners;
|
|
m_cache_valid = true;
|
|
}
|
|
|
|
if (m_cache_copy.empty())
|
|
return;
|
|
_DispatchRaw(m_cache_copy.begin(), m_cache_copy.end(), evtparams);
|
|
}
|