| Index: base/files/file_path_watcher_browsertest.cc
 | 
| diff --git a/base/files/file_path_watcher_browsertest.cc b/base/files/file_path_watcher_browsertest.cc
 | 
| deleted file mode 100644
 | 
| index bc7e6307c86297533c9ea0373b41c96faf1675cd..0000000000000000000000000000000000000000
 | 
| --- a/base/files/file_path_watcher_browsertest.cc
 | 
| +++ /dev/null
 | 
| @@ -1,871 +0,0 @@
 | 
| -// 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 "base/files/file_path_watcher.h"
 | 
| -
 | 
| -#if defined(OS_WIN)
 | 
| -#include <windows.h>
 | 
| -#include <aclapi.h>
 | 
| -#elif defined(OS_POSIX)
 | 
| -#include <sys/stat.h>
 | 
| -#endif
 | 
| -
 | 
| -#include <set>
 | 
| -
 | 
| -#include "base/basictypes.h"
 | 
| -#include "base/bind.h"
 | 
| -#include "base/bind_helpers.h"
 | 
| -#include "base/compiler_specific.h"
 | 
| -#include "base/files/file_path.h"
 | 
| -#include "base/files/file_util.h"
 | 
| -#include "base/files/scoped_temp_dir.h"
 | 
| -#include "base/message_loop/message_loop.h"
 | 
| -#include "base/message_loop/message_loop_proxy.h"
 | 
| -#include "base/run_loop.h"
 | 
| -#include "base/stl_util.h"
 | 
| -#include "base/strings/stringprintf.h"
 | 
| -#include "base/synchronization/waitable_event.h"
 | 
| -#include "base/test/test_file_util.h"
 | 
| -#include "base/test/test_timeouts.h"
 | 
| -#include "base/threading/thread.h"
 | 
| -#include "testing/gtest/include/gtest/gtest.h"
 | 
| -
 | 
