Skip to content
This repository has been archived by the owner on Jul 25, 2019. It is now read-only.

Commit

Permalink
fixed cancel/cancelAll
Browse files Browse the repository at this point in the history
  • Loading branch information
evant committed Nov 9, 2014
1 parent 8735e6e commit 7d70ab7
Show file tree
Hide file tree
Showing 2 changed files with 17 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -6,12 +6,15 @@
import android.os.PowerManager;
import android.support.v4.content.WakefulBroadcastReceiver;

import org.apache.http.entity.ContentProducer;

import java.util.ArrayList;
import java.util.List;

import me.tatarka.support.internal.util.ArraySet;
import me.tatarka.support.job.JobInfo;
import me.tatarka.support.server.job.controllers.BootReceiver;
import me.tatarka.support.server.job.controllers.ControllerPrefs;
import me.tatarka.support.server.job.controllers.IdleReceiver;
import me.tatarka.support.server.job.controllers.JobStatus;
import me.tatarka.support.server.job.controllers.NetworkReceiver;
Expand Down Expand Up @@ -123,6 +126,11 @@ private void scheduleJob(JobStatus job) {

private void handleCancelJob(int jobId) {
unscheduleJob(jobId);
JobStore jobStore = JobStore.initAndGet(this);
synchronized (jobStore) {
JobStatus job = jobStore.getJobByJobId(jobId);
jobStore.remove(job);
}
JobSchedulerService.stopJob(this, jobId);
}

Expand All @@ -134,6 +142,7 @@ private void handleCancelAll() {
JobStatus jobStatus = jobStatuses.valueAt(i);
unscheduleJob(jobStatus.getJobId());
}
jobStore.clear();
}
JobSchedulerService.stopAll(this);
}
Expand Down Expand Up @@ -162,6 +171,8 @@ private void handleRunJobs() {
}

private void handleBoot() {
ControllerPrefs.getInstance(this).clear();

JobStore jobStore = JobStore.initAndGet(this);
synchronized (jobStore) {
ArraySet<JobStatus> jobStatuses = jobStore.getJobs();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
/**
* Created by evantatarka on 11/8/14.
*/
class ControllerPrefs {
public class ControllerPrefs {
private static final String PREFS_NAME = "me.tatarka.support.job.controllers.PREFS";
private static final String KEY_BATTERY_LOW = "battery_low";
private static final String KEY_NEXT_JOB_EXPIRED_ELAPSED_MILLIS = "next_job_expired_elapsed_millis";
Expand All @@ -15,7 +15,7 @@ class ControllerPrefs {

private static ControllerPrefs sInstance;

static ControllerPrefs getInstance(Context context) {
public static ControllerPrefs getInstance(Context context) {
if (sInstance == null) {
sInstance = new ControllerPrefs(context);
}
Expand Down Expand Up @@ -48,6 +48,10 @@ Editor edit() {
return new Editor(prefs.edit());
}

public void clear() {
prefs.edit().clear().apply();
}

static class Editor {
SharedPreferences.Editor editor;

Expand Down

0 comments on commit 7d70ab7

Please sign in to comment.