| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "chrome/browser/sessions/session_service.h" | 5 #include "chrome/browser/sessions/session_service.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <set> | 8 #include <set> |
| 9 #include <utility> | 9 #include <utility> |
| 10 #include <vector> | 10 #include <vector> |
| 11 | 11 |
| 12 #include "base/bind.h" | 12 #include "base/bind.h" |
| 13 #include "base/bind_helpers.h" | 13 #include "base/bind_helpers.h" |
| 14 #include "base/command_line.h" | 14 #include "base/command_line.h" |
| 15 #include "base/message_loop/message_loop.h" | 15 #include "base/message_loop/message_loop.h" |
| 16 #include "base/metrics/histogram.h" | 16 #include "base/metrics/histogram.h" |
| 17 #include "base/pickle.h" | 17 #include "base/pickle.h" |
| 18 #include "base/threading/thread.h" | 18 #include "base/threading/thread.h" |
| 19 #include "chrome/browser/background/background_mode_manager.h" | 19 #include "chrome/browser/background/background_mode_manager.h" |
| 20 #include "chrome/browser/browser_process.h" | 20 #include "chrome/browser/browser_process.h" |
| 21 #include "chrome/browser/chrome_notification_types.h" | 21 #include "chrome/browser/chrome_notification_types.h" |
| 22 #include "chrome/browser/defaults.h" | 22 #include "chrome/browser/defaults.h" |
| 23 #include "chrome/browser/extensions/tab_helper.h" | 23 #include "chrome/browser/extensions/tab_helper.h" |
| 24 #include "chrome/browser/prefs/session_startup_pref.h" | 24 #include "chrome/browser/prefs/session_startup_pref.h" |
| 25 #include "chrome/browser/profiles/profile.h" | 25 #include "chrome/browser/profiles/profile.h" |
| 26 #include "chrome/browser/profiles/profile_manager.h" | 26 #include "chrome/browser/profiles/profile_manager.h" |
| 27 #include "chrome/browser/sessions/base_session_service_delegate_impl.h" | 27 #include "chrome/browser/sessions/session_common_utils.h" |
| 28 #include "chrome/browser/sessions/session_data_deleter.h" | 28 #include "chrome/browser/sessions/session_data_deleter.h" |
| 29 #include "chrome/browser/sessions/session_restore.h" | 29 #include "chrome/browser/sessions/session_restore.h" |
| 30 #include "chrome/browser/sessions/session_service_utils.h" | 30 #include "chrome/browser/sessions/session_service_utils.h" |
| 31 #include "chrome/browser/sessions/session_tab_helper.h" | 31 #include "chrome/browser/sessions/session_tab_helper.h" |
| 32 #include "chrome/browser/ui/browser_iterator.h" | 32 #include "chrome/browser/ui/browser_iterator.h" |
| 33 #include "chrome/browser/ui/browser_list.h" | 33 #include "chrome/browser/ui/browser_list.h" |
| 34 #include "chrome/browser/ui/browser_tabstrip.h" | 34 #include "chrome/browser/ui/browser_tabstrip.h" |
| 35 #include "chrome/browser/ui/browser_window.h" | 35 #include "chrome/browser/ui/browser_window.h" |
| 36 #include "chrome/browser/ui/host_desktop.h" | 36 #include "chrome/browser/ui/host_desktop.h" |
| 37 #include "chrome/browser/ui/startup/startup_browser_creator.h" | 37 #include "chrome/browser/ui/startup/startup_browser_creator.h" |
| (...skipping 19 matching lines...) Expand all Loading... |
| 57 using content::WebContents; | 57 using content::WebContents; |
| 58 using sessions::ContentSerializedNavigationBuilder; | 58 using sessions::ContentSerializedNavigationBuilder; |
| 59 using sessions::SerializedNavigationEntry; | 59 using sessions::SerializedNavigationEntry; |
| 60 | 60 |
| 61 // Every kWritesPerReset commands triggers recreating the file. | 61 // Every kWritesPerReset commands triggers recreating the file. |
| 62 static const int kWritesPerReset = 250; | 62 static const int kWritesPerReset = 250; |
| 63 | 63 |
| 64 // SessionService ------------------------------------------------------------- | 64 // SessionService ------------------------------------------------------------- |
| 65 | 65 |
| 66 SessionService::SessionService(Profile* profile) | 66 SessionService::SessionService(Profile* profile) |
| 67 : BaseSessionServiceDelegateImpl(true), | 67 : profile_(profile), |
| 68 profile_(profile), | 68 should_use_delayed_save_(true), |
| 69 base_session_service_( | 69 base_session_service_(new sessions::BaseSessionService( |
| 70 new sessions::BaseSessionService( | 70 sessions::BaseSessionService::SESSION_RESTORE, |
| 71 sessions::BaseSessionService::SESSION_RESTORE, | 71 profile->GetPath(), |
| 72 profile->GetPath(), | 72 this)), |
| 73 this)), | |
| 74 has_open_trackable_browsers_(false), | 73 has_open_trackable_browsers_(false), |
| 75 move_on_new_browser_(false), | 74 move_on_new_browser_(false), |
| 76 save_delay_in_millis_(base::TimeDelta::FromMilliseconds(2500)), | 75 save_delay_in_millis_(base::TimeDelta::FromMilliseconds(2500)), |
| 77 save_delay_in_mins_(base::TimeDelta::FromMinutes(10)), | 76 save_delay_in_mins_(base::TimeDelta::FromMinutes(10)), |
| 78 save_delay_in_hrs_(base::TimeDelta::FromHours(8)), | 77 save_delay_in_hrs_(base::TimeDelta::FromHours(8)), |
| 79 force_browser_not_alive_with_no_windows_(false), | 78 force_browser_not_alive_with_no_windows_(false), |
| 80 weak_factory_(this) { | 79 weak_factory_(this) { |
| 81 // We should never be created when incognito. | 80 // We should never be created when incognito. |
| 82 DCHECK(!profile->IsOffTheRecord()); | 81 DCHECK(!profile->IsOffTheRecord()); |
| 83 Init(); | 82 Init(); |
| 84 } | 83 } |
| 85 | 84 |
| 86 SessionService::SessionService(const base::FilePath& save_path) | 85 SessionService::SessionService(const base::FilePath& save_path) |
| 87 : BaseSessionServiceDelegateImpl(false), | 86 : profile_(NULL), |
| 88 profile_(NULL), | 87 should_use_delayed_save_(false), |
| 89 base_session_service_( | 88 base_session_service_(new sessions::BaseSessionService( |
| 90 new sessions::BaseSessionService( | 89 sessions::BaseSessionService::SESSION_RESTORE, |
| 91 sessions::BaseSessionService::SESSION_RESTORE, | 90 save_path, |
| 92 save_path, | 91 this)), |
| 93 this)), | |
| 94 has_open_trackable_browsers_(false), | 92 has_open_trackable_browsers_(false), |
| 95 move_on_new_browser_(false), | 93 move_on_new_browser_(false), |
| 96 save_delay_in_millis_(base::TimeDelta::FromMilliseconds(2500)), | 94 save_delay_in_millis_(base::TimeDelta::FromMilliseconds(2500)), |
| 97 save_delay_in_mins_(base::TimeDelta::FromMinutes(10)), | 95 save_delay_in_mins_(base::TimeDelta::FromMinutes(10)), |
| 98 save_delay_in_hrs_(base::TimeDelta::FromHours(8)), | 96 save_delay_in_hrs_(base::TimeDelta::FromHours(8)), |
| 99 force_browser_not_alive_with_no_windows_(false), | 97 force_browser_not_alive_with_no_windows_(false), |
| 100 weak_factory_(this) { | 98 weak_factory_(this) { |
| 101 Init(); | 99 Init(); |
| 102 } | 100 } |
| 103 | 101 |
| (...skipping 302 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 406 } | 404 } |
| 407 | 405 |
| 408 ScheduleCommand(sessions::CreateTabNavigationPathPrunedFromFrontCommand( | 406 ScheduleCommand(sessions::CreateTabNavigationPathPrunedFromFrontCommand( |
| 409 tab_id, count).Pass()); | 407 tab_id, count).Pass()); |
| 410 } | 408 } |
| 411 | 409 |
| 412 void SessionService::UpdateTabNavigation( | 410 void SessionService::UpdateTabNavigation( |
| 413 const SessionID& window_id, | 411 const SessionID& window_id, |
| 414 const SessionID& tab_id, | 412 const SessionID& tab_id, |
| 415 const SerializedNavigationEntry& navigation) { | 413 const SerializedNavigationEntry& navigation) { |
| 416 if (!ShouldTrackEntry(navigation.virtual_url()) || | 414 if (!ShouldTrackURLForRestore(navigation.virtual_url()) || |
| 417 !ShouldTrackChangesToWindow(window_id)) { | 415 !ShouldTrackChangesToWindow(window_id)) { |
| 418 return; | 416 return; |
| 419 } | 417 } |
| 420 | 418 |
| 421 if (tab_to_available_range_.find(tab_id.id()) != | 419 if (tab_to_available_range_.find(tab_id.id()) != |
| 422 tab_to_available_range_.end()) { | 420 tab_to_available_range_.end()) { |
| 423 std::pair<int, int>& range = tab_to_available_range_[tab_id.id()]; | 421 std::pair<int, int>& range = tab_to_available_range_[tab_id.id()]; |
| 424 range.first = std::min(navigation.index(), range.first); | 422 range.first = std::min(navigation.index(), range.first); |
| 425 range.second = std::max(navigation.index(), range.second); | 423 range.second = std::max(navigation.index(), range.second); |
| 426 } | 424 } |
| (...skipping 75 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 502 base::CancelableTaskTracker* tracker) { | 500 base::CancelableTaskTracker* tracker) { |
| 503 // OnGotSessionCommands maps the SessionCommands to browser state, then run | 501 // OnGotSessionCommands maps the SessionCommands to browser state, then run |
| 504 // the callback. | 502 // the callback. |
| 505 return base_session_service_->ScheduleGetLastSessionCommands( | 503 return base_session_service_->ScheduleGetLastSessionCommands( |
| 506 base::Bind(&SessionService::OnGotSessionCommands, | 504 base::Bind(&SessionService::OnGotSessionCommands, |
| 507 weak_factory_.GetWeakPtr(), | 505 weak_factory_.GetWeakPtr(), |
| 508 callback), | 506 callback), |
| 509 tracker); | 507 tracker); |
| 510 } | 508 } |
| 511 | 509 |
| 510 base::SequencedWorkerPool* SessionService::GetBlockingPool() { |
| 511 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); |
| 512 return content::BrowserThread::GetBlockingPool(); |
| 513 } |
| 514 |
| 515 bool SessionService::ShouldUseDelayedSave() { |
| 516 return should_use_delayed_save_; |
| 517 } |
| 518 |
| 512 void SessionService::OnSavedCommands() { | 519 void SessionService::OnSavedCommands() { |
| 513 RecordSessionUpdateHistogramData(chrome::NOTIFICATION_SESSION_SERVICE_SAVED, | 520 RecordSessionUpdateHistogramData(chrome::NOTIFICATION_SESSION_SERVICE_SAVED, |
| 514 &last_updated_save_time_); | 521 &last_updated_save_time_); |
| 515 content::NotificationService::current()->Notify( | 522 content::NotificationService::current()->Notify( |
| 516 chrome::NOTIFICATION_SESSION_SERVICE_SAVED, | 523 chrome::NOTIFICATION_SESSION_SERVICE_SAVED, |
| 517 content::Source<Profile>(profile()), | 524 content::Source<Profile>(profile()), |
| 518 content::NotificationService::NoDetails()); | 525 content::NotificationService::NoDetails()); |
| 519 } | 526 } |
| 520 | 527 |
| 521 void SessionService::Init() { | 528 void SessionService::Init() { |
| (...skipping 235 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 757 base_session_service_->AppendRebuildCommand( | 764 base_session_service_->AppendRebuildCommand( |
| 758 sessions::CreateSetTabUserAgentOverrideCommand(session_id, | 765 sessions::CreateSetTabUserAgentOverrideCommand(session_id, |
| 759 ua_override)); | 766 ua_override)); |
| 760 } | 767 } |
| 761 | 768 |
| 762 for (int i = min_index; i < max_index; ++i) { | 769 for (int i = min_index; i < max_index; ++i) { |
| 763 const NavigationEntry* entry = (i == pending_index) ? | 770 const NavigationEntry* entry = (i == pending_index) ? |
| 764 tab->GetController().GetPendingEntry() : | 771 tab->GetController().GetPendingEntry() : |
| 765 tab->GetController().GetEntryAtIndex(i); | 772 tab->GetController().GetEntryAtIndex(i); |
| 766 DCHECK(entry); | 773 DCHECK(entry); |
| 767 if (ShouldTrackEntry(entry->GetVirtualURL())) { | 774 if (ShouldTrackURLForRestore(entry->GetVirtualURL())) { |
| 768 const SerializedNavigationEntry navigation = | 775 const SerializedNavigationEntry navigation = |
| 769 ContentSerializedNavigationBuilder::FromNavigationEntry(i, *entry); | 776 ContentSerializedNavigationBuilder::FromNavigationEntry(i, *entry); |
| 770 base_session_service_->AppendRebuildCommand( | 777 base_session_service_->AppendRebuildCommand( |
| 771 CreateUpdateTabNavigationCommand(session_id, navigation)); | 778 CreateUpdateTabNavigationCommand(session_id, navigation)); |
| 772 } | 779 } |
| 773 } | 780 } |
| 774 base_session_service_->AppendRebuildCommand( | 781 base_session_service_->AppendRebuildCommand( |
| 775 sessions::CreateSetSelectedNavigationIndexCommand(session_id, | 782 sessions::CreateSetSelectedNavigationIndexCommand(session_id, |
| 776 current_index)); | 783 current_index)); |
| 777 | 784 |
| (...skipping 331 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1109 for (chrome::BrowserIterator it; !it.done(); it.Next()) { | 1116 for (chrome::BrowserIterator it; !it.done(); it.Next()) { |
| 1110 if ((*it)->profile() == profile()) | 1117 if ((*it)->profile() == profile()) |
| 1111 return; | 1118 return; |
| 1112 } | 1119 } |
| 1113 DeleteSessionOnlyData(profile()); | 1120 DeleteSessionOnlyData(profile()); |
| 1114 } | 1121 } |
| 1115 | 1122 |
| 1116 sessions::BaseSessionService* SessionService::GetBaseSessionServiceForTest() { | 1123 sessions::BaseSessionService* SessionService::GetBaseSessionServiceForTest() { |
| 1117 return base_session_service_.get(); | 1124 return base_session_service_.get(); |
| 1118 } | 1125 } |
| OLD | NEW |