sync/internal_api/sync_context_proxy_impl.h

   1 // Copyright 2014 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 #ifndef SYNC_INTERNAL_API_SYNC_CONTEXT_PROXY_IMPL_H_
   6 #define SYNC_INTERNAL_API_SYNC_CONTEXT_PROXY_IMPL_H_
   7
   8 #include "base/memory/scoped_ptr.h"
   9 #include "base/memory/weak_ptr.h"
  10 #include "base/sequenced_task_runner.h"
  11 #include "sync/base/sync_export.h"
  12 #include "sync/internal_api/public/base/model_type.h"
  13 #include "sync/internal_api/public/sync_context_proxy.h"
  14
  15 namespace syncer {
  16 class ModelTypeSyncProxyImpl;
  17 }
  18
  19 namespace syncer_v2 {
  20
  21 class SyncContext;
  22 struct DataTypeState;
  23
  24 // Encapsulates a reference to the sync context and the thread it's running on.
  25 // Used by sync's data types to connect with the sync context.
  26 //
  27 // It is expected that this object will be copied to and used on many different
  28 // threads.  It is small and safe to pass by value.
  29 class SYNC_EXPORT_PRIVATE SyncContextProxyImpl : public SyncContextProxy {
  30  public:
  31   SyncContextProxyImpl(
  32       const scoped_refptr<base::SequencedTaskRunner>& sync_task_runner,
  33       const base::WeakPtr<SyncContext>& sync_context);
  34   ~SyncContextProxyImpl() override;
  35
  36   // Attempts to connect a non-blocking type to the sync context.
  37   //
  38   // This may fail under some unusual circumstances, like shutdown.  Due to the
  39   // nature of WeakPtrs and cross-thread communication, the caller will be
  40   // unable to distinguish a slow success from failure.
  41   //
  42   // Must be called from the thread where the data type lives.
  43   void ConnectTypeToSync(syncer::ModelType type,
  44                          const DataTypeState& data_type_state,
  45                          const UpdateResponseDataList& pending_updates,
  46                          const base::WeakPtr<syncer::ModelTypeSyncProxyImpl>&
  47                              sync_proxy_impl) override;
  48
  49   // Disables syncing for the given type on the sync thread.
  50   void Disconnect(syncer::ModelType type) override;
  51
  52   scoped_ptr<SyncContextProxy> Clone() const override;
  53
  54  private:
  55   // A SequencedTaskRunner representing the thread where the SyncContext lives.
  56   scoped_refptr<base::SequencedTaskRunner> sync_task_runner_;
  57
  58   // The SyncContext this object is wrapping.
  59   base::WeakPtr<SyncContext> sync_context_;
  60 };
  61
  62 }  // namespace syncer
  63
  64 #endif  // SYNC_INTERNAL_API_SYNC_CONTEXT_PROXY_IMPL_H_