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

Bug 514323 - Use info/collections to check if there's new data. r=thunder

Browse Source 
Fetch info/collections before syncing engines and set the lastModified property on the engine so that they can check if they need to process incoming.
This commit is contained in:
Edward Lee 2009-09-03 21:30:40 -07:00
parent ec0c49c88c
commit 19443b737b
2 changed files with 20 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -380,6 +380,12 @@ SyncEngine.prototype = {
// Generate outgoing records
_processIncoming: function SyncEngine__processIncoming() {
// Only bother getting data from the server if there's new things
if (this.lastModified <= this.lastSync) {
this._log.debug("Nothing new from the server to process");
return;
}
this._log.debug("Downloading & applying server changes");
// enable cache, and keep only the first few items. Otherwise (when

19
services/sync/modules/service.js
View File

@ -215,9 +215,8 @@ WeaveSvc.prototype = {
this._genKeyURLs();
},
get userURL() {
return this.clusterURL + this.username;
},
get userURL() this.clusterURL + this.username,
get infoURL() this.userURL + "/info/collections",
get userPath() { return ID.get('WeaveID').username; },
@ -501,7 +500,7 @@ WeaveSvc.prototype = {
this._log.debug("Verifying login for user " + this.username);
this._setCluster();
let res = new Resource(this.userURL + "/info/collections");
let res = new Resource(this.infoURL);
try {
let test = res.get();
switch (test.status) {
@ -1080,6 +1079,16 @@ WeaveSvc.prototype = {
if (!(this._remoteSetup()))
throw "aborting sync, remote setup failed";
// Figure out what the last modified time is for each collection
let info = new Resource(this.infoURL).get();
if (!info.success)
throw "aborting sync, failed to get collections";
// Convert the response to an object and read out the modified times
info = JSON.parse(info);
for each (let engine in [Clients].concat(Engines.getEnabled()))
engine.lastModified = info[engine.name] || 0;
this._log.debug("Refreshing client list");
Clients.sync();
@ -1215,7 +1224,7 @@ WeaveSvc.prototype = {
wipeServer: function WeaveSvc_wipeServer(engines)
this._catch(this._notify("wipe-server", "", function() {
// Grab all the collections for the user
let res = new Resource(this.userURL + "/info/collections");
let res = new Resource(this.infoURL);
res.get();
// Get the array of collections and delete each one