| -namespace base {
 | 
| -
 | 
| -namespace {
 | 
| -
 | 
| -class TestDelegate;
 | 
| -
 | 
| -// Aggregates notifications from the test delegates and breaks the message loop
 | 
| -// the test thread is waiting on once they all came in.
 | 
| -class NotificationCollector
 | 
| -    : public base::RefCountedThreadSafe<NotificationCollector> {
 | 
| - public:
 | 
| -  NotificationCollector()
 | 
| -      : loop_(base::MessageLoopProxy::current()) {}
 | 
| -
 | 
| -  // Called from the file thread by the delegates.
 | 
| -  void OnChange(TestDelegate* delegate) {
 | 
| -    loop_->PostTask(FROM_HERE,
 | 
| -                    base::Bind(&NotificationCollector::RecordChange, this,
 | 
| -                               base::Unretained(delegate)));
 | 
| -  }
 | 
| -
 | 
| -  void Register(TestDelegate* delegate) {
 | 
| -    delegates_.insert(delegate);
 | 
| -  }
 | 
| -
 | 
| -  void Reset() {
 | 
| -    signaled_.clear();
 | 
| -  }
 | 
| -
 | 
| -  bool Success() {
 | 
| -    return signaled_ == delegates_;
 | 
| -  }
 | 
| -
 | 
| - private:
 | 
| -  friend class base::RefCountedThreadSafe<NotificationCollector>;
 | 
| -  ~NotificationCollector() {}
 | 
| -
 | 
| -  void RecordChange(TestDelegate* delegate) {
 | 
| -    // Warning: |delegate| is Unretained. Do not dereference.
 | 
| -    ASSERT_TRUE(loop_->BelongsToCurrentThread());
 | 
| -    ASSERT_TRUE(delegates_.count(delegate));
 | 
| -    signaled_.insert(delegate);
 | 
| -
 | 
| -    // Check whether all delegates have been signaled.
 | 
| -    if (signaled_ == delegates_)
 | 
| -      loop_->PostTask(FROM_HERE, MessageLoop::QuitWhenIdleClosure());
 | 
| -  }
 | 
| -
 | 
| -  // Set of registered delegates.
 | 
| -  std::set<TestDelegate*> delegates_;
 | 
| -
 | 
| -  // Set of signaled delegates.
 | 
| -  std::set<TestDelegate*> signaled_;
 | 
| -
 | 
| -  // The loop we should break after all delegates signaled.
 | 
| -  scoped_refptr<base::MessageLoopProxy> loop_;
 | 
| -};
 | 
| -
 | 
| -class TestDelegateBase : public SupportsWeakPtr<TestDelegateBase> {
 | 
| - public:
 | 
| -  TestDelegateBase() {}
 | 
| -  virtual ~TestDelegateBase() {}
 | 
| -
 | 
| -  virtual void OnFileChanged(const FilePath& path, bool error) = 0;
 | 
| -
 | 
| - private:
 | 
| -  DISALLOW_COPY_AND_ASSIGN(TestDelegateBase);
 | 
| -};
 | 
| -
 | 
| -// A mock class for testing. Gmock is not appropriate because it is not
 | 
| -// thread-safe for setting expectations. Thus the test code cannot safely
 | 
| -// reset expectations while the file watcher is running.
 | 
| -// Instead, TestDelegate gets the notifications from FilePathWatcher and uses
 | 
| -// NotificationCollector to aggregate the results.
 | 
| -class TestDelegate : public TestDelegateBase {
 | 
| - public:
 | 
| -  explicit TestDelegate(NotificationCollector* collector)
 | 
| -      : collector_(collector) {
 | 
| -    collector_->Register(this);
 | 
| -  }
 | 
| -  ~TestDelegate() override {}
 | 
| -
 | 
| -  void OnFileChanged(const FilePath& path, bool error) override {
 | 
| -    if (error)
 | 
| -      ADD_FAILURE() << "Error " << path.value();
 | 
| -    else
 | 
| -      collector_->OnChange(this);
 | 
| -  }
 | 
| -
 | 
| - private:
 | 
| -  scoped_refptr<NotificationCollector> collector_;
 | 
| -
 | 
| -  DISALLOW_COPY_AND_ASSIGN(TestDelegate);
 | 
| -};
 | 
| -
 | 
| -void SetupWatchCallback(const FilePath& target,
 | 
| -                        FilePathWatcher* watcher,
 | 
| -                        TestDelegateBase* delegate,
 | 
| -                        bool recursive_watch,
 | 
| -                        bool* result,
 | 
| -                        base::WaitableEvent* completion) {
 | 
| -  *result = watcher->Watch(target, recursive_watch,
 | 
| -                           base::Bind(&TestDelegateBase::OnFileChanged,
 | 
| -                                      delegate->AsWeakPtr()));
 | 
| -  completion->Signal();
 | 
| -}
 | 
| -
 | 
| -class FilePathWatcherTest : public testing::Test {
 | 
| - public:
 | 
| -  FilePathWatcherTest()
 | 
| -      : file_thread_("FilePathWatcherTest") {}
 | 
| -
 | 
| -  ~FilePathWatcherTest() override {}
 | 
| -
 | 
| - protected:
 | 
| -  void SetUp() override {
 | 
| -    // Create a separate file thread in order to test proper thread usage.
 | 
| -    base::Thread::Options options(MessageLoop::TYPE_IO, 0);
 | 
| -    ASSERT_TRUE(file_thread_.StartWithOptions(options));
 | 
| -    ASSERT_TRUE(temp_dir_.CreateUniqueTempDir());
 | 
| -    collector_ = new NotificationCollector();
 | 
| -  }
 | 
| -
 | 
| -  void TearDown() override { RunLoop().RunUntilIdle(); }
 | 
| -
 | 
| -  void DeleteDelegateOnFileThread(TestDelegate* delegate) {
 | 
| -    file_thread_.message_loop_proxy()->DeleteSoon(FROM_HERE, delegate);
 | 
| -  }
 | 
| -
 | 
| -  FilePath test_file() {
 | 
| -    return temp_dir_.path().AppendASCII("FilePathWatcherTest");
 | 
| -  }
 | 
| -
 | 
| -  FilePath test_link() {
 | 
| -    return temp_dir_.path().AppendASCII("FilePathWatcherTest.lnk");
 | 
| -  }
 | 
| -
 | 
| -  // Write |content| to |file|. Returns true on success.
 | 
| -  bool WriteFile(const FilePath& file, const std::string& content) {
 | 
| -    int write_size = ::base::WriteFile(file, content.c_str(), content.length());
 | 
| -    return write_size == static_cast<int>(content.length());
 | 
| -  }
 | 
| -
 | 
| -  bool SetupWatch(const FilePath& target,
 | 
| -                  FilePathWatcher* watcher,
 | 
| -                  TestDelegateBase* delegate,
 | 
| -                  bool recursive_watch) WARN_UNUSED_RESULT;
 | 
| -
 | 
| -  bool WaitForEvents() WARN_UNUSED_RESULT {
 | 
| -    collector_->Reset();
 | 
| -    loop_.Run();
 | 
| -    return collector_->Success();
 | 
| -  }
 | 
| -
 | 
| -  NotificationCollector* collector() { return collector_.get(); }
 | 
| -
 | 
| -  MessageLoop loop_;
 | 
| -  base::Thread file_thread_;
 | 
| -  ScopedTempDir temp_dir_;
 | 
| -  scoped_refptr<NotificationCollector> collector_;
 | 
| -
 | 
| - private:
 | 
| -  DISALLOW_COPY_AND_ASSIGN(FilePathWatcherTest);
 | 
| -};
 | 
| -
 | 
| -bool FilePathWatcherTest::SetupWatch(const FilePath& target,
 | 
| -                                     FilePathWatcher* watcher,
 | 
| -                                     TestDelegateBase* delegate,
 | 
| -                                     bool recursive_watch) {
 | 
| -  base::WaitableEvent completion(false, false);
 | 
| -  bool result;
 | 
| -  file_thread_.message_loop_proxy()->PostTask(
 | 
| -      FROM_HERE,
 | 
| -      base::Bind(SetupWatchCallback, target, watcher, delegate, recursive_watch,
 | 
| -                 &result, &completion));
 | 
| -  completion.Wait();
 | 
| -  return result;
 | 
| -}
 | 
| -
 | 
| -// Basic test: Create the file and verify that we notice.
 | 
| -TEST_F(FilePathWatcherTest, NewFile) {
 | 
| -  FilePathWatcher watcher;
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegate.get(), false));
 | 
| -
 | 
| -  ASSERT_TRUE(WriteFile(test_file(), "content"));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -// Verify that modifying the file is caught.
 | 
| -TEST_F(FilePathWatcherTest, ModifiedFile) {
 | 
| -  ASSERT_TRUE(WriteFile(test_file(), "content"));
 | 
| -
 | 
| -  FilePathWatcher watcher;
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegate.get(), false));
 | 
