111 lines
3.3 KiB
Java
111 lines
3.3 KiB
Java
package org.thoughtcrime.securesms.jobmanager;
|
|
|
|
import android.app.Application;
|
|
import android.os.PowerManager;
|
|
import androidx.annotation.NonNull;
|
|
|
|
import com.annimon.stream.Stream;
|
|
|
|
import org.session.libsignal.utilities.Log;
|
|
import org.thoughtcrime.securesms.util.WakeLockUtil;
|
|
|
|
import java.util.List;
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
class JobRunner extends Thread {
|
|
|
|
private static final String TAG = JobRunner.class.getSimpleName();
|
|
|
|
private static long WAKE_LOCK_TIMEOUT = TimeUnit.MINUTES.toMillis(10);
|
|
|
|
private final Application application;
|
|
private final int id;
|
|
private final JobController jobController;
|
|
|
|
JobRunner(@NonNull Application application, int id, @NonNull JobController jobController) {
|
|
super("JobRunner-" + id);
|
|
|
|
this.application = application;
|
|
this.id = id;
|
|
this.jobController = jobController;
|
|
}
|
|
|
|
@Override
|
|
public synchronized void run() {
|
|
while (true) {
|
|
Job job = jobController.pullNextEligibleJobForExecution();
|
|
Job.Result result = run(job);
|
|
|
|
jobController.onJobFinished(job);
|
|
|
|
switch (result) {
|
|
case SUCCESS:
|
|
jobController.onSuccess(job);
|
|
break;
|
|
case RETRY:
|
|
jobController.onRetry(job);
|
|
job.onRetry();
|
|
break;
|
|
case FAILURE:
|
|
List<Job> dependents = jobController.onFailure(job);
|
|
job.onCanceled();
|
|
Stream.of(dependents).forEach(Job::onCanceled);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
private Job.Result run(@NonNull Job job) {
|
|
Log.i(TAG, JobLogger.format(job, String.valueOf(id), "Running job."));
|
|
|
|
if (isJobExpired(job)) {
|
|
Log.w(TAG, JobLogger.format(job, String.valueOf(id), "Failing after surpassing its lifespan."));
|
|
return Job.Result.FAILURE;
|
|
}
|
|
|
|
Job.Result result = null;
|
|
PowerManager.WakeLock wakeLock = null;
|
|
|
|
try {
|
|
wakeLock = WakeLockUtil.acquire(application, PowerManager.PARTIAL_WAKE_LOCK, WAKE_LOCK_TIMEOUT, job.getId());
|
|
result = job.run();
|
|
} catch (Exception e) {
|
|
Log.w(TAG, JobLogger.format(job, String.valueOf(id), "Failing due to an unexpected exception."), e);
|
|
return Job.Result.FAILURE;
|
|
} finally {
|
|
if (wakeLock != null) {
|
|
WakeLockUtil.release(wakeLock, job.getId());
|
|
}
|
|
}
|
|
|
|
printResult(job, result);
|
|
|
|
if (result == Job.Result.RETRY && job.getRunAttempt() + 1 >= job.getParameters().getMaxAttempts() &&
|
|
job.getParameters().getMaxAttempts() != Job.Parameters.UNLIMITED)
|
|
{
|
|
Log.w(TAG, JobLogger.format(job, String.valueOf(id), "Failing after surpassing its max number of attempts."));
|
|
return Job.Result.FAILURE;
|
|
}
|
|
|
|
return result;
|
|
}
|
|
|
|
private boolean isJobExpired(@NonNull Job job) {
|
|
long expirationTime = job.getParameters().getCreateTime() + job.getParameters().getLifespan();
|
|
|
|
if (expirationTime < 0) {
|
|
expirationTime = Long.MAX_VALUE;
|
|
}
|
|
|
|
return job.getParameters().getLifespan() != Job.Parameters.IMMORTAL && expirationTime <= System.currentTimeMillis();
|
|
}
|
|
|
|
private void printResult(@NonNull Job job, @NonNull Job.Result result) {
|
|
if (result == Job.Result.FAILURE) {
|
|
Log.w(TAG, JobLogger.format(job, String.valueOf(id), "Job failed."));
|
|
} else {
|
|
Log.i(TAG, JobLogger.format(job, String.valueOf(id), "Job finished with result: " + result));
|
|
}
|
|
}
|
|
}
|