OLD | NEW |
---|---|
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "chrome/browser/chromeos/policy/remote_commands/device_command_screensh ot_job.h" | 5 #include "chrome/browser/chromeos/policy/remote_commands/device_command_screensh ot_job.h" |
6 | 6 |
7 #include <fstream> | 7 #include <fstream> |
8 | 8 |
9 #include "ash/shell.h" | 9 #include "ash/shell.h" |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
11 #include "base/json/json_reader.h" | 11 #include "base/json/json_reader.h" |
12 #include "base/json/json_writer.h" | 12 #include "base/json/json_writer.h" |
13 #include "base/strings/string_number_conversions.h" | 13 #include "base/strings/string_number_conversions.h" |
14 #include "base/strings/stringprintf.h" | 14 #include "base/strings/stringprintf.h" |
15 #include "base/thread_task_runner_handle.h" | 15 #include "base/thread_task_runner_handle.h" |
16 #include "base/threading/sequenced_worker_pool.h" | 16 #include "base/threading/sequenced_worker_pool.h" |
17 #include "base/values.h" | 17 #include "base/values.h" |
18 #include "chrome/browser/chromeos/policy/status_uploader.h" | |
18 #include "chrome/browser/chromeos/policy/upload_job_impl.h" | 19 #include "chrome/browser/chromeos/policy/upload_job_impl.h" |
19 #include "content/public/browser/browser_thread.h" | 20 #include "content/public/browser/browser_thread.h" |
20 #include "net/http/http_request_headers.h" | 21 #include "net/http/http_request_headers.h" |
21 #include "policy/proto/device_management_backend.pb.h" | 22 #include "policy/proto/device_management_backend.pb.h" |
22 | 23 |
23 namespace policy { | 24 namespace policy { |
24 | 25 |
25 namespace { | 26 namespace { |
26 | 27 |
27 // Determines the time, measured from the time of issue, after which the command | 28 // Determines the time, measured from the time of issue, after which the command |
(...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
83 if (result_code != SUCCESS) | 84 if (result_code != SUCCESS) |
84 root_dict.Set(kResultFieldName, new base::FundamentalValue(result_code)); | 85 root_dict.Set(kResultFieldName, new base::FundamentalValue(result_code)); |
85 base::JSONWriter::Write(&root_dict, &payload_); | 86 base::JSONWriter::Write(&root_dict, &payload_); |
86 } | 87 } |
87 | 88 |
88 scoped_ptr<std::string> DeviceCommandScreenshotJob::Payload::Serialize() { | 89 scoped_ptr<std::string> DeviceCommandScreenshotJob::Payload::Serialize() { |
89 return make_scoped_ptr(new std::string(payload_)); | 90 return make_scoped_ptr(new std::string(payload_)); |
90 } | 91 } |
91 | 92 |
92 DeviceCommandScreenshotJob::DeviceCommandScreenshotJob( | 93 DeviceCommandScreenshotJob::DeviceCommandScreenshotJob( |
93 scoped_ptr<Delegate> screenshot_delegate) | 94 scoped_ptr<Delegate> screenshot_delegate, |
95 StatusUploader* uploader) | |
94 : num_pending_screenshots_(0), | 96 : num_pending_screenshots_(0), |
95 screenshot_delegate_(screenshot_delegate.Pass()), | 97 screenshot_delegate_(screenshot_delegate.Pass()), |
98 status_uploader_(uploader), | |
96 weak_ptr_factory_(this) { | 99 weak_ptr_factory_(this) { |
97 DCHECK(screenshot_delegate_); | 100 DCHECK(screenshot_delegate_); |
98 } | 101 } |
99 | 102 |
100 DeviceCommandScreenshotJob::~DeviceCommandScreenshotJob() { | 103 DeviceCommandScreenshotJob::~DeviceCommandScreenshotJob() { |
101 } | 104 } |
102 | 105 |
103 enterprise_management::RemoteCommand_Type DeviceCommandScreenshotJob::GetType() | 106 enterprise_management::RemoteCommand_Type DeviceCommandScreenshotJob::GetType() |
104 const { | 107 const { |
105 return enterprise_management::RemoteCommand_Type_DEVICE_SCREENSHOT; | 108 return enterprise_management::RemoteCommand_Type_DEVICE_SCREENSHOT; |
(...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
189 const CallbackWithResult& failed_callback) { | 192 const CallbackWithResult& failed_callback) { |
190 succeeded_callback_ = succeeded_callback; | 193 succeeded_callback_ = succeeded_callback; |
191 failed_callback_ = failed_callback; | 194 failed_callback_ = failed_callback; |
192 | 195 |
193 upload_job_ = screenshot_delegate_->CreateUploadJob(upload_url_, this); | 196 upload_job_ = screenshot_delegate_->CreateUploadJob(upload_url_, this); |
194 DCHECK(upload_job_); | 197 DCHECK(upload_job_); |
195 | 198 |
196 aura::Window::Windows root_windows = ash::Shell::GetAllRootWindows(); | 199 aura::Window::Windows root_windows = ash::Shell::GetAllRootWindows(); |
197 | 200 |
198 // Immediately fail if there are no attached screens. | 201 // Immediately fail if there are no attached screens. |
199 if (root_windows.size() == 0) { | 202 if (root_windows.size() == 0) { |
Andrew T Wilson (Slow)
2015/05/14 09:20:28
BTW, should this check for attached screens be don
cschuet (SLOW)
2015/05/14 09:46:01
Yes, that makes total sense. Would you move it up?
Andrew T Wilson (Slow)
2015/05/15 09:43:51
Done.
| |
200 base::ThreadTaskRunnerHandle::Get()->PostTask( | 203 base::ThreadTaskRunnerHandle::Get()->PostTask( |
201 FROM_HERE, | 204 FROM_HERE, |
202 base::Bind(failed_callback_, base::Passed(make_scoped_ptr(new Payload( | 205 base::Bind(failed_callback_, base::Passed(make_scoped_ptr(new Payload( |
203 FAILURE_SCREENSHOT_ACQUISITION))))); | 206 FAILURE_SCREENSHOT_ACQUISITION))))); |
204 } | 207 } |
205 | 208 |
209 if (!status_uploader_ || !status_uploader_->IsSessionDataUploadAllowed()) { | |
210 base::ThreadTaskRunnerHandle::Get()->PostTask( | |
211 FROM_HERE, | |
212 base::Bind(failed_callback_, base::Passed(make_scoped_ptr( | |
213 new Payload(FAILURE_USER_INPUT))))); | |
214 } | |
215 | |
206 // Post tasks to the sequenced worker pool for taking screenshots on each | 216 // Post tasks to the sequenced worker pool for taking screenshots on each |
207 // attached screen. | 217 // attached screen. |
208 num_pending_screenshots_ = root_windows.size(); | 218 num_pending_screenshots_ = root_windows.size(); |
209 for (size_t screen = 0; screen < root_windows.size(); ++screen) { | 219 for (size_t screen = 0; screen < root_windows.size(); ++screen) { |
210 aura::Window* root_window = root_windows[screen]; | 220 aura::Window* root_window = root_windows[screen]; |
211 gfx::Rect rect = root_window->bounds(); | 221 gfx::Rect rect = root_window->bounds(); |
212 screenshot_delegate_->TakeSnapshot( | 222 screenshot_delegate_->TakeSnapshot( |
213 root_window, rect, | 223 root_window, rect, |
214 base::Bind(&RunStoreScreenshotOnTaskRunner, | 224 base::Bind(&RunStoreScreenshotOnTaskRunner, |
215 base::Bind(&DeviceCommandScreenshotJob::StoreScreenshot, | 225 base::Bind(&DeviceCommandScreenshotJob::StoreScreenshot, |
216 weak_ptr_factory_.GetWeakPtr(), screen), | 226 weak_ptr_factory_.GetWeakPtr(), screen), |
217 base::ThreadTaskRunnerHandle::Get())); | 227 base::ThreadTaskRunnerHandle::Get())); |
218 } | 228 } |
219 } | 229 } |
220 | 230 |
221 void DeviceCommandScreenshotJob::TerminateImpl() { | 231 void DeviceCommandScreenshotJob::TerminateImpl() { |
222 weak_ptr_factory_.InvalidateWeakPtrs(); | 232 weak_ptr_factory_.InvalidateWeakPtrs(); |
223 } | 233 } |
224 | 234 |
225 } // namespace policy | 235 } // namespace policy |
OLD | NEW |