DevTools: use inotify to pick changes on the filesystem.

chrome/browser/devtools/devtools_file_helper.cc

 // Copyright (c) 2012 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/devtools/devtools_file_helper.h"
 
 #include <set>
 #include <vector>
 
 #include "base/bind.h"
 #include "base/callback.h"
 #include "base/files/file_util.h"
 #include "base/lazy_instance.h"
 #include "base/md5.h"
 #include "base/prefs/pref_service.h"
 #include "base/prefs/scoped_user_pref_update.h"
 #include "base/strings/utf_string_conversions.h"
 #include "base/value_conversions.h"
 #include "chrome/browser/browser_process.h"
+#include "chrome/browser/devtools/devtools_file_watcher.h"
 #include "chrome/browser/download/download_prefs.h"
 #include "chrome/browser/platform_util.h"
 #include "chrome/browser/profiles/profile.h"
 #include "chrome/browser/ui/chrome_select_file_policy.h"
 #include "chrome/common/pref_names.h"
 #include "chrome/grit/generated_resources.h"
 #include "content/public/browser/browser_context.h"
 #include "content/public/browser/browser_thread.h"
 #include "content/public/browser/child_process_security_policy.h"
 #include "content/public/browser/download_manager.h"
@@ skipping 175 matching lines @@
                                        Profile* profile,
                                        Delegate* delegate)
     : web_contents_(web_contents),
       profile_(profile),
       delegate_(delegate),
       weak_factory_(this) {
   pref_change_registrar_.Init(profile_->GetPrefs());
   pref_change_registrar_.Add(prefs::kDevToolsFileSystemPaths,
       base::Bind(&DevToolsFileHelper::FileSystemPathsSettingChanged,
                  base::Unretained(this)));
+  file_watcher_.reset(new DevToolsFileWatcher(
+      base::Bind(&DevToolsFileHelper::FilePathsChanged,
+                 weak_factory_.GetWeakPtr())));
 }
 
 DevToolsFileHelper::~DevToolsFileHelper() {
+  BrowserThread::DeleteSoon(BrowserThread::FILE, FROM_HERE,
+                            file_watcher_.release());
 }
 
 void DevToolsFileHelper::Save(const std::string& url,
                               const std::string& content,
                               bool save_as,
                               const SaveCallback& saveCallback,
                               const SaveCallback& cancelCallback) {
   PathsMap::iterator it = saved_files_.find(url);
   if (it != saved_files_.end() && !save_as) {
     SaveAsFileSelected(url, content, saveCallback, it->second);
@@ skipping 157 matching lines @@
 DevToolsFileHelper::GetFileSystems() {
   file_system_paths_ = GetAddedFileSystemPaths(profile_);
   std::vector<FileSystem> file_systems;
   for (auto file_system_path : file_system_paths_) {
     base::FilePath path = base::FilePath::FromUTF8Unsafe(file_system_path);
     std::string file_system_id = RegisterFileSystem(web_contents_, path);
     FileSystem filesystem = CreateFileSystemStruct(web_contents_,
                                                    file_system_id,
                                                    file_system_path);
     file_systems.push_back(filesystem);
+    BrowserThread::PostTask(BrowserThread::FILE, FROM_HERE,
+                            Bind(&DevToolsFileWatcher::AddWatch,
+                                 base::Unretained(file_watcher_.get()), path));
   }
   return file_systems;
 }
 
 void DevToolsFileHelper::RemoveFileSystem(const std::string& file_system_path) {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
   base::FilePath path = base::FilePath::FromUTF8Unsafe(file_system_path);
   isolated_context()->RevokeFileSystemByPath(path);
 
   DictionaryPrefUpdate update(profile_->GetPrefs(),
@@ skipping 14 matching lines @@
   remaining.swap(file_system_paths_);
 
   for (auto file_system_path : GetAddedFileSystemPaths(profile_)) {
     if (remaining.find(file_system_path) == remaining.end()) {
       base::FilePath path = base::FilePath::FromUTF8Unsafe(file_system_path);
       std::string file_system_id = RegisterFileSystem(web_contents_, path);
       FileSystem filesystem = CreateFileSystemStruct(web_contents_,
                                                      file_system_id,
                                                      file_system_path);
       delegate_->FileSystemAdded(filesystem);
+      BrowserThread::PostTask(BrowserThread::FILE, FROM_HERE,
+                              Bind(&DevToolsFileWatcher::AddWatch,
+                                   base::Unretained(file_watcher_.get()),
+                                   path));
     } else {
       remaining.erase(file_system_path);
     }
     file_system_paths_.insert(file_system_path);
   }
 
-  for (auto file_system_path : remaining)
+  for (auto file_system_path : remaining) {
     delegate_->FileSystemRemoved(file_system_path);
+    base::FilePath path = base::FilePath::FromUTF8Unsafe(file_system_path);
+    BrowserThread::PostTask(BrowserThread::FILE, FROM_HERE,
+                            Bind(&DevToolsFileWatcher::RemoveWatch,
+                                 base::Unretained(file_watcher_.get()), path));
+  }
 }
+
+void DevToolsFileHelper::FilePathsChanged(
+    const std::vector<std::string>& paths) {
+  delegate_->FilePathsChanged(paths);
+}