Implement CopyFileFromLocal of MTPDeviceAsyncDelegate.

device/media_transfer_protocol/media_transfer_protocol_daemon_client.cc

 // 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 "device/media_transfer_protocol/media_transfer_protocol_daemon_client.h"
 
 #include <algorithm>
 
 #include "base/bind.h"
 #include "base/memory/weak_ptr.h"
@@ skipping 54 matching lines @@
   }
 
   // MediaTransferProtocolDaemonClient override.
   void OpenStorage(const std::string& storage_name,
                    const std::string& mode,
                    const OpenStorageCallback& callback,
                    const ErrorCallback& error_callback) override {
     dbus::MethodCall method_call(mtpd::kMtpdInterface, mtpd::kOpenStorage);
     dbus::MessageWriter writer(&method_call);
     writer.AppendString(storage_name);
-    DCHECK_EQ(mtpd::kReadOnlyMode, mode);
-    writer.AppendString(mtpd::kReadOnlyMode);
+    DCHECK(mode == mtpd::kReadOnlyMode || mode == mtpd::kReadWriteMode);
+    writer.AppendString(mode);
     proxy_->CallMethod(
         &method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT,
         base::Bind(&MediaTransferProtocolDaemonClientImpl::OnOpenStorage,
                    weak_ptr_factory_.GetWeakPtr(),
                    callback,
                    error_callback));
   }
 
   // MediaTransferProtocolDaemonClient override.
   void CloseStorage(const std::string& handle,
@@ skipping 77 matching lines @@
     writer.AppendUint32(offset);
     writer.AppendUint32(bytes_to_read);
     proxy_->CallMethod(
         &method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT,
         base::Bind(&MediaTransferProtocolDaemonClientImpl::OnReadFile,
                    weak_ptr_factory_.GetWeakPtr(),
                    callback,
                    error_callback));
   }
 
+  void CopyFileFromLocal(const std::string& handle,
+                         const int source_file_descriptor,
+                         const uint32 parent_id,
+                         const std::string& file_name,
+                         const CopyFileFromLocalCallback& callback,
+                         const ErrorCallback& error_callback) override {
+    dbus::FileDescriptor file_descriptor(source_file_descriptor);
+    file_descriptor.CheckValidity();
+
+    dbus::MethodCall method_call(mtpd::kMtpdInterface,
+                                 mtpd::kCopyFileFromLocal);
+    dbus::MessageWriter writer(&method_call);
+    writer.AppendString(handle);
+    writer.AppendFileDescriptor(file_descriptor);
+    writer.AppendUint32(parent_id);
+    writer.AppendString(file_name);
+    proxy_->CallMethod(
+        &method_call, dbus::ObjectProxy::TIMEOUT_INFINITE,
+        base::Bind(&MediaTransferProtocolDaemonClientImpl::OnCopyFileFromLocal,
+                   weak_ptr_factory_.GetWeakPtr(), callback, error_callback));
+  }
+
   // MediaTransferProtocolDaemonClient override.
   void ListenForChanges(const MTPStorageEventHandler& handler) override {
     DCHECK(!listen_for_changes_called_);
     listen_for_changes_called_ = true;
 
     static const SignalEventTuple kSignalEventTuples[] = {
       { mtpd::kMTPStorageAttached, true },
       { mtpd::kMTPStorageDetached, false },
     };
     const size_t kNumSignalEventTuples = arraysize(kSignalEventTuples);
@@ skipping 158 matching lines @@
     size_t data_length = 0;
     dbus::MessageReader reader(response);
     if (!reader.PopArrayOfBytes(&data_bytes, &data_length)) {
       error_callback.Run();
       return;
     }
     std::string data(reinterpret_cast<const char*>(data_bytes), data_length);
     callback.Run(data);
   }
 
+  void OnCopyFileFromLocal(const CopyFileFromLocalCallback& callback,
+                           const ErrorCallback& error_callback,
+                           dbus::Response* response) {
+    if (!response) {
+      error_callback.Run();
+      return;
+    }
+
+    callback.Run();
+  }
+
   // Handles MTPStorageAttached/Dettached signals and calls |handler|.
   void OnMTPStorageSignal(MTPStorageEventHandler handler,
                           bool is_attach,
                           dbus::Signal* signal) {
     dbus::MessageReader reader(signal);
     std::string storage_name;
     if (!reader.PopString(&storage_name)) {
       LOG(ERROR) << "Invalid signal: " << signal->ToString();
       return;
     }
@@ skipping 30 matching lines @@
 
 MediaTransferProtocolDaemonClient::~MediaTransferProtocolDaemonClient() {}
 
 // static
 MediaTransferProtocolDaemonClient* MediaTransferProtocolDaemonClient::Create(
     dbus::Bus* bus) {
   return new MediaTransferProtocolDaemonClientImpl(bus);
 }
 
 }  // namespace device