| -
 | 
| -  // Now make sure we get notified if the file is modified.
 | 
| -  ASSERT_TRUE(WriteFile(test_file(), "new content"));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -// Verify that moving the file into place is caught.
 | 
| -TEST_F(FilePathWatcherTest, MovedFile) {
 | 
| -  FilePath source_file(temp_dir_.path().AppendASCII("source"));
 | 
| -  ASSERT_TRUE(WriteFile(source_file, "content"));
 | 
| -
 | 
| -  FilePathWatcher watcher;
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegate.get(), false));
 | 
| -
 | 
| -  // Now make sure we get notified if the file is modified.
 | 
| -  ASSERT_TRUE(base::Move(source_file, test_file()));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -TEST_F(FilePathWatcherTest, DeletedFile) {
 | 
| -  ASSERT_TRUE(WriteFile(test_file(), "content"));
 | 
| -
 | 
| -  FilePathWatcher watcher;
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegate.get(), false));
 | 
| -
 | 
| -  // Now make sure we get notified if the file is deleted.
 | 
| -  base::DeleteFile(test_file(), false);
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -// Used by the DeleteDuringNotify test below.
 | 
| -// Deletes the FilePathWatcher when it's notified.
 | 
| -class Deleter : public TestDelegateBase {
 | 
| - public:
 | 
| -  Deleter(FilePathWatcher* watcher, MessageLoop* loop)
 | 
| -      : watcher_(watcher),
 | 
| -        loop_(loop) {
 | 
| -  }
 | 
| -  ~Deleter() override {}
 | 
| -
 | 
| -  void OnFileChanged(const FilePath&, bool) override {
 | 
| -    watcher_.reset();
 | 
| -    loop_->PostTask(FROM_HERE, MessageLoop::QuitWhenIdleClosure());
 | 
| -  }
 | 
| -
 | 
| -  FilePathWatcher* watcher() const { return watcher_.get(); }
 | 
| -
 | 
| - private:
 | 
| -  scoped_ptr<FilePathWatcher> watcher_;
 | 
| -  MessageLoop* loop_;
 | 
| -
 | 
| -  DISALLOW_COPY_AND_ASSIGN(Deleter);
 | 
| -};
 | 
| -
 | 
| -// Verify that deleting a watcher during the callback doesn't crash.
 | 
| -TEST_F(FilePathWatcherTest, DeleteDuringNotify) {
 | 
| -  FilePathWatcher* watcher = new FilePathWatcher;
 | 
| -  // Takes ownership of watcher.
 | 
| -  scoped_ptr<Deleter> deleter(new Deleter(watcher, &loop_));
 | 
| -  ASSERT_TRUE(SetupWatch(test_file(), watcher, deleter.get(), false));
 | 
| -
 | 
| -  ASSERT_TRUE(WriteFile(test_file(), "content"));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  // We win if we haven't crashed yet.
 | 
| -  // Might as well double-check it got deleted, too.
 | 
| -  ASSERT_TRUE(deleter->watcher() == NULL);
 | 
| -}
 | 
| -
 | 
| -// Verify that deleting the watcher works even if there is a pending
 | 
| -// notification.
 | 
| -// Flaky on MacOS (and ARM linux): http://crbug.com/85930
 | 
| -TEST_F(FilePathWatcherTest, DISABLED_DestroyWithPendingNotification) {
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  FilePathWatcher* watcher = new FilePathWatcher;
 | 
| -  ASSERT_TRUE(SetupWatch(test_file(), watcher, delegate.get(), false));
 | 
| -  ASSERT_TRUE(WriteFile(test_file(), "content"));
 | 
| -  file_thread_.message_loop_proxy()->DeleteSoon(FROM_HERE, watcher);
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -TEST_F(FilePathWatcherTest, MultipleWatchersSingleFile) {
 | 
| -  FilePathWatcher watcher1, watcher2;
 | 
| -  scoped_ptr<TestDelegate> delegate1(new TestDelegate(collector()));
 | 
| -  scoped_ptr<TestDelegate> delegate2(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(test_file(), &watcher1, delegate1.get(), false));
 | 
| -  ASSERT_TRUE(SetupWatch(test_file(), &watcher2, delegate2.get(), false));
 | 
| -
 | 
| -  ASSERT_TRUE(WriteFile(test_file(), "content"));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate1.release());
 | 
| -  DeleteDelegateOnFileThread(delegate2.release());
 | 
| -}
 | 
