| OLD | NEW |
| 1 /* | 1 /* |
| 2 * This file is part of the Adblock Plus, | 2 * This file is part of the Adblock Plus, |
| 3 * Copyright (C) 2006-2012 Eyeo GmbH | 3 * Copyright (C) 2006-2012 Eyeo GmbH |
| 4 * | 4 * |
| 5 * Adblock Plus is free software: you can redistribute it and/or modify | 5 * Adblock Plus is free software: you can redistribute it and/or modify |
| 6 * it under the terms of the GNU General Public License version 3 as | 6 * it under the terms of the GNU General Public License version 3 as |
| 7 * published by the Free Software Foundation. | 7 * published by the Free Software Foundation. |
| 8 * | 8 * |
| 9 * Adblock Plus is distributed in the hope that it will be useful, | 9 * Adblock Plus is distributed in the hope that it will be useful, |
| 10 * but WITHOUT ANY WARRANTY; without even the implied warranty of | 10 * but WITHOUT ANY WARRANTY; without even the implied warranty of |
| (...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 54 * @class | 54 * @class |
| 55 */ | 55 */ |
| 56 let Synchronizer = exports.Synchronizer = | 56 let Synchronizer = exports.Synchronizer = |
| 57 { | 57 { |
| 58 /** | 58 /** |
| 59 * Called on module startup. | 59 * Called on module startup. |
| 60 */ | 60 */ |
| 61 init: function() | 61 init: function() |
| 62 { | 62 { |
| 63 TimeLine.enter("Entered Synchronizer.init()"); | 63 TimeLine.enter("Entered Synchronizer.init()"); |
| 64 | 64 |
| 65 let callback = function() | 65 let callback = function() |
| 66 { | 66 { |
| 67 timer.delay = CHECK_INTERVAL * MILLISECONDS_IN_SECOND; | 67 timer.delay = CHECK_INTERVAL * MILLISECONDS_IN_SECOND; |
| 68 checkSubscriptions(); | 68 checkSubscriptions(); |
| 69 }; | 69 }; |
| 70 | 70 |
| 71 timer = Cc["@mozilla.org/timer;1"].createInstance(Ci.nsITimer); | 71 timer = Cc["@mozilla.org/timer;1"].createInstance(Ci.nsITimer); |
| 72 timer.initWithCallback(callback, INITIAL_DELAY * MILLISECONDS_IN_SECOND, Ci.
nsITimer.TYPE_REPEATING_SLACK); | 72 timer.initWithCallback(callback, INITIAL_DELAY * MILLISECONDS_IN_SECOND, Ci.
nsITimer.TYPE_REPEATING_SLACK); |
| 73 onShutdown.add(function() | 73 onShutdown.add(function() |
| 74 { | 74 { |
| 75 timer.cancel(); | 75 timer.cancel(); |
| 76 }); | 76 }); |
| 77 | 77 |
| 78 TimeLine.leave("Synchronizer.init() done"); | 78 TimeLine.leave("Synchronizer.init() done"); |
| 79 }, | 79 }, |
| 80 | 80 |
| 81 /** | 81 /** |
| 82 * Checks whether a subscription is currently being downloaded. | 82 * Checks whether a subscription is currently being downloaded. |
| 83 * @param {String} url URL of the subscription | 83 * @param {String} url URL of the subscription |
| 84 * @return {Boolean} | 84 * @return {Boolean} |
| 85 */ | 85 */ |
| 86 isExecuting: function(url) | 86 isExecuting: function(url) |
| 87 { | 87 { |
| (...skipping 73 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 161 else | 161 else |
| 162 { | 162 { |
| 163 // Ignore modification date if we are downloading from a different locatio
n | 163 // Ignore modification date if we are downloading from a different locatio
n |
| 164 forceDownload = true; | 164 forceDownload = true; |
| 165 } | 165 } |
| 166 | 166 |
| 167 let {addonVersion} = require("info"); | 167 let {addonVersion} = require("info"); |
| 168 loadFrom = loadFrom.replace(/%VERSION%/, "ABP" + addonVersion); | 168 loadFrom = loadFrom.replace(/%VERSION%/, "ABP" + addonVersion); |
| 169 | 169 |
| 170 let request = null; | 170 let request = null; |
| 171 function errorCallback(error) | 171 let errorCallback = function(error) |
| 172 { | 172 { |
| 173 let channelStatus = -1; | 173 let channelStatus = -1; |
| 174 try | 174 try |
| 175 { | 175 { |
| 176 channelStatus = request.channel.status; | 176 channelStatus = request.channel.status; |
| 177 } catch (e) {} | 177 } catch (e) {} |
| 178 let responseStatus = ""; | 178 let responseStatus = ""; |
| 179 try | 179 try |
| 180 { | 180 { |
| 181 responseStatus = request.channel.QueryInterface(Ci.nsIHttpChannel).respo
nseStatus; | 181 responseStatus = request.channel.QueryInterface(Ci.nsIHttpChannel).respo
nseStatus; |
| 182 } catch (e) {} | 182 } catch (e) {} |
| 183 setError(subscription, error, channelStatus, responseStatus, loadFrom, isB
aseLocation, manual); | 183 setError(subscription, error, channelStatus, responseStatus, loadFrom, isB
aseLocation, manual); |
| 184 } | 184 }; |
| 185 | 185 |
| 186 try | 186 try |
| 187 { | 187 { |
| 188 request = Cc["@mozilla.org/xmlextras/xmlhttprequest;1"].createInstance(Ci.
nsIXMLHttpRequest); | 188 request = Cc["@mozilla.org/xmlextras/xmlhttprequest;1"].createInstance(Ci.
nsIXMLHttpRequest); |
| 189 request.mozBackgroundRequest = true; | 189 request.mozBackgroundRequest = true; |
| 190 request.open("GET", loadFrom); | 190 request.open("GET", loadFrom); |
| 191 } | 191 } |
| 192 catch (e) | 192 catch (e) |
| 193 { | 193 { |
| 194 errorCallback("synchronize_invalid_url"); | 194 errorCallback("synchronize_invalid_url"); |
| (...skipping 18 matching lines...) Expand all Loading... |
| 213 | 213 |
| 214 getInterface: function(iid) | 214 getInterface: function(iid) |
| 215 { | 215 { |
| 216 if (iid.equals(Ci.nsIChannelEventSink)) | 216 if (iid.equals(Ci.nsIChannelEventSink)) |
| 217 { | 217 { |
| 218 try { | 218 try { |
| 219 oldEventSink = oldNotifications.QueryInterface(iid); | 219 oldEventSink = oldNotifications.QueryInterface(iid); |
| 220 } catch(e) {} | 220 } catch(e) {} |
| 221 return this; | 221 return this; |
| 222 } | 222 } |
| 223 | 223 |
| 224 if (oldNotifications) | 224 if (oldNotifications) |
| 225 return oldNotifications.QueryInterface(iid); | 225 return oldNotifications.QueryInterface(iid); |
| 226 else | 226 else |
| 227 throw Cr.NS_ERROR_NO_INTERFACE; | 227 throw Cr.NS_ERROR_NO_INTERFACE; |
| 228 }, | 228 }, |
| 229 | 229 |
| 230 asyncOnChannelRedirect: function(oldChannel, newChannel, flags, callback
) | 230 asyncOnChannelRedirect: function(oldChannel, newChannel, flags, callback
) |
| 231 { | 231 { |
| 232 if (isBaseLocation && !hadTemporaryRedirect && oldChannel instanceof C
i.nsIHttpChannel) | 232 if (isBaseLocation && !hadTemporaryRedirect && oldChannel instanceof C
i.nsIHttpChannel) |
| 233 { | 233 { |
| (...skipping 371 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 605 newSubscription.disabled = subscription.disabled; | 605 newSubscription.disabled = subscription.disabled; |
| 606 FilterStorage.removeSubscription(subscription); | 606 FilterStorage.removeSubscription(subscription); |
| 607 FilterStorage.addSubscription(newSubscription); | 607 FilterStorage.addSubscription(newSubscription); |
| 608 Synchronizer.execute(newSubscription); | 608 Synchronizer.execute(newSubscription); |
| 609 } | 609 } |
| 610 }, false); | 610 }, false); |
| 611 request.send(null); | 611 request.send(null); |
| 612 } | 612 } |
| 613 } | 613 } |
| 614 } | 614 } |
| OLD | NEW |