Index: sync/sessions/sync_session.cc |
diff --git a/sync/sessions/sync_session.cc b/sync/sessions/sync_session.cc |
deleted file mode 100644 |
index 70c1a8237ddfb348be226707ebd1bb5f05bf0608..0000000000000000000000000000000000000000 |
--- a/sync/sessions/sync_session.cc |
+++ /dev/null |
@@ -1,100 +0,0 @@ |
-// 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/sessions/sync_session.h" |
- |
-#include <algorithm> |
-#include <iterator> |
- |
-#include "base/logging.h" |
-#include "sync/internal_api/public/base/model_type.h" |
-#include "sync/internal_api/public/engine/model_safe_worker.h" |
-#include "sync/syncable/directory.h" |
- |
-namespace syncer { |
-namespace sessions { |
- |
-// static |
-SyncSession* SyncSession::Build(SyncSessionContext* context, |
- Delegate* delegate) { |
- return new SyncSession(context, delegate); |
-} |
- |
-SyncSession::SyncSession( |
- SyncSessionContext* context, |
- Delegate* delegate) |
- : context_(context), |
- delegate_(delegate) { |
- status_controller_.reset(new StatusController()); |
-} |
- |
-SyncSession::~SyncSession() {} |
- |
-SyncSessionSnapshot SyncSession::TakeSnapshot() const { |
- return TakeSnapshotWithSource(sync_pb::GetUpdatesCallerInfo::UNKNOWN); |
-} |
- |
-SyncSessionSnapshot SyncSession::TakeSnapshotWithSource( |
- sync_pb::GetUpdatesCallerInfo::GetUpdatesSource legacy_updates_source) const { |
- syncable::Directory* dir = context_->directory(); |
- |
- ProgressMarkerMap download_progress_markers; |
- for (int i = FIRST_REAL_MODEL_TYPE; i < MODEL_TYPE_COUNT; ++i) { |
- ModelType type(ModelTypeFromInt(i)); |
- dir->GetDownloadProgressAsString(type, &download_progress_markers[type]); |
- } |
- |
- std::vector<int> num_entries_by_type(MODEL_TYPE_COUNT, 0); |
- std::vector<int> num_to_delete_entries_by_type(MODEL_TYPE_COUNT, 0); |
- dir->CollectMetaHandleCounts(&num_entries_by_type, |
- &num_to_delete_entries_by_type); |
- |
- SyncSessionSnapshot snapshot( |
- status_controller_->model_neutral_state(), |
- download_progress_markers, |
- delegate_->IsCurrentlyThrottled(), |
- status_controller_->num_encryption_conflicts(), |
- status_controller_->num_hierarchy_conflicts(), |
- status_controller_->num_server_conflicts(), |
- context_->notifications_enabled(), |
- dir->GetEntriesCount(), |
- status_controller_->sync_start_time(), |
- status_controller_->poll_finish_time(), |
- num_entries_by_type, |
- num_to_delete_entries_by_type, |
- legacy_updates_source); |
- |
- return snapshot; |
-} |
- |
-void SyncSession::SendSyncCycleEndEventNotification( |
- sync_pb::GetUpdatesCallerInfo::GetUpdatesSource source) { |
- SyncCycleEvent event(SyncCycleEvent::SYNC_CYCLE_ENDED); |
- event.snapshot = TakeSnapshotWithSource(source); |
- |
- DVLOG(1) << "Sending cycle end event with snapshot: " |
- << event.snapshot.ToString(); |
- FOR_EACH_OBSERVER(SyncEngineEventListener, |
- *(context_->listeners()), |
- OnSyncCycleEvent(event)); |
-} |
- |
-void SyncSession::SendEventNotification(SyncCycleEvent::EventCause cause) { |
- SyncCycleEvent event(cause); |
- event.snapshot = TakeSnapshot(); |
- |
- DVLOG(1) << "Sending event with snapshot: " << event.snapshot.ToString(); |
- FOR_EACH_OBSERVER(SyncEngineEventListener, |
- *(context_->listeners()), |
- OnSyncCycleEvent(event)); |
-} |
- |
-void SyncSession::SendProtocolEvent(const ProtocolEvent& event) { |
- FOR_EACH_OBSERVER(SyncEngineEventListener, |
- *(context_->listeners()), |
- OnProtocolEvent(event)); |
-} |
- |
-} // namespace sessions |
-} // namespace syncer |