| -
 | 
| -// Verify that watching a file whose parent directory doesn't exist yet works if
 | 
| -// the directory and file are created eventually.
 | 
| -TEST_F(FilePathWatcherTest, NonExistentDirectory) {
 | 
| -  FilePathWatcher watcher;
 | 
| -  FilePath dir(temp_dir_.path().AppendASCII("dir"));
 | 
| -  FilePath file(dir.AppendASCII("file"));
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(file, &watcher, delegate.get(), false));
 | 
| -
 | 
| -  ASSERT_TRUE(base::CreateDirectory(dir));
 | 
| -
 | 
| -  ASSERT_TRUE(WriteFile(file, "content"));
 | 
| -
 | 
| -  VLOG(1) << "Waiting for file creation";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  ASSERT_TRUE(WriteFile(file, "content v2"));
 | 
| -  VLOG(1) << "Waiting for file change";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  ASSERT_TRUE(base::DeleteFile(file, false));
 | 
| -  VLOG(1) << "Waiting for file deletion";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -// Exercises watch reconfiguration for the case that directories on the path
 | 
| -// are rapidly created.
 | 
| -TEST_F(FilePathWatcherTest, DirectoryChain) {
 | 
| -  FilePath path(temp_dir_.path());
 | 
| -  std::vector<std::string> dir_names;
 | 
| -  for (int i = 0; i < 20; i++) {
 | 
| -    std::string dir(base::StringPrintf("d%d", i));
 | 
| -    dir_names.push_back(dir);
 | 
| -    path = path.AppendASCII(dir);
 | 
| -  }
 | 
| -
 | 
| -  FilePathWatcher watcher;
 | 
| -  FilePath file(path.AppendASCII("file"));
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(file, &watcher, delegate.get(), false));
 | 
| -
 | 
| -  FilePath sub_path(temp_dir_.path());
 | 
| -  for (std::vector<std::string>::const_iterator d(dir_names.begin());
 | 
| -       d != dir_names.end(); ++d) {
 | 
| -    sub_path = sub_path.AppendASCII(*d);
 | 
| -    ASSERT_TRUE(base::CreateDirectory(sub_path));
 | 
| -  }
 | 
| -  VLOG(1) << "Create File";
 | 
| -  ASSERT_TRUE(WriteFile(file, "content"));
 | 
| -  VLOG(1) << "Waiting for file creation";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  ASSERT_TRUE(WriteFile(file, "content v2"));
 | 
| -  VLOG(1) << "Waiting for file modification";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -#if defined(OS_MACOSX)
 | 
| -// http://crbug.com/85930
 | 
| -#define DisappearingDirectory DISABLED_DisappearingDirectory
 | 
| -#endif
 | 
| -TEST_F(FilePathWatcherTest, DisappearingDirectory) {
 | 
| -  FilePathWatcher watcher;
 | 
| -  FilePath dir(temp_dir_.path().AppendASCII("dir"));
 | 
| -  FilePath file(dir.AppendASCII("file"));
 | 
| -  ASSERT_TRUE(base::CreateDirectory(dir));
 | 
| -  ASSERT_TRUE(WriteFile(file, "content"));
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(file, &watcher, delegate.get(), false));
 | 
| -
 | 
| -  ASSERT_TRUE(base::DeleteFile(dir, true));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -// Tests that a file that is deleted and reappears is tracked correctly.
 | 
| -TEST_F(FilePathWatcherTest, DeleteAndRecreate) {
 | 
| -  ASSERT_TRUE(WriteFile(test_file(), "content"));
 | 
| -  FilePathWatcher watcher;
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegate.get(), false));
 | 
| -
 | 
| -  ASSERT_TRUE(base::DeleteFile(test_file(), false));
 | 
| -  VLOG(1) << "Waiting for file deletion";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  ASSERT_TRUE(WriteFile(test_file(), "content"));
 | 
| -  VLOG(1) << "Waiting for file creation";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -TEST_F(FilePathWatcherTest, WatchDirectory) {
 | 
| -  FilePathWatcher watcher;
 | 
| -  FilePath dir(temp_dir_.path().AppendASCII("dir"));
 | 
| -  FilePath file1(dir.AppendASCII("file1"));
 | 
| -  FilePath file2(dir.AppendASCII("file2"));
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(dir, &watcher, delegate.get(), false));
 | 
| -
 | 
| -  ASSERT_TRUE(base::CreateDirectory(dir));
 | 
| -  VLOG(1) << "Waiting for directory creation";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  ASSERT_TRUE(WriteFile(file1, "content"));
 | 
| -  VLOG(1) << "Waiting for file1 creation";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -#if !defined(OS_MACOSX)
 | 
| -  // Mac implementation does not detect files modified in a directory.
 | 
| -  ASSERT_TRUE(WriteFile(file1, "content v2"));
 | 
| -  VLOG(1) << "Waiting for file1 modification";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -#endif  // !OS_MACOSX
 | 
