ClosedPublic

Revision Contents

Diff 436470

Show All 29 Linesworker.postMessage = function(message, ...transfers) { worker.postMessage = function(message, ...transfers) { self.postMessage(message, ...transfers); self.postMessage(message, ...transfers); }; }; worker.close = function() { worker.close = function() { self.close(); self.close(); }; };

self.addEventListener("message", msg => worker.handleMessage(msg)); self.addEventListener("message", msg => worker.handleMessage(msg)); self.addEventListener("unhandledrejection", function(error) { throw error.reason; });

Show First 20 Lines • Show All 185 Lines • ▼ Show 20 Linesworker.postMessage = function(result, ...transfers) { worker.postMessage = function(result, ...transfers) { self.postMessage(result, ...transfers); self.postMessage(result, ...transfers); }; }; worker.close = function() { worker.close = function() { self.close(); self.close(); }; };

self.addEventListener("message", msg => worker.handleMessage(msg)); self.addEventListener("message", msg => worker.handleMessage(msg)); self.addEventListener("unhandledrejection", function(error) { throw error.reason; });

Show All 24 Linesworker.postMessage = function(result, ...transfers) { worker.postMessage = function(result, ...transfers) { self.postMessage(result, ...transfers); self.postMessage(result, ...transfers); }; }; worker.close = function() { worker.close = function() { self.close(); self.close(); }; };

self.addEventListener("message", msg => worker.handleMessage(msg)); self.addEventListener("message", msg => worker.handleMessage(msg)); self.addEventListener("unhandledrejection", function(error) { throw error.reason; });

// The various possible states // The various possible states

/** /** * We just started (we haven't written anything to disk yet) from * We just started (we haven't written anything to disk yet) from * `Paths.clean`. The backup directory may not exist. * `Paths.clean`. The backup directory may not exist. */ */ const STATE_CLEAN = "clean"; const STATE_CLEAN = "clean"; ▲ Show 20 Lines • Show All 374 Lines • Show Last 20 Lines

Show First 20 Lines • Show All 54 Lines • ▼ Show 20 Lines worker.postMessage = function(message, ...transfers) { self.postMessage(message, ...transfers); self.postMessage(message, ...transfers); }; }; worker.close = function() { worker.close = function() { self.close(); self.close(); }; }; let Meta = PromiseWorker.Meta; let Meta = PromiseWorker.Meta;

self.addEventListener("message", msg => worker.handleMessage(msg)); self.addEventListener("message", msg => worker.handleMessage(msg)); self.addEventListener("unhandledrejection", function(error) { throw error.reason; });

/** /** * A data structure used to track opened resources * A data structure used to track opened resources */ */ let ResourceTracker = function ResourceTracker() { let ResourceTracker = function ResourceTracker() { // A number used to generate ids // A number used to generate ids this._idgen = 0; this._idgen = 0; // A map from id to resource // A map from id to resource ▲ Show 20 Lines • Show All 405 Lines • Show Last 20 Lines

Show All 18 Lines}; }; worker.close = function() { worker.close = function() { self.close(); self.close(); }; }; worker.log = function(...args) { worker.log = function(...args) { dump("Worker: " + args.join(" ") + "\n"); dump("Worker: " + args.join(" ") + "\n"); }; }; self.addEventListener("message", msg => worker.handleMessage(msg)); self.addEventListener("message", msg => worker.handleMessage(msg)); self.addEventListener("unhandledrejection", function(error) { throw error.reason; });

var Agent = { var Agent = { bounce(...args) { bounce(...args) { return args; return args; }, },

throwError(msg, ...args) { throwError(msg, ...args) { throw new Error(msg); throw new Error(msg); }, }, }; };

Show All 36 Linesconst EXCEPTION_NAMES = { const EXCEPTION_NAMES = { EvalError: "EvalError", EvalError: "EvalError", InternalError: "InternalError", InternalError: "InternalError", RangeError: "RangeError", RangeError: "RangeError", ReferenceError: "ReferenceError", ReferenceError: "ReferenceError", SyntaxError: "SyntaxError", SyntaxError: "SyntaxError", TypeError: "TypeError", TypeError: "TypeError", URIError: "URIError", URIError: "URIError", }; };

