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
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
// Copyright 2013 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "chrome/browser/extensions/api/image_writer_private/operation.h"
#include <stdint.h>
#include <utility>
#include "base/functional/bind.h"
#include "base/logging.h"
#include "chrome/browser/extensions/api/image_writer_private/error_constants.h"
#include "chromeos/ash/components/dbus/image_burner/image_burner_client.h"
#include "chromeos/ash/components/disks/disk.h"
#include "chromeos/ash/components/disks/disk_mount_manager.h"
#include "content/public/browser/browser_task_traits.h"
#include "content/public/browser/browser_thread.h"
namespace extensions {
namespace image_writer {
using ::ash::ImageBurnerClient;
using ::ash::disks::DiskMountManager;
using content::BrowserThread;
namespace {
void ClearImageBurner() {
if (!BrowserThread::CurrentlyOn(BrowserThread::UI)) {
content::GetUIThreadTaskRunner({})->PostTask(
FROM_HERE, base::BindOnce(&ClearImageBurner));
return;
}
ImageBurnerClient::Get()->ResetEventHandlers();
}
} // namespace
void Operation::Write(base::OnceClosure continuation) {
DCHECK(IsRunningInCorrectSequence());
SetStage(image_writer_api::Stage::kWrite);
// Note this has to be run on the FILE thread to avoid concurrent access.
AddCleanUpFunction(base::BindOnce(&ClearImageBurner));
content::GetUIThreadTaskRunner({})->PostTask(
FROM_HERE, base::BindOnce(&Operation::UnmountVolumes, this,
std::move(continuation)));
}
void Operation::VerifyWrite(base::OnceClosure continuation) {
DCHECK(IsRunningInCorrectSequence());
// No verification is available in Chrome OS currently.
std::move(continuation).Run();
}
void Operation::UnmountVolumes(base::OnceClosure continuation) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
DiskMountManager::GetInstance()->UnmountDeviceRecursively(
device_path_.value(), base::BindOnce(&Operation::UnmountVolumesCallback,
this, std::move(continuation)));
}
void Operation::UnmountVolumesCallback(base::OnceClosure continuation,
ash::MountError error_code) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
if (error_code != ash::MountError::kSuccess) {
LOG(ERROR) << "Volume unmounting failed with error code " << error_code;
PostTask(
base::BindOnce(&Operation::Error, this, error::kUnmountVolumesError));
return;
}
const DiskMountManager::Disks& disks =
DiskMountManager::GetInstance()->disks();
DiskMountManager::Disks::const_iterator iter =
disks.find(device_path_.value());
if (iter == disks.end()) {
LOG(ERROR) << "Disk not found in disk list after unmounting volumes.";
PostTask(
base::BindOnce(&Operation::Error, this, error::kUnmountVolumesError));
return;
}
StartWriteOnUIThread(iter->get()->file_path(), std::move(continuation));
}
void Operation::StartWriteOnUIThread(const std::string& target_path,
base::OnceClosure continuation) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
// TODO(haven): Image Burner cannot handle multiple burns. crbug.com/373575
ImageBurnerClient* burner = ImageBurnerClient::Get();
burner->SetEventHandlers(
base::BindOnce(&Operation::OnBurnFinished, this, std::move(continuation)),
base::BindRepeating(&Operation::OnBurnProgress, this));
burner->BurnImage(image_path_.value(), target_path,
base::BindOnce(&Operation::OnBurnError, this));
}
void Operation::OnBurnFinished(base::OnceClosure continuation,
const std::string& target_path,
bool success,
const std::string& error) {
if (success) {
PostTask(base::BindOnce(&Operation::SetProgress, this, kProgressComplete));
PostTask(std::move(continuation));
} else {
DLOG(ERROR) << "Error encountered while burning: " << error;
PostTask(base::BindOnce(&Operation::Error, this,
error::kChromeOSImageBurnerError));
}
}
void Operation::OnBurnProgress(const std::string& target_path,
int64_t num_bytes_burnt,
int64_t total_size) {
int progress = kProgressComplete * num_bytes_burnt / total_size;
PostTask(base::BindOnce(&Operation::SetProgress, this, progress));
}
void Operation::OnBurnError() {
PostTask(base::BindOnce(&Operation::Error, this,
error::kChromeOSImageBurnerError));
}
} // namespace image_writer
} // namespace extensions
|