| -
 | 
| -  ASSERT_TRUE(base::DeleteFile(file1, false));
 | 
| -  VLOG(1) << "Waiting for file1 deletion";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  ASSERT_TRUE(WriteFile(file2, "content"));
 | 
| -  VLOG(1) << "Waiting for file2 creation";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -TEST_F(FilePathWatcherTest, MoveParent) {
 | 
| -  FilePathWatcher file_watcher;
 | 
| -  FilePathWatcher subdir_watcher;
 | 
| -  FilePath dir(temp_dir_.path().AppendASCII("dir"));
 | 
| -  FilePath dest(temp_dir_.path().AppendASCII("dest"));
 | 
| -  FilePath subdir(dir.AppendASCII("subdir"));
 | 
| -  FilePath file(subdir.AppendASCII("file"));
 | 
| -  scoped_ptr<TestDelegate> file_delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(file, &file_watcher, file_delegate.get(), false));
 | 
| -  scoped_ptr<TestDelegate> subdir_delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(subdir, &subdir_watcher, subdir_delegate.get(),
 | 
| -                         false));
 | 
| -
 | 
| -  // Setup a directory hierarchy.
 | 
| -  ASSERT_TRUE(base::CreateDirectory(subdir));
 | 
| -  ASSERT_TRUE(WriteFile(file, "content"));
 | 
| -  VLOG(1) << "Waiting for file creation";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  // Move the parent directory.
 | 
| -  base::Move(dir, dest);
 | 
| -  VLOG(1) << "Waiting for directory move";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(file_delegate.release());
 | 
| -  DeleteDelegateOnFileThread(subdir_delegate.release());
 | 
| -}
 | 
| -
 | 
| -TEST_F(FilePathWatcherTest, RecursiveWatch) {
 | 
| -  FilePathWatcher watcher;
 | 
| -  FilePath dir(temp_dir_.path().AppendASCII("dir"));
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  bool setup_result = SetupWatch(dir, &watcher, delegate.get(), true);
 | 
| -  if (!FilePathWatcher::RecursiveWatchAvailable()) {
 | 
| -    ASSERT_FALSE(setup_result);
 | 
| -    DeleteDelegateOnFileThread(delegate.release());
 | 
| -    return;
 | 
| -  }
 | 
| -  ASSERT_TRUE(setup_result);
 | 
| -
 | 
| -  // Main directory("dir") creation.
 | 
| -  ASSERT_TRUE(base::CreateDirectory(dir));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  // Create "$dir/file1".
 | 
| -  FilePath file1(dir.AppendASCII("file1"));
 | 
| -  ASSERT_TRUE(WriteFile(file1, "content"));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  // Create "$dir/subdir".
 | 
| -  FilePath subdir(dir.AppendASCII("subdir"));
 | 
| -  ASSERT_TRUE(base::CreateDirectory(subdir));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  // Create "$dir/subdir/subdir_file1".
 | 
| -  FilePath subdir_file1(subdir.AppendASCII("subdir_file1"));
 | 
| -  ASSERT_TRUE(WriteFile(subdir_file1, "content"));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  // Create "$dir/subdir/subdir_child_dir".
 | 
| -  FilePath subdir_child_dir(subdir.AppendASCII("subdir_child_dir"));
 | 
| -  ASSERT_TRUE(base::CreateDirectory(subdir_child_dir));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  // Create "$dir/subdir/subdir_child_dir/child_dir_file1".
 | 
| -  FilePath child_dir_file1(subdir_child_dir.AppendASCII("child_dir_file1"));
 | 
| -  ASSERT_TRUE(WriteFile(child_dir_file1, "content v2"));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  // Write into "$dir/subdir/subdir_child_dir/child_dir_file1".
 | 
| -  ASSERT_TRUE(WriteFile(child_dir_file1, "content"));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  // Modify "$dir/subdir/subdir_child_dir/child_dir_file1" attributes.
 | 
| -  ASSERT_TRUE(base::MakeFileUnreadable(child_dir_file1));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  // Delete "$dir/subdir/subdir_file1".
 | 
| -  ASSERT_TRUE(base::DeleteFile(subdir_file1, false));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  // Delete "$dir/subdir/subdir_child_dir/child_dir_file1".
 | 
| -  ASSERT_TRUE(base::DeleteFile(child_dir_file1, false));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -#if defined(OS_POSIX)
 | 
| -TEST_F(FilePathWatcherTest, RecursiveWithSymLink) {
 | 
| -  if (!FilePathWatcher::RecursiveWatchAvailable())
 | 
| -    return;
 | 
| -
 | 
| -  FilePathWatcher watcher;
 | 
| -  FilePath test_dir(temp_dir_.path().AppendASCII("test_dir"));
 | 
| -  ASSERT_TRUE(base::CreateDirectory(test_dir));
 | 
| -  FilePath symlink(test_dir.AppendASCII("symlink"));
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(symlink, &watcher, delegate.get(), true));
 | 
| -
 | 
| -  // Link creation.
 | 
| -  FilePath target1(temp_dir_.path().AppendASCII("target1"));
 | 
| -  ASSERT_TRUE(base::CreateSymbolicLink(target1, symlink));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  // Target1 creation.
 | 
| -  ASSERT_TRUE(base::CreateDirectory(target1));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  // Create a file in target1.
 | 
| -  FilePath target1_file(target1.AppendASCII("file"));
 | 
| -  ASSERT_TRUE(WriteFile(target1_file, "content"));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  // Link change.
 | 
| -  FilePath target2(temp_dir_.path().AppendASCII("target2"));
 | 
| -  ASSERT_TRUE(base::CreateDirectory(target2));
 | 
| -  ASSERT_TRUE(base::DeleteFile(symlink, false));
 | 
| -  ASSERT_TRUE(base::CreateSymbolicLink(target2, symlink));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  // Create a file in target2.
 | 
| -  FilePath target2_file(target2.AppendASCII("file"));
 | 
| -  ASSERT_TRUE(WriteFile(target2_file, "content"));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -#endif  // OS_POSIX
 | 
| -
 | 
| -TEST_F(FilePathWatcherTest, MoveChild) {
 | 
| -  FilePathWatcher file_watcher;
 | 
| -  FilePathWatcher subdir_watcher;
 | 
| -  FilePath source_dir(temp_dir_.path().AppendASCII("source"));
 | 
| -  FilePath source_subdir(source_dir.AppendASCII("subdir"));
 | 
| -  FilePath source_file(source_subdir.AppendASCII("file"));
 | 
| -  FilePath dest_dir(temp_dir_.path().AppendASCII("dest"));
 | 
| -  FilePath dest_subdir(dest_dir.AppendASCII("subdir"));
 | 
| -  FilePath dest_file(dest_subdir.AppendASCII("file"));
 | 
| -
 | 
| -  // Setup a directory hierarchy.
 | 
| -  ASSERT_TRUE(base::CreateDirectory(source_subdir));
 | 
| -  ASSERT_TRUE(WriteFile(source_file, "content"));
 | 
| -
 | 
| -  scoped_ptr<TestDelegate> file_delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(dest_file, &file_watcher, file_delegate.get(), false));
 | 
| -  scoped_ptr<TestDelegate> subdir_delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(dest_subdir, &subdir_watcher, subdir_delegate.get(),
 | 
| -                         false));
 | 
