Add DeviceEventRouter class.

chrome/browser/chromeos/extensions/file_manager/device_event_router.cc

+// Copyright (c) 2014 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/bind.h"
+#include "chrome/browser/chromeos/extensions/file_manager/device_event_router.h"
+#include "chrome/browser/chromeos/file_manager/volume_manager.h"
+#include "content/public/browser/browser_thread.h"
+
+namespace file_manager {
+namespace {
+namespace file_browser_private = extensions::api::file_browser_private;
+using content::BrowserThread;
+const base::TimeDelta kStartupTimeSpan = base::TimeDelta::FromSeconds(10);
+const base::TimeDelta kScanReportTimeSpan = base::TimeDelta::FromSeconds(5);
+const base::TimeDelta kResumingTimeSpan = base::TimeDelta::FromSeconds(5);
+}  // namespace
+
+DeviceEventRouter::DeviceEventRouter()
+    : is_startup_(false), is_suspended_(false), weak_factory_(this) {
+}
+
+DeviceEventRouter::~DeviceEventRouter() {
+}
+
+void DeviceEventRouter::Startup() {
+  is_startup_ = true;
+  PostDelayedTask(base::Bind(&DeviceEventRouter::StartupDelayed,

[mtomasz, 2014/08/20 06:31:01]

PostDelayedTask seems to be not implemented.

[hirono, 2014/08/20 08:07:16]

Yes, the method is implemented in sub-classes.

[mtomasz, 2014/08/20 08:20:17]

The Impl seems not included in this CL, is it OK?

[hirono, 2014/08/21 07:09:32]

Yes, currently the class is used only from the unit test.
The following CL modifies EventRouter and make it use the class.

+                             weak_factory_.GetWeakPtr()),
+                  kStartupTimeSpan);
+}
+
+void DeviceEventRouter::StartupDelayed() {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+  is_startup_ = false;
+}
+
+void DeviceEventRouter::OnDeviceAdded(const std::string& device_path) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+
+  if (is_startup_ || is_suspended_) {

[mtomasz, 2014/08/20 06:31:01]

is_suspended_ is true while we're are not suspended anymore. How about renaming
to "resuming"?

[hirono, 2014/08/20 08:07:16]

Done.

+    SetDeviceState(device_path, DEVICE_STATE_USUAL);
+    return;
+  }
+
+  if (IsExternalStorageDisabled()) {
+    OnDeviceEvent(file_browser_private::DEVICE_EVENT_TYPE_DISABLED,
+                  device_path);
+    SetDeviceState(device_path, DEVICE_STATE_USUAL);
+    return;
+  }
+
+  SetDeviceState(device_path, DEVICE_SCANNED);
+  PostDelayedTask(base::Bind(&DeviceEventRouter::OnDeviceAddedDelayed,
+                             weak_factory_.GetWeakPtr(),
+                             device_path),
+                  kScanReportTimeSpan);
+}
+
+void DeviceEventRouter::OnDeviceAddedDelayed(const std::string& device_path) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+
+  if (GetDeviceState(device_path) == DEVICE_SCANNED) {
+    // TODO(hirono): Rename DEVICE_EVENT_TYPE_ADDED with
+    // DEVICE_EVENT_TYPE_SCAN_STARTED.
+    OnDeviceEvent(file_browser_private::DEVICE_EVENT_TYPE_ADDED, device_path);
+    SetDeviceState(device_path, DEVICE_SCANNED_AND_REPORTED);
+  }
+}
+
+void DeviceEventRouter::OnDeviceRemoved(const std::string& device_path) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+  SetDeviceState(device_path, DEVICE_STATE_USUAL);
+  OnDeviceEvent(file_browser_private::DEVICE_EVENT_TYPE_REMOVED, device_path);
+}
+
+void DeviceEventRouter::OnDiskAdded(
+    const chromeos::disks::DiskMountManager::Disk& disk,
+    bool mounting) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+
+  if (!mounting) {
+    // If the disk is not being mounted, mark the device scan cancelled.
+    const std::string& device_path = disk.system_path_prefix();
+    if (GetDeviceState(device_path) == DEVICE_SCANNED_AND_REPORTED) {
+      OnDeviceEvent(file_browser_private::DEVICE_EVENT_TYPE_SCAN_CANCELED,
+                    device_path);
+    }
+    SetDeviceState(device_path, DEVICE_STATE_USUAL);
+  }
+}
+
+void DeviceEventRouter::OnDiskRemoved(
+    const chromeos::disks::DiskMountManager::Disk& disk) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+  if (is_suspended_ || is_startup_)
+    return;
+
+  const std::string& device_path = disk.system_path_prefix();
+  if (!disk.mount_path().empty() &&
+      GetDeviceState(device_path) != DEVICE_HARD_UNPLUGGED_AND_REPORTED) {
+    OnDeviceEvent(file_browser_private::DEVICE_EVENT_TYPE_HARD_UNPLUGGED,
+                  device_path);
+    SetDeviceState(device_path, DEVICE_HARD_UNPLUGGED_AND_REPORTED);
+  }
+}
+
+void DeviceEventRouter::OnVolumeMounted(chromeos::MountError error_code,
+                                        const VolumeInfo& volume_info,
+                                        bool is_remounting) {
+  const std::string& device_path =
+      volume_info.system_path_prefix.AsUTF8Unsafe();
+  SetDeviceState(device_path, DEVICE_STATE_USUAL);
+}
+
+void DeviceEventRouter::OnVolumeUnmounted(chromeos::MountError error_code,
+                                          const VolumeInfo& volume_info) {
+  // Do nothing.
+}
+
+void DeviceEventRouter::OnFormatStarted(const std::string& device_path,
+                                        bool success) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+
+  if (success) {
+    OnDeviceEvent(file_browser_private::DEVICE_EVENT_TYPE_FORMAT_START,
+                  device_path);
+  } else {
+    OnDeviceEvent(file_browser_private::DEVICE_EVENT_TYPE_FORMAT_FAIL,
+                  device_path);
+  }
+}
+
+void DeviceEventRouter::OnFormatCompleted(const std::string& device_path,
+                                          bool success) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+  OnDeviceEvent(success ? file_browser_private::DEVICE_EVENT_TYPE_FORMAT_SUCCESS
+                        : file_browser_private::DEVICE_EVENT_TYPE_FORMAT_FAIL,
+                device_path);
+}
+
+void DeviceEventRouter::SuspendImminent() {
+  is_suspended_ = true;
+}
+
+void DeviceEventRouter::SuspendDone(const base::TimeDelta& sleep_duration) {
+  PostDelayedTask(base::Bind(&DeviceEventRouter::SuspendDoneDelayed,
+                             weak_factory_.GetWeakPtr()),
+                  kResumingTimeSpan);
+}
+
+void DeviceEventRouter::SuspendDoneDelayed() {
+  is_suspended_ = false;
+}
+
+DeviceState DeviceEventRouter::GetDeviceState(const std::string& device_path) {
+  return device_states_.count(device_path) > 0 ? device_states_[device_path]
+                                               : DEVICE_STATE_USUAL;
+}
+
+void DeviceEventRouter::SetDeviceState(const std::string& device_path,
+                                       DeviceState state) {
+  if (state != DEVICE_STATE_USUAL) {
+    device_states_[device_path] = state;
+  } else {
+    const std::map<std::string, DeviceState>::iterator it =
+        device_states_.find(device_path);
+    if (it != device_states_.end())
+      device_states_.erase(it);
+  }
+}
+
+}  // namespace file_manager