chrome/browser/chromeos/extensions/file_manager/file_watcher.cc - Issue 23945002: file_manager: Move non-binding code to c/b/chromeos/file_manager

Side by Side Diff: chrome/browser/chromeos/extensions/file_manager/file_watcher.cc

Issue 23945002: file_manager: Move non-binding code to c/b/chromeos/file_manager (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src

Patch Set: rebase Created 7 years, 3 months ago

Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.

Jump to:

View unified diff | Download patch | Annotate | Revision Log

« no previous file with comments | « chrome/browser/chromeos/extensions/file_manager/file_watcher.h ('k') | chrome/browser/chromeos/extensions/file_manager/file_watcher_unittest.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Hide Comments ('s')

OLD	NEW
	(Empty)
1 // Copyright 2013 The Chromium Authors. All rights reserved.

2 // Use of this source code is governed by a BSD-style license that can be

3 // found in the LICENSE file.

4

5 #include "chrome/browser/chromeos/extensions/file_manager/file_watcher.h"

6

7 #include "base/bind.h"

8 #include "base/message_loop/message_loop_proxy.h"

9 #include "chrome/browser/google_apis/task_util.h"

10 #include "content/public/browser/browser_thread.h"

11

12 using content::BrowserThread;

13

14 namespace file_manager {

15 namespace {

16

17 // Creates a base::FilePathWatcher and starts watching at \|watch_path\| with

18 // \|callback\|. Returns NULL on failure.

19 base::FilePathWatcher* CreateAndStartFilePathWatcher(

20 const base::FilePath& watch_path,

21 const base::FilePathWatcher::Callback& callback) {

22 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));

23 DCHECK(!callback.is_null());

24

25 scoped_ptr<base::FilePathWatcher> watcher(new base::FilePathWatcher);

26 if (!watcher->Watch(watch_path, false /* recursive */, callback))

27 return NULL;

28

29 return watcher.release();

30 }

31

32 } // namespace

33

34 FileWatcher::FileWatcher(const base::FilePath& virtual_path)

35 : local_file_watcher_(NULL),

36 virtual_path_(virtual_path),

37 weak_ptr_factory_(this) {

38 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));

39 }

40

41 FileWatcher::~FileWatcher() {

42 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));

43

44 BrowserThread::DeleteSoon(BrowserThread::FILE,

45 FROM_HERE,

46 local_file_watcher_);

47 }

48

49 void FileWatcher::AddExtension(const std::string& extension_id) {

50 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));

51

52 extensions_[extension_id]++;

53 }

54

55 void FileWatcher::RemoveExtension(const std::string& extension_id) {

56 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));

57

58 ExtensionCountMap::iterator it = extensions_.find(extension_id);

59 if (it == extensions_.end()) {

60 LOG(ERROR) << " Extension [" << extension_id

61 << "] tries to unsubscribe from folder ["

62 << virtual_path_.value()

63 << "] it isn't subscribed";

64 return;

65 }

66

67 // If entry found - decrease it's count and remove if necessary

68 --it->second;

69 if (it->second == 0)

70 extensions_.erase(it);

71 }

72

73 std::vector<std::string> FileWatcher::GetExtensionIds() const {

74 std::vector<std::string> extension_ids;

75 for (ExtensionCountMap::const_iterator iter = extensions_.begin();

76 iter != extensions_.end(); ++iter) {

77 extension_ids.push_back(iter->first);

78 }

79 return extension_ids;

80 }

81

82 void FileWatcher::WatchLocalFile(

83 const base::FilePath& local_path,

84 const base::FilePathWatcher::Callback& file_watcher_callback,

85 const BoolCallback& callback) {

86 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));

87 DCHECK(!callback.is_null());

88 DCHECK(!local_file_watcher_);

89

90 BrowserThread::PostTaskAndReplyWithResult(

91 BrowserThread::FILE,

92 FROM_HERE,

93 base::Bind(&CreateAndStartFilePathWatcher,

94 local_path,

95 google_apis::CreateRelayCallback(file_watcher_callback)),

96 base::Bind(&FileWatcher::OnWatcherStarted,

97 weak_ptr_factory_.GetWeakPtr(),

98 callback));

99 }

100

101 void FileWatcher::OnWatcherStarted(

102 const BoolCallback& callback,

103 base::FilePathWatcher* file_watcher) {

104 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));

105 DCHECK(!callback.is_null());

106 DCHECK(!local_file_watcher_);

107

108 if (file_watcher) {

109 local_file_watcher_ = file_watcher;

110 callback.Run(true);

111 } else {

112 callback.Run(false);

113 }

114 }

115

116 } // namespace file_manager

OLD	NEW