1 // Copyright (c) 2006-2009 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "chrome/browser/sync/engine/post_commit_message_command.h"
6
7 #include <vector>
8
9 #include "chrome/browser/sync/engine/syncer_proto_util.h"
10 #include "chrome/browser/sync/engine/syncproto.h"
11 #include "chrome/browser/sync/sessions/sync_session.h"
12 #include "chrome/browser/sync/syncable/directory_manager.h"
13
14 using std::vector;
15
16 namespace browser_sync {
17
PostCommitMessageCommand()18 PostCommitMessageCommand::PostCommitMessageCommand() {}
~PostCommitMessageCommand()19 PostCommitMessageCommand::~PostCommitMessageCommand() {}
20
ExecuteImpl(sessions::SyncSession * session)21 void PostCommitMessageCommand::ExecuteImpl(sessions::SyncSession* session) {
22 if (session->status_controller()->commit_ids().empty())
23 return; // Nothing to commit.
24 ClientToServerResponse response;
25 syncable::ScopedDirLookup dir(session->context()->directory_manager(),
26 session->context()->account_name());
27 if (!dir.good())
28 return;
29 sessions::StatusController* status = session->status_controller();
30 if (!SyncerProtoUtil::PostClientToServerMessage(status->commit_message(),
31 &response, session)) {
32 // None of our changes got through. Clear the SYNCING bit which was
33 // set to true during BuildCommitCommand, and which may still be true.
34 // Not to be confused with IS_UNSYNCED, this bit is used to detect local
35 // changes to items that happen during the server Commit operation.
36 status->increment_num_consecutive_errors();
37 syncable::WriteTransaction trans(dir, syncable::SYNCER, __FILE__, __LINE__);
38 const vector<syncable::Id>& commit_ids = status->commit_ids();
39 for (size_t i = 0; i < commit_ids.size(); i++) {
40 syncable::MutableEntry entry(&trans, syncable::GET_BY_ID, commit_ids[i]);
41 entry.Put(syncable::SYNCING, false);
42 }
43 return;
44 } else {
45 status->set_items_committed();
46 }
47 status->mutable_commit_response()->CopyFrom(response);
48 }
49
50 } // namespace browser_sync
51