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
13namespace remoting {
14
15ChromotingHostContext::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
46ChromotingHostContext::~ChromotingHostContext() {
47}
48
49scoped_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
67scoped_refptr<AutoThreadTaskRunner>
68ChromotingHostContext::audio_task_runner() {
69  return audio_task_runner_;
70}
71
72scoped_refptr<AutoThreadTaskRunner>
73ChromotingHostContext::file_task_runner() {
74  return file_task_runner_;
75}
76
77scoped_refptr<AutoThreadTaskRunner>
78ChromotingHostContext::input_task_runner() {
79  return input_task_runner_;
80}
81
82scoped_refptr<AutoThreadTaskRunner>
83ChromotingHostContext::network_task_runner() {
84  return network_task_runner_;
85}
86
87scoped_refptr<AutoThreadTaskRunner>
88ChromotingHostContext::ui_task_runner() {
89  return ui_task_runner_;
90}
91
92scoped_refptr<AutoThreadTaskRunner>
93ChromotingHostContext::video_capture_task_runner() {
94  return video_capture_task_runner_;
95}
96
97scoped_refptr<AutoThreadTaskRunner>
98ChromotingHostContext::video_encode_task_runner() {
99  return video_encode_task_runner_;
100}
101
102scoped_refptr<net::URLRequestContextGetter>
103ChromotingHostContext::url_request_context_getter() {
104  return url_request_context_getter_;
105}
106
107}  // namespace remoting
108