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

Side by Side Diff: chrome/browser/sync/sessions/sync_session.h

Issue 6182004: [SYNC] Refactor SyncSourceInfo and add support in chrome invalidation client ... (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src/
Patch Set: Added util functions 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 // A class representing an attempt to synchronize the local syncable data 5 // A class representing an attempt to synchronize the local syncable data
6 // store with a sync server. A SyncSession instance is passed as a stateful 6 // store with a sync server. A SyncSession instance is passed as a stateful
7 // bundle to and from various SyncerCommands with the goal of converging the 7 // bundle to and from various SyncerCommands with the goal of converging the
8 // client view of data with that of the server. The commands twiddle with 8 // client view of data with that of the server. The commands twiddle with
9 // session status in response to events and hiccups along the way, set and 9 // session status in response to events and hiccups along the way, set and
10 // query session progress with regards to conflict resolution and applying 10 // query session progress with regards to conflict resolution and applying
11 // server updates, and access the SyncSessionContext for the current session 11 // server updates, and access the SyncSessionContext for the current session
12 // via SyncSession instances. 12 // via SyncSession instances.
13 13
14 #ifndef CHROME_BROWSER_SYNC_SESSIONS_SYNC_SESSION_H_ 14 #ifndef CHROME_BROWSER_SYNC_SESSIONS_SYNC_SESSION_H_
15 #define CHROME_BROWSER_SYNC_SESSIONS_SYNC_SESSION_H_ 15 #define CHROME_BROWSER_SYNC_SESSIONS_SYNC_SESSION_H_
16 #pragma once 16 #pragma once
17 17
18 #include <map>
19 #include <string>
18 #include <utility> 20 #include <utility>
19 #include <vector> 21 #include <vector>
20 22
21 #include "base/basictypes.h" 23 #include "base/basictypes.h"
22 #include "base/scoped_ptr.h" 24 #include "base/scoped_ptr.h"
23 #include "base/time.h" 25 #include "base/time.h"
26 #include "chrome/browser/sync/engine/model_safe_worker.h"
akalin 2011/01/24 22:17:29 I think you can forward declare ModelSafeRoutingIn
Nicolas Zea 2011/01/25 00:29:14 ModelSafeRoutingInfo is a typedef, so can't be for
akalin 2011/01/26 01:15:17 Ah, actually if it's a typedef, then we should inc
24 #include "chrome/browser/sync/sessions/ordered_commit_set.h" 27 #include "chrome/browser/sync/sessions/ordered_commit_set.h"
25 #include "chrome/browser/sync/sessions/session_state.h" 28 #include "chrome/browser/sync/sessions/session_state.h"
26 #include "chrome/browser/sync/sessions/status_controller.h" 29 #include "chrome/browser/sync/sessions/status_controller.h"
27 #include "chrome/browser/sync/sessions/sync_session_context.h" 30 #include "chrome/browser/sync/sessions/sync_session_context.h"
31 #include "chrome/browser/sync/syncable/model_type.h"
28 #include "chrome/browser/sync/util/extensions_activity_monitor.h" 32 #include "chrome/browser/sync/util/extensions_activity_monitor.h"
29 33
30 namespace syncable { 34 namespace syncable {
31 class WriteTransaction; 35 class WriteTransaction;
32 } 36 }
33 37
34 namespace browser_sync { 38 namespace browser_sync {
35 class ModelSafeWorker; 39 class ModelSafeWorker;
36 40
37 namespace sessions { 41 namespace sessions {
38 typedef std::pair<sync_pb::GetUpdatesCallerInfo::GetUpdatesSource, 42
39 syncable::ModelTypeBitSet> SyncSourceInfo; 43 // A container that contains a set of datatypes with possible string payloads.
44 typedef std::map<syncable::ModelType, std::string> ModelTypeMap;
akalin 2011/01/24 22:17:29 ModelTypeMap is a bit generic -- how about ModelTy
Nicolas Zea 2011/01/25 00:29:14 Done.
45
46 // Helper utils for building ModelTypeMaps.
47 void BuildModelTypeMapFromModelTypeBitSet(
akalin 2011/01/24 22:17:29 These names are a bit long. I suggest: ModelType
Nicolas Zea 2011/01/25 00:29:14 Done.
48 const syncable::ModelTypeBitSet& types,
49 const std::string& payload,
50 ModelTypeMap* map);
51 void BuildModelTypeMapFromModelSafeRoutingInfo(
52 const ModelSafeRoutingInfo& routes,
53 const std::string& payload,
54 ModelTypeMap* map);
55
56 // A container for the source of a sync session. This includes the update
57 // source, the datatypes triggering the sync session, and possible session
58 // specific payloads which should be sent to the server.
59 struct SyncSourceInfo {
60 SyncSourceInfo();
61 SyncSourceInfo(
62 const sync_pb::GetUpdatesCallerInfo::GetUpdatesSource& u,
63 const ModelTypeMap& t);
64
65 sync_pb::GetUpdatesCallerInfo::GetUpdatesSource updates_source;
66 ModelTypeMap types;
67 };
40 68
41 class SyncSession { 69 class SyncSession {
42 public: 70 public:
43 // The Delegate services events that occur during the session requiring an 71 // The Delegate services events that occur during the session requiring an
44 // explicit (and session-global) action, as opposed to events that are simply 72 // explicit (and session-global) action, as opposed to events that are simply
45 // recorded in per-session state. 73 // recorded in per-session state.
46 class Delegate { 74 class Delegate {
47 public: 75 public:
48 // The client was throttled and should cease-and-desist syncing activity 76 // The client was throttled and should cease-and-desist syncing activity
49 // until the specified time. 77 // until the specified time.
(...skipping 113 matching lines...) Expand 10 before | Expand all | Expand 10 after
163 191
164 private: 192 private:
165 SyncSession* session_; 193 SyncSession* session_;
166 DISALLOW_COPY_AND_ASSIGN(ScopedSetSessionWriteTransaction); 194 DISALLOW_COPY_AND_ASSIGN(ScopedSetSessionWriteTransaction);
167 }; 195 };
168 196
169 } // namespace sessions 197 } // namespace sessions
170 } // namespace browser_sync 198 } // namespace browser_sync
171 199
172 #endif // CHROME_BROWSER_SYNC_SESSIONS_SYNC_SESSION_H_ 200 #endif // CHROME_BROWSER_SYNC_SESSIONS_SYNC_SESSION_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698