File tree Expand file tree Collapse file tree 1 file changed +3
-6
lines changed
firebase-firestore/src/main/java/com/google/firebase/firestore/local Expand file tree Collapse file tree 1 file changed +3
-6
lines changed Original file line number Diff line number Diff line change @@ -59,7 +59,6 @@ public void setIndexManager(IndexManager indexManager) {
59
59
}
60
60
61
61
public class Scheduler implements com .google .firebase .firestore .local .Scheduler {
62
- private boolean hasRun = false ;
63
62
@ Nullable private AsyncQueue .DelayedTask backfillTask ;
64
63
private final AsyncQueue asyncQueue ;
65
64
@@ -69,7 +68,7 @@ public Scheduler(AsyncQueue asyncQueue) {
69
68
70
69
@ Override
71
70
public void start () {
72
- scheduleBackfill ();
71
+ scheduleBackfill (INITIAL_BACKFILL_DELAY_MS );
73
72
}
74
73
75
74
@ Override
@@ -79,17 +78,15 @@ public void stop() {
79
78
}
80
79
}
81
80
82
- private void scheduleBackfill () {
83
- long delay = hasRun ? REGULAR_BACKFILL_DELAY_MS : INITIAL_BACKFILL_DELAY_MS ;
81
+ private void scheduleBackfill (long delay ) {
84
82
backfillTask =
85
83
asyncQueue .enqueueAfterDelay (
86
84
AsyncQueue .TimerId .INDEX_BACKFILL ,
87
85
delay ,
88
86
() -> {
89
87
int documentsProcessed = backfill ();
90
88
Logger .debug (LOG_TAG , "Documents written: %s" , documentsProcessed );
91
- hasRun = true ;
92
- scheduleBackfill ();
89
+ scheduleBackfill (REGULAR_BACKFILL_DELAY_MS );
93
90
});
94
91
}
95
92
}
You can’t perform that action at this time.
0 commit comments