chromium/components/sync/engine/forwarding_data_type_processor.cc

// Copyright 2019 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/forwarding_data_type_processor.h"

#include <utility>

#include "base/functional/callback.h"
#include "components/sync/engine/commit_queue.h"
#include "components/sync/protocol/data_type_state.pb.h"

namespace syncer {

ForwardingDataTypeProcessor::ForwardingDataTypeProcessor(
    DataTypeProcessor* processor)
    : … { … }

ForwardingDataTypeProcessor::~ForwardingDataTypeProcessor() = default;

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

void ForwardingDataTypeProcessor::DisconnectSync() { … }

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

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

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

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

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

}  // namespace syncer