Split up SyncEngineEventListener callbacks

sync/engine/all_status.cc

 // Copyright (c) 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/all_status.h"
 
 #include <algorithm>
 
 #include "base/logging.h"
 #include "base/port.h"
@@ skipping 17 matching lines @@
   // are not to be cleared here.
   SyncStatus status = status_;
   status.encryption_conflicts = 0;
   status.hierarchy_conflicts = 0;
   status.server_conflicts = 0;
   status.committed_count = 0;
   status.updates_available = 0;
   return status;
 }
 
-SyncStatus AllStatus::CalcSyncing(const SyncEngineEvent &event) const {
+SyncStatus AllStatus::CalcSyncing(const SyncCycleEvent &event) const {
   SyncStatus status = CreateBlankStatus();
   const sessions::SyncSessionSnapshot& snapshot = event.snapshot;
   status.encryption_conflicts = snapshot.num_encryption_conflicts();
   status.hierarchy_conflicts = snapshot.num_hierarchy_conflicts();
   status.server_conflicts = snapshot.num_server_conflicts();
   status.committed_count =
       snapshot.model_neutral_state().num_successful_commits;
 
-  if (event.what_happened == SyncEngineEvent::SYNC_CYCLE_BEGIN) {
+  if (event.what_happened == SyncCycleEvent::SYNC_CYCLE_BEGIN) {
     status.syncing = true;
-  } else if (event.what_happened == SyncEngineEvent::SYNC_CYCLE_ENDED) {
+  } else if (event.what_happened == SyncCycleEvent::SYNC_CYCLE_ENDED) {
     status.syncing = false;
   }
 
   status.updates_available += snapshot.num_server_changes_remaining();
-  status.sync_protocol_error =
-      snapshot.model_neutral_state().sync_protocol_error;

[Nicolas Zea, 2014/02/10 23:15:16]

Why is this removed?

[rlarocque, 2014/02/11 00:19:43]

It's handled in OnActionableError() now.

I suppose that won't help in the case where the error is not 'Actionable'. 
However, IsActionableError() defines an 'actionable error' as error.action !=
UNKNOWN_ACTION.  That case doesn't seem very important.

 
   status.num_entries_by_type = snapshot.num_entries_by_type();
   status.num_to_delete_entries_by_type =
       snapshot.num_to_delete_entries_by_type();
 
   // Accumulate update count only once per session to avoid double-counting.
-  if (event.what_happened == SyncEngineEvent::SYNC_CYCLE_ENDED) {
+  if (event.what_happened == SyncCycleEvent::SYNC_CYCLE_ENDED) {
     status.updates_received +=
         snapshot.model_neutral_state().num_updates_downloaded_total;
     status.tombstone_updates_received +=
         snapshot.model_neutral_state().num_tombstone_updates_downloaded_total;
     status.reflected_updates_received +=
         snapshot.model_neutral_state().num_reflected_updates_downloaded_total;
     status.num_commits_total +=
         snapshot.model_neutral_state().num_successful_commits;
     status.num_local_overwrites_total +=
         snapshot.model_neutral_state().num_local_overwrites;
@@ skipping 12 matching lines @@
     if (snapshot.model_neutral_state().num_successful_commits == 0 &&
         snapshot.model_neutral_state().num_updates_downloaded_total == 0) {
       ++status.useless_sync_cycles;
     } else {
       ++status.useful_sync_cycles;
     }
   }
   return status;
 }
 
-void AllStatus::OnSyncEngineEvent(const SyncEngineEvent& event) {
+void AllStatus::OnSyncCycleEvent(const SyncCycleEvent& event) {
   ScopedStatusLock lock(this);
   switch (event.what_happened) {
-    case SyncEngineEvent::SYNC_CYCLE_BEGIN:
-    case SyncEngineEvent::STATUS_CHANGED:
-    case SyncEngineEvent::SYNC_CYCLE_ENDED:
+    case SyncCycleEvent::SYNC_CYCLE_BEGIN:
+    case SyncCycleEvent::STATUS_CHANGED:
+    case SyncCycleEvent::SYNC_CYCLE_ENDED:
       status_ = CalcSyncing(event);
       break;
-    case SyncEngineEvent::STOP_SYNCING_PERMANENTLY:
-       break;
-    case SyncEngineEvent::ACTIONABLE_ERROR:
-      status_ = CreateBlankStatus();
-      status_.sync_protocol_error =
-          event.snapshot.model_neutral_state().sync_protocol_error;
-      break;
-    case SyncEngineEvent::RETRY_TIME_CHANGED:
-      status_.retry_time = event.retry_time;
-      break;
-    case SyncEngineEvent::THROTTLED_TYPES_CHANGED:
-      status_.throttled_types = event.throttled_types;
-      break;
     default:
       LOG(ERROR) << "Unrecognized Syncer Event: " << event.what_happened;
       break;
   }
 }
 
+void AllStatus::OnActionableError(
+    const SyncProtocolError& sync_protocol_error) {
+  ScopedStatusLock lock(this);
+  status_ = CreateBlankStatus();
+  status_.sync_protocol_error = sync_protocol_error;
+}
+
+void AllStatus::OnRetryTimeChanged(base::Time retry_time) {
+  ScopedStatusLock lock(this);
+  status_.retry_time = retry_time;
+}
+
+void AllStatus::OnThrottledTypesChanged(ModelTypeSet throttled_types) {
+  ScopedStatusLock lock(this);
+  status_.throttled_types = throttled_types;
+}
+
 SyncStatus AllStatus::status() const {
   base::AutoLock lock(mutex_);
   return status_;
 }
 
 void AllStatus::SetNotificationsEnabled(bool notifications_enabled) {
   ScopedStatusLock lock(this);
   status_.notifications_enabled = notifications_enabled;
 }
 
@@ skipping 66 matching lines @@
 ScopedStatusLock::ScopedStatusLock(AllStatus* allstatus)
     : allstatus_(allstatus) {
   allstatus->mutex_.Acquire();
 }
 
 ScopedStatusLock::~ScopedStatusLock() {
   allstatus_->mutex_.Release();
 }
 
 }  // namespace syncer