1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
|
// Copyright (c) 2010 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.
#include "chrome/browser/sync/notifier/invalidation_util.h"
#include <sstream>
namespace sync_notifier {
void RunAndDeleteClosure(invalidation::Closure* task) {
task->Run();
delete task;
}
bool RealModelTypeToObjectId(syncable::ModelType model_type,
invalidation::ObjectId* object_id) {
std::string notification_type;
if (!syncable::RealModelTypeToNotificationType(
model_type, ¬ification_type)) {
return false;
}
object_id->mutable_name()->set_string_value(notification_type);
object_id->set_source(invalidation::ObjectId::CHROME_SYNC);
return true;
}
bool ObjectIdToRealModelType(const invalidation::ObjectId& object_id,
syncable::ModelType* model_type) {
return
syncable::NotificationTypeToRealModelType(
object_id.name().string_value(), model_type);
}
std::string ObjectIdToString(
const invalidation::ObjectId& object_id) {
std::stringstream ss;
ss << "{ ";
ss << "name: " << object_id.name().string_value() << ", ";
ss << "source: " << object_id.source();
ss << " }";
return ss.str();
}
std::string StatusToString(
const invalidation::Status& status) {
std::stringstream ss;
ss << "{ ";
ss << "code: " << status.code() << ", ";
ss << "description: " << status.description();
ss << " }";
return ss.str();
}
std::string InvalidationToString(
const invalidation::Invalidation& invalidation) {
std::stringstream ss;
ss << "{ ";
ss << "object_id: " << ObjectIdToString(invalidation.object_id()) << ", ";
ss << "version: " << invalidation.version() << ", ";
ss << "components: { ";
const invalidation::ComponentStampLog& component_stamp_log =
invalidation.component_stamp_log();
for (int i = 0; i < component_stamp_log.stamp_size(); ++i) {
const invalidation::ComponentStamp& component_stamp =
component_stamp_log.stamp(i);
ss << "component: " << component_stamp.component() << ", ";
ss << "time: " << component_stamp.time() << ", ";
}
ss << " }";
ss << " }";
return ss.str();
}
std::string RegistrationUpdateToString(
const invalidation::RegistrationUpdate& update) {
std::stringstream ss;
ss << "{ ";
ss << "type: " << update.type() << ", ";
ss << "object_id: " << ObjectIdToString(update.object_id()) << ", ";
ss << "version: " << update.version() << ", ";
ss << "sequence_number: " << update.sequence_number();
ss << " }";
return ss.str();
}
std::string RegistrationUpdateResultToString(
const invalidation::RegistrationUpdateResult& update_result) {
std::stringstream ss;
ss << "{ ";
ss << "operation: "
<< RegistrationUpdateToString(update_result.operation()) << ", ";
ss << "status: " << StatusToString(update_result.status());
ss << " }";
return ss.str();
}
} // namespace sync_notifier
|
