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
|
// 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 "chrome/browser/chromeos/drive/debug_info_collector.h"
#include <utility>
#include "base/callback.h"
#include "base/logging.h"
#include "google_apis/drive/task_util.h"
namespace drive {
namespace {
void IterateFileCacheInternal(
internal::ResourceMetadata* metadata,
const DebugInfoCollector::IterateFileCacheCallback& iteration_callback) {
scoped_ptr<internal::ResourceMetadata::Iterator> it = metadata->GetIterator();
for (; !it->IsAtEnd(); it->Advance()) {
if (it->GetValue().file_specific_info().has_cache_state()) {
iteration_callback.Run(it->GetID(),
it->GetValue().file_specific_info().cache_state());
}
}
DCHECK(!it->HasError());
}
// Runs the callback with arguments.
void RunGetResourceEntryCallback(const GetResourceEntryCallback& callback,
scoped_ptr<ResourceEntry> entry,
FileError error) {
DCHECK(!callback.is_null());
if (error != FILE_ERROR_OK)
entry.reset();
callback.Run(error, std::move(entry));
}
// Runs the callback with arguments.
void RunReadDirectoryCallback(
const DebugInfoCollector::ReadDirectoryCallback& callback,
scoped_ptr<ResourceEntryVector> entries,
FileError error) {
DCHECK(!callback.is_null());
if (error != FILE_ERROR_OK)
entries.reset();
callback.Run(error, std::move(entries));
}
} // namespace
DebugInfoCollector::DebugInfoCollector(
internal::ResourceMetadata* metadata,
FileSystemInterface* file_system,
base::SequencedTaskRunner* blocking_task_runner)
: metadata_(metadata),
file_system_(file_system),
blocking_task_runner_(blocking_task_runner) {
DCHECK(metadata_);
DCHECK(file_system_);
}
DebugInfoCollector::~DebugInfoCollector() {
}
void DebugInfoCollector::GetResourceEntry(
const base::FilePath& file_path,
const GetResourceEntryCallback& callback) {
DCHECK(thread_checker_.CalledOnValidThread());
DCHECK(!callback.is_null());
scoped_ptr<ResourceEntry> entry(new ResourceEntry);
ResourceEntry* entry_ptr = entry.get();
base::PostTaskAndReplyWithResult(
blocking_task_runner_.get(),
FROM_HERE,
base::Bind(&internal::ResourceMetadata::GetResourceEntryByPath,
base::Unretained(metadata_),
file_path,
entry_ptr),
base::Bind(&RunGetResourceEntryCallback, callback, base::Passed(&entry)));
}
void DebugInfoCollector::ReadDirectory(
const base::FilePath& file_path,
const ReadDirectoryCallback& callback) {
DCHECK(thread_checker_.CalledOnValidThread());
DCHECK(!callback.is_null());
scoped_ptr<ResourceEntryVector> entries(new ResourceEntryVector);
ResourceEntryVector* entries_ptr = entries.get();
base::PostTaskAndReplyWithResult(
blocking_task_runner_.get(),
FROM_HERE,
base::Bind(&internal::ResourceMetadata::ReadDirectoryByPath,
base::Unretained(metadata_),
file_path,
entries_ptr),
base::Bind(&RunReadDirectoryCallback, callback, base::Passed(&entries)));
}
void DebugInfoCollector::IterateFileCache(
const IterateFileCacheCallback& iteration_callback,
const base::Closure& completion_callback) {
DCHECK(thread_checker_.CalledOnValidThread());
DCHECK(!iteration_callback.is_null());
DCHECK(!completion_callback.is_null());
blocking_task_runner_->PostTaskAndReply(
FROM_HERE,
base::Bind(&IterateFileCacheInternal,
metadata_,
google_apis::CreateRelayCallback(iteration_callback)),
completion_callback);
}
void DebugInfoCollector::GetMetadata(
const GetFilesystemMetadataCallback& callback) {
DCHECK(thread_checker_.CalledOnValidThread());
DCHECK(!callback.is_null());
// Currently, this is just a proxy to the FileSystem.
// TODO(hidehiko): Move the implementation to here to simplify the
// FileSystem's implementation. crbug.com/237088
file_system_->GetMetadata(callback);
}
} // namespace drive
|
