Commit 970d492b authored by Victor Hugo Vianna Silva's avatar Victor Hugo Vianna Silva Committed by Chromium LUCI CQ

[sync] Convert PSS.{requestStart,requestStop}() into setSyncRequested()

This CL brings the java version of ProfileSyncService closer to the
native one by merging the requestStart() and requestStop() methods into
a single setSyncRequested() one. No behavior is changed.

Bug: 985290
Change-Id: I56700c65ec5ee9152eee4bc21603802fc0ef7962
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/2592806
Auto-Submit: Victor Vianna <victorvianna@google.com>
Commit-Queue: Jan Krcal <jkrcal@chromium.org>
Reviewed-by: default avatarJan Krcal <jkrcal@chromium.org>
Cr-Commit-Position: refs/heads/master@{#837961}
parent 76dae0ec
...@@ -290,14 +290,9 @@ public class ProfileSyncService { ...@@ -290,14 +290,9 @@ public class ProfileSyncService {
mNativeProfileSyncServiceAndroid, ProfileSyncService.this); mNativeProfileSyncServiceAndroid, ProfileSyncService.this);
} }
public void requestStart() { public void setSyncRequested(boolean requested) {
ProfileSyncServiceJni.get().requestStart( ProfileSyncServiceJni.get().setSyncRequested(
mNativeProfileSyncServiceAndroid, ProfileSyncService.this); mNativeProfileSyncServiceAndroid, ProfileSyncService.this, requested);
}
public void requestStop() {
ProfileSyncServiceJni.get().requestStop(
mNativeProfileSyncServiceAndroid, ProfileSyncService.this);
} }
/** /**
...@@ -653,8 +648,8 @@ public class ProfileSyncService { ...@@ -653,8 +648,8 @@ public class ProfileSyncService {
interface Natives { interface Natives {
long init(ProfileSyncService caller); long init(ProfileSyncService caller);
void requestStart(long nativeProfileSyncServiceAndroid, ProfileSyncService caller); void setSyncRequested(
void requestStop(long nativeProfileSyncServiceAndroid, ProfileSyncService caller); long nativeProfileSyncServiceAndroid, ProfileSyncService caller, boolean requested);
boolean isSyncAllowedByPlatform( boolean isSyncAllowedByPlatform(
long nativeProfileSyncServiceAndroid, ProfileSyncService caller); long nativeProfileSyncServiceAndroid, ProfileSyncService caller);
void setSyncAllowedByPlatform( void setSyncAllowedByPlatform(
......
...@@ -103,7 +103,7 @@ public class SyncController ...@@ -103,7 +103,7 @@ public class SyncController
if (isSyncEnabledInAndroidSyncSettings() == mProfileSyncService.isSyncRequested()) return; if (isSyncEnabledInAndroidSyncSettings() == mProfileSyncService.isSyncRequested()) return;
if (isSyncEnabledInAndroidSyncSettings()) { if (isSyncEnabledInAndroidSyncSettings()) {
mProfileSyncService.requestStart(); mProfileSyncService.setSyncRequested(true);
return; return;
} }
...@@ -124,7 +124,7 @@ public class SyncController ...@@ -124,7 +124,7 @@ public class SyncController
"Sync.StopSource", source, StopSource.STOP_SOURCE_LIMIT); "Sync.StopSource", source, StopSource.STOP_SOURCE_LIMIT);
} }
mProfileSyncService.requestStop(); mProfileSyncService.setSyncRequested(false);
} }
} }
......
...@@ -396,9 +396,9 @@ public class ManageSyncSettings extends PreferenceFragmentCompat ...@@ -396,9 +396,9 @@ public class ManageSyncSettings extends PreferenceFragmentCompat
boolean atLeastOneDataTypeEnabled = boolean atLeastOneDataTypeEnabled =
mSyncEverything.isChecked() || selectedModelTypes.size() > 0; mSyncEverything.isChecked() || selectedModelTypes.size() > 0;
if (mProfileSyncService.isSyncRequested() && !atLeastOneDataTypeEnabled) { if (mProfileSyncService.isSyncRequested() && !atLeastOneDataTypeEnabled) {
mProfileSyncService.requestStop(); mProfileSyncService.setSyncRequested(false);
} else if (!mProfileSyncService.isSyncRequested() && atLeastOneDataTypeEnabled) { } else if (!mProfileSyncService.isSyncRequested() && atLeastOneDataTypeEnabled) {
mProfileSyncService.requestStart(); mProfileSyncService.setSyncRequested(true);
} }
} }
...@@ -713,7 +713,7 @@ public class ManageSyncSettings extends PreferenceFragmentCompat ...@@ -713,7 +713,7 @@ public class ManageSyncSettings extends PreferenceFragmentCompat
this, primaryAccountInfo, REQUEST_CODE_TRUSTED_VAULT_KEY_RETRIEVAL); this, primaryAccountInfo, REQUEST_CODE_TRUSTED_VAULT_KEY_RETRIEVAL);
return; return;
case SyncError.SYNC_SETUP_INCOMPLETE: case SyncError.SYNC_SETUP_INCOMPLETE:
mProfileSyncService.requestStart(); mProfileSyncService.setSyncRequested(true);
mProfileSyncService.setFirstSetupComplete( mProfileSyncService.setFirstSetupComplete(
SyncFirstSetupCompleteSource.ADVANCED_FLOW_INTERRUPTED_TURN_SYNC_ON); SyncFirstSetupCompleteSource.ADVANCED_FLOW_INTERRUPTED_TURN_SYNC_ON);
return; return;
......
...@@ -324,11 +324,11 @@ public class SyncSettingsUtils { ...@@ -324,11 +324,11 @@ public class SyncSettingsUtils {
if (enable == profileSyncService.isSyncRequested()) return; if (enable == profileSyncService.isSyncRequested()) return;
if (enable) { if (enable) {
profileSyncService.requestStart(); profileSyncService.setSyncRequested(true);
} else { } else {
RecordHistogram.recordEnumeratedHistogram("Sync.StopSource", RecordHistogram.recordEnumeratedHistogram("Sync.StopSource",
StopSource.CHROME_SYNC_SETTINGS, StopSource.STOP_SOURCE_LIMIT); StopSource.CHROME_SYNC_SETTINGS, StopSource.STOP_SOURCE_LIMIT);
profileSyncService.requestStop(); profileSyncService.setSyncRequested(false);
} }
} }
......
...@@ -142,7 +142,7 @@ public class SyncTestRule extends ChromeTabbedActivityTestRule { ...@@ -142,7 +142,7 @@ public class SyncTestRule extends ChromeTabbedActivityTestRule {
private void ruleTearDown() { private void ruleTearDown() {
TestThreadUtils.runOnUiThreadBlocking(() -> { TestThreadUtils.runOnUiThreadBlocking(() -> {
mProfileSyncService.requestStop(); mProfileSyncService.setSyncRequested(false);
FakeServerHelper.deleteFakeServer(); FakeServerHelper.deleteFakeServer();
}); });
ProfileSyncService.resetForTests(); ProfileSyncService.resetForTests();
...@@ -234,7 +234,8 @@ public class SyncTestRule extends ChromeTabbedActivityTestRule { ...@@ -234,7 +234,8 @@ public class SyncTestRule extends ChromeTabbedActivityTestRule {
} }
public void startSync() { public void startSync() {
TestThreadUtils.runOnUiThreadBlocking(() -> { mProfileSyncService.requestStart(); }); TestThreadUtils.runOnUiThreadBlocking(
() -> { mProfileSyncService.setSyncRequested(true); });
} }
public void startSyncAndWait() { public void startSyncAndWait() {
...@@ -243,7 +244,8 @@ public class SyncTestRule extends ChromeTabbedActivityTestRule { ...@@ -243,7 +244,8 @@ public class SyncTestRule extends ChromeTabbedActivityTestRule {
} }
public void stopSync() { public void stopSync() {
TestThreadUtils.runOnUiThreadBlocking(() -> { mProfileSyncService.requestStop(); }); TestThreadUtils.runOnUiThreadBlocking(
() -> { mProfileSyncService.setSyncRequested(false); });
InstrumentationRegistry.getInstrumentation().waitForIdleSync(); InstrumentationRegistry.getInstrumentation().waitForIdleSync();
} }
......
...@@ -131,16 +131,11 @@ jboolean ProfileSyncServiceAndroid::CanSyncFeatureStart( ...@@ -131,16 +131,11 @@ jboolean ProfileSyncServiceAndroid::CanSyncFeatureStart(
return sync_service_->CanSyncFeatureStart(); return sync_service_->CanSyncFeatureStart();
} }
void ProfileSyncServiceAndroid::RequestStart(JNIEnv* env, void ProfileSyncServiceAndroid::SetSyncRequested(JNIEnv* env,
const JavaParamRef<jobject>&) { const JavaParamRef<jobject>&,
DCHECK_CURRENTLY_ON(BrowserThread::UI); jboolean requested) {
sync_service_->GetUserSettings()->SetSyncRequested(true);
}
void ProfileSyncServiceAndroid::RequestStop(JNIEnv* env,
const JavaParamRef<jobject>&) {
DCHECK_CURRENTLY_ON(BrowserThread::UI); DCHECK_CURRENTLY_ON(BrowserThread::UI);
sync_service_->GetUserSettings()->SetSyncRequested(false); sync_service_->GetUserSettings()->SetSyncRequested(requested);
} }
jboolean ProfileSyncServiceAndroid::IsSyncAllowedByPlatform( jboolean ProfileSyncServiceAndroid::IsSyncAllowedByPlatform(
......
...@@ -39,12 +39,11 @@ class ProfileSyncServiceAndroid : public syncer::SyncServiceObserver { ...@@ -39,12 +39,11 @@ class ProfileSyncServiceAndroid : public syncer::SyncServiceObserver {
// Pure ProfileSyncService calls. // Pure ProfileSyncService calls.
jboolean IsSyncRequested(JNIEnv* env, jboolean IsSyncRequested(JNIEnv* env,
const base::android::JavaParamRef<jobject>& obj); const base::android::JavaParamRef<jobject>& obj);
void SetSyncRequested(JNIEnv* env,
const base::android::JavaParamRef<jobject>& obj,
jboolean requested);
jboolean CanSyncFeatureStart(JNIEnv* env, jboolean CanSyncFeatureStart(JNIEnv* env,
const base::android::JavaParamRef<jobject>& obj); const base::android::JavaParamRef<jobject>& obj);
void RequestStart(JNIEnv* env,
const base::android::JavaParamRef<jobject>& obj);
void RequestStop(JNIEnv* env,
const base::android::JavaParamRef<jobject>& obj);
jboolean IsSyncAllowedByPlatform( jboolean IsSyncAllowedByPlatform(
JNIEnv* env, JNIEnv* env,
const base::android::JavaParamRef<jobject>& obj); const base::android::JavaParamRef<jobject>& obj);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment