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
87
88
89
90
91
92
93
94
95
96
97
|
// Copyright 2012 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef REMOTING_PROTOCOL_JINGLE_SESSION_MANAGER_H_
#define REMOTING_PROTOCOL_JINGLE_SESSION_MANAGER_H_
#include <map>
#include <string>
#include "base/memory/raw_ptr.h"
#include "base/memory/weak_ptr.h"
#include "base/observer_list.h"
#include "base/sequence_checker.h"
#include "remoting/protocol/jingle_messages.h"
#include "remoting/protocol/session_manager.h"
#include "remoting/protocol/session_observer.h"
#include "remoting/signaling/signal_strategy.h"
namespace jingle_xmpp {
class XmlElement;
} // namespace jingle_xmpp
namespace remoting {
class IqSender;
namespace protocol {
class JingleSession;
// JingleSessionManager and JingleSession implement the subset of the
// Jingle protocol used in Chromoting. JingleSessionManager provides
// the protocol::SessionManager interface for accepting incoming and
// creating outgoing sessions.
class JingleSessionManager : public SessionManager,
public SignalStrategy::Listener {
public:
explicit JingleSessionManager(SignalStrategy* signal_strategy);
JingleSessionManager(const JingleSessionManager&) = delete;
JingleSessionManager& operator=(const JingleSessionManager&) = delete;
~JingleSessionManager() override;
// SessionManager interface.
void AcceptIncoming(
const IncomingSessionCallback& incoming_session_callback) override;
void set_protocol_config(
std::unique_ptr<CandidateSessionConfig> config) override;
std::unique_ptr<Session> Connect(
const SignalingAddress& peer_address,
std::unique_ptr<Authenticator> authenticator) override;
void set_authenticator_factory(
std::unique_ptr<AuthenticatorFactory> authenticator_factory) override;
[[nodiscard]] SessionObserver::Subscription AddSessionObserver(
SessionObserver* observer) override;
private:
friend class JingleSession;
void RemoveSessionObserver(SessionObserver* observer);
// SignalStrategy::Listener interface.
void OnSignalStrategyStateChange(SignalStrategy::State state) override;
bool OnSignalStrategyIncomingStanza(
const jingle_xmpp::XmlElement* stanza) override;
typedef std::map<std::string, raw_ptr<JingleSession, CtnExperimental>>
SessionsMap;
IqSender* iq_sender() { return iq_sender_.get(); }
void SendReply(std::unique_ptr<jingle_xmpp::XmlElement> original_stanza,
JingleMessageReply::ErrorType error);
// Called by JingleSession when it is being destroyed.
void SessionDestroyed(JingleSession* session);
raw_ptr<SignalStrategy> signal_strategy_ = nullptr;
IncomingSessionCallback incoming_session_callback_;
std::unique_ptr<CandidateSessionConfig> protocol_config_;
std::unique_ptr<AuthenticatorFactory> authenticator_factory_;
std::unique_ptr<IqSender> iq_sender_;
SessionsMap sessions_;
base::ObserverList<SessionObserver> observers_;
SEQUENCE_CHECKER(sequence_checker_);
base::WeakPtrFactory<JingleSessionManager> weak_factory_{this};
};
} // namespace protocol
} // namespace remoting
#endif // REMOTING_PROTOCOL_JINGLE_SESSION_MANAGER_H_
|
