02ea99254a
We've been seeing a lot of socket timeouts on REST requests under certain conditions. The issue seems to be a problem with the OkHttp client. Through testing, I've seen that resetting the receiver and retrying again seems to resolve most issues.
71 lines
2.5 KiB
Java
71 lines
2.5 KiB
Java
package org.thoughtcrime.securesms.gcm;
|
|
|
|
import android.app.job.JobInfo;
|
|
import android.app.job.JobParameters;
|
|
import android.app.job.JobService;
|
|
import android.content.ComponentName;
|
|
import android.content.Context;
|
|
|
|
import androidx.annotation.NonNull;
|
|
import androidx.annotation.RequiresApi;
|
|
|
|
import org.thoughtcrime.securesms.ApplicationContext;
|
|
import org.thoughtcrime.securesms.dependencies.ApplicationDependencies;
|
|
import org.thoughtcrime.securesms.logging.Log;
|
|
import org.thoughtcrime.securesms.notifications.MessageNotifier;
|
|
import org.thoughtcrime.securesms.util.ServiceUtil;
|
|
import org.thoughtcrime.securesms.util.TextSecurePreferences;
|
|
import org.thoughtcrime.securesms.util.concurrent.SignalExecutors;
|
|
|
|
/**
|
|
* Pulls down messages. Used when we fail to pull down messages in {@link FcmService}.
|
|
*/
|
|
@RequiresApi(26)
|
|
public class FcmJobService extends JobService {
|
|
|
|
private static final String TAG = FcmJobService.class.getSimpleName();
|
|
|
|
private static final int ID = 1337;
|
|
|
|
@RequiresApi(26)
|
|
public static void schedule(@NonNull Context context) {
|
|
JobInfo.Builder jobInfoBuilder = new JobInfo.Builder(ID, new ComponentName(context, FcmJobService.class))
|
|
.setRequiredNetworkType(JobInfo.NETWORK_TYPE_ANY)
|
|
.setBackoffCriteria(0, JobInfo.BACKOFF_POLICY_LINEAR)
|
|
.setPersisted(true);
|
|
|
|
ServiceUtil.getJobScheduler(context).schedule(jobInfoBuilder.build());
|
|
}
|
|
|
|
@Override
|
|
public boolean onStartJob(JobParameters params) {
|
|
Log.d(TAG, "onStartJob()");
|
|
|
|
if (ApplicationContext.getInstance(getApplicationContext()).isAppVisible()) {
|
|
Log.i(TAG, "App is foregrounded. No need to run.");
|
|
return false;
|
|
}
|
|
|
|
SignalExecutors.UNBOUNDED.execute(() -> {
|
|
Context context = getApplicationContext();
|
|
MessageRetriever retriever = ApplicationDependencies.getMessageRetriever();
|
|
boolean success = retriever.retrieveMessages(context, new RestStrategy(), new RestStrategy());
|
|
|
|
if (success) {
|
|
Log.i(TAG, "Successfully retrieved messages.");
|
|
jobFinished(params, false);
|
|
} else {
|
|
Log.w(TAG, "Failed to retrieve messages. Scheduling a retry.");
|
|
jobFinished(params, true);
|
|
}
|
|
});
|
|
|
|
return true;
|
|
}
|
|
|
|
@Override
|
|
public boolean onStopJob(JobParameters params) {
|
|
Log.d(TAG, "onStopJob()");
|
|
return TextSecurePreferences.getNeedsMessagePull(getApplicationContext());
|
|
}
|
|
}
|