Index: sync/sessions/sync_session.cc |
diff --git a/sync/sessions/sync_session.cc b/sync/sessions/sync_session.cc |
index 030ef0f0f5849b7859ebf5db67a887483f75fdf6..957cfbfd741a1558dfa29decab5f4698a5c0a209 100644 |
--- a/sync/sessions/sync_session.cc |
+++ b/sync/sessions/sync_session.cc |
@@ -69,20 +69,24 @@ SyncSessionSnapshot SyncSession::TakeSnapshotWithSource( |
void SyncSession::SendSyncCycleEndEventNotification( |
sync_pb::GetUpdatesCallerInfo::GetUpdatesSource source) { |
- SyncEngineEvent event(SyncEngineEvent::SYNC_CYCLE_ENDED); |
+ SyncCycleEvent event(SyncCycleEvent::SYNC_CYCLE_ENDED); |
event.snapshot = TakeSnapshotWithSource(source); |
DVLOG(1) << "Sending cycle end event with snapshot: " |
<< event.snapshot.ToString(); |
- context()->NotifyListeners(event); |
+ FOR_EACH_OBSERVER(SyncEngineEventListener, |
+ *(context_->listeners()), |
+ OnSyncCycleEvent(event)); |
} |
-void SyncSession::SendEventNotification(SyncEngineEvent::EventCause cause) { |
- SyncEngineEvent event(cause); |
+void SyncSession::SendEventNotification(SyncCycleEvent::EventCause cause) { |
+ SyncCycleEvent event(cause); |
event.snapshot = TakeSnapshot(); |
DVLOG(1) << "Sending event with snapshot: " << event.snapshot.ToString(); |
- context()->NotifyListeners(event); |
+ FOR_EACH_OBSERVER(SyncEngineEventListener, |
+ *(context_->listeners()), |
+ OnSyncCycleEvent(event)); |
} |
} // namespace sessions |