Prevent push/pull race conditions

This commit is contained in:
Gregory Schier committed 2017-01-11 16:12:03 -08:00
1 parent 805f2c6a7f
commit 0ff8f977fa
2 files changed
+7 -6

No files matched your search

+1 -1
View File
@@ -1,7 +1,7 @@
{
"private": true,
"name": "insomnia",
"version": "4.1.0",
"version": "4.1.1",
"productName": "Insomnia",
"longName": "Insomnia REST Client",
"description": "A simple and beautiful REST API client",
+6 -5
View File
@@ -9,7 +9,6 @@ import {trackEvent} from '../analytics/index';
export const START_DELAY = 1E3;
export const PULL_PERIOD = 15E3;
export const PUSH_PERIOD = 15E3;
export const WRITE_PERIOD = 1E3;
const WHITE_LIST = {
@@ -26,7 +25,6 @@ export const logger = new Logger();
const NO_VERSION = '__NO_VERSION__';
const resourceGroupSymmetricKeysCache = {};
let _pullChangesInterval = null;
let _pushChangesInterval = null;
let _writeChangesInterval = null;
let _pendingDBChanges = {};
let _isInitialized = false;
@@ -59,11 +57,15 @@ export async function init () {
});
await misc.delay(START_DELAY);
await push();
await pull();
_pullChangesInterval = setInterval(pull, PULL_PERIOD);
_pushChangesInterval = setInterval(push, PUSH_PERIOD);
_pullChangesInterval = setInterval(async () => {
await push();
await pull();
}, PULL_PERIOD);
_writeChangesInterval = setInterval(writePendingChanges, WRITE_PERIOD);
logger.debug('Initialized');
@@ -73,7 +75,6 @@ export async function init () {
export function _testReset () {
_isInitialized = false;
clearInterval(_pullChangesInterval);
clearInterval(_pushChangesInterval);
clearInterval(_writeChangesInterval);
}