| 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
|
|
|