wine/gecko
0
0
Fork 0
mirror of https://gitlab.winehq.org/wine/wine-gecko.git synced 2024-09-13 09:24:08 -07:00
Code Issues Packages Projects Releases Wiki Activity

Update lastSync to the lastModified time from info/collections instead of updating times on each record. This is to prepare for fetching a list of GUIDs and processing a list of GUIDs.

Browse Source
This commit is contained in:
Edward Lee 2009-09-10 12:41:38 -07:00
parent 0dc7cf0d81
commit 8f5372e6b1
1 changed files with 8 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
services/sync/modules/engines.js
View File

@ -391,24 +391,23 @@ SyncEngine.prototype = {
newitems.sort = "index";
let count = {applied: 0, reconciled: 0};
this._lastSyncTmp = 0;
newitems.recordHandler = Utils.bind2(this, function(item) {
try {
item.decrypt(ID.get("WeaveCryptoID"));
if (this._reconcile(item)) {
count.applied++;
this._applyIncoming(item);
this._tracker.ignoreAll = true;
this._store.applyIncoming(item);
} else {
count.reconciled++;
this._log.trace("Skipping reconciled incoming item " + item.id);
if (this._lastSyncTmp < item.modified)
this._lastSyncTmp = item.modified;
}
} catch (e) {
this._log.error("Could not process incoming record: " +
Utils.exceptionStr(e));
}
catch(ex) {
this._log.warn("Error processing record: " + Utils.exceptionStr(e));
}
this._tracker.ignoreAll = false;
Sync.sleep(0);
});
@ -416,8 +415,8 @@ SyncEngine.prototype = {
if (!resp.success)
throw resp;
if (this.lastSync < this._lastSyncTmp)
this.lastSync = this._lastSyncTmp;
if (this.lastSync < this.lastModified)
this.lastSync = this.lastModified;
this._log.info("Applied " + count.applied + " records, reconciled " +
count.reconciled + " records");
@ -525,20 +524,6 @@ SyncEngine.prototype = {
return true;
},
// Apply incoming records
_applyIncoming: function SyncEngine__applyIncoming(item) {
try {
this._tracker.ignoreAll = true;
this._store.applyIncoming(item);
if (this._lastSyncTmp < item.modified)
this._lastSyncTmp = item.modified;
} catch (e) {
this._log.warn("Error while applying record: " + Utils.stackTrace(e));
} finally {
this._tracker.ignoreAll = false;
}
},
// Upload outgoing records
_uploadOutgoing: function SyncEngine__uploadOutgoing() {
let outnum = [i for (i in this._tracker.changedIDs)].length;