Index: chrome/browser/sync/engine/syncapi.h |
=================================================================== |
--- chrome/browser/sync/engine/syncapi.h (revision 22320) |
+++ chrome/browser/sync/engine/syncapi.h (working copy) |
@@ -1,709 +0,0 @@ |
-// Copyright (c) 2009 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-// This file defines the "sync API", an interface to the syncer |
-// backend that exposes (1) the core functionality of maintaining a consistent |
-// local snapshot of a hierarchical object set; (2) a means to transactionally |
-// access and modify those objects; (3) a means to control client/server |
-// synchronization tasks, namely: pushing local object modifications to a |
-// server, pulling nonlocal object modifications from a server to this client, |
-// and resolving conflicts that may arise between the two; and (4) an |
-// abstraction of some external functionality that is to be provided by the |
-// host environment. |
-// |
-// This interface is used as the entry point into the syncer backend |
-// when the backend is compiled as a library and embedded in another |
-// application. A goal for this interface layer is to depend on very few |
-// external types, so that an application can use the sync backend |
-// without introducing a dependency on specific types. A non-goal is to |
-// have binary compatibility across versions or compilers; this allows the |
-// interface to use C++ classes. An application wishing to use the sync API |
-// should ideally compile the syncer backend and this API as part of the |
-// application's own build, to avoid e.g. mismatches in calling convention, |
-// structure padding, or name mangling that could arise if there were a |
-// compiler mismatch. |
-// |
-// The schema of the objects in the sync domain is based on the model, which |
-// is essentially a hierarchy of items and folders similar to a filesystem, |
-// but with a few important differences. The sync API contains fields |
-// such as URL to easily allow the embedding application to store web |
-// browser bookmarks. Also, the sync API allows duplicate titles in a parent. |
-// Consequently, it does not support looking up an object by title |
-// and parent, since such a lookup is not uniquely determined. Lastly, |
-// unlike a filesystem model, objects in the Sync API model have a strict |
-// ordering within a parent; the position is manipulable by callers, and |
-// children of a node can be enumerated in the order of their position. |
- |
-#ifndef CHROME_BROWSER_SYNC_ENGINE_SYNCAPI_H_ |
-#define CHROME_BROWSER_SYNC_ENGINE_SYNCAPI_H_ |
- |
-#include "base/basictypes.h" |
- |
-#if (defined(OS_WIN) || defined(OS_WINDOWS)) |
-typedef wchar_t sync_char16; |
-#else |
-typedef uint16 sync_char16; |
-#endif |
- |
-// The MSVC compiler for Windows requires that any classes exported by, or |
-// imported from, a dynamic library be decorated with the following fanciness. |
-#if (defined(OS_WIN) || defined(OS_WINDOWS)) |
-#if COMPILING_SYNCAPI_LIBRARY |
-#define SYNC_EXPORT __declspec(dllexport) |
-#else |
-#define SYNC_EXPORT __declspec(dllimport) |
-#endif |
-#else |
-#define SYNC_EXPORT |
-#endif // OS_WIN || OS_WINDOWS |
- |
-// Forward declarations of internal class types so that sync API objects |
-// may have opaque pointers to these types. |
-namespace syncable { |
-class BaseTransaction; |
-class DirectoryManager; |
-class Entry; |
-class MutableEntry; |
-class ReadTransaction; |
-class ScopedDirLookup; |
-class WriteTransaction; |
-} |
- |
-namespace sync_api { |
- |
-// Forward declarations of classes to be defined later in this file. |
-class BaseTransaction; |
-class HttpPostProviderFactory; |
-class ModelSafeWorkerInterface; |
-class SyncManager; |
-class WriteTransaction; |
-struct UserShare; |
- |
-// A valid BaseNode will never have an ID of zero. |
-static const int64 kInvalidId = 0; |
- |
-// BaseNode wraps syncable::Entry, and corresponds to a single object's state. |
-// This, like syncable::Entry, is intended for use on the stack. A valid |
-// transaction is necessary to create a BaseNode or any of its children. |
-// Unlike syncable::Entry, a sync API BaseNode is identified primarily by its |
-// int64 metahandle, which we call an ID here. |
-class SYNC_EXPORT BaseNode { |
- public: |
- // All subclasses of BaseNode must provide a way to initialize themselves by |
- // doing an ID lookup. Returns false on failure. An invalid or deleted |
- // ID will result in failure. |
- virtual bool InitByIdLookup(int64 id) = 0; |
- |
- // Each object is identified by a 64-bit id (internally, the syncable |
- // metahandle). These ids are strictly local handles. They will persist |
- // on this client, but the same object on a different client may have a |
- // different ID value. |
- int64 GetId() const; |
- |
- // Nodes are hierarchically arranged into a single-rooted tree. |
- // InitByRootLookup on ReadNode allows access to the root. GetParentId is |
- // how you find a node's parent. |
- int64 GetParentId() const; |
- |
- // Nodes are either folders or not. This corresponds to the IS_DIR property |
- // of syncable::Entry. |
- bool GetIsFolder() const; |
- |
- // Returns the title of the object as a C string. The memory is owned by |
- // BaseNode and becomes invalid if GetTitle() is called a second time on this |
- // node, or when the node is destroyed. A caller should convert this |
- // immediately into e.g. a std::string. Uniqueness of the title is not |
- // enforced on siblings -- it is not an error for two children to share |
- // a title. |
- const sync_char16* GetTitle() const; |
- |
- // Returns the URL of a bookmark object as a C string. The memory is owned |
- // by BaseNode and becomes invalid if GetURL() is called a second time on |
- // this node, or when the node is destroyed. A caller should convert this |
- // immediately into e.g. a std::string. |
- const sync_char16* GetURL() const; |
- |
- // Return a pointer to the byte data of the favicon image for this node. |
- // Will return NULL if there is no favicon data associated with this node. |
- // The length of the array is returned to the caller via |size_in_bytes|. |
- // Favicons are expected to be PNG images, and though no verification is |
- // done on the syncapi client of this, the server may reject favicon updates |
- // that are invalid for whatever reason. |
- const unsigned char* GetFaviconBytes(size_t* size_in_bytes); |
- |
- // Returns the local external ID associated with the node. |
- int64 GetExternalId() const; |
- |
- // Return the ID of the node immediately before this in the sibling order. |
- // For the first node in the ordering, return 0. |
- int64 GetPredecessorId() const; |
- |
- // Return the ID of the node immediately after this in the sibling order. |
- // For the last node in the ordering, return 0. |
- int64 GetSuccessorId() const; |
- |
- // Return the ID of the first child of this node. If this node has no |
- // children, return 0. |
- int64 GetFirstChildId() const; |
- |
- // Get an array containing the IDs of this node's children. The memory is |
- // owned by BaseNode and becomes invalid if GetChildIds() is called a second |
- // time on this node, or when the node is destroyed. Return the array size |
- // in the child_count parameter. |
- const int64* GetChildIds(size_t* child_count) const; |
- |
- // These virtual accessors provide access to data members of derived classes. |
- virtual const syncable::Entry* GetEntry() const = 0; |
- virtual const BaseTransaction* GetTransaction() const = 0; |
- |
- protected: |
- BaseNode(); |
- virtual ~BaseNode(); |
- |
- private: |
- struct BaseNodeInternal; |
- |
- // Node is meant for stack use only. |
- void* operator new(size_t size); |
- |
- // Provides storage for member functions that return pointers to class |
- // memory, e.g. C strings returned by GetTitle(). |
- BaseNodeInternal* data_; |
- |
- DISALLOW_COPY_AND_ASSIGN(BaseNode); |
-}; |
- |
-// WriteNode extends BaseNode to add mutation, and wraps |
-// syncable::MutableEntry. A WriteTransaction is needed to create a WriteNode. |
-class SYNC_EXPORT WriteNode : public BaseNode { |
- public: |
- // Create a WriteNode using the given transaction. |
- explicit WriteNode(WriteTransaction* transaction); |
- virtual ~WriteNode(); |
- |
- // A client must use one (and only one) of the following Init variants to |
- // populate the node. |
- |
- // BaseNode implementation. |
- virtual bool InitByIdLookup(int64 id); |
- |
- // Create a new node with the specified parent and predecessor. Use a NULL |
- // |predecessor| to indicate that this is to be the first child. |
- // |predecessor| must be a child of |new_parent| or NULL. Returns false on |
- // failure. |
- bool InitByCreation(const BaseNode& parent, const BaseNode* predecessor); |
- |
- // These Set() functions correspond to the Get() functions of BaseNode. |
- void SetIsFolder(bool folder); |
- void SetTitle(const sync_char16* title); |
- void SetURL(const sync_char16* url); |
- void SetFaviconBytes(const unsigned char* bytes, size_t size_in_bytes); |
- // External ID is a client-only field, so setting it doesn't cause the item to |
- // be synced again. |
- void SetExternalId(int64 external_id); |
- |
- // Remove this node and its children. |
- void Remove(); |
- |
- // Set a new parent and position. Position is specified by |predecessor|; if |
- // it is NULL, the node is moved to the first position. |predecessor| must |
- // be a child of |new_parent| or NULL. Returns false on failure.. |
- bool SetPosition(const BaseNode& new_parent, const BaseNode* predecessor); |
- |
- // Implementation of BaseNode's abstract virtual accessors. |
- virtual const syncable::Entry* GetEntry() const; |
- |
- virtual const BaseTransaction* GetTransaction() const; |
- |
- private: |
- void* operator new(size_t size); // Node is meant for stack use only. |
- |
- // Helper to set the previous node. |
- void PutPredecessor(const BaseNode* predecessor); |
- |
- // Sets IS_UNSYNCED and SYNCING to ensure this entry is considered in an |
- // upcoming commit pass. |
- void MarkForSyncing(); |
- |
- // The underlying syncable object which this class wraps. |
- syncable::MutableEntry* entry_; |
- |
- // The sync API transaction that is the parent of this node. |
- WriteTransaction* transaction_; |
- |
- DISALLOW_COPY_AND_ASSIGN(WriteNode); |
-}; |
- |
-// ReadNode wraps a syncable::Entry to provide the functionality of a |
-// read-only BaseNode. |
-class SYNC_EXPORT ReadNode : public BaseNode { |
- public: |
- // Create an unpopulated ReadNode on the given transaction. Call some flavor |
- // of Init to populate the ReadNode with a database entry. |
- explicit ReadNode(const BaseTransaction* transaction); |
- virtual ~ReadNode(); |
- |
- // A client must use one (and only one) of the following Init variants to |
- // populate the node. |
- |
- // BaseNode implementation. |
- virtual bool InitByIdLookup(int64 id); |
- |
- // There is always a root node, so this can't fail. The root node is |
- // never mutable, so root lookup is only possible on a ReadNode. |
- void InitByRootLookup(); |
- |
- // Each server-created permanent node is tagged with a unique string. |
- // Look up the node with the particular tag. If it does not exist, |
- // return false. Since these nodes are special, lookup is only |
- // provided only through ReadNode. |
- bool InitByTagLookup(const sync_char16* tag); |
- |
- // Implementation of BaseNode's abstract virtual accessors. |
- virtual const syncable::Entry* GetEntry() const; |
- virtual const BaseTransaction* GetTransaction() const; |
- |
- private: |
- void* operator new(size_t size); // Node is meant for stack use only. |
- |
- // The underlying syncable object which this class wraps. |
- syncable::Entry* entry_; |
- |
- // The sync API transaction that is the parent of this node. |
- const BaseTransaction* transaction_; |
- |
- DISALLOW_COPY_AND_ASSIGN(ReadNode); |
-}; |
- |
-// Sync API's BaseTransaction, ReadTransaction, and WriteTransaction allow for |
-// batching of several read and/or write operations. The read and write |
-// operations are performed by creating ReadNode and WriteNode instances using |
-// the transaction. These transaction classes wrap identically named classes in |
-// syncable, and are used in a similar way. Unlike syncable::BaseTransaction, |
-// whose construction requires an explicit syncable::ScopedDirLookup, a sync |
-// API BaseTransaction creates its own ScopedDirLookup implicitly. |
-class SYNC_EXPORT BaseTransaction { |
- public: |
- // Provide access to the underlying syncable.h objects from BaseNode. |
- virtual syncable::BaseTransaction* GetWrappedTrans() const = 0; |
- const syncable::ScopedDirLookup& GetLookup() const { return *lookup_; } |
- |
- protected: |
- // The ScopedDirLookup is created in the constructor and destroyed |
- // in the destructor. Creation of the ScopedDirLookup is not expected |
- // to fail. |
- explicit BaseTransaction(UserShare* share); |
- virtual ~BaseTransaction(); |
- |
- private: |
- // A syncable ScopedDirLookup, which is the parent of syncable transactions. |
- syncable::ScopedDirLookup* lookup_; |
- |
- DISALLOW_COPY_AND_ASSIGN(BaseTransaction); |
-}; |
- |
-// Sync API's ReadTransaction is a read-only BaseTransaction. It wraps |
-// a syncable::ReadTransaction. |
-class SYNC_EXPORT ReadTransaction : public BaseTransaction { |
- public: |
- // Start a new read-only transaction on the specified repository. |
- explicit ReadTransaction(UserShare* share); |
- virtual ~ReadTransaction(); |
- |
- // BaseTransaction override. |
- virtual syncable::BaseTransaction* GetWrappedTrans() const; |
- private: |
- void* operator new(size_t size); // Transaction is meant for stack use only. |
- |
- // The underlying syncable object which this class wraps. |
- syncable::ReadTransaction* transaction_; |
- |
- DISALLOW_COPY_AND_ASSIGN(ReadTransaction); |
-}; |
- |
-// Sync API's WriteTransaction is a read/write BaseTransaction. It wraps |
-// a syncable::WriteTransaction. |
-class SYNC_EXPORT WriteTransaction : public BaseTransaction { |
- public: |
- // Start a new read/write transaction. |
- explicit WriteTransaction(UserShare* share); |
- virtual ~WriteTransaction(); |
- |
- // Provide access to the syncable.h transaction from the API WriteNode. |
- virtual syncable::BaseTransaction* GetWrappedTrans() const; |
- syncable::WriteTransaction* GetWrappedWriteTrans() { return transaction_; } |
- |
- private: |
- void* operator new(size_t size); // Transaction is meant for stack use only. |
- |
- // The underlying syncable object which this class wraps. |
- syncable::WriteTransaction* transaction_; |
- |
- DISALLOW_COPY_AND_ASSIGN(WriteTransaction); |
-}; |
- |
-// SyncManager encapsulates syncable::DirectoryManager and serves as the parent |
-// of all other objects in the sync API. SyncManager is thread-safe. If |
-// multiple threads interact with the same local sync repository (i.e. the |
-// same sqlite database), they should share a single SyncManager instance. The |
-// caller should typically create one SyncManager for the lifetime of a user |
-// session. |
-class SYNC_EXPORT SyncManager { |
- public: |
- // SyncInternal contains the implementation of SyncManager, while abstracting |
- // internal types from clients of the interface. |
- class SyncInternal; |
- |
- // ChangeRecord indicates a single item that changed as a result of a sync |
- // operation. This gives the sync id of the node that changed, and the type |
- // of change. To get the actual property values after an ADD or UPDATE, the |
- // client should get the node with InitByIdLookup(), using the provided id. |
- struct ChangeRecord { |
- enum Action { |
- ACTION_ADD, |
- ACTION_DELETE, |
- ACTION_UPDATE, |
- }; |
- ChangeRecord() : id(kInvalidId), action(ACTION_ADD) {} |
- int64 id; |
- Action action; |
- }; |
- |
- // When the SyncManager is unable to initiate the syncing process due to a |
- // failure during authentication, AuthProblem describes the actual problem |
- // more precisely. |
- enum AuthProblem { |
- AUTH_PROBLEM_NONE = 0, |
- // The credentials supplied to GAIA were either invalid, or the locally |
- // cached credentials have expired. If this happens, the sync system |
- // will continue as if offline until authentication is reattempted. |
- AUTH_PROBLEM_INVALID_GAIA_CREDENTIALS, |
- // The GAIA user is not authorized to use the sync service. |
- AUTH_PROBLEM_USER_NOT_SIGNED_UP, |
- // Could not connect to server to verify credentials. This could be in |
- // response to either failure to connect to GAIA or failure to connect to |
- // the sync service during authentication. |
- AUTH_PROBLEM_CONNECTION_FAILED, |
- }; |
- |
- // Status encapsulates detailed state about the internals of the SyncManager. |
- struct Status { |
- // Summary is a distilled set of important information that the end-user may |
- // wish to be informed about (through UI, for example). Note that if a |
- // summary state requires user interaction (such as auth failures), more |
- // detailed information may be contained in additional status fields. |
- enum Summary { |
- // The internal instance is in an unrecognizable state. This should not |
- // happen. |
- INVALID = 0, |
- // Can't connect to server, but there are no pending changes in |
- // our local cache. |
- OFFLINE, |
- // Can't connect to server, and there are pending changes in our |
- // local cache. |
- OFFLINE_UNSYNCED, |
- // Connected and syncing. |
- SYNCING, |
- // Connected, no pending changes. |
- READY, |
- // User has chosen to pause syncing. |
- PAUSED, |
- // Internal sync error. |
- CONFLICT, |
- // Can't connect to server, and we haven't completed the initial |
- // sync yet. So there's nothing we can do but wait for the server. |
- OFFLINE_UNUSABLE, |
- }; |
- Summary summary; |
- |
- // Various server related information. |
- bool authenticated; // Successfully authenticated via GAIA. |
- bool server_up; // True if we have received at least one good |
- // reply from the server. |
- bool server_reachable; // True if we received any reply from the server. |
- bool server_broken; // True of the syncer is stopped because of server |
- // issues. |
- |
- bool notifications_enabled; // True only if subscribed for notifications. |
- int notifications_received; |
- int notifications_sent; |
- |
- // Various Syncer data. |
- int unsynced_count; |
- int conflicting_count; |
- bool syncing; |
- bool syncer_paused; |
- bool initial_sync_ended; |
- bool syncer_stuck; |
- int64 updates_available; |
- int64 updates_received; |
- bool disk_full; |
- bool invalid_store; |
- int max_consecutive_errors; // The max number of errors from any component. |
- }; |
- |
- // An interface the embedding application implements to receive notifications |
- // from the SyncManager. Register an observer via SyncManager::AddObserver. |
- // This observer is an event driven model as the events may be raised from |
- // different internal threads, and simply providing an "OnStatusChanged" type |
- // notification complicates things such as trying to determine "what changed", |
- // if different members of the Status object are modified from different |
- // threads. This way, the event is explicit, and it is safe for the Observer |
- // to dispatch to a native thread or synchronize accordingly. |
- class Observer { |
- public: |
- Observer() { } |
- virtual ~Observer() { } |
- // Notify the observer that changes have been applied to the sync model. |
- // This will be invoked on the same thread as on which ApplyChanges was |
- // called. |changes| is an array of size |change_count|, and contains the ID |
- // of each individual item that was changed. |changes| exists only |
- // for the duration of the call. Because the observer is passed a |trans|, |
- // the observer can assume a read lock on the database that will be released |
- // after the function returns. |
- // |
- // The SyncManager constructs |changes| in the following guaranteed order: |
- // |
- // 1. Deletions, from leaves up to parents. |
- // 2. Updates to existing items with synced parents & predecessors. |
- // 3. New items with synced parents & predecessors. |
- // 4. Items with parents & predecessors in |changes|. |
- // 5. Repeat #4 until all items are in |changes|. |
- // |
- // Thus, an implementation of OnChangesApplied should be able to |
- // process the change records in the order without having to worry about |
- // forward dependencies. But since deletions come before reparent |
- // operations, a delete may temporarily orphan a node that is |
- // updated later in the list. |
- virtual void OnChangesApplied(const BaseTransaction* trans, |
- const ChangeRecord* changes, |
- int change_count) = 0; |
- |
- // A round-trip sync-cycle took place and the syncer has resolved any |
- // conflicts that may have arisen. This is kept separate from |
- // OnStatusChanged as there isn't really any state update; it is plainly |
- // a notification of a state transition. |
- virtual void OnSyncCycleCompleted() = 0; |
- |
- // Called when user interaction may be required due to an auth problem. |
- virtual void OnAuthProblem(AuthProblem auth_problem) = 0; |
- |
- // Called when initialization is complete to the point that SyncManager can |
- // process changes. This does not necessarily mean authentication succeeded |
- // or that the SyncManager is online. |
- // IMPORTANT: Creating any type of transaction before receiving this |
- // notification is illegal! |
- // WARNING: Calling methods on the SyncManager before receiving this |
- // message, unless otherwise specified, produces undefined behavior. |
- virtual void OnInitializationComplete() = 0; |
- |
- private: |
- DISALLOW_COPY_AND_ASSIGN(Observer); |
- }; |
- |
- // Create an uninitialized SyncManager. Callers must Init() before using. |
- SyncManager(); |
- virtual ~SyncManager(); |
- |
- // Initialize the sync manager. |database_location| specifies the path of |
- // the directory in which to locate a sqlite repository storing the syncer |
- // backend state. Initialization will open the database, or create it if it |
- // does not already exist. Returns false on failure. |
- // |sync_server_and_path| and |sync_server_port| represent the Chrome sync |
- // server to use, and |use_ssl| specifies whether to communicate securely; |
- // the default is false. |
- // |gaia_service_id| is the service id used for GAIA authentication. If it's |
- // null then default will be used. |
- // |post_factory| will be owned internally and used to create |
- // instances of an HttpPostProvider. |
- // |auth_post_factory| will be owned internally and used to create |
- // instances of an HttpPostProvider for communicating with GAIA. |
- // TODO(timsteele): It seems like one factory should suffice, but for now to |
- // avoid having to deal with threading issues since the auth code and syncer |
- // code live on separate threads that run simultaneously, we just dedicate |
- // one to each component. Long term we may want to reconsider the HttpBridge |
- // API to take all the params in one chunk in a threadsafe manner.. which is |
- // still suboptimal as there will be high contention between the two threads |
- // on startup; so maybe what we have now is the best solution- it does mirror |
- // the CURL implementation as each thread creates their own internet handle. |
- // Investigate. |
- // |model_safe_worker| ownership is given to the SyncManager. |
- // |user_agent| is a 7-bit ASCII string suitable for use as the User-Agent |
- // HTTP header. Used internally when collecting stats to classify clients. |
- bool Init(const sync_char16* database_location, |
- const char* sync_server_and_path, |
- int sync_server_port, |
- const char* gaia_service_id, |
- const char* gaia_source, |
- bool use_ssl, |
- HttpPostProviderFactory* post_factory, |
- HttpPostProviderFactory* auth_post_factory, |
- ModelSafeWorkerInterface* model_safe_worker, |
- bool attempt_last_user_authentication, |
- const char* user_agent); |
- |
- // Returns the username last used for a successful authentication as a |
- // null-terminated string. Returns empty if there is no such username. |
- // The memory is not owned by the caller and should be copied. |
- const char* GetAuthenticatedUsername(); |
- |
- // Submit credentials to GAIA for verification and start the |
- // syncing process on success. On success, both |username| and the obtained |
- // auth token are persisted on disk for future re-use. |
- // If authentication fails, OnAuthProblem is called on our Observer. |
- // The Observer may, in turn, decide to try again with new |
- // credentials. Calling this method again is the appropriate course of action |
- // to "retry". |
- // |username| and |password| are expected to be owned by the caller. |
- void Authenticate(const char* username, const char* password); |
- |
- // Adds a listener to be notified of sync events. |
- // NOTE: It is OK (in fact, it's probably a good idea) to call this before |
- // having received OnInitializationCompleted. |
- void SetObserver(Observer* observer); |
- |
- // Remove the observer set by SetObserver (no op if none was set). |
- // Make sure to call this if the Observer set in SetObserver is being |
- // destroyed so the SyncManager doesn't potentially dereference garbage. |
- void RemoveObserver(); |
- |
- // Status-related getters. Typically GetStatusSummary will suffice, but |
- // GetDetailedSyncStatus can be useful for gathering debug-level details of |
- // the internals of the sync engine. |
- Status::Summary GetStatusSummary() const; |
- Status GetDetailedStatus() const; |
- |
- // Get the internal implementation for use by BaseTransaction, etc. |
- SyncInternal* GetImpl() const; |
- |
- // Call periodically from a database-safe thread to persist recent changes |
- // to the syncapi model. |
- void SaveChanges(); |
- |
- // Invoking this method will result in the syncapi bypassing authentication |
- // and opening a local store suitable for testing client code. When in this |
- // mode, nothing will ever get synced to a server (in fact no HTTP |
- // communication will take place). |
- // Note: The SyncManager precondition that you must first call Init holds; |
- // this will fail unless we're initialized. |
- void SetupForTestMode(const sync_char16* test_username); |
- |
- // Issue a final SaveChanges, close sqlite handles, and stop running threads. |
- // Must be called from the same thread that called Init(). |
- void Shutdown(); |
- |
- UserShare* GetUserShare() const; |
- |
- private: |
- // An opaque pointer to the nested private class. |
- SyncInternal* data_; |
- |
- DISALLOW_COPY_AND_ASSIGN(SyncManager); |
-}; |
- |
-// An interface the embedding application (e.g. Chromium) implements to |
-// provide required HTTP POST functionality to the syncer backend. |
-// This interface is designed for one-time use. You create one, use it, and |
-// create another if you want to make a subsequent POST. |
-// TODO(timsteele): Bug 1482576. Consider splitting syncapi.h into two files: |
-// one for the API defining the exports, which doesn't need to be included from |
-// anywhere internally, and another file for the interfaces like this one. |
-class HttpPostProviderInterface { |
- public: |
- HttpPostProviderInterface() { } |
- virtual ~HttpPostProviderInterface() { } |
- |
- // Use specified user agent string when POSTing. If not called a default UA |
- // may be used. |
- virtual void SetUserAgent(const char* user_agent) = 0; |
- |
- // Set the URL to POST to. |
- virtual void SetURL(const char* url, int port) = 0; |
- |
- // Set the type, length and content of the POST payload. |
- // |content_type| is a null-terminated MIME type specifier. |
- // |content| is a data buffer; Do not interpret as a null-terminated string. |
- // |content_length| is the total number of chars in |content|. It is used to |
- // assign/copy |content| data. |
- virtual void SetPostPayload(const char* content_type, int content_length, |
- const char* content) = 0; |
- |
- // Add the specified cookie to the request context using the url set by |
- // SetURL as the key. |cookie| should be a standard cookie line |
- // [e.g "name=val; name2=val2"]. |cookie| should be copied. |
- virtual void AddCookieForRequest(const char* cookie) = 0; |
- |
- // Returns true if the URL request succeeded. If the request failed, |
- // os_error() may be non-zero and hence contain more information. |
- virtual bool MakeSynchronousPost(int* os_error_code, int* response_code) = 0; |
- |
- // Get the length of the content returned in the HTTP response. |
- // This does not count the trailing null-terminating character returned |
- // by GetResponseContent, so it is analogous to calling string.length. |
- virtual int GetResponseContentLength() const = 0; |
- |
- // Get the content returned in the HTTP response. |
- // This is a null terminated string of characters. |
- // Value should be copied. |
- virtual const char* GetResponseContent() const = 0; |
- |
- // To simplify passing a vector<string> across this API, we provide the |
- // following two methods. Use GetResponseCookieCount to bound a loop calling |
- // GetResponseCookieAt once for each integer in the range |
- // [0, GetNumCookiesInResponse). The char* returned should be copied. |
- virtual int GetResponseCookieCount() const = 0; |
- virtual const char* GetResponseCookieAt(int cookie_number) const = 0; |
- |
- private: |
- DISALLOW_COPY_AND_ASSIGN(HttpPostProviderInterface); |
-}; |
- |
-// A factory to create HttpPostProviders to hide details about the |
-// implementations and dependencies. |
-// A factory instance itself should be owned by whomever uses it to create |
-// HttpPostProviders. |
-class HttpPostProviderFactory { |
- public: |
- // Obtain a new HttpPostProviderInterface instance, owned by caller. |
- virtual HttpPostProviderInterface* Create() = 0; |
- |
- // When the interface is no longer needed (ready to be cleaned up), clients |
- // must call Destroy(). |
- // This allows actual HttpPostProvider subclass implementations to be |
- // reference counted, which is useful if a particular implementation uses |
- // multiple threads to serve network requests. |
- virtual void Destroy(HttpPostProviderInterface* http) = 0; |
- virtual ~HttpPostProviderFactory() { } |
-}; |
- |
-// A class syncapi clients should use whenever the underlying model is bound to |
-// a particular thread in the embedding application. This exposes an interface |
-// by which any model-modifying invocations will be forwarded to the |
-// appropriate thread in the embedding application. |
-// "model safe" refers to not allowing an embedding application model to fall |
-// out of sync with the syncable::Directory due to race conditions. |
-class ModelSafeWorkerInterface { |
- public: |
- virtual ~ModelSafeWorkerInterface() { } |
- // A Visitor is passed to CallDoWorkFromModelSafeThreadAndWait invocations, |
- // and it's sole purpose is to provide a way for the ModelSafeWorkerInterface |
- // implementation to actually _do_ the work required, by calling the only |
- // method on this class, DoWork(). |
- class Visitor { |
- public: |
- virtual ~Visitor() { } |
- // When on a model safe thread, this should be called to have the syncapi |
- // actually perform the work needing to be done. |
- virtual void DoWork() = 0; |
- }; |
- // Subclasses should implement to invoke DoWork on |visitor| once on a thread |
- // appropriate for data model modifications. |
- // While it doesn't hurt, the impl does not need to be re-entrant (for now). |
- // Note: |visitor| is owned by caller. |
- virtual void CallDoWorkFromModelSafeThreadAndWait(Visitor* visitor) = 0; |
-}; |
- |
-} // namespace sync_api |
- |
-#endif // CHROME_BROWSER_SYNC_ENGINE_SYNCAPI_H_ |