sync: Add interfaces for per-type sync

sync/engine/commit.cc

 // Copyright 2012 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 "sync/engine/commit.h"
 
 #include "base/debug/trace_event.h"
+#include "sync/engine/commit_contribution.h"
 #include "sync/engine/commit_processor.h"
 #include "sync/engine/commit_util.h"
-#include "sync/engine/sync_directory_commit_contribution.h"
 #include "sync/engine/syncer.h"
 #include "sync/engine/syncer_proto_util.h"
 #include "sync/sessions/sync_session.h"
 
 namespace syncer {
 
 Commit::Commit(
-    const std::map<ModelType, SyncDirectoryCommitContribution*>& contributions,
+    const std::map<ModelType, CommitContribution*>& contributions,
     const sync_pb::ClientToServerMessage& message,
     ExtensionsActivity::Records extensions_activity_buffer)
   : contributions_(contributions),
     deleter_(&contributions_),
     message_(message),
     extensions_activity_buffer_(extensions_activity_buffer),
     cleaned_up_(false) {
 }
 
 Commit::~Commit() {
@@ skipping 35 matching lines @@
         &extensions_activity_buffer,
         commit_message);
   }
 
   // Set the client config params.
   commit_util::AddClientConfigParamsToMessage(
       enabled_types,
       commit_message);
 
   // Finally, serialize all our contributions.
-  for (std::map<ModelType, SyncDirectoryCommitContribution*>::iterator it =
+  for (std::map<ModelType, CommitContribution*>::iterator it =
            contributions.begin(); it != contributions.end(); ++it) {
     it->second->AddToCommitMessage(&message);
   }
 
   // If we made it this far, then we've successfully prepared a commit message.
   return new Commit(contributions, message, extensions_activity_buffer);
 }
 
 SyncerError Commit::PostAndProcessResponse(
     sessions::SyncSession* session,
@@ skipping 38 matching lines @@
   }
 
   if (session->context()->debug_info_getter()) {
     // Clear debug info now that we have successfully sent it to the server.
     DVLOG(1) << "Clearing client debug info.";
     session->context()->debug_info_getter()->ClearDebugInfo();
   }
 
   // Let the contributors process the responses to each of their requests.
   SyncerError processing_result = SYNCER_OK;
-  for (std::map<ModelType, SyncDirectoryCommitContribution*>::iterator it =
+  for (std::map<ModelType, CommitContribution*>::iterator it =
        contributions_.begin(); it != contributions_.end(); ++it) {
     TRACE_EVENT1("sync", "ProcessCommitResponse",
                  "type", ModelTypeToString(it->first));
     SyncerError type_result =
         it->second->ProcessCommitResponse(response_, status);
     if (processing_result == SYNCER_OK && type_result != SYNCER_OK) {
       processing_result = type_result;
     }
   }
 
   // Handle bookmarks' special extensions activity stats.
   if (session->status_controller().
           model_neutral_state().num_successful_bookmark_commits == 0) {
     extensions_activity->PutRecords(extensions_activity_buffer_);
   }
 
   return processing_result;
 }
 
 void Commit::CleanUp() {
   for (ContributionMap::iterator it = contributions_.begin();
        it != contributions_.end(); ++it) {
     it->second->CleanUp();
   }
   cleaned_up_ = true;
 }
 
 }  // namespace syncer