Foundry376/Mailspring
1
1
Fork 0
mirror of https://github.com/Foundry376/Mailspring.git synced 2025-09-11 15:14:31 +08:00
Code Issues Projects Releases Packages Wiki Activity

[local-sync] Fix sync worker - Restore fns removed by mistake

Browse source
This commit is contained in:
Juan Tejada 2016-12-15 20:43:52 -08:00
parent 2c6be51970
commit b17be6b873
1 changed files with 22 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
packages/local-sync/src/local-sync-worker/sync-worker.js
View file

@ -190,6 +190,19 @@ class SyncWorker {
return await this._conn.connect();
}
cleanup() {
clearTimeout(this._syncTimer);
this._syncTimer = null;
this._destroyed = true;
this.closeConnection()
}
closeConnection() {
if (this._conn) {
this._conn.end();
}
}
async runNewSyncbackTasks() {
const tasks = await this._getNewSyncbackTasks()
if (tasks.length === 0) { return Promise.resolve() }
@ -335,12 +348,19 @@ class SyncWorker {
const reason = this._interrupted ? 'Sync interrupted for restart' : 'Scheduled'
const interval = shouldSyncImmediately ? 1 : intervals.active;
const nextSyncTime = this._lastSyncTime + interval
const nextSyncStart = Math.max(1, nextSyncTime - Date.now())
this._logger.info(`SyncWorker: Scheduling next sync iteration for ${nextSyncTime - Date.now()}ms`)
this._logger.info({
moreToSync,
shouldSyncImmediately,
interrupted: this._interrupted,
nextSyncStartingIn: `${nextSyncStart}ms`,
syncAttemptsWhileInProgress: this._syncAttemptsWhileInProgress,
}, `SyncWorker: Scheduling next sync iteration`)
this._syncTimer = setTimeout(() => {
this.syncNow({reason});
}, nextSyncTime - Date.now());
}, nextSyncStart);
}
}