/** /** * A constructor used to return data to the caller thread while * A constructor used to return data to the caller thread while * also executing some specific treatment (e.g. shutting down * also executing some specific treatment (e.g. shutting down * the current thread, transmitting data instead of copying it). * the current thread, transmitting data instead of copying it). * * * @param {object=} data The data to return to the caller thread. * @param {object=} data The data to return to the caller thread. * @param {object=} meta Additional instructions, as an object * @param {object=} meta Additional instructions, as an object Show All 30 Lines * } * } * } * } * * * By default, the AbstractWorker is not connected to a message port, * By default, the AbstractWorker is not connected to a message port, * hence will not receive anything. * hence will not receive anything. * * * To connect it, use `onmessage`, as follows: * To connect it, use `onmessage`, as follows: * self.addEventListener("message", msg => myWorkerInstance.handleMessage(msg)); * self.addEventListener("message", msg => myWorkerInstance.handleMessage(msg)); * To handle rejected promises we receive from handleMessage, we must connect it to * the onError handler as follows: * self.addEventListener("unhandledrejection", function(error) { * throw error.reason; * }); */ */ function AbstractWorker(agent) { function AbstractWorker(agent) { this._agent = agent; this._agent = agent; } } AbstractWorker.prototype = { AbstractWorker.prototype = { // Default logger: discard all messages // Default logger: discard all messages log() {}, log() {},

/** /** * Handle a message. * Handle a message. */ */ handleMessage(msg) { async handleMessage(msg) { let data = msg.data; let data = msg.data; this.log("Received message", data); this.log("Received message", data); let id = data.id; let id = data.id;

let start; let start; let options; let options; if (data.args) { if (data.args) { options = data.args[data.args.length - 1]; options = data.args[data.args.length - 1]; Show All 9 Lines async handleMessage(msg) { } }

let result; let result; let exn; let exn; let durationMs; let durationMs; let method = data.fun; let method = data.fun; try { try { this.log("Calling method", method); this.log("Calling method", method); result = this.dispatch(method, data.args); result = await this.dispatch(method, data.args); this.log("Method", method, "succeeded"); this.log("Method", method, "succeeded"); } catch (ex) { } catch (ex) { exn = ex; exn = ex; this.log( this.log( "Error while calling agent method", "Error while calling agent method", method, method, exn, exn, exn.moduleStack || exn.stack || "" exn.moduleStack || exn.stack || "" Show All 24 Lines if (!exn) { } } if (result.meta.shutdown || false) { if (result.meta.shutdown || false) { // Time to close the worker // Time to close the worker this.close(); this.close(); } } } else { } else { this.postMessage({ ok: result, id, durationMs }); this.postMessage({ ok: result, id, durationMs }); } } } else if (exn.constructor.name in EXCEPTION_NAMES) { } else if (exn.constructor.name in EXCEPTION_NAMES) { // Rather than letting the DOM mechanism [de]serialize built-in // Rather than letting the DOM mechanism [de]serialize built-in // JS errors, which loses lots of information (in particular, // JS errors, which loses lots of information (in particular, // the constructor name, the moduleName and the moduleStack), // the constructor name, the moduleName and the moduleStack),

// we [de]serialize them manually with a little more care. // we [de]serialize them manually with a little more care. this.log("Sending back exception", exn.constructor.name, "id is", id); this.log("Sending back exception", exn.constructor.name, "id is", id); let error = { let error = { exn: exn.constructor.name, exn: exn.constructor.name, message: exn.message, message: exn.message, fileName: exn.moduleName || exn.fileName, fileName: exn.moduleName || exn.fileName, lineNumber: exn.lineNumber, lineNumber: exn.lineNumber, stack: exn.moduleStack, stack: exn.moduleStack, ▲ Show 20 Lines • Show All 42 Lines • Show Last 20 Lines

Show All 31 Lines}; }; worker.log = function(...args) { worker.log = function(...args) { if (DEBUG) { if (DEBUG) { dump("ReaderWorker: " + args.join(" ") + "\n"); dump("ReaderWorker: " + args.join(" ") + "\n"); } } }; };

self.addEventListener("message", msg => worker.handleMessage(msg)); self.addEventListener("message", msg => worker.handleMessage(msg)); self.addEventListener("unhandledrejection", function(error) { throw error.reason; });

var Agent = { var Agent = { /** /** * Parses structured article data from a document. * Parses structured article data from a document. * * * @param {object} uri URI data for the document. * @param {object} uri URI data for the document. * @param {string} serializedDoc The serialized document. * @param {string} serializedDoc The serialized document. * @param {object} options Options object to pass to Readability. * @param {object} options Options object to pass to Readability. * * * @return {object} Article object returned from Readability. * @return {object} Article object returned from Readability. */ */ parseDocument(uri, serializedDoc, options) { parseDocument(uri, serializedDoc, options) { let doc = new JSDOMParser().parse(serializedDoc, uri.spec); let doc = new JSDOMParser().parse(serializedDoc, uri.spec); return new Readability(doc, options).parse(); return new Readability(doc, options).parse(); }, }, }; };

Show All 26 Linesworker.postMessage = function(message, ...transfers) { worker.postMessage = function(message, ...transfers) { self.postMessage(message, ...transfers); self.postMessage(message, ...transfers); }; }; worker.close = function() { worker.close = function() { self.close(); self.close(); }; };

self.addEventListener("message", msg => worker.handleMessage(msg)); self.addEventListener("message", msg => worker.handleMessage(msg)); self.addEventListener("unhandledrejection", function(error) { throw error.reason; });

var Agent = { var Agent = { // Checks if the specified file exists and has an age less than as // Checks if the specified file exists and has an age less than as // specifed (in seconds). // specifed (in seconds). isFileRecent: function Agent_isFileRecent(path, maxAge) { isFileRecent: function Agent_isFileRecent(path, maxAge) { try { try { let stat = OS.File.stat(path); let stat = OS.File.stat(path); let maxDate = new Date(); let maxDate = new Date(); ▲ Show 20 Lines • Show All 138 Lines • Show Last 20 Lines