Index: chrome/browser/media_gallery/linux/open_mtp_storage_worker.cc |
diff --git a/chrome/browser/media_gallery/linux/open_mtp_storage_worker.cc b/chrome/browser/media_gallery/linux/open_mtp_storage_worker.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..9d3c28509e0c4d2760ae5156ba7d0d4a9c75d21c |
--- /dev/null |
+++ b/chrome/browser/media_gallery/linux/open_mtp_storage_worker.cc |
@@ -0,0 +1,74 @@ |
+// 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. |
+// |
+// OpenMTPStorageWorker implementation. |
+ |
+#include "chrome/browser/media_gallery/linux/open_mtp_storage_worker.h" |
+ |
+#include "base/bind.h" |
+#include "base/logging.h" |
+#include "base/sequenced_task_runner.h" |
+#include "base/synchronization/waitable_event.h" |
+#include "chrome/browser/media_transfer_protocol/media_transfer_protocol_manager.h" |
+#include "content/public/browser/browser_thread.h" |
+#include "third_party/cros_system_api/dbus/service_constants.h" |
+ |
+namespace chrome { |
+ |
+OpenMTPStorageWorker::OpenMTPStorageWorker( |
+ const std::string& name, |
+ base::SequencedTaskRunner* task_runner, |
+ base::WaitableEvent* task_completed_event, |
+ base::WaitableEvent* shutdown_event) |
+ : storage_name_(name), |
+ media_task_runner_(task_runner), |
+ on_task_completed_event_(task_completed_event), |
+ on_shutdown_event_(shutdown_event) { |
+ DCHECK(on_task_completed_event_); |
+ DCHECK(on_shutdown_event_); |
+} |
+ |
+void OpenMTPStorageWorker::Run() { |
+ if (on_shutdown_event_->IsSignaled()) { |
+ // Process is in shutdown mode. |
+ // Do not post any task on |media_task_runner_|. |
+ return; |
+ } |
+ |
+ DCHECK(media_task_runner_->RunsTasksOnCurrentThread()); |
+ content::BrowserThread::PostTask( |
+ content::BrowserThread::UI, FROM_HERE, |
+ base::Bind(&OpenMTPStorageWorker::DoWorkOnUIThread, this)); |
+ on_task_completed_event_->Wait(); |
+ |
+ if (on_shutdown_event_->IsSignaled()) |
+ cancel_tasks_flag_.Set(); |
+} |
+ |
+OpenMTPStorageWorker::~OpenMTPStorageWorker() { |
+ // This object must be destructed on |media_task_runner_|. |
+} |
+ |
+void OpenMTPStorageWorker::DoWorkOnUIThread() { |
+ DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); |
+ if (cancel_tasks_flag_.IsSet()) |
+ return; |
+ |
+ GetMediaTransferProtocolManager()->OpenStorage( |
+ storage_name_, mtpd::kReadOnlyMode, |
+ base::Bind(&OpenMTPStorageWorker::OnDidWorkOnUIThread, this)); |
+} |
+ |
+void OpenMTPStorageWorker::OnDidWorkOnUIThread(const std::string& device_handle, |
+ bool error) { |
+ DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); |
+ if (cancel_tasks_flag_.IsSet()) |
+ return; |
+ |
+ if (!error) |
+ device_handle_ = device_handle; |
+ on_task_completed_event_->Signal(); |
+} |
+ |
+} // namespace chrome |