chromium/components/sync/engine/data_type_processor_proxy.cc

// Copyright 2016 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "components/sync/engine/data_type_processor_proxy.h"

#include <utility>

#include "base/functional/bind.h"
#include "base/location.h"
#include "base/task/sequenced_task_runner.h"
#include "components/sync/engine/commit_queue.h"
#include "components/sync/protocol/data_type_state.pb.h"

namespace syncer {

DataTypeProcessorProxy::DataTypeProcessorProxy(
    const base::WeakPtr<DataTypeProcessor>& processor,
    const scoped_refptr<base::SequencedTaskRunner>& task_runner)
    : … { … }

DataTypeProcessorProxy::~DataTypeProcessorProxy() = default;

void DataTypeProcessorProxy::ConnectSync(std::unique_ptr<CommitQueue> worker) { … }

void DataTypeProcessorProxy::DisconnectSync() { … }

void ForwardGetLocalChangesCall(
    base::WeakPtr<DataTypeProcessor> processor,
    size_t max_entries,
    DataTypeProcessor::GetLocalChangesCallback callback) { … }

void DataTypeProcessorProxy::GetLocalChanges(
    size_t max_entries,
    GetLocalChangesCallback callback) { … }

void DataTypeProcessorProxy::OnCommitCompleted(
    const sync_pb::DataTypeState& type_state,
    const CommitResponseDataList& committed_response_list,
    const FailedCommitResponseDataList& error_response_list) { … }

void DataTypeProcessorProxy::OnCommitFailed(SyncCommitError commit_error) { … }

void DataTypeProcessorProxy::OnUpdateReceived(
    const sync_pb::DataTypeState& type_state,
    UpdateResponseDataList updates,
    std::optional<sync_pb::GarbageCollectionDirective> gc_directive) { … }

void DataTypeProcessorProxy::StorePendingInvalidations(
    std::vector<sync_pb::DataTypeState::Invalidation> invalidations_to_store) { … }

}  // namespace syncer