blob: 28b5f2abdee714035ac70a485575a7f089a5fc04 [file] [log] [blame]
// 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 <map>
#include "base/memory/ref_counted.h"
#include "base/memory/scoped_ptr.h"
#include "base/stl_util.h"
#include "base/threading/non_thread_safe.h"
#include "sync/api/attachments/attachment_store.h"
#include "sync/base/sync_export.h"
namespace base {
class SequencedTaskRunner;
} // namespace base
namespace sync_pb {
class AttachmentId;
} // namespace sync_pb
namespace syncer {
class Attachment;
// AttachmentStoreHandle is helper to post AttachmentStore calls to backend on
// different thread. Backend is expected to know on which thread to post
// callbacks with results.
// AttachmentStoreHandle takes ownership of backend. Backend is deleted on
// backend thread.
// AttachmentStoreHandle is not thread safe, it should only be accessed from
// model thread.
class SYNC_EXPORT AttachmentStoreHandle : public AttachmentStore,
public base::NonThreadSafe {
scoped_ptr<AttachmentStoreBase> backend,
const scoped_refptr<base::SequencedTaskRunner>& backend_task_runner);
// AttachmentStore implementation.
virtual void Read(const AttachmentIdList& id,
const ReadCallback& callback) OVERRIDE;
virtual void Write(const AttachmentList& attachments,
const WriteCallback& callback) OVERRIDE;
virtual void Drop(const AttachmentIdList& id,
const DropCallback& callback) OVERRIDE;
virtual ~AttachmentStoreHandle();
// AttachmentStoreHandle controls backend's lifetime. It is safe for
// AttachmentStoreHandle to bind backend through base::Unretained for posts.
// Backend is deleted on backend_task_runner, after that backend_ pointer is
// invalid.
scoped_ptr<AttachmentStoreBase> backend_;
scoped_refptr<base::SequencedTaskRunner> backend_task_runner_;
} // namespace syncer