| Index: sync/engine/commit.h
|
| diff --git a/sync/engine/commit.h b/sync/engine/commit.h
|
| index 168d950c276a1242695cb70f476dcc0845c2672b..3ad4a2a1fe8ba0df20332d3ae88814c860ab1c3b 100644
|
| --- a/sync/engine/commit.h
|
| +++ b/sync/engine/commit.h
|
| @@ -5,33 +5,67 @@
|
| #ifndef SYNC_ENGINE_COMMIT_H_
|
| #define SYNC_ENGINE_COMMIT_H_
|
|
|
| +#include <map>
|
| +
|
| +#include "base/stl_util.h"
|
| +#include "sync/base/sync_export.h"
|
| +#include "sync/engine/sync_directory_commit_contributor.h"
|
| #include "sync/internal_api/public/base/model_type.h"
|
| +#include "sync/internal_api/public/engine/model_safe_worker.h"
|
| #include "sync/internal_api/public/util/syncer_error.h"
|
| +#include "sync/protocol/sync.pb.h"
|
| +#include "sync/util/extensions_activity.h"
|
|
|
| namespace syncer {
|
|
|
| namespace sessions {
|
| +class StatusController;
|
| class SyncSession;
|
| }
|
|
|
| +class SyncDirectoryCommitContribution;
|
| class Syncer;
|
|
|
| -// This function will commit batches of unsynced items to the server until the
|
| -// number of unsynced and ready to commit items reaches zero or an error is
|
| -// encountered. A request to exit early will be treated as an error and will
|
| -// abort any blocking operations.
|
| -//
|
| -// The Syncer parameter is provided only for access to its ExitRequested()
|
| -// method. This is technically unnecessary since an early exit request should
|
| -// be detected as we attempt to contact the sync server.
|
| +// This class wraps the actions related to building and executing a single
|
| +// commit operation.
|
| //
|
| -// The SyncSession parameter contains pointers to various bits of state,
|
| -// including the syncable::Directory that contains all sync items and the
|
| -// ServerConnectionManager used to contact the server.
|
| -SyncerError BuildAndPostCommits(
|
| - ModelTypeSet request_types,
|
| - Syncer* syncer,
|
| - sessions::SyncSession* session);
|
| +// This class' most important responsibility is to manage the ContributionsMap.
|
| +// This class serves as a container for those objects. Although it would have
|
| +// been acceptable to let this class be a dumb container object, it turns out
|
| +// that there was no other convenient place to put the Init() and
|
| +// PostAndProcessCommitResponse() functions. So they ended up here.
|
| +class SYNC_EXPORT_PRIVATE Commit {
|
| + public:
|
| + static Commit* Init(
|
| + ModelTypeSet requested_types,
|
| + size_t max_entries,
|
| + const std::string& account_name,
|
| + const std::string& cache_guid,
|
| + CommitContributorMap* contributor_map,
|
| + ExtensionsActivity* extensions_activity);
|
| +
|
| + Commit(
|
| + const std::map<ModelType, SyncDirectoryCommitContribution*>&
|
| + contributions,
|
| + const sync_pb::ClientToServerMessage& message,
|
| + ExtensionsActivity::Records extensions_activity_buffer);
|
| + ~Commit();
|
| +
|
| + SyncerError PostAndProcessResponse(
|
| + sessions::SyncSession* session,
|
| + sessions::StatusController* status,
|
| + ExtensionsActivity* extensions_activity);
|
| +
|
| + private:
|
| + typedef std::map<ModelType, SyncDirectoryCommitContribution*> ContributionMap;
|
| +
|
| + ContributionMap contributions_;
|
| + STLValueDeleter<ContributionMap> deleter_;
|
| +
|
| + sync_pb::ClientToServerMessage message_;
|
| + sync_pb::ClientToServerResponse response_;
|
| + ExtensionsActivity::Records extensions_activity_buffer_;
|
| +};
|
|
|
| } // namespace syncer
|
|
|
|
|