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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
// 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_HOST_IPC_DESKTOP_ENVIRONMENT_H_
#define REMOTING_HOST_IPC_DESKTOP_ENVIRONMENT_H_
#include <map>
#include <string>
#include "base/basictypes.h"
#include "base/callback_forward.h"
#include "base/memory/ref_counted.h"
#include "base/memory/scoped_ptr.h"
#include "base/memory/weak_ptr.h"
#include "remoting/host/curtain_mode.h"
#include "remoting/host/desktop_environment.h"
#include "remoting/host/desktop_session_connector.h"
namespace base {
class SingleThreadTaskRunner;
} // base
namespace IPC {
class Sender;
} // namespace IPC
namespace remoting {
class DesktopSessionProxy;
struct DesktopSessionParams;
// A variant of desktop environment integrating with the desktop by means of
// a helper process and talking to that process via IPC.
class IpcDesktopEnvironment : public DesktopEnvironment {
public:
// |desktop_session_connector| is used to bind DesktopSessionProxy to
// a desktop session, to be notified every time the desktop process is
// restarted.
IpcDesktopEnvironment(
scoped_refptr<base::SingleThreadTaskRunner> caller_task_runner,
scoped_refptr<base::SingleThreadTaskRunner> io_task_runner,
const std::string& client_jid,
const base::Closure& disconnect_callback,
base::WeakPtr<DesktopSessionConnector> desktop_session_connector,
bool virtual_terminal);
virtual ~IpcDesktopEnvironment();
// DesktopEnvironment implementation.
virtual scoped_ptr<AudioCapturer> CreateAudioCapturer(
scoped_refptr<base::SingleThreadTaskRunner> audio_task_runner) OVERRIDE;
virtual scoped_ptr<EventExecutor> CreateEventExecutor(
scoped_refptr<base::SingleThreadTaskRunner> input_task_runner,
scoped_refptr<base::SingleThreadTaskRunner> ui_task_runner) OVERRIDE;
virtual scoped_ptr<media::ScreenCapturer> CreateVideoCapturer(
scoped_refptr<base::SingleThreadTaskRunner> capture_task_runner,
scoped_refptr<base::SingleThreadTaskRunner> encode_task_runner) OVERRIDE;
private:
// Task runner on which public methods of this class should be called.
scoped_refptr<base::SingleThreadTaskRunner> caller_task_runner_;
scoped_refptr<DesktopSessionProxy> desktop_session_proxy_;
DISALLOW_COPY_AND_ASSIGN(IpcDesktopEnvironment);
};
// Used to create IpcDesktopEnvironment objects integrating with the desktop via
// a helper process and talking to that process via IPC.
class IpcDesktopEnvironmentFactory
: public CurtainMode,
public DesktopEnvironmentFactory,
public DesktopSessionConnector {
public:
// Passes a reference to the IPC channel connected to the daemon process and
// relevant task runners. |daemon_channel| must outlive this object.
IpcDesktopEnvironmentFactory(
scoped_refptr<base::SingleThreadTaskRunner> caller_task_runner,
scoped_refptr<base::SingleThreadTaskRunner> io_task_runner,
IPC::Sender* daemon_channel);
virtual ~IpcDesktopEnvironmentFactory();
// CurtainMode implementation.
virtual void SetActivated(bool activated) OVERRIDE;
// DesktopEnvironmentFactory implementation.
virtual scoped_ptr<DesktopEnvironment> Create(
const std::string& client_jid,
const base::Closure& disconnect_callback) OVERRIDE;
virtual bool SupportsAudioCapture() const OVERRIDE;
// DesktopSessionConnector implementation.
virtual void ConnectTerminal(
DesktopSessionProxy* desktop_session_proxy,
const DesktopSessionParams& params,
bool virtual_terminal) OVERRIDE;
virtual void DisconnectTerminal(
DesktopSessionProxy* desktop_session_proxy) OVERRIDE;
virtual void OnDesktopSessionAgentAttached(
int terminal_id,
base::ProcessHandle desktop_process,
IPC::PlatformFileForTransit desktop_pipe) OVERRIDE;
virtual void OnTerminalDisconnected(int terminal_id) OVERRIDE;
private:
// Task runner on which public methods of this class should be called.
scoped_refptr<base::SingleThreadTaskRunner> caller_task_runner_;
// Task runner used for running background I/O.
scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_;
// True if curtain mode is activated.
bool curtain_activated_;
// IPC channel connected to the daemon process.
IPC::Sender* daemon_channel_;
// List of DesktopEnvironment instances we've told the daemon process about.
typedef std::map<int, DesktopSessionProxy*> ActiveConnectionsList;
ActiveConnectionsList active_connections_;
// Factory for weak pointers to DesktopSessionConnector interface.
base::WeakPtrFactory<DesktopSessionConnector> connector_factory_;
// Next desktop session ID. IDs are allocated sequentially starting from 0.
// This gives us more than 67 years of unique IDs assuming a new ID is
// allocated every second.
int next_id_;
DISALLOW_COPY_AND_ASSIGN(IpcDesktopEnvironmentFactory);
};
} // namespace remoting
#endif // REMOTING_HOST_IPC_DESKTOP_ENVIRONMENT_H_
|
