1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "remoting/host/chromoting_host_context.h"
6
7 #include <string>
8
9 #include "base/bind.h"
10 #include "remoting/base/auto_thread.h"
11 #include "remoting/base/url_request_context_getter.h"
12
13 namespace remoting {
14
ChromotingHostContext(AutoThreadTaskRunner * ui_task_runner)15 ChromotingHostContext::ChromotingHostContext(
16 AutoThreadTaskRunner* ui_task_runner)
17 : ui_task_runner_(ui_task_runner) {
18 #if defined(OS_WIN)
19 // On Windows the AudioCapturer requires COM, so we run a single-threaded
20 // apartment, which requires a UI thread.
21 audio_task_runner_ =
22 AutoThread::CreateWithLoopAndComInitTypes("ChromotingAudioThread",
23 ui_task_runner_,
24 base::MessageLoop::TYPE_UI,
25 AutoThread::COM_INIT_STA);
26 #else // !defined(OS_WIN)
27 audio_task_runner_ = AutoThread::CreateWithType(
28 "ChromotingAudioThread", ui_task_runner_, base::MessageLoop::TYPE_IO);
29 #endif // !defined(OS_WIN)
30
31 file_task_runner_ = AutoThread::CreateWithType(
32 "ChromotingFileThread", ui_task_runner_, base::MessageLoop::TYPE_IO);
33 input_task_runner_ = AutoThread::CreateWithType(
34 "ChromotingInputThread", ui_task_runner_, base::MessageLoop::TYPE_IO);
35 network_task_runner_ = AutoThread::CreateWithType(
36 "ChromotingNetworkThread", ui_task_runner_, base::MessageLoop::TYPE_IO);
37 video_capture_task_runner_ =
38 AutoThread::Create("ChromotingCaptureThread", ui_task_runner_);
39 video_encode_task_runner_ = AutoThread::Create(
40 "ChromotingEncodeThread", ui_task_runner_);
41
42 url_request_context_getter_ = new URLRequestContextGetter(
43 network_task_runner_, file_task_runner_);
44 }
45
~ChromotingHostContext()46 ChromotingHostContext::~ChromotingHostContext() {
47 }
48
Create(scoped_refptr<AutoThreadTaskRunner> ui_task_runner)49 scoped_ptr<ChromotingHostContext> ChromotingHostContext::Create(
50 scoped_refptr<AutoThreadTaskRunner> ui_task_runner) {
51 DCHECK(ui_task_runner->BelongsToCurrentThread());
52
53 scoped_ptr<ChromotingHostContext> context(
54 new ChromotingHostContext(ui_task_runner.get()));
55 if (!context->audio_task_runner_.get() || !context->file_task_runner_.get() ||
56 !context->input_task_runner_.get() ||
57 !context->network_task_runner_.get() ||
58 !context->video_capture_task_runner_.get() ||
59 !context->video_encode_task_runner_.get() ||
60 !context->url_request_context_getter_.get()) {
61 context.reset();
62 }
63
64 return context.Pass();
65 }
66
67 scoped_refptr<AutoThreadTaskRunner>
audio_task_runner()68 ChromotingHostContext::audio_task_runner() {
69 return audio_task_runner_;
70 }
71
72 scoped_refptr<AutoThreadTaskRunner>
file_task_runner()73 ChromotingHostContext::file_task_runner() {
74 return file_task_runner_;
75 }
76
77 scoped_refptr<AutoThreadTaskRunner>
input_task_runner()78 ChromotingHostContext::input_task_runner() {
79 return input_task_runner_;
80 }
81
82 scoped_refptr<AutoThreadTaskRunner>
network_task_runner()83 ChromotingHostContext::network_task_runner() {
84 return network_task_runner_;
85 }
86
87 scoped_refptr<AutoThreadTaskRunner>
ui_task_runner()88 ChromotingHostContext::ui_task_runner() {
89 return ui_task_runner_;
90 }
91
92 scoped_refptr<AutoThreadTaskRunner>
video_capture_task_runner()93 ChromotingHostContext::video_capture_task_runner() {
94 return video_capture_task_runner_;
95 }
96
97 scoped_refptr<AutoThreadTaskRunner>
video_encode_task_runner()98 ChromotingHostContext::video_encode_task_runner() {
99 return video_encode_task_runner_;
100 }
101
102 scoped_refptr<net::URLRequestContextGetter>
url_request_context_getter()103 ChromotingHostContext::url_request_context_getter() {
104 return url_request_context_getter_;
105 }
106
107 } // namespace remoting
108