Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(73)

Side by Side Diff: chrome/browser/sync/engine/syncer_thread.cc

Issue 6182004: [SYNC] Refactor SyncSourceInfo and add support in chrome invalidation client ... (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src/
Patch Set: Done! Created 9 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2010 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/sync/engine/syncer_thread.h" 5 #include "chrome/browser/sync/engine/syncer_thread.h"
6 6
7 #include <algorithm> 7 #include <algorithm>
8 #include <map>
9 #include <queue> 8 #include <queue>
9 #include <string>
10 #include <vector>
10 11
11 #include "base/rand_util.h" 12 #include "base/rand_util.h"
12 #include "base/third_party/dynamic_annotations/dynamic_annotations.h" 13 #include "base/third_party/dynamic_annotations/dynamic_annotations.h"
13 #include "build/build_config.h" 14 #include "build/build_config.h"
14 #include "chrome/browser/sync/engine/model_safe_worker.h" 15 #include "chrome/browser/sync/engine/model_safe_worker.h"
15 #include "chrome/browser/sync/engine/net/server_connection_manager.h" 16 #include "chrome/browser/sync/engine/net/server_connection_manager.h"
16 #include "chrome/browser/sync/engine/syncer.h" 17 #include "chrome/browser/sync/engine/syncer.h"
17 #include "chrome/browser/sync/sessions/sync_session.h" 18 #include "chrome/browser/sync/sessions/sync_session.h"
18 #include "jingle/notifier/listener/notification_constants.h" 19 #include "jingle/notifier/listener/notification_constants.h"
19 20
20 #if defined(OS_MACOSX) 21 #if defined(OS_MACOSX)
21 #include <CoreFoundation/CFNumber.h> 22 #include <CoreFoundation/CFNumber.h>
22 #include <IOKit/IOTypes.h> 23 #include <IOKit/IOTypes.h>
23 #include <IOKit/IOKitLib.h> 24 #include <IOKit/IOKitLib.h>
24 #endif 25 #endif
25 26
26 using std::priority_queue; 27 using std::priority_queue;
27 using std::min; 28 using std::min;
28 using base::Time; 29 using base::Time;
29 using base::TimeDelta; 30 using base::TimeDelta;
30 using base::TimeTicks; 31 using base::TimeTicks;
31 32
32 namespace browser_sync { 33 namespace browser_sync {
33 34
34 using sessions::SyncSession; 35 using sessions::SyncSession;
35 using sessions::SyncSessionSnapshot; 36 using sessions::SyncSessionSnapshot;
36 using sessions::SyncSourceInfo; 37 using sessions::SyncSourceInfo;
38 using sessions::TypePayloadMap;
37 39
38 // We use high values here to ensure that failure to receive poll updates from 40 // We use high values here to ensure that failure to receive poll updates from
39 // the server doesn't result in rapid-fire polling from the client due to low 41 // the server doesn't result in rapid-fire polling from the client due to low
40 // local limits. 42 // local limits.
41 const int SyncerThread::kDefaultShortPollIntervalSeconds = 3600 * 8; 43 const int SyncerThread::kDefaultShortPollIntervalSeconds = 3600 * 8;
42 const int SyncerThread::kDefaultLongPollIntervalSeconds = 3600 * 12; 44 const int SyncerThread::kDefaultLongPollIntervalSeconds = 3600 * 12;
43 45
44 // TODO(tim): This is used to regulate the short poll (when notifications are 46 // TODO(tim): This is used to regulate the short poll (when notifications are
45 // disabled) based on user idle time. If it is set to a smaller value than 47 // disabled) based on user idle time. If it is set to a smaller value than
46 // the short poll interval, it basically does nothing; for now, this is what 48 // the short poll interval, it basically does nothing; for now, this is what
47 // we want and allows stronger control over the poll rate from the server. We 49 // we want and allows stronger control over the poll rate from the server. We
48 // should probably re-visit this code later and figure out if user idle time 50 // should probably re-visit this code later and figure out if user idle time
49 // is really something we want and make sure it works, if it is. 51 // is really something we want and make sure it works, if it is.
50 const int SyncerThread::kDefaultMaxPollIntervalMs = 30 * 60 * 1000; 52 const int SyncerThread::kDefaultMaxPollIntervalMs = 30 * 60 * 1000;
51 53
52 // Backoff interval randomization factor. 54 // Backoff interval randomization factor.
53 static const int kBackoffRandomizationFactor = 2; 55 static const int kBackoffRandomizationFactor = 2;
54 56
55 const int SyncerThread::kMaxBackoffSeconds = 60 * 60 * 4; // 4 hours. 57 const int SyncerThread::kMaxBackoffSeconds = 60 * 60 * 4; // 4 hours.
56 58
59 void SyncerThread::NudgeSyncerWithPayloads(
60 int milliseconds_from_now,
61 NudgeSource source,
62 const TypePayloadMap& model_types_with_payloads) {
63 base::AutoLock lock(lock_);
64 if (vault_.syncer_ == NULL) {
65 return;
66 }
67
68 NudgeSyncImpl(milliseconds_from_now, source, model_types_with_payloads);
69 }
70
57 void SyncerThread::NudgeSyncerWithDataTypes( 71 void SyncerThread::NudgeSyncerWithDataTypes(
58 int milliseconds_from_now, 72 int milliseconds_from_now,
59 NudgeSource source, 73 NudgeSource source,
60 const syncable::ModelTypeBitSet& model_types) { 74 const syncable::ModelTypeBitSet& model_types) {
61 base::AutoLock lock(lock_); 75 base::AutoLock lock(lock_);
62 if (vault_.syncer_ == NULL) { 76 if (vault_.syncer_ == NULL) {
63 return; 77 return;
64 } 78 }
65 79
66 NudgeSyncImpl(milliseconds_from_now, source, model_types); 80 TypePayloadMap model_types_with_payloads =
81 sessions::ModelTypeBitSetToTypePayloadMap(model_types, std::string());
82 NudgeSyncImpl(milliseconds_from_now, source, model_types_with_payloads);
67 } 83 }
68 84
69 void SyncerThread::NudgeSyncer( 85 void SyncerThread::NudgeSyncer(
70 int milliseconds_from_now, 86 int milliseconds_from_now,
71 NudgeSource source) { 87 NudgeSource source) {
72 base::AutoLock lock(lock_); 88 base::AutoLock lock(lock_);
73 if (vault_.syncer_ == NULL) { 89 if (vault_.syncer_ == NULL) {
74 return; 90 return;
75 } 91 }
76 92
77 syncable::ModelTypeBitSet model_types; // All false by default. 93 // Set all enabled datatypes.
78 NudgeSyncImpl(milliseconds_from_now, source, model_types); 94 ModelSafeRoutingInfo routes;
95 session_context_->registrar()->GetModelSafeRoutingInfo(&routes);
96 TypePayloadMap model_types_with_payloads =
97 sessions::RoutingInfoToTypePayloadMap(routes, std::string());
98 NudgeSyncImpl(milliseconds_from_now, source, model_types_with_payloads);
79 } 99 }
80 100
81 SyncerThread::SyncerThread(sessions::SyncSessionContext* context) 101 SyncerThread::SyncerThread(sessions::SyncSessionContext* context)
82 : thread_main_started_(false, false), 102 : thread_main_started_(false, false),
83 thread_("SyncEngine_SyncerThread"), 103 thread_("SyncEngine_SyncerThread"),
84 vault_field_changed_(&lock_), 104 vault_field_changed_(&lock_),
85 conn_mgr_hookup_(NULL), 105 conn_mgr_hookup_(NULL),
86 syncer_short_poll_interval_seconds_(kDefaultShortPollIntervalSeconds), 106 syncer_short_poll_interval_seconds_(kDefaultShortPollIntervalSeconds),
87 syncer_long_poll_interval_seconds_(kDefaultLongPollIntervalSeconds), 107 syncer_long_poll_interval_seconds_(kDefaultLongPollIntervalSeconds),
88 syncer_polling_interval_(kDefaultShortPollIntervalSeconds), 108 syncer_polling_interval_(kDefaultShortPollIntervalSeconds),
(...skipping 246 matching lines...) Expand 10 before | Expand all | Expand 10 after
335 // event. This will also update the source of the following SyncMain call. 355 // event. This will also update the source of the following SyncMain call.
336 VLOG(1) << "Calling Sync Main at time " << Time::Now().ToInternalValue(); 356 VLOG(1) << "Calling Sync Main at time " << Time::Now().ToInternalValue();
337 bool nudged = false; 357 bool nudged = false;
338 scoped_ptr<SyncSession> session; 358 scoped_ptr<SyncSession> session;
339 session.reset(SyncMain(vault_.syncer_, 359 session.reset(SyncMain(vault_.syncer_,
340 throttled, continue_sync_cycle, &initial_sync_for_thread, &nudged)); 360 throttled, continue_sync_cycle, &initial_sync_for_thread, &nudged));
341 361
342 // Update timing information for how often these datatypes are triggering 362 // Update timing information for how often these datatypes are triggering
343 // nudges. 363 // nudges.
344 base::TimeTicks now = TimeTicks::Now(); 364 base::TimeTicks now = TimeTicks::Now();
345 for (size_t i = syncable::FIRST_REAL_MODEL_TYPE; 365 if (!last_sync_time.is_null()) {
346 i < session->source().second.size(); 366 TypePayloadMap::const_iterator iter;
347 ++i) { 367 for (iter = session->source().types.begin();
348 if (session->source().second[i]) { 368 iter != session->source().types.end();
349 syncable::PostTimeToTypeHistogram(syncable::ModelType(i), 369 ++iter) {
370 syncable::PostTimeToTypeHistogram(iter->first,
350 now - last_sync_time); 371 now - last_sync_time);
351 } 372 }
352 } 373 }
353 374
354 last_sync_time = now; 375 last_sync_time = now;
355 376
356 VLOG(1) << "Updating the next polling time after SyncMain"; 377 VLOG(1) << "Updating the next polling time after SyncMain";
357 vault_.current_wait_interval_ = CalculatePollingWaitTime( 378 vault_.current_wait_interval_ = CalculatePollingWaitTime(
358 static_cast<int>(vault_.current_wait_interval_.poll_delta.InSeconds()), 379 static_cast<int>(vault_.current_wait_interval_.poll_delta.InSeconds()),
359 &user_idle_milliseconds, &continue_sync_cycle, nudged); 380 &user_idle_milliseconds, &continue_sync_cycle, nudged);
(...skipping 207 matching lines...) Expand 10 before | Expand all | Expand 10 after
567 VLOG(1) << "Done calling SyncShare."; 588 VLOG(1) << "Done calling SyncShare.";
568 return session.release(); 589 return session.release();
569 } 590 }
570 591
571 SyncSourceInfo SyncerThread::GetAndResetNudgeSource(bool was_throttled, 592 SyncSourceInfo SyncerThread::GetAndResetNudgeSource(bool was_throttled,
572 bool continue_sync_cycle, 593 bool continue_sync_cycle,
573 bool* initial_sync, 594 bool* initial_sync,
574 bool* was_nudged) { 595 bool* was_nudged) {
575 bool nudged = false; 596 bool nudged = false;
576 NudgeSource nudge_source = kUnknown; 597 NudgeSource nudge_source = kUnknown;
577 syncable::ModelTypeBitSet model_types; 598 TypePayloadMap model_types_with_payloads;
578 // Has the previous sync cycle completed? 599 // Has the previous sync cycle completed?
579 if (continue_sync_cycle) 600 if (continue_sync_cycle)
580 nudge_source = kContinuation; 601 nudge_source = kContinuation;
581 // Update the nudge source if a new nudge has come through during the 602 // Update the nudge source if a new nudge has come through during the
582 // previous sync cycle. 603 // previous sync cycle.
583 if (!vault_.pending_nudge_time_.is_null()) { 604 if (!vault_.pending_nudge_time_.is_null()) {
584 if (!was_throttled) { 605 if (!was_throttled) {
585 nudge_source = vault_.pending_nudge_source_; 606 nudge_source = vault_.pending_nudge_source_;
586 model_types = vault_.pending_nudge_types_; 607 model_types_with_payloads = vault_.pending_nudge_types_;
587 nudged = true; 608 nudged = true;
588 } 609 }
589 VLOG(1) << "Clearing pending nudge from " << vault_.pending_nudge_source_ 610 VLOG(1) << "Clearing pending nudge from " << vault_.pending_nudge_source_
590 << " at tick " << vault_.pending_nudge_time_.ToInternalValue(); 611 << " at tick " << vault_.pending_nudge_time_.ToInternalValue();
591 vault_.pending_nudge_source_ = kUnknown; 612 vault_.pending_nudge_source_ = kUnknown;
592 vault_.pending_nudge_types_.reset(); 613 vault_.pending_nudge_types_.clear();
593 vault_.pending_nudge_time_ = base::TimeTicks(); 614 vault_.pending_nudge_time_ = base::TimeTicks();
594 } 615 }
595 616
596 *was_nudged = nudged; 617 *was_nudged = nudged;
597 618
598 // TODO(tim): Hack for bug 64136 to correctly tag continuations that result 619 // TODO(tim): Hack for bug 64136 to correctly tag continuations that result
599 // from syncer having more work to do. This will be handled properly with 620 // from syncer having more work to do. This will be handled properly with
600 // the message loop based syncer thread, bug 26339. 621 // the message loop based syncer thread, bug 26339.
601 return MakeSyncSourceInfo(nudged || nudge_source == kContinuation, 622 return MakeSyncSourceInfo(nudged || nudge_source == kContinuation,
602 nudge_source, model_types, initial_sync); 623 nudge_source, model_types_with_payloads, initial_sync);
603 } 624 }
604 625
605 SyncSourceInfo SyncerThread::MakeSyncSourceInfo(bool nudged, 626 SyncSourceInfo SyncerThread::MakeSyncSourceInfo(bool nudged,
606 NudgeSource nudge_source, const syncable::ModelTypeBitSet& nudge_types, 627 NudgeSource nudge_source,
628 const TypePayloadMap& model_types_with_payloads,
607 bool* initial_sync) { 629 bool* initial_sync) {
608 sync_pb::GetUpdatesCallerInfo::GetUpdatesSource updates_source = 630 sync_pb::GetUpdatesCallerInfo::GetUpdatesSource updates_source =
609 sync_pb::GetUpdatesCallerInfo::UNKNOWN; 631 sync_pb::GetUpdatesCallerInfo::UNKNOWN;
610 if (*initial_sync) { 632 if (*initial_sync) {
611 updates_source = sync_pb::GetUpdatesCallerInfo::FIRST_UPDATE; 633 updates_source = sync_pb::GetUpdatesCallerInfo::FIRST_UPDATE;
612 *initial_sync = false; 634 *initial_sync = false;
613 } else if (!nudged) { 635 } else if (!nudged) {
614 updates_source = sync_pb::GetUpdatesCallerInfo::PERIODIC; 636 updates_source = sync_pb::GetUpdatesCallerInfo::PERIODIC;
615 } else { 637 } else {
616 switch (nudge_source) { 638 switch (nudge_source) {
617 case kNotification: 639 case kNotification:
618 updates_source = sync_pb::GetUpdatesCallerInfo::NOTIFICATION; 640 updates_source = sync_pb::GetUpdatesCallerInfo::NOTIFICATION;
619 break; 641 break;
620 case kLocal: 642 case kLocal:
621 updates_source = sync_pb::GetUpdatesCallerInfo::LOCAL; 643 updates_source = sync_pb::GetUpdatesCallerInfo::LOCAL;
622 break; 644 break;
623 case kContinuation: 645 case kContinuation:
624 updates_source = sync_pb::GetUpdatesCallerInfo::SYNC_CYCLE_CONTINUATION; 646 updates_source = sync_pb::GetUpdatesCallerInfo::SYNC_CYCLE_CONTINUATION;
625 break; 647 break;
626 case kClearPrivateData: 648 case kClearPrivateData:
627 updates_source = sync_pb::GetUpdatesCallerInfo::CLEAR_PRIVATE_DATA; 649 updates_source = sync_pb::GetUpdatesCallerInfo::CLEAR_PRIVATE_DATA;
628 break; 650 break;
629 case kUnknown: 651 case kUnknown:
630 default: 652 default:
631 updates_source = sync_pb::GetUpdatesCallerInfo::UNKNOWN; 653 updates_source = sync_pb::GetUpdatesCallerInfo::UNKNOWN;
632 break; 654 break;
633 } 655 }
634 } 656 }
635 return SyncSourceInfo(updates_source, nudge_types); 657
658 TypePayloadMap sync_source_types;
659 if (model_types_with_payloads.empty()) {
660 // No datatypes requested. This must be a poll so set all enabled datatypes.
661 ModelSafeRoutingInfo routes;
662 session_context_->registrar()->GetModelSafeRoutingInfo(&routes);
663 sync_source_types = sessions::RoutingInfoToTypePayloadMap(routes,
664 std::string());
665 } else {
666 sync_source_types = model_types_with_payloads;
667 }
668
669 return SyncSourceInfo(updates_source, sync_source_types);
636 } 670 }
637 671
638 void SyncerThread::CreateSyncer(const std::string& dirname) { 672 void SyncerThread::CreateSyncer(const std::string& dirname) {
639 base::AutoLock lock(lock_); 673 base::AutoLock lock(lock_);
640 VLOG(1) << "Creating syncer up for: " << dirname; 674 VLOG(1) << "Creating syncer up for: " << dirname;
641 // The underlying database structure is ready, and we should create 675 // The underlying database structure is ready, and we should create
642 // the syncer. 676 // the syncer.
643 CHECK(vault_.syncer_ == NULL); 677 CHECK(vault_.syncer_ == NULL);
644 session_context_->set_account_name(dirname); 678 session_context_->set_account_name(dirname);
645 vault_.syncer_ = new Syncer(); 679 vault_.syncer_ = new Syncer();
(...skipping 81 matching lines...) Expand 10 before | Expand all | Expand 10 after
727 // rate. 761 // rate.
728 if (idle >= kPollBackoffThresholdMultiplier * syncer_polling_interval_ms) { 762 if (idle >= kPollBackoffThresholdMultiplier * syncer_polling_interval_ms) {
729 next_wait = std::min(GetRecommendedDelaySeconds( 763 next_wait = std::min(GetRecommendedDelaySeconds(
730 last_interval / 1000), syncer_max_interval_ / 1000) * 1000; 764 last_interval / 1000), syncer_max_interval_ / 1000) * 1000;
731 } 765 }
732 766
733 return next_wait; 767 return next_wait;
734 } 768 }
735 769
736 // Called with mutex_ already locked. 770 // Called with mutex_ already locked.
737 void SyncerThread::NudgeSyncImpl(int milliseconds_from_now, 771 void SyncerThread::NudgeSyncImpl(
738 NudgeSource source, 772 int milliseconds_from_now,
739 const syncable::ModelTypeBitSet& model_types) { 773 NudgeSource source,
774 const TypePayloadMap& model_types_with_payloads) {
740 // TODO(sync): Add the option to reset the backoff state machine. 775 // TODO(sync): Add the option to reset the backoff state machine.
741 // This is needed so nudges that are a result of the user's desire 776 // This is needed so nudges that are a result of the user's desire
742 // to download updates for a new data type can be satisfied quickly. 777 // to download updates for a new data type can be satisfied quickly.
743 if (vault_.current_wait_interval_.mode == WaitInterval::THROTTLED || 778 if (vault_.current_wait_interval_.mode == WaitInterval::THROTTLED ||
744 vault_.current_wait_interval_.had_nudge_during_backoff) { 779 vault_.current_wait_interval_.had_nudge_during_backoff) {
745 // Drop nudges on the floor if we've already had one since starting this 780 // Drop nudges on the floor if we've already had one since starting this
746 // stage of exponential backoff or we are throttled. 781 // stage of exponential backoff or we are throttled.
747 return; 782 return;
748 } 783 }
749 784
750 // Union the current bitset with any from nudges that may have already 785 // Union the current TypePayloadMap with any from nudges that may have already
751 // posted (coalesce the nudge datatype information). 786 // posted (coalesce the nudge datatype information).
752 // TODO(tim): It seems weird to do this if the sources don't match up (e.g. 787 // TODO(tim): It seems weird to do this if the sources don't match up (e.g.
753 // if pending_source is kLocal and |source| is kClearPrivateData). 788 // if pending_source is kLocal and |source| is kClearPrivateData).
754 vault_.pending_nudge_types_ |= model_types; 789 sessions::CoalescePayloads(&vault_.pending_nudge_types_,
790 model_types_with_payloads);
755 791
756 const TimeTicks nudge_time = TimeTicks::Now() + 792 const TimeTicks nudge_time = TimeTicks::Now() +
757 TimeDelta::FromMilliseconds(milliseconds_from_now); 793 TimeDelta::FromMilliseconds(milliseconds_from_now);
758 if (nudge_time <= vault_.pending_nudge_time_) { 794 if (nudge_time <= vault_.pending_nudge_time_) {
759 VLOG(1) << "Nudge for source " << source 795 VLOG(1) << "Nudge for source " << source
760 << " dropped due to existing later pending nudge"; 796 << " dropped due to existing later pending nudge";
761 return; 797 return;
762 } 798 }
763 799
764 VLOG(1) << "Replacing pending nudge for source " << source 800 VLOG(1) << "Replacing pending nudge for source " << source
(...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after
842 was_logged = true; 878 was_logged = true;
843 VLOG(1) << "UserIdleTime unimplemented on this platform, synchronization " 879 VLOG(1) << "UserIdleTime unimplemented on this platform, synchronization "
844 "will not throttle when user idle"; 880 "will not throttle when user idle";
845 } 881 }
846 #endif 882 #endif
847 883
848 return 0; 884 return 0;
849 } 885 }
850 886
851 } // namespace browser_sync 887 } // namespace browser_sync
OLDNEW
« no previous file with comments | « chrome/browser/sync/engine/syncer_thread.h ('k') | chrome/browser/sync/engine/syncer_thread_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698