| OLD | NEW |
| (Empty) |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "sync/internal_api/public/attachments/attachment_store_frontend.h" | |
| 6 | |
| 7 #include "base/bind.h" | |
| 8 #include "base/location.h" | |
| 9 #include "base/sequenced_task_runner.h" | |
| 10 #include "sync/api/attachments/attachment.h" | |
| 11 #include "sync/api/attachments/attachment_store_backend.h" | |
| 12 | |
| 13 namespace syncer { | |
| 14 | |
| 15 namespace { | |
| 16 | |
| 17 // NoOp is needed to bind base::Passed(backend) in AttachmentStoreFrontend dtor. | |
| 18 // It doesn't need to do anything. | |
| 19 void NoOp(scoped_ptr<AttachmentStoreBackend> backend) { | |
| 20 } | |
| 21 | |
| 22 } // namespace | |
| 23 | |
| 24 AttachmentStoreFrontend::AttachmentStoreFrontend( | |
| 25 scoped_ptr<AttachmentStoreBackend> backend, | |
| 26 const scoped_refptr<base::SequencedTaskRunner>& backend_task_runner) | |
| 27 : backend_(backend.Pass()), backend_task_runner_(backend_task_runner) { | |
| 28 DCHECK(backend_); | |
| 29 DCHECK(backend_task_runner_.get()); | |
| 30 } | |
| 31 | |
| 32 AttachmentStoreFrontend::~AttachmentStoreFrontend() { | |
| 33 DCHECK(backend_); | |
| 34 // To delete backend post task that doesn't do anything, but binds backend | |
| 35 // through base::Passed. This way backend will be deleted regardless whether | |
| 36 // task runs or not. | |
| 37 backend_task_runner_->PostTask(FROM_HERE, | |
| 38 base::Bind(&NoOp, base::Passed(&backend_))); | |
| 39 } | |
| 40 | |
| 41 void AttachmentStoreFrontend::Init( | |
| 42 const AttachmentStore::InitCallback& callback) { | |
| 43 DCHECK(CalledOnValidThread()); | |
| 44 backend_task_runner_->PostTask( | |
| 45 FROM_HERE, base::Bind(&AttachmentStoreBackend::Init, | |
| 46 base::Unretained(backend_.get()), callback)); | |
| 47 } | |
| 48 | |
| 49 void AttachmentStoreFrontend::Read( | |
| 50 const AttachmentIdList& ids, | |
| 51 const AttachmentStore::ReadCallback& callback) { | |
| 52 DCHECK(CalledOnValidThread()); | |
| 53 backend_task_runner_->PostTask( | |
| 54 FROM_HERE, base::Bind(&AttachmentStoreBackend::Read, | |
| 55 base::Unretained(backend_.get()), ids, callback)); | |
| 56 } | |
| 57 | |
| 58 void AttachmentStoreFrontend::Write( | |
| 59 AttachmentStore::AttachmentReferrer referrer, | |
| 60 const AttachmentList& attachments, | |
| 61 const AttachmentStore::WriteCallback& callback) { | |
| 62 DCHECK(CalledOnValidThread()); | |
| 63 backend_task_runner_->PostTask( | |
| 64 FROM_HERE, base::Bind(&AttachmentStoreBackend::Write, | |
| 65 base::Unretained(backend_.get()), referrer, | |
| 66 attachments, callback)); | |
| 67 } | |
| 68 | |
| 69 void AttachmentStoreFrontend::Drop( | |
| 70 AttachmentStore::AttachmentReferrer referrer, | |
| 71 const AttachmentIdList& ids, | |
| 72 const AttachmentStore::DropCallback& callback) { | |
| 73 DCHECK(CalledOnValidThread()); | |
| 74 backend_task_runner_->PostTask( | |
| 75 FROM_HERE, | |
| 76 base::Bind(&AttachmentStoreBackend::Drop, | |
| 77 base::Unretained(backend_.get()), referrer, ids, callback)); | |
| 78 } | |
| 79 | |
| 80 void AttachmentStoreFrontend::ReadMetadata( | |
| 81 const AttachmentIdList& ids, | |
| 82 const AttachmentStore::ReadMetadataCallback& callback) { | |
| 83 DCHECK(CalledOnValidThread()); | |
| 84 backend_task_runner_->PostTask( | |
| 85 FROM_HERE, base::Bind(&AttachmentStoreBackend::ReadMetadata, | |
| 86 base::Unretained(backend_.get()), ids, callback)); | |
| 87 } | |
| 88 | |
| 89 void AttachmentStoreFrontend::ReadAllMetadata( | |
| 90 AttachmentStore::AttachmentReferrer referrer, | |
| 91 const AttachmentStore::ReadMetadataCallback& callback) { | |
| 92 DCHECK(CalledOnValidThread()); | |
| 93 backend_task_runner_->PostTask( | |
| 94 FROM_HERE, | |
| 95 base::Bind(&AttachmentStoreBackend::ReadAllMetadata, | |
| 96 base::Unretained(backend_.get()), referrer, callback)); | |
| 97 } | |
| 98 | |
| 99 } // namespace syncer | |
| OLD | NEW |