| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 <limits> | 8 #include <limits> |
| 9 #include <set> | 9 #include <set> |
| 10 #include <vector> | 10 #include <vector> |
| 11 | 11 |
| 12 #include "base/bind.h" |
| 13 #include "base/bind_helpers.h" |
| 12 #include "base/file_util.h" | 14 #include "base/file_util.h" |
| 13 #include "base/memory/scoped_vector.h" | 15 #include "base/memory/scoped_vector.h" |
| 14 #include "base/message_loop.h" | 16 #include "base/message_loop.h" |
| 15 #include "base/metrics/histogram.h" | 17 #include "base/metrics/histogram.h" |
| 16 #include "base/pickle.h" | 18 #include "base/pickle.h" |
| 17 #include "base/threading/thread.h" | 19 #include "base/threading/thread.h" |
| 18 #include "chrome/browser/extensions/extension_tab_helper.h" | 20 #include "chrome/browser/extensions/extension_tab_helper.h" |
| 19 #include "chrome/browser/prefs/session_startup_pref.h" | 21 #include "chrome/browser/prefs/session_startup_pref.h" |
| 20 #include "chrome/browser/profiles/profile.h" | 22 #include "chrome/browser/profiles/profile.h" |
| 21 #include "chrome/browser/sessions/restore_tab_helper.h" | 23 #include "chrome/browser/sessions/restore_tab_helper.h" |
| (...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 69 namespace { | 71 namespace { |
| 70 | 72 |
| 71 // The callback from GetLastSession is internally routed to SessionService | 73 // The callback from GetLastSession is internally routed to SessionService |
| 72 // first and then the caller. This is done so that the SessionWindows can be | 74 // first and then the caller. This is done so that the SessionWindows can be |
| 73 // recreated from the SessionCommands and the SessionWindows passed to the | 75 // recreated from the SessionCommands and the SessionWindows passed to the |
| 74 // caller. The following class is used for this. | 76 // caller. The following class is used for this. |
| 75 class InternalSessionRequest | 77 class InternalSessionRequest |
| 76 : public BaseSessionService::InternalGetCommandsRequest { | 78 : public BaseSessionService::InternalGetCommandsRequest { |
| 77 public: | 79 public: |
| 78 InternalSessionRequest( | 80 InternalSessionRequest( |
| 79 CallbackType* callback, | 81 const CallbackType& callback, |
| 80 SessionService::SessionCallback* real_callback) | 82 SessionService::SessionCallback* real_callback) |
| 81 : BaseSessionService::InternalGetCommandsRequest(callback), | 83 : BaseSessionService::InternalGetCommandsRequest(callback), |
| 82 real_callback(real_callback) { | 84 real_callback(real_callback) { |
| 83 } | 85 } |
| 84 | 86 |
| 85 // The callback supplied to GetLastSession and GetCurrentSession. | 87 // The callback supplied to GetLastSession and GetCurrentSession. |
| 86 scoped_ptr<SessionService::SessionCallback> real_callback; | 88 scoped_ptr<SessionService::SessionCallback> real_callback; |
| 87 | 89 |
| 88 private: | 90 private: |
| 89 ~InternalSessionRequest() {} | 91 ~InternalSessionRequest() {} |
| (...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 176 void SessionService::MoveCurrentSessionToLastSession() { | 178 void SessionService::MoveCurrentSessionToLastSession() { |
| 177 pending_tab_close_ids_.clear(); | 179 pending_tab_close_ids_.clear(); |
| 178 window_closing_ids_.clear(); | 180 window_closing_ids_.clear(); |
| 179 pending_window_close_ids_.clear(); | 181 pending_window_close_ids_.clear(); |
| 180 | 182 |
| 181 Save(); | 183 Save(); |
| 182 | 184 |
| 183 if (!backend_thread()) { | 185 if (!backend_thread()) { |
| 184 backend()->MoveCurrentSessionToLastSession(); | 186 backend()->MoveCurrentSessionToLastSession(); |
| 185 } else { | 187 } else { |
| 186 backend_thread()->message_loop()->PostTask(FROM_HERE, NewRunnableMethod( | 188 backend_thread()->message_loop()->PostTask( |
| 187 backend(), &SessionBackend::MoveCurrentSessionToLastSession)); | 189 FROM_HERE, base::Bind(&SessionBackend::MoveCurrentSessionToLastSession, |
| 190 backend())); |
| 188 } | 191 } |
| 189 } | 192 } |
| 190 | 193 |
| 191 void SessionService::SetTabWindow(const SessionID& window_id, | 194 void SessionService::SetTabWindow(const SessionID& window_id, |
| 192 const SessionID& tab_id) { | 195 const SessionID& tab_id) { |
| 193 if (!ShouldTrackChangesToWindow(window_id)) | 196 if (!ShouldTrackChangesToWindow(window_id)) |
| 194 return; | 197 return; |
| 195 | 198 |
| 196 ScheduleCommand(CreateSetTabWindowCommand(window_id, tab_id)); | 199 ScheduleCommand(CreateSetTabWindowCommand(window_id, tab_id)); |
| 197 } | 200 } |
| (...skipping 214 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 412 return; | 415 return; |
| 413 | 416 |
| 414 ScheduleCommand(CreateSetSelectedTabInWindow(window_id, index)); | 417 ScheduleCommand(CreateSetSelectedTabInWindow(window_id, index)); |
| 415 } | 418 } |
| 416 | 419 |
| 417 SessionService::Handle SessionService::GetLastSession( | 420 SessionService::Handle SessionService::GetLastSession( |
| 418 CancelableRequestConsumerBase* consumer, | 421 CancelableRequestConsumerBase* consumer, |
| 419 SessionCallback* callback) { | 422 SessionCallback* callback) { |
| 420 return ScheduleGetLastSessionCommands( | 423 return ScheduleGetLastSessionCommands( |
| 421 new InternalSessionRequest( | 424 new InternalSessionRequest( |
| 422 NewCallback(this, &SessionService::OnGotSessionCommands), | 425 base::Bind(&SessionService::OnGotSessionCommands, |
| 423 callback), consumer); | 426 base::Unretained(this)), |
| 427 callback), |
| 428 consumer); |
| 424 } | 429 } |
| 425 | 430 |
| 426 SessionService::Handle SessionService::GetCurrentSession( | 431 SessionService::Handle SessionService::GetCurrentSession( |
| 427 CancelableRequestConsumerBase* consumer, | 432 CancelableRequestConsumerBase* consumer, |
| 428 SessionCallback* callback) { | 433 SessionCallback* callback) { |
| 429 if (pending_window_close_ids_.empty()) { | 434 if (pending_window_close_ids_.empty()) { |
| 430 // If there are no pending window closes, we can get the current session | 435 // If there are no pending window closes, we can get the current session |
| 431 // from memory. | 436 // from memory. |
| 432 scoped_refptr<InternalSessionRequest> request(new InternalSessionRequest( | 437 scoped_refptr<InternalSessionRequest> request(new InternalSessionRequest( |
| 433 NewCallback(this, &SessionService::OnGotSessionCommands), | 438 base::Bind(&SessionService::OnGotSessionCommands, |
| 439 base::Unretained(this)), |
| 434 callback)); | 440 callback)); |
| 435 AddRequest(request, consumer); | 441 AddRequest(request, consumer); |
| 436 IdToRange tab_to_available_range; | 442 IdToRange tab_to_available_range; |
| 437 std::set<SessionID::id_type> windows_to_track; | 443 std::set<SessionID::id_type> windows_to_track; |
| 438 BuildCommandsFromBrowsers(&(request->commands), | 444 BuildCommandsFromBrowsers(&(request->commands), |
| 439 &tab_to_available_range, | 445 &tab_to_available_range, |
| 440 &windows_to_track); | 446 &windows_to_track); |
| 441 request->ForwardResult( | 447 request->ForwardResult(request->handle(), request); |
| 442 BaseSessionService::InternalGetCommandsRequest::TupleType( | |
| 443 request->handle(), request)); | |
| 444 return request->handle(); | 448 return request->handle(); |
| 445 } else { | 449 } else { |
| 446 // If there are pending window closes, read the current session from disk. | 450 // If there are pending window closes, read the current session from disk. |
| 447 return ScheduleGetCurrentSessionCommands( | 451 return ScheduleGetCurrentSessionCommands( |
| 448 new InternalSessionRequest( | 452 new InternalSessionRequest( |
| 449 NewCallback(this, &SessionService::OnGotSessionCommands), | 453 base::Bind(&SessionService::OnGotSessionCommands, |
| 450 callback), consumer); | 454 base::Unretained(this)), |
| 455 callback), |
| 456 consumer); |
| 451 } | 457 } |
| 452 } | 458 } |
| 453 | 459 |
| 454 void SessionService::Save() { | 460 void SessionService::Save() { |
| 455 bool had_commands = !pending_commands().empty(); | 461 bool had_commands = !pending_commands().empty(); |
| 456 BaseSessionService::Save(); | 462 BaseSessionService::Save(); |
| 457 if (had_commands) { | 463 if (had_commands) { |
| 458 RecordSessionUpdateHistogramData( | 464 RecordSessionUpdateHistogramData( |
| 459 chrome::NOTIFICATION_SESSION_SERVICE_SAVED, | 465 chrome::NOTIFICATION_SESSION_SERVICE_SAVED, |
| 460 &last_updated_save_time_); | 466 &last_updated_save_time_); |
| (...skipping 1072 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1533 50); | 1539 50); |
| 1534 if (use_long_period) { | 1540 if (use_long_period) { |
| 1535 std::string long_name_("SessionRestore.SaveLongPeriod"); | 1541 std::string long_name_("SessionRestore.SaveLongPeriod"); |
| 1536 UMA_HISTOGRAM_CUSTOM_TIMES(long_name_, | 1542 UMA_HISTOGRAM_CUSTOM_TIMES(long_name_, |
| 1537 delta, | 1543 delta, |
| 1538 save_delay_in_mins_, | 1544 save_delay_in_mins_, |
| 1539 save_delay_in_hrs_, | 1545 save_delay_in_hrs_, |
| 1540 50); | 1546 50); |
| 1541 } | 1547 } |
| 1542 } | 1548 } |
| OLD | NEW |