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
|
// 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/file_manager/file_watcher.h"
#include "base/bind.h"
#include "content/public/browser/browser_thread.h"
#include "google_apis/drive/task_util.h"
using content::BrowserThread;
namespace file_manager {
namespace {
// Creates a base::FilePathWatcher and starts watching at |watch_path| with
// |callback|. Returns NULL on failure.
base::FilePathWatcher* CreateAndStartFilePathWatcher(
const base::FilePath& watch_path,
const base::FilePathWatcher::Callback& callback) {
DCHECK_CURRENTLY_ON(BrowserThread::FILE);
DCHECK(!callback.is_null());
scoped_ptr<base::FilePathWatcher> watcher(new base::FilePathWatcher);
if (!watcher->Watch(watch_path, false /* recursive */, callback))
return NULL;
return watcher.release();
}
} // namespace
FileWatcher::FileWatcher(const base::FilePath& virtual_path)
: local_file_watcher_(NULL),
virtual_path_(virtual_path),
weak_ptr_factory_(this) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
}
FileWatcher::~FileWatcher() {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
BrowserThread::DeleteSoon(BrowserThread::FILE,
FROM_HERE,
local_file_watcher_);
}
void FileWatcher::AddExtension(const std::string& extension_id) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
extensions_[extension_id]++;
}
void FileWatcher::RemoveExtension(const std::string& extension_id) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
ExtensionCountMap::iterator it = extensions_.find(extension_id);
if (it == extensions_.end()) {
LOG(ERROR) << " Extension [" << extension_id
<< "] tries to unsubscribe from folder ["
<< virtual_path_.value()
<< "] it isn't subscribed";
return;
}
// If entry found - decrease it's count and remove if necessary
--it->second;
if (it->second == 0)
extensions_.erase(it);
}
std::vector<std::string> FileWatcher::GetExtensionIds() const {
std::vector<std::string> extension_ids;
for (ExtensionCountMap::const_iterator iter = extensions_.begin();
iter != extensions_.end(); ++iter) {
extension_ids.push_back(iter->first);
}
return extension_ids;
}
void FileWatcher::WatchLocalFile(
const base::FilePath& local_path,
const base::FilePathWatcher::Callback& file_watcher_callback,
const BoolCallback& callback) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
DCHECK(!callback.is_null());
DCHECK(!local_file_watcher_);
BrowserThread::PostTaskAndReplyWithResult(
BrowserThread::FILE,
FROM_HERE,
base::Bind(&CreateAndStartFilePathWatcher,
local_path,
google_apis::CreateRelayCallback(file_watcher_callback)),
base::Bind(&FileWatcher::OnWatcherStarted,
weak_ptr_factory_.GetWeakPtr(),
callback));
}
void FileWatcher::OnWatcherStarted(
const BoolCallback& callback,
base::FilePathWatcher* file_watcher) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
DCHECK(!callback.is_null());
DCHECK(!local_file_watcher_);
if (file_watcher) {
local_file_watcher_ = file_watcher;
callback.Run(true);
} else {
callback.Run(false);
}
}
} // namespace file_manager
|
