blob: f52f7c56c46dde7208c0a7f1c37335931134bfc2 (
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
|
// Copyright (c) 2012 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 REMOTING_PROTOCOL_JINGLE_SESSION_MANAGER_H_
#define REMOTING_PROTOCOL_JINGLE_SESSION_MANAGER_H_
#include <map>
#include <string>
#include "base/macros.h"
#include "remoting/protocol/jingle_messages.h"
#include "remoting/protocol/session_manager.h"
#include "remoting/signaling/signal_strategy.h"
namespace buzz {
class XmlElement;
} // namespace buzz
namespace remoting {
class IqSender;
namespace protocol {
class JingleSession;
class TransportFactory;
// 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:
JingleSessionManager(scoped_ptr<TransportFactory> transport_factory,
SignalStrategy* signal_strategy);
~JingleSessionManager() override;
// SessionManager interface.
void AcceptIncoming(
const IncomingSessionCallback& incoming_session_callback) override;
void set_protocol_config(scoped_ptr<CandidateSessionConfig> config) override;
scoped_ptr<Session> Connect(
const std::string& host_jid,
scoped_ptr<Authenticator> authenticator) override;
void set_authenticator_factory(
scoped_ptr<AuthenticatorFactory> authenticator_factory) override;
private:
friend class JingleSession;
// SignalStrategy::Listener interface.
void OnSignalStrategyStateChange(SignalStrategy::State state) override;
bool OnSignalStrategyIncomingStanza(const buzz::XmlElement* stanza) override;
typedef std::map<std::string, JingleSession*> SessionsMap;
IqSender* iq_sender() { return iq_sender_.get(); }
void SendReply(const buzz::XmlElement* original_stanza,
JingleMessageReply::ErrorType error);
// Called by JingleSession when it is being destroyed.
void SessionDestroyed(JingleSession* session);
scoped_ptr<TransportFactory> transport_factory_;
SignalStrategy* signal_strategy_;
IncomingSessionCallback incoming_session_callback_;
scoped_ptr<CandidateSessionConfig> protocol_config_;
scoped_ptr<AuthenticatorFactory> authenticator_factory_;
scoped_ptr<IqSender> iq_sender_;
SessionsMap sessions_;
DISALLOW_COPY_AND_ASSIGN(JingleSessionManager);
};
} // namespace protocol
} // namespace remoting
#endif // REMOTING_PROTOCOL_JINGLE_SESSION_MANAGER_H_
|
