blob: 13523df4a88107a8a88ba5a3408f3a22e9e63fbe [file] [log] [blame]
// 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.
#ifndef CHROME_BROWSER_CHROMEOS_DRIVE_FILE_WRITE_WATCHER_H_
#define CHROME_BROWSER_CHROMEOS_DRIVE_FILE_WRITE_WATCHER_H_
#include "base/callback_forward.h"
#include "base/memory/scoped_ptr.h"
#include "base/memory/weak_ptr.h"
#include "chrome/browser/chromeos/drive/file_system_util.h"
namespace base {
class FilePath;
} // namespace base
namespace drive {
namespace file_system {
class OperationObserver;
} // namespace file_system
namespace internal {
typedef base::Callback<void(bool)> StartWatchCallback;
// The class watches modification to Drive files in the cache directory.
// This is used for returning a local writable snapshot of Drive files from the
// Save-As file dialog, so that the callers of the dialog can save to Drive
// without any special handling about Drive.
class FileWriteWatcher {
public:
explicit FileWriteWatcher(file_system::OperationObserver* observer);
~FileWriteWatcher();
// Starts watching the modification to |path|. When it successfully started
// watching, it runs |callback| by passing true as the argument. Or if it
// failed, the callback is run with false.
// When modification is detected, it is notified to the |observer| passed to
// the constructor by calling OnCacheFileUploadNeededByOperation(resource_id).
//
// Currently, the modification is watched in "one-shot" manner. That is, once
// a modification is notified, the watch is deactivated for freeing system
// resources. As a heuristic to capture the real end of write operations that
// might be done by several chunked writes, the notification is fired after
// 5 seconds has passed after the last write operation is detected.
//
// TODO(kinaba): investigate the possibility to continuously watch the whole
// cache directory. http://crbug.com/269424
void StartWatch(const base::FilePath& path,
const std::string& resource_id,
const StartWatchCallback& callback);
// For testing purpose, stops inserting delay between the write detection and
// notification to the observer.
void DisableDelayForTesting();
private:
// Invoked when a modification is observed.
void OnWriteEvent(const std::string& resource_id);
class FileWriteWatcherImpl;
scoped_ptr<FileWriteWatcherImpl, util::DestroyHelper> watcher_impl_;
file_system::OperationObserver* operation_observer_;
// Note: This should remain the last member so it'll be destroyed and
// invalidate its weak pointers before any other members are destroyed.
base::WeakPtrFactory<FileWriteWatcher> weak_ptr_factory_;
DISALLOW_COPY_AND_ASSIGN(FileWriteWatcher);
};
} // namespace internal
} // namespace drive
#endif // CHROME_BROWSER_CHROMEOS_DRIVE_FILE_WRITE_WATCHER_H_