blob: 9516ff189783f00a3837d052d87d993714dfe9a9 (
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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
// Copyright 2018 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef OSP_IMPL_SERVICE_LISTENER_IMPL_H_
#define OSP_IMPL_SERVICE_LISTENER_IMPL_H_
#include <vector>
#include "osp/impl/receiver_list.h"
#include "osp/impl/with_destruction_callback.h"
#include "osp/public/service_info.h"
#include "osp/public/service_listener.h"
#include "platform/base/macros.h"
namespace openscreen {
namespace osp {
class ServiceListenerImpl final : public ServiceListener,
public WithDestructionCallback {
public:
class Delegate {
public:
Delegate();
void SetListenerImpl(ServiceListenerImpl* listener);
virtual void StartListener() = 0;
virtual void StartAndSuspendListener() = 0;
virtual void StopListener() = 0;
virtual void SuspendListener() = 0;
virtual void ResumeListener() = 0;
virtual void SearchNow(State from) = 0;
protected:
virtual ~Delegate();
void SetState(State state) { listener_->SetState(state); }
ServiceListenerImpl* listener_ = nullptr;
};
// |delegate| is used to implement state transitions.
explicit ServiceListenerImpl(Delegate* delegate);
~ServiceListenerImpl() override;
// Called by |delegate_| when there are updates to the available receivers.
void OnReceiverAdded(const ServiceInfo& info);
void OnReceiverChanged(const ServiceInfo& info);
void OnReceiverRemoved(const ServiceInfo& info);
void OnAllReceiversRemoved();
// Called by |delegate_| when an internal error occurs.
void OnError(ServiceListenerError error);
// ServiceListener overrides.
bool Start() override;
bool StartAndSuspend() override;
bool Stop() override;
bool Suspend() override;
bool Resume() override;
bool SearchNow() override;
void AddObserver(Observer* observer) override;
void RemoveObserver(Observer* observer) override;
const std::vector<ServiceInfo>& GetReceivers() const override;
private:
// Called by |delegate_| to transition the state machine (except kStarting and
// kStopping which are done automatically).
void SetState(State state);
// Notifies each observer in |observers_| if the transition to |state_| is one
// that is watched by the observer interface.
void MaybeNotifyObservers();
Delegate* const delegate_;
ReceiverList receiver_list_;
OSP_DISALLOW_COPY_AND_ASSIGN(ServiceListenerImpl);
};
} // namespace osp
} // namespace openscreen
#endif // OSP_IMPL_SERVICE_LISTENER_IMPL_H_
|
