OLD | NEW |
1 // Copyright 2017 The Chromium Authors. All rights reserved. | 1 // Copyright 2017 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/media/router/discovery/dial/safe_dial_device_descriptio
n_parser.h" | 5 #include "chrome/browser/media/router/discovery/dial/safe_dial_device_descriptio
n_parser.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 | 8 |
9 #include "chrome/grit/generated_resources.h" | 9 #include "chrome/grit/generated_resources.h" |
10 #include "content/public/browser/browser_thread.h" | 10 #include "content/public/browser/browser_thread.h" |
11 #include "ui/base/l10n/l10n_util.h" | 11 #include "ui/base/l10n/l10n_util.h" |
12 | 12 |
13 namespace media_router { | 13 namespace media_router { |
14 | 14 |
15 SafeDialDeviceDescriptionParser::SafeDialDeviceDescriptionParser() {} | 15 SafeDialDeviceDescriptionParser::SafeDialDeviceDescriptionParser() {} |
16 | 16 |
17 SafeDialDeviceDescriptionParser::~SafeDialDeviceDescriptionParser() {} | 17 SafeDialDeviceDescriptionParser::~SafeDialDeviceDescriptionParser() {} |
18 | 18 |
19 void SafeDialDeviceDescriptionParser::Start( | 19 void SafeDialDeviceDescriptionParser::Start( |
20 const std::string& xml_text, | 20 const std::string& xml_text, |
21 const DeviceDescriptionCallback& callback) { | 21 const DeviceDescriptionCallback& callback) { |
| 22 DVLOG(2) << "Start parsing device description..."; |
22 DCHECK(thread_checker_.CalledOnValidThread()); | 23 DCHECK(thread_checker_.CalledOnValidThread()); |
23 DCHECK(!utility_process_mojo_client_); | 24 |
24 DCHECK(callback); | 25 DCHECK(callback); |
25 | 26 |
26 device_description_callback_ = callback; | 27 if (!utility_process_mojo_client_) { |
| 28 DVLOG(2) << "Start utility process in background..."; |
| 29 utility_process_mojo_client_ = |
| 30 base::MakeUnique<content::UtilityProcessMojoClient< |
| 31 chrome::mojom::DialDeviceDescriptionParser>>( |
| 32 l10n_util::GetStringUTF16( |
| 33 IDS_UTILITY_PROCESS_DIAL_DEVICE_DESCRIPTION_PARSER_NAME)); |
27 | 34 |
28 utility_process_mojo_client_ = | 35 utility_process_mojo_client_->set_error_callback( |
29 base::MakeUnique<content::UtilityProcessMojoClient< | 36 base::Bind(callback, nullptr)); |
30 chrome::mojom::DialDeviceDescriptionParser>>( | |
31 l10n_util::GetStringUTF16( | |
32 IDS_UTILITY_PROCESS_DIAL_DEVICE_DESCRIPTION_PARSER_NAME)); | |
33 | 37 |
34 utility_process_mojo_client_->set_error_callback(base::Bind( | 38 // This starts utility process in the background. |
35 &SafeDialDeviceDescriptionParser::OnParseDeviceDescriptionFailed, | 39 utility_process_mojo_client_->Start(); |
36 base::Unretained(this))); | 40 } |
37 | |
38 // This starts utility process in the background. | |
39 utility_process_mojo_client_->Start(); | |
40 | 41 |
41 // This call is queued up until the Mojo message pipe has been established to | 42 // This call is queued up until the Mojo message pipe has been established to |
42 // the service running in the utility process. | 43 // the service running in the utility process. |
43 utility_process_mojo_client_->service()->ParseDialDeviceDescription( | 44 utility_process_mojo_client_->service()->ParseDialDeviceDescription(xml_text, |
44 xml_text, | 45 callback); |
45 base::Bind( | |
46 &SafeDialDeviceDescriptionParser::OnParseDeviceDescriptionComplete, | |
47 base::Unretained(this))); | |
48 } | |
49 | |
50 void SafeDialDeviceDescriptionParser::OnParseDeviceDescriptionComplete( | |
51 chrome::mojom::DialDeviceDescriptionPtr device_description) { | |
52 DCHECK(thread_checker_.CalledOnValidThread()); | |
53 | |
54 utility_process_mojo_client_.reset(); // Terminate the utility process. | |
55 | |
56 DCHECK(device_description_callback_); | |
57 device_description_callback_.Run(std::move(device_description)); | |
58 } | |
59 | |
60 void SafeDialDeviceDescriptionParser::OnParseDeviceDescriptionFailed() { | |
61 DCHECK(thread_checker_.CalledOnValidThread()); | |
62 | |
63 utility_process_mojo_client_.reset(); // Terminate the utility process. | |
64 | |
65 DCHECK(device_description_callback_); | |
66 device_description_callback_.Run(nullptr); | |
67 } | 46 } |
68 | 47 |
69 } // namespace media_router | 48 } // namespace media_router |
OLD | NEW |