| -
 | 
| -  // Move the directory into place, s.t. the watched file appears.
 | 
| -  ASSERT_TRUE(base::Move(source_dir, dest_dir));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(file_delegate.release());
 | 
| -  DeleteDelegateOnFileThread(subdir_delegate.release());
 | 
| -}
 | 
| -
 | 
| -// Verify that changing attributes on a file is caught
 | 
| -TEST_F(FilePathWatcherTest, FileAttributesChanged) {
 | 
| -  ASSERT_TRUE(WriteFile(test_file(), "content"));
 | 
| -  FilePathWatcher watcher;
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(test_file(), &watcher, delegate.get(), false));
 | 
| -
 | 
| -  // Now make sure we get notified if the file is modified.
 | 
| -  ASSERT_TRUE(base::MakeFileUnreadable(test_file()));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -#if defined(OS_LINUX)
 | 
| -
 | 
| -// Verify that creating a symlink is caught.
 | 
| -TEST_F(FilePathWatcherTest, CreateLink) {
 | 
| -  FilePathWatcher watcher;
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  // Note that we are watching the symlink
 | 
| -  ASSERT_TRUE(SetupWatch(test_link(), &watcher, delegate.get(), false));
 | 
| -
 | 
| -  // Now make sure we get notified if the link is created.
 | 
| -  // Note that test_file() doesn't have to exist.
 | 
| -  ASSERT_TRUE(CreateSymbolicLink(test_file(), test_link()));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -// Verify that deleting a symlink is caught.
 | 
| -TEST_F(FilePathWatcherTest, DeleteLink) {
 | 
| -  // Unfortunately this test case only works if the link target exists.
 | 
| -  // TODO(craig) fix this as part of crbug.com/91561.
 | 
| -  ASSERT_TRUE(WriteFile(test_file(), "content"));
 | 
| -  ASSERT_TRUE(CreateSymbolicLink(test_file(), test_link()));
 | 
| -  FilePathWatcher watcher;
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(test_link(), &watcher, delegate.get(), false));
 | 
| -
 | 
| -  // Now make sure we get notified if the link is deleted.
 | 
| -  ASSERT_TRUE(base::DeleteFile(test_link(), false));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -// Verify that modifying a target file that a link is pointing to
 | 
| -// when we are watching the link is caught.
 | 
| -TEST_F(FilePathWatcherTest, ModifiedLinkedFile) {
 | 
| -  ASSERT_TRUE(WriteFile(test_file(), "content"));
 | 
| -  ASSERT_TRUE(CreateSymbolicLink(test_file(), test_link()));
 | 
| -  FilePathWatcher watcher;
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  // Note that we are watching the symlink.
 | 
| -  ASSERT_TRUE(SetupWatch(test_link(), &watcher, delegate.get(), false));
 | 
| -
 | 
| -  // Now make sure we get notified if the file is modified.
 | 
| -  ASSERT_TRUE(WriteFile(test_file(), "new content"));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -// Verify that creating a target file that a link is pointing to
 | 
| -// when we are watching the link is caught.
 | 
| -TEST_F(FilePathWatcherTest, CreateTargetLinkedFile) {
 | 
| -  ASSERT_TRUE(CreateSymbolicLink(test_file(), test_link()));
 | 
| -  FilePathWatcher watcher;
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  // Note that we are watching the symlink.
 | 
| -  ASSERT_TRUE(SetupWatch(test_link(), &watcher, delegate.get(), false));
 | 
| -
 | 
| -  // Now make sure we get notified if the target file is created.
 | 
| -  ASSERT_TRUE(WriteFile(test_file(), "content"));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -// Verify that deleting a target file that a link is pointing to
 | 
| -// when we are watching the link is caught.
 | 
| -TEST_F(FilePathWatcherTest, DeleteTargetLinkedFile) {
 | 
| -  ASSERT_TRUE(WriteFile(test_file(), "content"));
 | 
| -  ASSERT_TRUE(CreateSymbolicLink(test_file(), test_link()));
 | 
| -  FilePathWatcher watcher;
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  // Note that we are watching the symlink.
 | 
| -  ASSERT_TRUE(SetupWatch(test_link(), &watcher, delegate.get(), false));
 | 
| -
 | 
| -  // Now make sure we get notified if the target file is deleted.
 | 
| -  ASSERT_TRUE(base::DeleteFile(test_file(), false));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -// Verify that watching a file whose parent directory is a link that
 | 
| -// doesn't exist yet works if the symlink is created eventually.
 | 
| -TEST_F(FilePathWatcherTest, LinkedDirectoryPart1) {
 | 
| -  FilePathWatcher watcher;
 | 
| -  FilePath dir(temp_dir_.path().AppendASCII("dir"));
 | 
| -  FilePath link_dir(temp_dir_.path().AppendASCII("dir.lnk"));
 | 
| -  FilePath file(dir.AppendASCII("file"));
 | 
| -  FilePath linkfile(link_dir.AppendASCII("file"));
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  // dir/file should exist.
 | 
| -  ASSERT_TRUE(base::CreateDirectory(dir));
 | 
| -  ASSERT_TRUE(WriteFile(file, "content"));
 | 
| -  // Note that we are watching dir.lnk/file which doesn't exist yet.
 | 
| -  ASSERT_TRUE(SetupWatch(linkfile, &watcher, delegate.get(), false));
 | 
| -
 | 
| -  ASSERT_TRUE(CreateSymbolicLink(dir, link_dir));
 | 
| -  VLOG(1) << "Waiting for link creation";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  ASSERT_TRUE(WriteFile(file, "content v2"));
 | 
| -  VLOG(1) << "Waiting for file change";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  ASSERT_TRUE(base::DeleteFile(file, false));
 | 
| -  VLOG(1) << "Waiting for file deletion";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -// Verify that watching a file whose parent directory is a
 | 
| -// dangling symlink works if the directory is created eventually.
 | 
| -TEST_F(FilePathWatcherTest, LinkedDirectoryPart2) {
 | 
| -  FilePathWatcher watcher;
 | 
| -  FilePath dir(temp_dir_.path().AppendASCII("dir"));
 | 
| -  FilePath link_dir(temp_dir_.path().AppendASCII("dir.lnk"));
 | 
| -  FilePath file(dir.AppendASCII("file"));
 | 
| -  FilePath linkfile(link_dir.AppendASCII("file"));
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  // Now create the link from dir.lnk pointing to dir but
 | 
| -  // neither dir nor dir/file exist yet.
 | 
| -  ASSERT_TRUE(CreateSymbolicLink(dir, link_dir));
 | 
| -  // Note that we are watching dir.lnk/file.
 | 
| -  ASSERT_TRUE(SetupWatch(linkfile, &watcher, delegate.get(), false));
 | 
| -
 | 
| -  ASSERT_TRUE(base::CreateDirectory(dir));
 | 
| -  ASSERT_TRUE(WriteFile(file, "content"));
 | 
| -  VLOG(1) << "Waiting for dir/file creation";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  ASSERT_TRUE(WriteFile(file, "content v2"));
 | 
| -  VLOG(1) << "Waiting for file change";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  ASSERT_TRUE(base::DeleteFile(file, false));
 | 
| -  VLOG(1) << "Waiting for file deletion";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -// Verify that watching a file with a symlink on the path
 | 
| -// to the file works.
 | 
| -TEST_F(FilePathWatcherTest, LinkedDirectoryPart3) {
 | 
| -  FilePathWatcher watcher;
 | 
| -  FilePath dir(temp_dir_.path().AppendASCII("dir"));
 | 
| -  FilePath link_dir(temp_dir_.path().AppendASCII("dir.lnk"));
 | 
| -  FilePath file(dir.AppendASCII("file"));
 | 
| -  FilePath linkfile(link_dir.AppendASCII("file"));
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(base::CreateDirectory(dir));
 | 
| -  ASSERT_TRUE(CreateSymbolicLink(dir, link_dir));
 | 
| -  // Note that we are watching dir.lnk/file but the file doesn't exist yet.
 | 
| -  ASSERT_TRUE(SetupWatch(linkfile, &watcher, delegate.get(), false));
 | 
| -
 | 
| -  ASSERT_TRUE(WriteFile(file, "content"));
 | 
| -  VLOG(1) << "Waiting for file creation";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  ASSERT_TRUE(WriteFile(file, "content v2"));
 | 
| -  VLOG(1) << "Waiting for file change";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -
 | 
| -  ASSERT_TRUE(base::DeleteFile(file, false));
 | 
| -  VLOG(1) << "Waiting for file deletion";
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -#endif  // OS_LINUX
 | 
| -
 | 
| -enum Permission {
 | 
| -  Read,
 | 
| -  Write,
 | 
| -  Execute
 | 
| -};
 | 
| -
 | 
| -#if defined(OS_MACOSX)
 | 
| -bool ChangeFilePermissions(const FilePath& path, Permission perm, bool allow) {
 | 
| -  struct stat stat_buf;
 | 
| -
 | 
| -  if (stat(path.value().c_str(), &stat_buf) != 0)
 | 
| -    return false;
 | 
| -
 | 
| -  mode_t mode = 0;
 | 
| -  switch (perm) {
 | 
| -    case Read:
 | 
| -      mode = S_IRUSR | S_IRGRP | S_IROTH;
 | 
| -      break;
 | 
| -    case Write:
 | 
| -      mode = S_IWUSR | S_IWGRP | S_IWOTH;
 | 
| -      break;
 | 
| -    case Execute:
 | 
| -      mode = S_IXUSR | S_IXGRP | S_IXOTH;
 | 
| -      break;
 | 
| -    default:
 | 
| -      ADD_FAILURE() << "unknown perm " << perm;
 | 
| -      return false;
 | 
| -  }
 | 
| -  if (allow) {
 | 
| -    stat_buf.st_mode |= mode;
 | 
| -  } else {
 | 
| -    stat_buf.st_mode &= ~mode;
 | 
| -  }
 | 
| -  return chmod(path.value().c_str(), stat_buf.st_mode) == 0;
 | 
| -}
 | 
| -#endif  // defined(OS_MACOSX)
 | 
| -
 | 
| -#if defined(OS_MACOSX)
 | 
| -// Linux implementation of FilePathWatcher doesn't catch attribute changes.
 | 
| -// http://crbug.com/78043
 | 
| -// Windows implementation of FilePathWatcher catches attribute changes that
 | 
| -// don't affect the path being watched.
 | 
| -// http://crbug.com/78045
 | 
| -
 | 
| -// Verify that changing attributes on a directory works.
 | 
| -TEST_F(FilePathWatcherTest, DirAttributesChanged) {
 | 
| -  FilePath test_dir1(temp_dir_.path().AppendASCII("DirAttributesChangedDir1"));
 | 
| -  FilePath test_dir2(test_dir1.AppendASCII("DirAttributesChangedDir2"));
 | 
| -  FilePath test_file(test_dir2.AppendASCII("DirAttributesChangedFile"));
 | 
| -  // Setup a directory hierarchy.
 | 
| -  ASSERT_TRUE(base::CreateDirectory(test_dir1));
 | 
| -  ASSERT_TRUE(base::CreateDirectory(test_dir2));
 | 
| -  ASSERT_TRUE(WriteFile(test_file, "content"));
 | 
| -
 | 
| -  FilePathWatcher watcher;
 | 
| -  scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
 | 
| -  ASSERT_TRUE(SetupWatch(test_file, &watcher, delegate.get(), false));
 | 
| -
 | 
| -  // We should not get notified in this case as it hasn't affected our ability
 | 
| -  // to access the file.
 | 
| -  ASSERT_TRUE(ChangeFilePermissions(test_dir1, Read, false));
 | 
| -  loop_.PostDelayedTask(FROM_HERE,
 | 
| -                        MessageLoop::QuitWhenIdleClosure(),
 | 
| -                        TestTimeouts::tiny_timeout());
 | 
| -  ASSERT_FALSE(WaitForEvents());
 | 
| -  ASSERT_TRUE(ChangeFilePermissions(test_dir1, Read, true));
 | 
| -
 | 
| -  // We should get notified in this case because filepathwatcher can no
 | 
| -  // longer access the file
 | 
| -  ASSERT_TRUE(ChangeFilePermissions(test_dir1, Execute, false));
 | 
| -  ASSERT_TRUE(WaitForEvents());
 | 
| -  ASSERT_TRUE(ChangeFilePermissions(test_dir1, Execute, true));
 | 
| -  DeleteDelegateOnFileThread(delegate.release());
 | 
| -}
 | 
| -
 | 
| -#endif  // OS_MACOSX
 | 
| -}  // namespace
 | 
| -
 | 
| -}  // namespace base
 | 
| 
 |