1ddb351dbec246cf1fab5ec20d2d5520909041de1Kristian Monsen// Copyright (c) 2011 The Chromium Authors. All rights reserved. 2c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch// Use of this source code is governed by a BSD-style license that can be 3c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch// found in the LICENSE file. 4c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch 5c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch#include "chrome/browser/sync/sessions/sync_session.h" 6c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch#include "chrome/browser/sync/syncable/directory_manager.h" 7c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch#include "chrome/browser/sync/syncable/model_type.h" 8c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch 9c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdochnamespace browser_sync { 10c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdochnamespace sessions { 11c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch 12201ade2fbba22bfb27ae029f4d23fca6ded109a0Ben MurdochSyncSession::SyncSession(SyncSessionContext* context, Delegate* delegate, 13ddb351dbec246cf1fab5ec20d2d5520909041de1Kristian Monsen const SyncSourceInfo& source, 14201ade2fbba22bfb27ae029f4d23fca6ded109a0Ben Murdoch const ModelSafeRoutingInfo& routing_info, 1572a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen const std::vector<ModelSafeWorker*>& workers) 1672a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen : context_(context), 1772a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen source_(source), 1872a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen write_transaction_(NULL), 1972a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen delegate_(delegate), 2072a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen workers_(workers), 2172a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen routing_info_(routing_info) { 22c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch status_controller_.reset(new StatusController(routing_info_)); 23c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch} 24c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch 25731df977c0511bca2206b5f333555b1205ff1f43Iain MerrickSyncSession::~SyncSession() {} 26731df977c0511bca2206b5f333555b1205ff1f43Iain Merrick 2772a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsenvoid SyncSession::Coalesce(const SyncSession& session) { 2872a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen if (context_ != session.context() || delegate_ != session.delegate_) { 2972a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen NOTREACHED(); 3072a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen return; 3172a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen } 3272a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen 3372a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen // When we coalesce sessions, the sync update source gets overwritten with the 3472a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen // most recent, while the type/payload map gets merged. 3572a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen CoalescePayloads(&source_.types, session.source_.types); 3672a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen source_.updates_source = session.source_.updates_source; 3772a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen 3872a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen std::vector<ModelSafeWorker*> temp; 3972a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen std::set_union(workers_.begin(), workers_.end(), 4072a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen session.workers_.begin(), session.workers_.end(), 4172a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen std::back_inserter(temp)); 4272a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen workers_.swap(temp); 4372a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen 44ddb351dbec246cf1fab5ec20d2d5520909041de1Kristian Monsen // We have to update the model safe routing info to the union. In case the 45ddb351dbec246cf1fab5ec20d2d5520909041de1Kristian Monsen // same key is present in both pick the one from session. 46ddb351dbec246cf1fab5ec20d2d5520909041de1Kristian Monsen for (ModelSafeRoutingInfo::const_iterator it = 47ddb351dbec246cf1fab5ec20d2d5520909041de1Kristian Monsen session.routing_info_.begin(); 48ddb351dbec246cf1fab5ec20d2d5520909041de1Kristian Monsen it != session.routing_info_.end(); 49ddb351dbec246cf1fab5ec20d2d5520909041de1Kristian Monsen ++it) { 50ddb351dbec246cf1fab5ec20d2d5520909041de1Kristian Monsen routing_info_[it->first] = it->second; 51ddb351dbec246cf1fab5ec20d2d5520909041de1Kristian Monsen } 5272a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen} 5372a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen 5472a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsenvoid SyncSession::ResetTransientState() { 5572a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen status_controller_.reset(new StatusController(routing_info_)); 5672a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen} 5772a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen 58c407dc5cd9bdc5668497f21b26b09d988ab439deBen MurdochSyncSessionSnapshot SyncSession::TakeSnapshot() const { 59c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch syncable::ScopedDirLookup dir(context_->directory_manager(), 60c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch context_->account_name()); 61c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch if (!dir.good()) 62c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch LOG(ERROR) << "Scoped dir lookup failed!"; 63c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch 64c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch bool is_share_useable = true; 65c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch syncable::ModelTypeBitSet initial_sync_ended; 6672a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen std::string download_progress_markers[syncable::MODEL_TYPE_COUNT]; 67c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch for (int i = 0; i < syncable::MODEL_TYPE_COUNT; ++i) { 68c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch syncable::ModelType type(syncable::ModelTypeFromInt(i)); 69c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch if (routing_info_.count(type) != 0) { 70c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch if (dir->initial_sync_ended_for_type(type)) 71c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch initial_sync_ended.set(type); 72c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch else 73c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch is_share_useable = false; 7472a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen dir->GetDownloadProgressAsString(type, &download_progress_markers[i]); 75c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch } 76c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch } 77c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch 78c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch return SyncSessionSnapshot( 79c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch status_controller_->syncer_status(), 80c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch status_controller_->error_counters(), 81c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch status_controller_->num_server_changes_remaining(), 82c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch is_share_useable, 83c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch initial_sync_ended, 8472a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen download_progress_markers, 85c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch HasMoreToSync(), 86c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch delegate_->IsSyncingCurrentlySilenced(), 87c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch status_controller_->unsynced_handles().size(), 88c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch status_controller_->TotalNumConflictingItems(), 8972a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen status_controller_->did_commit_items(), 9072a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen source_); 91c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch} 92c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch 934a5e2dc747d50c653511c68ccb2cfbfb740bd5a7Ben MurdochSyncSourceInfo SyncSession::TestAndSetSource() { 944a5e2dc747d50c653511c68ccb2cfbfb740bd5a7Ben Murdoch SyncSourceInfo old_source = source_; 95201ade2fbba22bfb27ae029f4d23fca6ded109a0Ben Murdoch source_ = SyncSourceInfo( 96201ade2fbba22bfb27ae029f4d23fca6ded109a0Ben Murdoch sync_pb::GetUpdatesCallerInfo::SYNC_CYCLE_CONTINUATION, 9772a454cd3513ac24fbdd0e0cb9ad70b86a99b801Kristian Monsen source_.types); 98c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch return old_source; 99c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch} 100c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch 101c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdochbool SyncSession::HasMoreToSync() const { 102c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch const StatusController* status = status_controller_.get(); 103c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch return ((status->commit_ids().size() < status->unsynced_handles().size()) && 104c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch status->syncer_status().num_successful_commits > 0) || 105c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch status->conflict_sets_built() || 106c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch status->conflicts_resolved(); 107c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch // Or, we have conflicting updates, but we're making progress on 108c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch // resolving them... 109c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch } 110c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch 111c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch} // namespace sessions 112c407dc5cd9bdc5668497f21b26b09d988ab439deBen Murdoch} // namespace browser_sync 113