blob: 31cd0b50cccbaa10541f51d5b44747440a5dcb81 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
/*
* Copyright (C) 2016-2018 Team Kodi
* This file is part of Kodi - https://kodi.tv
*
* SPDX-License-Identifier: GPL-2.0-or-later
* See LICENSES/README.md for more information.
*/
#pragma once
#include "threads/CriticalSection.h"
#include <mutex>
namespace detail
{
template<typename Event>
class ISubscription
{
public:
virtual void HandleEvent(const Event& event) = 0;
virtual void Cancel() = 0;
virtual bool IsOwnedBy(void* obj) = 0;
virtual ~ISubscription() = default;
};
template<typename Event, typename Owner>
class CSubscription : public ISubscription<Event>
{
public:
typedef void (Owner::*Fn)(const Event&);
CSubscription(Owner* owner, Fn fn);
void HandleEvent(const Event& event) override;
void Cancel() override;
bool IsOwnedBy(void *obj) override;
private:
Owner* m_owner;
Fn m_eventHandler;
CCriticalSection m_criticalSection;
};
template<typename Event, typename Owner>
CSubscription<Event, Owner>::CSubscription(Owner* owner, Fn fn)
: m_owner(owner), m_eventHandler(fn)
{}
template<typename Event, typename Owner>
bool CSubscription<Event, Owner>::IsOwnedBy(void* obj)
{
std::unique_lock<CCriticalSection> lock(m_criticalSection);
return obj != nullptr && obj == m_owner;
}
template<typename Event, typename Owner>
void CSubscription<Event, Owner>::Cancel()
{
std::unique_lock<CCriticalSection> lock(m_criticalSection);
m_owner = nullptr;
}
template<typename Event, typename Owner>
void CSubscription<Event, Owner>::HandleEvent(const Event& event)
{
std::unique_lock<CCriticalSection> lock(m_criticalSection);
if (m_owner)
(m_owner->*m_eventHandler)(event);
}
}
|
