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
|
// Copyright 2013 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.
#include "components/safe_json/safe_json_parser_impl.h"
#include "base/callback.h"
#include "base/sequenced_task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/values.h"
#include "content/public/browser/browser_thread.h"
#include "grit/components_strings.h"
#include "ui/base/l10n/l10n_util.h"
namespace safe_json {
SafeJsonParserImpl::SafeJsonParserImpl(const std::string& unsafe_json,
const SuccessCallback& success_callback,
const ErrorCallback& error_callback)
: unsafe_json_(unsafe_json),
success_callback_(success_callback),
error_callback_(error_callback) {
io_thread_checker_.DetachFromThread();
}
SafeJsonParserImpl::~SafeJsonParserImpl() = default;
void SafeJsonParserImpl::Start() {
caller_task_runner_ = base::SequencedTaskRunnerHandle::Get();
content::BrowserThread::PostTask(
content::BrowserThread::IO, FROM_HERE,
base::Bind(&SafeJsonParserImpl::StartOnIOThread, base::Unretained(this)));
}
void SafeJsonParserImpl::StartOnIOThread() {
DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
DCHECK(io_thread_checker_.CalledOnValidThread());
mojo_json_parser_.reset(
new content::UtilityProcessMojoClient<mojom::SafeJsonParser>(
l10n_util::GetStringUTF16(IDS_UTILITY_PROCESS_JSON_PARSER_NAME)));
mojo_json_parser_->set_error_callback(base::Bind(
&SafeJsonParserImpl::OnConnectionError, base::Unretained(this)));
mojo_json_parser_->Start();
mojo_json_parser_->service()->Parse(
std::move(unsafe_json_),
base::Bind(&SafeJsonParserImpl::OnParseDone, base::Unretained(this)));
}
void SafeJsonParserImpl::OnConnectionError() {
DCHECK(io_thread_checker_.CalledOnValidThread());
// Shut down the utility process.
mojo_json_parser_.reset();
caller_task_runner_->PostTask(
FROM_HERE,
base::Bind(&SafeJsonParserImpl::ReportResults, base::Unretained(this),
nullptr, "Connection error with the json parser process."));
}
void SafeJsonParserImpl::OnParseDone(std::unique_ptr<base::Value> result,
const base::Optional<std::string>& error) {
DCHECK(io_thread_checker_.CalledOnValidThread());
// Shut down the utility process.
mojo_json_parser_.reset();
// Call ReportResults() on caller's thread.
caller_task_runner_->PostTask(
FROM_HERE,
base::Bind(&SafeJsonParserImpl::ReportResults, base::Unretained(this),
base::Passed(&result), error.value_or("")));
}
void SafeJsonParserImpl::ReportResults(std::unique_ptr<base::Value> parsed_json,
const std::string& error) {
DCHECK(caller_task_runner_->RunsTasksOnCurrentThread());
if (error.empty() && parsed_json) {
if (!success_callback_.is_null())
success_callback_.Run(std::move(parsed_json));
} else {
if (!error_callback_.is_null())
error_callback_.Run(error);
}
// The parsing is done whether an error occured or not, so this instance can
// be cleaned up.
delete this;
}
} // namespace safe_json
|
