Keep track of which attachments are referenced by which sync entries.

sync/api/attachments/attachment_service_proxy.cc

 // Copyright 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 "sync/api/attachments/attachment_service_proxy.h"
 
 #include "base/bind.h"
 #include "base/message_loop/message_loop.h"
 #include "sync/api/sync_data.h"
 
@@ skipping 17 matching lines @@
 
 // Invokes |callback| with |result| and |attachments| in the |task_runner|
 // thread.
 void ProxyDropCallback(
     const scoped_refptr<base::SequencedTaskRunner>& task_runner,
     const AttachmentService::DropCallback& callback,
     const AttachmentService::DropResult& result) {
   task_runner->PostTask(FROM_HERE, base::Bind(callback, result));
 }
 
+// Invokes |callback| with |result| and |attachments| in the |task_runner|
+// thread.
+void ProxyStoreCallback(
+    const scoped_refptr<base::SequencedTaskRunner>& task_runner,
+    const AttachmentService::StoreCallback& callback,
+    const AttachmentService::StoreResult& result) {
+  task_runner->PostTask(FROM_HERE, base::Bind(callback, result));
+}
+
 }  // namespace
 
 AttachmentServiceProxy::AttachmentServiceProxy() {
 }
 
 AttachmentServiceProxy::AttachmentServiceProxy(
     const scoped_refptr<base::SequencedTaskRunner>& wrapped_task_runner,
     const base::WeakPtr<syncer::AttachmentService>& wrapped)
     : wrapped_task_runner_(wrapped_task_runner), core_(new Core(wrapped)) {
   DCHECK(wrapped_task_runner_);
@@ skipping 30 matching lines @@
   DCHECK(wrapped_task_runner_);
   DropCallback proxy_callback = base::Bind(
       &ProxyDropCallback, base::MessageLoopProxy::current(), callback);
   wrapped_task_runner_->PostTask(FROM_HERE,
                                  base::Bind(&AttachmentService::DropAttachments,
                                             core_,
                                             attachment_ids,
                                             proxy_callback));
 }
 
-void AttachmentServiceProxy::OnSyncDataAdd(const SyncData& sync_data) {
+void AttachmentServiceProxy::StoreAttachments(
+    const AttachmentList& attachments,
+    const StoreCallback& callback) {
   DCHECK(wrapped_task_runner_);
+  StoreCallback proxy_callback = base::Bind(
+      &ProxyStoreCallback, base::MessageLoopProxy::current(), callback);
   wrapped_task_runner_->PostTask(
       FROM_HERE,
-      base::Bind(&AttachmentService::OnSyncDataAdd, core_, sync_data));
+      base::Bind(&AttachmentService::StoreAttachments,
+                 core_,
+                 attachments,
+                 proxy_callback));
 }
 
 void AttachmentServiceProxy::OnSyncDataDelete(const SyncData& sync_data) {
   DCHECK(wrapped_task_runner_);
   wrapped_task_runner_->PostTask(
       FROM_HERE,
       base::Bind(&AttachmentService::OnSyncDataDelete, core_, sync_data));
 }
 
 void AttachmentServiceProxy::OnSyncDataUpdate(
@@ skipping 27 matching lines @@
 
 void AttachmentServiceProxy::Core::DropAttachments(
     const AttachmentIdList& attachment_ids,
     const DropCallback& callback) {
   if (!wrapped_) {
     return;
   }
   wrapped_->DropAttachments(attachment_ids, callback);
 }
 
-void AttachmentServiceProxy::Core::OnSyncDataAdd(const SyncData& sync_data) {
+void AttachmentServiceProxy::Core::StoreAttachments(
+    const AttachmentList& attachments,
+    const StoreCallback& callback) {
   if (!wrapped_) {
     return;
   }
-  wrapped_->OnSyncDataAdd(sync_data);
+  wrapped_->StoreAttachments(attachments, callback);
 }
 
 void AttachmentServiceProxy::Core::OnSyncDataDelete(const SyncData& sync_data) {
   if (!wrapped_) {
     return;
   }
   wrapped_->OnSyncDataDelete(sync_data);
 }
 
 void AttachmentServiceProxy::Core::OnSyncDataUpdate(
     const AttachmentIdList& old_attachment_ids,
     const SyncData& updated_sync_data) {
   if (!wrapped_) {
     return;
   }
   wrapped_->OnSyncDataUpdate(old_attachment_ids, updated_sync_data);
 }
 
 }  // namespace syncer