[NOT FOR REVIEW] only for running build bots only Testing

chrome/browser/supervised_user/supervised_user_settings_service.cc

Index: chrome/browser/supervised_user/supervised_user_settings_service.cc
diff --git a/chrome/browser/supervised_user/supervised_user_settings_service.cc b/chrome/browser/supervised_user/supervised_user_settings_service.cc
index db09106b4e5df4dd6792f75746f69d280395fa07..2653af5f73100dba71f2ba963ca47a056e389b88 100644
--- a/chrome/browser/supervised_user/supervised_user_settings_service.cc
+++ b/chrome/browser/supervised_user/supervised_user_settings_service.cc
@@ -78,7 +78,7 @@ void SupervisedUserSettingsService::Init(
     // is fixed.
     CHECK(store_->IsInitializationComplete());
   } else {
-    store_->ReadPrefsAsync(NULL);
+    store_->ReadPrefsAsync(nullptr);
   }
 }
 
@@ -134,7 +134,7 @@ void SupervisedUserSettingsService::UploadItem(const std::string& key,
   DCHECK(!SettingShouldApplyToPrefs(key));
 
   std::string key_suffix = key;
-  base::DictionaryValue* dict = NULL;
+  base::DictionaryValue* dict = nullptr;
   if (sync_processor_) {
     content::RecordAction(UserMetricsAction("ManagedUsers_UploadItem_Syncing"));
     dict = GetDictionaryAndSplitKey(&key_suffix);
@@ -163,7 +163,7 @@ void SupervisedUserSettingsService::SetLocalSetting(
   if (value)
     local_settings_->SetWithoutPathExpansion(key, value.release());
   else
-    local_settings_->RemoveWithoutPathExpansion(key, NULL);
+    local_settings_->RemoveWithoutPathExpansion(key, nullptr);
 
   InformSubscribers();
 }
@@ -193,8 +193,36 @@ SyncMergeResult SupervisedUserSettingsService::MergeDataAndStartSyncing(
   sync_processor_ = std::move(sync_processor);
   error_handler_ = std::move(error_handler);
 
+  std::map<std::string, const base::Value*> seen_keys;
+  int num_before_association = GetAtomicSettings()->size();
+  for (base::DictionaryValue::Iterator it(*GetAtomicSettings()); !it.IsAtEnd();
+       it.Advance()) {
+    seen_keys[it.key()] = &it.value();
+  }
+  for (base::DictionaryValue::Iterator it(*GetSplitSettings()); !it.IsAtEnd();
+       it.Advance()) {
+    const base::DictionaryValue* dict = nullptr;
+    it.value().GetAsDictionary(&dict);
+    num_before_association += dict->size();
+    for (base::DictionaryValue::Iterator jt(*dict); !jt.IsAtEnd();
+         jt.Advance()) {
+      seen_keys[MakeSplitSettingKey(it.key(), jt.key())] = &jt.value();
+    }
+  }
+
+  LOG(ERROR) << "Deepak num_before_association:" << num_before_association;
+  for (std::map<std::string, const base::Value*>::iterator it =
+           seen_keys.begin();
+       it != seen_keys.end(); it++) {
+    LOG(ERROR) << "Deepak key:" << it->first;
+    std::string json_value;
+    base::JSONWriter::Write(*(it->second), &json_value);
+    LOG(ERROR) << "Deepak " << json_value;
+  }
   // Clear all atomic and split settings, then recreate them from Sync data.
   Clear();
+  int num_added = 0;
+  int num_modified = 0;
   for (const SyncData& sync_data : initial_sync_data) {
     DCHECK_EQ(SUPERVISED_USER_SETTINGS, sync_data.GetDataType());
     const ::sync_pb::ManagedUserSettingSpecifics& supervised_user_setting =
@@ -202,9 +230,37 @@ SyncMergeResult SupervisedUserSettingsService::MergeDataAndStartSyncing(
     scoped_ptr<base::Value> value =
         JSONReader::Read(supervised_user_setting.value());
     std::string name_suffix = supervised_user_setting.name();
+    std::string name_key = name_suffix;
+    LOG(ERROR) << "Deepak name_suffix:" << name_suffix;
     base::DictionaryValue* dict = GetDictionaryAndSplitKey(&name_suffix);
     dict->SetWithoutPathExpansion(name_suffix, value.release());
+    LOG(ERROR) << "Deepak " << supervised_user_setting.value();
+    std::map<std::string, const base::Value*>::iterator it =
+        seen_keys.find(name_key);
+    if (it == seen_keys.end()) {
+      LOG(ERROR) << "Deepak Item Added:" << name_suffix;
+      num_added++;
+    } else {
+      LOG(ERROR) << "Deepak for checking item modification";
+      if (it->second != value.get()) {
+        LOG(ERROR) << "Deepak modifying item";
+        num_modified++;
+      }
+      /*      for (DictionaryValue::Iterator jt(*dict); !jt.IsAtEnd();
+         jt.Advance()) {
+              std::string json_value;
+              base::JSONWriter::Write(jt.value(), &json_value);
+              LOG(ERROR) << "Deepak " << json_value;
+              if (seen_keys[name_key] != &jt.value()) {
+                LOG(ERROR) << "Deepak Item modified:" << name_key;
+                num_modified++;
+              }
+            }
+      */
+    }
   }
+
+  LOG(ERROR) << "Deepak added:" << num_added << "modified:" << num_modified;
   store_->ReportValueChanged(kAtomicSettings,
                              WriteablePrefStore::DEFAULT_PREF_WRITE_FLAGS);
   store_->ReportValueChanged(kSplitSettings,
@@ -218,6 +274,7 @@ SyncMergeResult SupervisedUserSettingsService::MergeDataAndStartSyncing(
   for (base::DictionaryValue::Iterator it(*queued_items); !it.IsAtEnd();
        it.Advance()) {
     std::string key_suffix = it.key();
+    std::string name_key = key_suffix;
     base::DictionaryValue* dict = GetDictionaryAndSplitKey(&key_suffix);
     SyncData data = CreateSyncDataForSetting(it.key(), it.value());
     SyncChange::SyncChangeType change_type =
@@ -225,8 +282,20 @@ SyncMergeResult SupervisedUserSettingsService::MergeDataAndStartSyncing(
                                  : SyncChange::ACTION_ADD;
     change_list.push_back(SyncChange(FROM_HERE, change_type, data));
     dict->SetWithoutPathExpansion(key_suffix, it.value().DeepCopy());
+    if (seen_keys.find(name_key) == seen_keys.end()) {
+      LOG(ERROR) << "Deepak adding";
+      num_added++;
+    } else {
+      for (DictionaryValue::Iterator jt(*dict); !jt.IsAtEnd(); jt.Advance()) {
+        if (seen_keys[name_key] != &jt.value()) {
+          LOG(ERROR) << "Deepak modifying";
+          num_modified++;
+        }
+      }
+    }
   }
   queued_items->Clear();
+  LOG(ERROR) << "Deepak added:" << num_added << "modified:" << num_modified;
 
   SyncMergeResult result(SUPERVISED_USER_SETTINGS);
   // Process all the accumulated changes from the queued items.
@@ -237,7 +306,26 @@ SyncMergeResult SupervisedUserSettingsService::MergeDataAndStartSyncing(
         sync_processor_->ProcessSyncChanges(FROM_HERE, change_list));
   }
 
-  // TODO(bauerb): Statistics?
+  // Calculating number of items after association.
+  int num_after_association = GetAtomicSettings()->size();
+  for (base::DictionaryValue::Iterator it(*GetSplitSettings()); !it.IsAtEnd();
+       it.Advance()) {
+    const base::DictionaryValue* dict = nullptr;
+    it.value().GetAsDictionary(&dict);
+    num_after_association += dict->size();
+  }
+
+  LOG(ERROR) << "Deepak added:" << num_added;
+  LOG(ERROR) << "Deepak modified:" << num_modified;
+  LOG(ERROR) << "Deepak deleted:" << num_before_association - num_modified;
+  LOG(ERROR) << "Deepak beforeAssociation:" << num_before_association;
+  LOG(ERROR) << "Deepak afterAssociation:" << num_after_association;
+
+  result.set_num_items_added(num_added);
+  result.set_num_items_modified(num_modified);
+  result.set_num_items_deleted(num_before_association - num_modified);
+  result.set_num_items_before_association(num_before_association);
+  result.set_num_items_after_association(num_after_association);
   return result;
 }
 
@@ -257,7 +345,7 @@ SyncDataList SupervisedUserSettingsService::GetAllSyncData(
   }
   for (base::DictionaryValue::Iterator it(*GetSplitSettings()); !it.IsAtEnd();
        it.Advance()) {
-    const base::DictionaryValue* dict = NULL;
+    const base::DictionaryValue* dict = nullptr;
     it.value().GetAsDictionary(&dict);
     for (base::DictionaryValue::Iterator jt(*dict);
          !jt.IsAtEnd(); jt.Advance()) {
@@ -298,7 +386,7 @@ SyncError SupervisedUserSettingsService::ProcessSyncChanges(
       case SyncChange::ACTION_DELETE: {
         DLOG_IF(WARNING, !dict->HasKey(key)) << "Trying to delete nonexistent "
                                              << "key " << key;
-        dict->RemoveWithoutPathExpansion(key, NULL);
+        dict->RemoveWithoutPathExpansion(key, nullptr);
         break;
       }
       case SyncChange::ACTION_INVALID: {
@@ -337,8 +425,8 @@ void SupervisedUserSettingsService::OnInitializationCompleted(bool success) {
 
 base::DictionaryValue* SupervisedUserSettingsService::GetOrCreateDictionary(
     const std::string& key) const {
-  base::Value* value = NULL;
-  base::DictionaryValue* dict = NULL;
+  base::Value* value = nullptr;
+  base::DictionaryValue* dict = nullptr;
   if (store_->GetMutableValue(key, &value)) {
     bool success = value->GetAsDictionary(&dict);
     DCHECK(success);
@@ -372,7 +460,7 @@ base::DictionaryValue* SupervisedUserSettingsService::GetDictionaryAndSplitKey(
 
   base::DictionaryValue* split_settings = GetSplitSettings();
   std::string prefix = key->substr(0, pos);
-  base::DictionaryValue* dict = NULL;
+  base::DictionaryValue* dict = nullptr;
   if (!split_settings->GetDictionary(prefix, &dict)) {
     dict = new base::DictionaryValue;
     DCHECK(!split_settings->HasKey(prefix));