Spaces:
Running
Running
| var cache; | |
| try { | |
| cache = typeof caches !== 'undefined' ? caches.open('llama-cache') : null; | |
| } catch (_) {} | |
| // The Module object: Our interface to the outside world. We import | |
| // and export values on it. There are various ways Module can be used: | |
| // 1. Not defined. We create it here | |
| // 2. A function parameter, function(Module) { ..generated code.. } | |
| // 3. pre-run appended it, var Module = {}; ..generated code.. | |
| // 4. External script tag defines var Module. | |
| // We need to check if Module already exists (e.g. case 3 above). | |
| // Substitution will be replaced with actual code on later stage of the build, | |
| // this way Closure Compiler will not mangle it (e.g. case 4. above). | |
| // Note that if you want to run closure, and also to use Module | |
| // after the generated code, you will need to define var Module = {}; | |
| // before the code. Then that object will be used in the code, and you | |
| // can continue to use Module afterwards as well. | |
| var Module = typeof Module != 'undefined' ? Module : {}; | |
| // See https://caniuse.com/mdn-javascript_builtins_object_assign | |
| // See https://caniuse.com/mdn-javascript_builtins_bigint64array | |
| // --pre-jses are emitted after the Module integration code, so that they can | |
| // refer to Module (if they choose; they can also define Module) | |
| if (!Module.expectedDataFileDownloads) { | |
| Module.expectedDataFileDownloads = 0; | |
| } | |
| Module.expectedDataFileDownloads++; | |
| (function() { | |
| // When running as a pthread, FS operations are proxied to the main thread, so we don't need to | |
| // fetch the .data bundle on the worker | |
| if (Module['ENVIRONMENT_IS_PTHREAD']) return; | |
| var loadPackage = function(metadata) { | |
| var PACKAGE_PATH = ''; | |
| if (typeof window === 'object') { | |
| PACKAGE_PATH = window['encodeURIComponent'](window.location.pathname.toString().substring(0, window.location.pathname.toString().lastIndexOf('/')) + '/'); | |
| } else if (typeof process === 'undefined' && typeof location !== 'undefined') { | |
| // web worker | |
| PACKAGE_PATH = encodeURIComponent(location.pathname.toString().substring(0, location.pathname.toString().lastIndexOf('/')) + '/'); | |
| } | |
| var PACKAGE_NAME = 'web/llama2.data'; | |
| var REMOTE_PACKAGE_BASE = 'llama2.data'; | |
| if (typeof Module['locateFilePackage'] === 'function' && !Module['locateFile']) { | |
| Module['locateFile'] = Module['locateFilePackage']; | |
| err('warning: you defined Module.locateFilePackage, that has been renamed to Module.locateFile (using your locateFilePackage for now)'); | |
| } | |
| var REMOTE_PACKAGE_NAME = Module['locateFile'] ? Module['locateFile'](REMOTE_PACKAGE_BASE, '') : REMOTE_PACKAGE_BASE; | |
| var REMOTE_PACKAGE_SIZE = metadata['remote_package_size']; | |
| function fetchRemotePackage(packageName, packageSize, callback, errback) { | |
| if (typeof process === 'object' && typeof process.versions === 'object' && typeof process.versions.node === 'string') { | |
| require('fs').readFile(packageName, function(err, contents) { | |
| if (err) { | |
| errback(err); | |
| } else { | |
| callback(contents.buffer); | |
| } | |
| }); | |
| return; | |
| } | |
| var xhr = new XMLHttpRequest(); | |
| xhr.open('GET', packageName, true); | |
| xhr.responseType = 'arraybuffer'; | |
| xhr.onprogress = function(event) { | |
| var url = packageName; | |
| var size = packageSize; | |
| if (event.total) size = event.total; | |
| if (event.loaded) { | |
| if (!xhr.addedTotal) { | |
| xhr.addedTotal = true; | |
| if (!Module.dataFileDownloads) Module.dataFileDownloads = {}; | |
| Module.dataFileDownloads[url] = { | |
| loaded: event.loaded, | |
| total: size | |
| }; | |
| } else { | |
| Module.dataFileDownloads[url].loaded = event.loaded; | |
| } | |
| var total = 0; | |
| var loaded = 0; | |
| var num = 0; | |
| for (var download in Module.dataFileDownloads) { | |
| var data = Module.dataFileDownloads[download]; | |
| total += data.total; | |
| loaded += data.loaded; | |
| num++; | |
| } | |
| total = Math.ceil(total * Module.expectedDataFileDownloads/num); | |
| if (Module['setStatus']) Module['setStatus']('Downloading data... (' + loaded + '/' + total + ')'); | |
| } else if (!Module.dataFileDownloads) { | |
| if (Module['setStatus']) Module['setStatus']('Downloading data...'); | |
| } | |
| }; | |
| xhr.onerror = function(event) { | |
| throw new Error("NetworkError for: " + packageName); | |
| } | |
| xhr.onload = function(event) { | |
| if(xhr.status == 200) { | |
| if (cache) { | |
| cache.then(async c => { | |
| try { | |
| await c.put(packageName, new Response(xhr.response)); | |
| } catch(_) {} | |
| callback(xhr.response); | |
| }); | |
| } else { | |
| callback(xhr.response); | |
| } | |
| } else if (xhr.status == 304 || xhr.status == 206 || (xhr.status == 0 && xhr.response)) { // file URLs can return 0 | |
| var packageData = xhr.response; | |
| callback(packageData); | |
| } else { | |
| throw new Error(xhr.statusText + " : " + xhr.responseURL); | |
| } | |
| }; | |
| if (cache) { | |
| cache.then(async c => { | |
| try { | |
| let response = await c.match(packageName); | |
| if (response){ | |
| callback(await response.arrayBuffer()); | |
| } else { | |
| xhr.send(null); | |
| } | |
| } catch (_) { | |
| xhr.send(null); | |
| } | |
| }) | |
| }else{ | |
| xhr.send(null); | |
| } | |
| }; | |
| function handleError(error) { | |
| console.error('package error:', error); | |
| }; | |
| var fetchedCallback = null; | |
| var fetched = Module['getPreloadedPackage'] ? Module['getPreloadedPackage'](REMOTE_PACKAGE_NAME, REMOTE_PACKAGE_SIZE) : null; | |
| if (!fetched) fetchRemotePackage(REMOTE_PACKAGE_NAME, REMOTE_PACKAGE_SIZE, function(data) { | |
| if (fetchedCallback) { | |
| fetchedCallback(data); | |
| fetchedCallback = null; | |
| } else { | |
| fetched = data; | |
| } | |
| }, handleError); | |
| function runWithFS() { | |
| function assert(check, msg) { | |
| if (!check) throw msg + new Error().stack; | |
| } | |
| /** @constructor */ | |
| function DataRequest(start, end, audio) { | |
| this.start = start; | |
| this.end = end; | |
| this.audio = audio; | |
| } | |
| DataRequest.prototype = { | |
| requests: {}, | |
| open: function(mode, name) { | |
| this.name = name; | |
| this.requests[name] = this; | |
| Module['addRunDependency']('fp ' + this.name); | |
| }, | |
| send: function() {}, | |
| onload: function() { | |
| var byteArray = this.byteArray.subarray(this.start, this.end); | |
| this.finish(byteArray); | |
| }, | |
| finish: function(byteArray) { | |
| var that = this; | |
| // canOwn this data in the filesystem, it is a slide into the heap that will never change | |
| Module['FS_createDataFile'](this.name, null, byteArray, true, true, true); | |
| Module['removeRunDependency']('fp ' + that.name); | |
| this.requests[this.name] = null; | |
| } | |
| }; | |
| var files = metadata['files']; | |
| for (var i = 0; i < files.length; ++i) { | |
| new DataRequest(files[i]['start'], files[i]['end'], files[i]['audio'] || 0).open('GET', files[i]['filename']); | |
| } | |
| function processPackageData(arrayBuffer) { | |
| assert(arrayBuffer, 'Loading data file failed.'); | |
| assert(arrayBuffer.constructor.name === ArrayBuffer.name, 'bad input to processPackageData'); | |
| var byteArray = new Uint8Array(arrayBuffer); | |
| var curr; | |
| // Reuse the bytearray from the XHR as the source for file reads. | |
| DataRequest.prototype.byteArray = byteArray; | |
| var files = metadata['files']; | |
| for (var i = 0; i < files.length; ++i) { | |
| DataRequest.prototype.requests[files[i].filename].onload(); | |
| } Module['removeRunDependency']('datafile_web/llama2.data'); | |
| }; | |
| Module['addRunDependency']('datafile_web/llama2.data'); | |
| if (!Module.preloadResults) Module.preloadResults = {}; | |
| Module.preloadResults[PACKAGE_NAME] = {fromCache: false}; | |
| if (fetched) { | |
| processPackageData(fetched); | |
| fetched = null; | |
| } else { | |
| fetchedCallback = processPackageData; | |
| } | |
| } | |
| if (Module['calledRun']) { | |
| runWithFS(); | |
| } else { | |
| if (!Module['preRun']) Module['preRun'] = []; | |
| Module["preRun"].push(runWithFS); // FS is not initialized yet, wait for it | |
| } | |
| } | |
| loadPackage({"files": [{"filename": "/model.bin", "start": 0, "end": 60816028}, {"filename": "/vocab.bin", "start": 60816028, "end": 61119133}], "remote_package_size": 61119133}); | |
| })(); | |
| // All the pre-js content up to here must remain later on, we need to run | |
| // it. | |
| if (Module['ENVIRONMENT_IS_PTHREAD']) Module['preRun'] = []; | |
| var necessaryPreJSTasks = Module['preRun'].slice(); | |
| if (!Module['preRun']) throw 'Module.preRun should exist because file support used it; did a pre-js delete it?'; | |
| necessaryPreJSTasks.forEach(function(task) { | |
| if (Module['preRun'].indexOf(task) < 0) throw 'All preRun tasks that exist before user pre-js code should remain after; did you replace Module or modify Module.preRun?'; | |
| }); | |
| // Sometimes an existing Module object exists with properties | |
| // meant to overwrite the default module functionality. Here | |
| // we collect those properties and reapply _after_ we configure | |
| // the current environment's defaults to avoid having to be so | |
| // defensive during initialization. | |
| var moduleOverrides = Object.assign({}, Module); | |
| var arguments_ = []; | |
| var thisProgram = './this.program'; | |
| var quit_ = (status, toThrow) => { | |
| throw toThrow; | |
| }; | |
| // Determine the runtime environment we are in. You can customize this by | |
| // setting the ENVIRONMENT setting at compile time (see settings.js). | |
| // Attempt to auto-detect the environment | |
| var ENVIRONMENT_IS_WEB = typeof window == 'object'; | |
| var ENVIRONMENT_IS_WORKER = typeof importScripts == 'function'; | |
| // N.b. Electron.js environment is simultaneously a NODE-environment, but | |
| // also a web environment. | |
| var ENVIRONMENT_IS_NODE = typeof process == 'object' && typeof process.versions == 'object' && typeof process.versions.node == 'string'; | |
| var ENVIRONMENT_IS_SHELL = !ENVIRONMENT_IS_WEB && !ENVIRONMENT_IS_NODE && !ENVIRONMENT_IS_WORKER; | |
| if (Module['ENVIRONMENT']) { | |
| throw new Error('Module.ENVIRONMENT has been deprecated. To force the environment, use the ENVIRONMENT compile-time option (for example, -sENVIRONMENT=web or -sENVIRONMENT=node)'); | |
| } | |
| // `/` should be present at the end if `scriptDirectory` is not empty | |
| var scriptDirectory = ''; | |
| function locateFile(path) { | |
| if (Module['locateFile']) { | |
| return Module['locateFile'](path, scriptDirectory); | |
| } | |
| return scriptDirectory + path; | |
| } | |
| // Hooks that are implemented differently in different runtime environments. | |
| var read_, | |
| readAsync, | |
| readBinary, | |
| setWindowTitle; | |
| // Normally we don't log exceptions but instead let them bubble out the top | |
| // level where the embedding environment (e.g. the browser) can handle | |
| // them. | |
| // However under v8 and node we sometimes exit the process direcly in which case | |
| // its up to use us to log the exception before exiting. | |
| // If we fix https://github.com/emscripten-core/emscripten/issues/15080 | |
| // this may no longer be needed under node. | |
| function logExceptionOnExit(e) { | |
| if (e instanceof ExitStatus) return; | |
| let toLog = e; | |
| if (e && typeof e == 'object' && e.stack) { | |
| toLog = [e, e.stack]; | |
| } | |
| err('exiting due to exception: ' + toLog); | |
| } | |
| if (ENVIRONMENT_IS_NODE) { | |
| if (typeof process == 'undefined' || !process.release || process.release.name !== 'node') throw new Error('not compiled for this environment (did you build to HTML and try to run it not on the web, or set ENVIRONMENT to something - like node - and run it someplace else - like on the web?)'); | |
| // `require()` is no-op in an ESM module, use `createRequire()` to construct | |
| // the require()` function. This is only necessary for multi-environment | |
| // builds, `-sENVIRONMENT=node` emits a static import declaration instead. | |
| // TODO: Swap all `require()`'s with `import()`'s? | |
| // These modules will usually be used on Node.js. Load them eagerly to avoid | |
| // the complexity of lazy-loading. | |
| var fs = require('fs'); | |
| var nodePath = require('path'); | |
| if (ENVIRONMENT_IS_WORKER) { | |
| scriptDirectory = nodePath.dirname(scriptDirectory) + '/'; | |
| } else { | |
| scriptDirectory = __dirname + '/'; | |
| } | |
| // include: node_shell_read.js | |
| read_ = (filename, binary) => { | |
| // We need to re-wrap `file://` strings to URLs. Normalizing isn't | |
| // necessary in that case, the path should already be absolute. | |
| filename = isFileURI(filename) ? new URL(filename) : nodePath.normalize(filename); | |
| return fs.readFileSync(filename, binary ? undefined : 'utf8'); | |
| }; | |
| readBinary = (filename) => { | |
| var ret = read_(filename, true); | |
| if (!ret.buffer) { | |
| ret = new Uint8Array(ret); | |
| } | |
| assert(ret.buffer); | |
| return ret; | |
| }; | |
| readAsync = (filename, onload, onerror) => { | |
| // See the comment in the `read_` function. | |
| filename = isFileURI(filename) ? new URL(filename) : nodePath.normalize(filename); | |
| fs.readFile(filename, function(err, data) { | |
| if (err) onerror(err); | |
| else onload(data.buffer); | |
| }); | |
| }; | |
| // end include: node_shell_read.js | |
| if (process['argv'].length > 1) { | |
| thisProgram = process['argv'][1].replace(/\\/g, '/'); | |
| } | |
| arguments_ = process['argv'].slice(2); | |
| if (typeof module != 'undefined') { | |
| module['exports'] = Module; | |
| } | |
| process['on']('uncaughtException', function(ex) { | |
| // suppress ExitStatus exceptions from showing an error | |
| if (!(ex instanceof ExitStatus)) { | |
| throw ex; | |
| } | |
| }); | |
| // Without this older versions of node (< v15) will log unhandled rejections | |
| // but return 0, which is not normally the desired behaviour. This is | |
| // not be needed with node v15 and about because it is now the default | |
| // behaviour: | |
| // See https://nodejs.org/api/cli.html#cli_unhandled_rejections_mode | |
| process['on']('unhandledRejection', function(reason) { throw reason; }); | |
| quit_ = (status, toThrow) => { | |
| if (keepRuntimeAlive()) { | |
| process['exitCode'] = status; | |
| throw toThrow; | |
| } | |
| logExceptionOnExit(toThrow); | |
| process['exit'](status); | |
| }; | |
| Module['inspect'] = function () { return '[Emscripten Module object]'; }; | |
| } else | |
| if (ENVIRONMENT_IS_SHELL) { | |
| if ((typeof process == 'object' && typeof require === 'function') || typeof window == 'object' || typeof importScripts == 'function') throw new Error('not compiled for this environment (did you build to HTML and try to run it not on the web, or set ENVIRONMENT to something - like node - and run it someplace else - like on the web?)'); | |
| if (typeof read != 'undefined') { | |
| read_ = function shell_read(f) { | |
| return read(f); | |
| }; | |
| } | |
| readBinary = function readBinary(f) { | |
| let data; | |
| if (typeof readbuffer == 'function') { | |
| return new Uint8Array(readbuffer(f)); | |
| } | |
| data = read(f, 'binary'); | |
| assert(typeof data == 'object'); | |
| return data; | |
| }; | |
| readAsync = function readAsync(f, onload, onerror) { | |
| setTimeout(() => onload(readBinary(f)), 0); | |
| }; | |
| if (typeof scriptArgs != 'undefined') { | |
| arguments_ = scriptArgs; | |
| } else if (typeof arguments != 'undefined') { | |
| arguments_ = arguments; | |
| } | |
| if (typeof quit == 'function') { | |
| quit_ = (status, toThrow) => { | |
| logExceptionOnExit(toThrow); | |
| quit(status); | |
| }; | |
| } | |
| if (typeof print != 'undefined') { | |
| // Prefer to use print/printErr where they exist, as they usually work better. | |
| if (typeof console == 'undefined') console = /** @type{!Console} */({}); | |
| console.log = /** @type{!function(this:Console, ...*): undefined} */ (print); | |
| console.warn = console.error = /** @type{!function(this:Console, ...*): undefined} */ (typeof printErr != 'undefined' ? printErr : print); | |
| } | |
| } else | |
| // Note that this includes Node.js workers when relevant (pthreads is enabled). | |
| // Node.js workers are detected as a combination of ENVIRONMENT_IS_WORKER and | |
| // ENVIRONMENT_IS_NODE. | |
| if (ENVIRONMENT_IS_WEB || ENVIRONMENT_IS_WORKER) { | |
| if (ENVIRONMENT_IS_WORKER) { // Check worker, not web, since window could be polyfilled | |
| scriptDirectory = self.location.href; | |
| } else if (typeof document != 'undefined' && document.currentScript) { // web | |
| scriptDirectory = document.currentScript.src; | |
| } | |
| // blob urls look like blob:http://site.com/etc/etc and we cannot infer anything from them. | |
| // otherwise, slice off the final part of the url to find the script directory. | |
| // if scriptDirectory does not contain a slash, lastIndexOf will return -1, | |
| // and scriptDirectory will correctly be replaced with an empty string. | |
| // If scriptDirectory contains a query (starting with ?) or a fragment (starting with #), | |
| // they are removed because they could contain a slash. | |
| if (scriptDirectory.indexOf('blob:') !== 0) { | |
| scriptDirectory = scriptDirectory.substr(0, scriptDirectory.replace(/[?#].*/, "").lastIndexOf('/')+1); | |
| } else { | |
| scriptDirectory = ''; | |
| } | |
| if (!(typeof window == 'object' || typeof importScripts == 'function')) throw new Error('not compiled for this environment (did you build to HTML and try to run it not on the web, or set ENVIRONMENT to something - like node - and run it someplace else - like on the web?)'); | |
| // Differentiate the Web Worker from the Node Worker case, as reading must | |
| // be done differently. | |
| { | |
| // include: web_or_worker_shell_read.js | |
| read_ = (url) => { | |
| var xhr = new XMLHttpRequest(); | |
| xhr.open('GET', url, false); | |
| xhr.send(null); | |
| return xhr.responseText; | |
| } | |
| if (ENVIRONMENT_IS_WORKER) { | |
| readBinary = (url) => { | |
| var xhr = new XMLHttpRequest(); | |
| xhr.open('GET', url, false); | |
| xhr.responseType = 'arraybuffer'; | |
| xhr.send(null); | |
| return new Uint8Array(/** @type{!ArrayBuffer} */(xhr.response)); | |
| }; | |
| } | |
| readAsync = (url, onload, onerror) => { | |
| var xhr = new XMLHttpRequest(); | |
| xhr.open('GET', url, true); | |
| xhr.responseType = 'arraybuffer'; | |
| xhr.onload = () => { | |
| if (xhr.status == 200 || (xhr.status == 0 && xhr.response)) { // file URLs can return 0 | |
| onload(xhr.response); | |
| return; | |
| } | |
| onerror(); | |
| }; | |
| xhr.onerror = onerror; | |
| xhr.send(null); | |
| } | |
| // end include: web_or_worker_shell_read.js | |
| } | |
| setWindowTitle = (title) => document.title = title; | |
| } else | |
| { | |
| throw new Error('environment detection error'); | |
| } | |
| var out = Module['print'] || console.log.bind(console); | |
| var err = Module['printErr'] || console.warn.bind(console); | |
| // Merge back in the overrides | |
| Object.assign(Module, moduleOverrides); | |
| // Free the object hierarchy contained in the overrides, this lets the GC | |
| // reclaim data used e.g. in memoryInitializerRequest, which is a large typed array. | |
| moduleOverrides = null; | |
| checkIncomingModuleAPI(); | |
| // Emit code to handle expected values on the Module object. This applies Module.x | |
| // to the proper local x. This has two benefits: first, we only emit it if it is | |
| // expected to arrive, and second, by using a local everywhere else that can be | |
| // minified. | |
| if (Module['arguments']) arguments_ = Module['arguments'];legacyModuleProp('arguments', 'arguments_'); | |
| if (Module['thisProgram']) thisProgram = Module['thisProgram'];legacyModuleProp('thisProgram', 'thisProgram'); | |
| if (Module['quit']) quit_ = Module['quit'];legacyModuleProp('quit', 'quit_'); | |
| // perform assertions in shell.js after we set up out() and err(), as otherwise if an assertion fails it cannot print the message | |
| // Assertions on removed incoming Module JS APIs. | |
| assert(typeof Module['memoryInitializerPrefixURL'] == 'undefined', 'Module.memoryInitializerPrefixURL option was removed, use Module.locateFile instead'); | |
| assert(typeof Module['pthreadMainPrefixURL'] == 'undefined', 'Module.pthreadMainPrefixURL option was removed, use Module.locateFile instead'); | |
| assert(typeof Module['cdInitializerPrefixURL'] == 'undefined', 'Module.cdInitializerPrefixURL option was removed, use Module.locateFile instead'); | |
| assert(typeof Module['filePackagePrefixURL'] == 'undefined', 'Module.filePackagePrefixURL option was removed, use Module.locateFile instead'); | |
| assert(typeof Module['read'] == 'undefined', 'Module.read option was removed (modify read_ in JS)'); | |
| assert(typeof Module['readAsync'] == 'undefined', 'Module.readAsync option was removed (modify readAsync in JS)'); | |
| assert(typeof Module['readBinary'] == 'undefined', 'Module.readBinary option was removed (modify readBinary in JS)'); | |
| assert(typeof Module['setWindowTitle'] == 'undefined', 'Module.setWindowTitle option was removed (modify setWindowTitle in JS)'); | |
| assert(typeof Module['TOTAL_MEMORY'] == 'undefined', 'Module.TOTAL_MEMORY has been renamed Module.INITIAL_MEMORY'); | |
| legacyModuleProp('read', 'read_'); | |
| legacyModuleProp('readAsync', 'readAsync'); | |
| legacyModuleProp('readBinary', 'readBinary'); | |
| legacyModuleProp('setWindowTitle', 'setWindowTitle'); | |
| var IDBFS = 'IDBFS is no longer included by default; build with -lidbfs.js'; | |
| var PROXYFS = 'PROXYFS is no longer included by default; build with -lproxyfs.js'; | |
| var WORKERFS = 'WORKERFS is no longer included by default; build with -lworkerfs.js'; | |
| var NODEFS = 'NODEFS is no longer included by default; build with -lnodefs.js'; | |
| assert(!ENVIRONMENT_IS_SHELL, "shell environment detected but not enabled at build time. Add 'shell' to `-sENVIRONMENT` to enable."); | |
| var STACK_ALIGN = 16; | |
| var POINTER_SIZE = 4; | |
| function getNativeTypeSize(type) { | |
| switch (type) { | |
| case 'i1': case 'i8': case 'u8': return 1; | |
| case 'i16': case 'u16': return 2; | |
| case 'i32': case 'u32': return 4; | |
| case 'i64': case 'u64': return 8; | |
| case 'float': return 4; | |
| case 'double': return 8; | |
| default: { | |
| if (type[type.length - 1] === '*') { | |
| return POINTER_SIZE; | |
| } | |
| if (type[0] === 'i') { | |
| const bits = Number(type.substr(1)); | |
| assert(bits % 8 === 0, 'getNativeTypeSize invalid bits ' + bits + ', type ' + type); | |
| return bits / 8; | |
| } | |
| return 0; | |
| } | |
| } | |
| } | |
| // include: runtime_debug.js | |
| function legacyModuleProp(prop, newName) { | |
| if (!Object.getOwnPropertyDescriptor(Module, prop)) { | |
| Object.defineProperty(Module, prop, { | |
| configurable: true, | |
| get: function() { | |
| abort('Module.' + prop + ' has been replaced with plain ' + newName + ' (the initial value can be provided on Module, but after startup the value is only looked for on a local variable of that name)'); | |
| } | |
| }); | |
| } | |
| } | |
| function ignoredModuleProp(prop) { | |
| if (Object.getOwnPropertyDescriptor(Module, prop)) { | |
| abort('`Module.' + prop + '` was supplied but `' + prop + '` not included in INCOMING_MODULE_JS_API'); | |
| } | |
| } | |
| // forcing the filesystem exports a few things by default | |
| function isExportedByForceFilesystem(name) { | |
| return name === 'FS_createPath' || | |
| name === 'FS_createDataFile' || | |
| name === 'FS_createPreloadedFile' || | |
| name === 'FS_unlink' || | |
| name === 'addRunDependency' || | |
| // The old FS has some functionality that WasmFS lacks. | |
| name === 'FS_createLazyFile' || | |
| name === 'FS_createDevice' || | |
| name === 'removeRunDependency'; | |
| } | |
| function missingLibrarySymbol(sym) { | |
| if (typeof globalThis !== 'undefined' && !Object.getOwnPropertyDescriptor(globalThis, sym)) { | |
| Object.defineProperty(globalThis, sym, { | |
| configurable: true, | |
| get: function() { | |
| // Can't `abort()` here because it would break code that does runtime | |
| // checks. e.g. `if (typeof SDL === 'undefined')`. | |
| var msg = '`' + sym + '` is a library symbol and not included by default; add it to your library.js __deps or to DEFAULT_LIBRARY_FUNCS_TO_INCLUDE on the command line'; | |
| // DEFAULT_LIBRARY_FUNCS_TO_INCLUDE requires the name as it appears in | |
| // library.js, which means $name for a JS name with no prefix, or name | |
| // for a JS name like _name. | |
| var librarySymbol = sym; | |
| if (!librarySymbol.startsWith('_')) { | |
| librarySymbol = '$' + sym; | |
| } | |
| msg += " (e.g. -sDEFAULT_LIBRARY_FUNCS_TO_INCLUDE=" + librarySymbol + ")"; | |
| if (isExportedByForceFilesystem(sym)) { | |
| msg += '. Alternatively, forcing filesystem support (-sFORCE_FILESYSTEM) can export this for you'; | |
| } | |
| warnOnce(msg); | |
| return undefined; | |
| } | |
| }); | |
| } | |
| } | |
| function unexportedRuntimeSymbol(sym) { | |
| if (!Object.getOwnPropertyDescriptor(Module, sym)) { | |
| Object.defineProperty(Module, sym, { | |
| configurable: true, | |
| get: function() { | |
| var msg = "'" + sym + "' was not exported. add it to EXPORTED_RUNTIME_METHODS (see the FAQ)"; | |
| if (isExportedByForceFilesystem(sym)) { | |
| msg += '. Alternatively, forcing filesystem support (-sFORCE_FILESYSTEM) can export this for you'; | |
| } | |
| abort(msg); | |
| } | |
| }); | |
| } | |
| } | |
| // end include: runtime_debug.js | |
| // === Preamble library stuff === | |
| // Documentation for the public APIs defined in this file must be updated in: | |
| // site/source/docs/api_reference/preamble.js.rst | |
| // A prebuilt local version of the documentation is available at: | |
| // site/build/text/docs/api_reference/preamble.js.txt | |
| // You can also build docs locally as HTML or other formats in site/ | |
| // An online HTML version (which may be of a different version of Emscripten) | |
| // is up at http://kripken.github.io/emscripten-site/docs/api_reference/preamble.js.html | |
| var wasmBinary; | |
| if (Module['wasmBinary']) wasmBinary = Module['wasmBinary'];legacyModuleProp('wasmBinary', 'wasmBinary'); | |
| var noExitRuntime = Module['noExitRuntime'] || true;legacyModuleProp('noExitRuntime', 'noExitRuntime'); | |
| if (typeof WebAssembly != 'object') { | |
| abort('no native wasm support detected'); | |
| } | |
| // Wasm globals | |
| var wasmMemory; | |
| //======================================== | |
| // Runtime essentials | |
| //======================================== | |
| // whether we are quitting the application. no code should run after this. | |
| // set in exit() and abort() | |
| var ABORT = false; | |
| // set by exit() and abort(). Passed to 'onExit' handler. | |
| // NOTE: This is also used as the process return code code in shell environments | |
| // but only when noExitRuntime is false. | |
| var EXITSTATUS; | |
| /** @type {function(*, string=)} */ | |
| function assert(condition, text) { | |
| if (!condition) { | |
| abort('Assertion failed' + (text ? ': ' + text : '')); | |
| } | |
| } | |
| // We used to include malloc/free by default in the past. Show a helpful error in | |
| // builds with assertions. | |
| // include: runtime_strings.js | |
| // runtime_strings.js: String related runtime functions that are part of both | |
| // MINIMAL_RUNTIME and regular runtime. | |
| var UTF8Decoder = typeof TextDecoder != 'undefined' ? new TextDecoder('utf8') : undefined; | |
| /** | |
| * Given a pointer 'idx' to a null-terminated UTF8-encoded string in the given | |
| * array that contains uint8 values, returns a copy of that string as a | |
| * Javascript String object. | |
| * heapOrArray is either a regular array, or a JavaScript typed array view. | |
| * @param {number} idx | |
| * @param {number=} maxBytesToRead | |
| * @return {string} | |
| */ | |
| function UTF8ArrayToString(heapOrArray, idx, maxBytesToRead) { | |
| var endIdx = idx + maxBytesToRead; | |
| var endPtr = idx; | |
| // TextDecoder needs to know the byte length in advance, it doesn't stop on | |
| // null terminator by itself. Also, use the length info to avoid running tiny | |
| // strings through TextDecoder, since .subarray() allocates garbage. | |
| // (As a tiny code save trick, compare endPtr against endIdx using a negation, | |
| // so that undefined means Infinity) | |
| while (heapOrArray[endPtr] && !(endPtr >= endIdx)) ++endPtr; | |
| if (endPtr - idx > 16 && heapOrArray.buffer && UTF8Decoder) { | |
| return UTF8Decoder.decode(heapOrArray.subarray(idx, endPtr)); | |
| } | |
| var str = ''; | |
| // If building with TextDecoder, we have already computed the string length | |
| // above, so test loop end condition against that | |
| while (idx < endPtr) { | |
| // For UTF8 byte structure, see: | |
| // http://en.wikipedia.org/wiki/UTF-8#Description | |
| // https://www.ietf.org/rfc/rfc2279.txt | |
| // https://tools.ietf.org/html/rfc3629 | |
| var u0 = heapOrArray[idx++]; | |
| if (!(u0 & 0x80)) { str += String.fromCharCode(u0); continue; } | |
| var u1 = heapOrArray[idx++] & 63; | |
| if ((u0 & 0xE0) == 0xC0) { str += String.fromCharCode(((u0 & 31) << 6) | u1); continue; } | |
| var u2 = heapOrArray[idx++] & 63; | |
| if ((u0 & 0xF0) == 0xE0) { | |
| u0 = ((u0 & 15) << 12) | (u1 << 6) | u2; | |
| } else { | |
| if ((u0 & 0xF8) != 0xF0) warnOnce('Invalid UTF-8 leading byte ' + ptrToString(u0) + ' encountered when deserializing a UTF-8 string in wasm memory to a JS string!'); | |
| u0 = ((u0 & 7) << 18) | (u1 << 12) | (u2 << 6) | (heapOrArray[idx++] & 63); | |
| } | |
| if (u0 < 0x10000) { | |
| str += String.fromCharCode(u0); | |
| } else { | |
| var ch = u0 - 0x10000; | |
| str += String.fromCharCode(0xD800 | (ch >> 10), 0xDC00 | (ch & 0x3FF)); | |
| } | |
| } | |
| return str; | |
| } | |
| /** | |
| * Given a pointer 'ptr' to a null-terminated UTF8-encoded string in the | |
| * emscripten HEAP, returns a copy of that string as a Javascript String object. | |
| * | |
| * @param {number} ptr | |
| * @param {number=} maxBytesToRead - An optional length that specifies the | |
| * maximum number of bytes to read. You can omit this parameter to scan the | |
| * string until the first \0 byte. If maxBytesToRead is passed, and the string | |
| * at [ptr, ptr+maxBytesToReadr[ contains a null byte in the middle, then the | |
| * string will cut short at that byte index (i.e. maxBytesToRead will not | |
| * produce a string of exact length [ptr, ptr+maxBytesToRead[) N.B. mixing | |
| * frequent uses of UTF8ToString() with and without maxBytesToRead may throw | |
| * JS JIT optimizations off, so it is worth to consider consistently using one | |
| * @return {string} | |
| */ | |
| function UTF8ToString(ptr, maxBytesToRead) { | |
| return ptr ? UTF8ArrayToString(HEAPU8, ptr, maxBytesToRead) : ''; | |
| } | |
| /** | |
| * Copies the given Javascript String object 'str' to the given byte array at | |
| * address 'outIdx', encoded in UTF8 form and null-terminated. The copy will | |
| * require at most str.length*4+1 bytes of space in the HEAP. Use the function | |
| * lengthBytesUTF8 to compute the exact number of bytes (excluding null | |
| * terminator) that this function will write. | |
| * | |
| * @param {string} str - The Javascript string to copy. | |
| * @param {ArrayBufferView|Array<number>} heap - The array to copy to. Each | |
| * index in this array is assumed | |
| * to be one 8-byte element. | |
| * @param {number} outIdx - The starting offset in the array to begin the copying. | |
| * @param {number} maxBytesToWrite - The maximum number of bytes this function | |
| * can write to the array. This count should | |
| * include the null terminator, i.e. if | |
| * maxBytesToWrite=1, only the null terminator | |
| * will be written and nothing else. | |
| * maxBytesToWrite=0 does not write any bytes | |
| * to the output, not even the null | |
| * terminator. | |
| * @return {number} The number of bytes written, EXCLUDING the null terminator. | |
| */ | |
| function stringToUTF8Array(str, heap, outIdx, maxBytesToWrite) { | |
| // Parameter maxBytesToWrite is not optional. Negative values, 0, null, | |
| // undefined and false each don't write out any bytes. | |
| if (!(maxBytesToWrite > 0)) | |
| return 0; | |
| var startIdx = outIdx; | |
| var endIdx = outIdx + maxBytesToWrite - 1; // -1 for string null terminator. | |
| for (var i = 0; i < str.length; ++i) { | |
| // Gotcha: charCodeAt returns a 16-bit word that is a UTF-16 encoded code | |
| // unit, not a Unicode code point of the character! So decode | |
| // UTF16->UTF32->UTF8. | |
| // See http://unicode.org/faq/utf_bom.html#utf16-3 | |
| // For UTF8 byte structure, see http://en.wikipedia.org/wiki/UTF-8#Description | |
| // and https://www.ietf.org/rfc/rfc2279.txt | |
| // and https://tools.ietf.org/html/rfc3629 | |
| var u = str.charCodeAt(i); // possibly a lead surrogate | |
| if (u >= 0xD800 && u <= 0xDFFF) { | |
| var u1 = str.charCodeAt(++i); | |
| u = 0x10000 + ((u & 0x3FF) << 10) | (u1 & 0x3FF); | |
| } | |
| if (u <= 0x7F) { | |
| if (outIdx >= endIdx) break; | |
| heap[outIdx++] = u; | |
| } else if (u <= 0x7FF) { | |
| if (outIdx + 1 >= endIdx) break; | |
| heap[outIdx++] = 0xC0 | (u >> 6); | |
| heap[outIdx++] = 0x80 | (u & 63); | |
| } else if (u <= 0xFFFF) { | |
| if (outIdx + 2 >= endIdx) break; | |
| heap[outIdx++] = 0xE0 | (u >> 12); | |
| heap[outIdx++] = 0x80 | ((u >> 6) & 63); | |
| heap[outIdx++] = 0x80 | (u & 63); | |
| } else { | |
| if (outIdx + 3 >= endIdx) break; | |
| if (u > 0x10FFFF) warnOnce('Invalid Unicode code point ' + ptrToString(u) + ' encountered when serializing a JS string to a UTF-8 string in wasm memory! (Valid unicode code points should be in range 0-0x10FFFF).'); | |
| heap[outIdx++] = 0xF0 | (u >> 18); | |
| heap[outIdx++] = 0x80 | ((u >> 12) & 63); | |
| heap[outIdx++] = 0x80 | ((u >> 6) & 63); | |
| heap[outIdx++] = 0x80 | (u & 63); | |
| } | |
| } | |
| // Null-terminate the pointer to the buffer. | |
| heap[outIdx] = 0; | |
| return outIdx - startIdx; | |
| } | |
| /** | |
| * Copies the given Javascript String object 'str' to the emscripten HEAP at | |
| * address 'outPtr', null-terminated and encoded in UTF8 form. The copy will | |
| * require at most str.length*4+1 bytes of space in the HEAP. | |
| * Use the function lengthBytesUTF8 to compute the exact number of bytes | |
| * (excluding null terminator) that this function will write. | |
| * | |
| * @return {number} The number of bytes written, EXCLUDING the null terminator. | |
| */ | |
| function stringToUTF8(str, outPtr, maxBytesToWrite) { | |
| assert(typeof maxBytesToWrite == 'number', 'stringToUTF8(str, outPtr, maxBytesToWrite) is missing the third parameter that specifies the length of the output buffer!'); | |
| return stringToUTF8Array(str, HEAPU8,outPtr, maxBytesToWrite); | |
| } | |
| /** | |
| * Returns the number of bytes the given Javascript string takes if encoded as a | |
| * UTF8 byte array, EXCLUDING the null terminator byte. | |
| * | |
| * @param {string} str - JavaScript string to operator on | |
| * @return {number} Length, in bytes, of the UTF8 encoded string. | |
| */ | |
| function lengthBytesUTF8(str) { | |
| var len = 0; | |
| for (var i = 0; i < str.length; ++i) { | |
| // Gotcha: charCodeAt returns a 16-bit word that is a UTF-16 encoded code | |
| // unit, not a Unicode code point of the character! So decode | |
| // UTF16->UTF32->UTF8. | |
| // See http://unicode.org/faq/utf_bom.html#utf16-3 | |
| var c = str.charCodeAt(i); // possibly a lead surrogate | |
| if (c <= 0x7F) { | |
| len++; | |
| } else if (c <= 0x7FF) { | |
| len += 2; | |
| } else if (c >= 0xD800 && c <= 0xDFFF) { | |
| len += 4; ++i; | |
| } else { | |
| len += 3; | |
| } | |
| } | |
| return len; | |
| } | |
| // end include: runtime_strings.js | |
| // Memory management | |
| var HEAP, | |
| /** @type {!ArrayBuffer} */ | |
| buffer, | |
| /** @type {!Int8Array} */ | |
| HEAP8, | |
| /** @type {!Uint8Array} */ | |
| HEAPU8, | |
| /** @type {!Int16Array} */ | |
| HEAP16, | |
| /** @type {!Uint16Array} */ | |
| HEAPU16, | |
| /** @type {!Int32Array} */ | |
| HEAP32, | |
| /** @type {!Uint32Array} */ | |
| HEAPU32, | |
| /** @type {!Float32Array} */ | |
| HEAPF32, | |
| /** @type {!Float64Array} */ | |
| HEAPF64; | |
| function updateGlobalBufferAndViews(buf) { | |
| buffer = buf; | |
| Module['HEAP8'] = HEAP8 = new Int8Array(buf); | |
| Module['HEAP16'] = HEAP16 = new Int16Array(buf); | |
| Module['HEAP32'] = HEAP32 = new Int32Array(buf); | |
| Module['HEAPU8'] = HEAPU8 = new Uint8Array(buf); | |
| Module['HEAPU16'] = HEAPU16 = new Uint16Array(buf); | |
| Module['HEAPU32'] = HEAPU32 = new Uint32Array(buf); | |
| Module['HEAPF32'] = HEAPF32 = new Float32Array(buf); | |
| Module['HEAPF64'] = HEAPF64 = new Float64Array(buf); | |
| } | |
| var STACK_SIZE = 65536; | |
| if (Module['STACK_SIZE']) assert(STACK_SIZE === Module['STACK_SIZE'], 'the stack size can no longer be determined at runtime') | |
| var INITIAL_MEMORY = Module['INITIAL_MEMORY'] || 16777216;legacyModuleProp('INITIAL_MEMORY', 'INITIAL_MEMORY'); | |
| assert(INITIAL_MEMORY >= STACK_SIZE, 'INITIAL_MEMORY should be larger than STACK_SIZE, was ' + INITIAL_MEMORY + '! (STACK_SIZE=' + STACK_SIZE + ')'); | |
| // check for full engine support (use string 'subarray' to avoid closure compiler confusion) | |
| assert(typeof Int32Array != 'undefined' && typeof Float64Array !== 'undefined' && Int32Array.prototype.subarray != undefined && Int32Array.prototype.set != undefined, | |
| 'JS engine does not provide full typed array support'); | |
| // If memory is defined in wasm, the user can't provide it. | |
| assert(!Module['wasmMemory'], 'Use of `wasmMemory` detected. Use -sIMPORTED_MEMORY to define wasmMemory externally'); | |
| assert(INITIAL_MEMORY == 16777216, 'Detected runtime INITIAL_MEMORY setting. Use -sIMPORTED_MEMORY to define wasmMemory dynamically'); | |
| // include: runtime_init_table.js | |
| // In regular non-RELOCATABLE mode the table is exported | |
| // from the wasm module and this will be assigned once | |
| // the exports are available. | |
| var wasmTable; | |
| // end include: runtime_init_table.js | |
| // include: runtime_stack_check.js | |
| // Initializes the stack cookie. Called at the startup of main and at the startup of each thread in pthreads mode. | |
| function writeStackCookie() { | |
| var max = _emscripten_stack_get_end(); | |
| assert((max & 3) == 0); | |
| // If the stack ends at address zero we write our cookies 4 bytes into the | |
| // stack. This prevents interference with the (separate) address-zero check | |
| // below. | |
| if (max == 0) { | |
| max += 4; | |
| } | |
| // The stack grow downwards towards _emscripten_stack_get_end. | |
| // We write cookies to the final two words in the stack and detect if they are | |
| // ever overwritten. | |
| HEAPU32[((max)>>2)] = 0x2135467; | |
| HEAPU32[(((max)+(4))>>2)] = 0x89BACDFE; | |
| // Also test the global address 0 for integrity. | |
| HEAPU32[0] = 0x63736d65; /* 'emsc' */ | |
| } | |
| function checkStackCookie() { | |
| if (ABORT) return; | |
| var max = _emscripten_stack_get_end(); | |
| // See writeStackCookie(). | |
| if (max == 0) { | |
| max += 4; | |
| } | |
| var cookie1 = HEAPU32[((max)>>2)]; | |
| var cookie2 = HEAPU32[(((max)+(4))>>2)]; | |
| if (cookie1 != 0x2135467 || cookie2 != 0x89BACDFE) { | |
| abort('Stack overflow! Stack cookie has been overwritten at ' + ptrToString(max) + ', expected hex dwords 0x89BACDFE and 0x2135467, but received ' + ptrToString(cookie2) + ' ' + ptrToString(cookie1)); | |
| } | |
| // Also test the global address 0 for integrity. | |
| if (HEAPU32[0] !== 0x63736d65 /* 'emsc' */) { | |
| abort('Runtime error: The application has corrupted its heap memory area (address zero)!'); | |
| } | |
| } | |
| // end include: runtime_stack_check.js | |
| // include: runtime_assertions.js | |
| // Endianness check | |
| (function() { | |
| var h16 = new Int16Array(1); | |
| var h8 = new Int8Array(h16.buffer); | |
| h16[0] = 0x6373; | |
| if (h8[0] !== 0x73 || h8[1] !== 0x63) throw 'Runtime error: expected the system to be little-endian! (Run with -sSUPPORT_BIG_ENDIAN to bypass)'; | |
| })(); | |
| // end include: runtime_assertions.js | |
| var __ATPRERUN__ = []; // functions called before the runtime is initialized | |
| var __ATINIT__ = []; // functions called during startup | |
| var __ATMAIN__ = []; // functions called when main() is to be run | |
| var __ATEXIT__ = []; // functions called during shutdown | |
| var __ATPOSTRUN__ = []; // functions called after the main() is called | |
| var runtimeInitialized = false; | |
| function keepRuntimeAlive() { | |
| return noExitRuntime; | |
| } | |
| function preRun() { | |
| if (Module['preRun']) { | |
| if (typeof Module['preRun'] == 'function') Module['preRun'] = [Module['preRun']]; | |
| while (Module['preRun'].length) { | |
| addOnPreRun(Module['preRun'].shift()); | |
| } | |
| } | |
| callRuntimeCallbacks(__ATPRERUN__); | |
| } | |
| function initRuntime() { | |
| assert(!runtimeInitialized); | |
| runtimeInitialized = true; | |
| checkStackCookie(); | |
| if (!Module["noFSInit"] && !FS.init.initialized) | |
| FS.init(); | |
| FS.ignorePermissions = false; | |
| TTY.init(); | |
| callRuntimeCallbacks(__ATINIT__); | |
| } | |
| function preMain() { | |
| checkStackCookie(); | |
| callRuntimeCallbacks(__ATMAIN__); | |
| } | |
| function postRun() { | |
| checkStackCookie(); | |
| if (Module['postRun']) { | |
| if (typeof Module['postRun'] == 'function') Module['postRun'] = [Module['postRun']]; | |
| while (Module['postRun'].length) { | |
| addOnPostRun(Module['postRun'].shift()); | |
| } | |
| } | |
| callRuntimeCallbacks(__ATPOSTRUN__); | |
| } | |
| function addOnPreRun(cb) { | |
| __ATPRERUN__.unshift(cb); | |
| } | |
| function addOnInit(cb) { | |
| __ATINIT__.unshift(cb); | |
| } | |
| function addOnPreMain(cb) { | |
| __ATMAIN__.unshift(cb); | |
| } | |
| function addOnExit(cb) { | |
| } | |
| function addOnPostRun(cb) { | |
| __ATPOSTRUN__.unshift(cb); | |
| } | |
| // include: runtime_math.js | |
| // https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Math/imul | |
| // https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Math/fround | |
| // https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Math/clz32 | |
| // https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Math/trunc | |
| assert(Math.imul, 'This browser does not support Math.imul(), build with LEGACY_VM_SUPPORT or POLYFILL_OLD_MATH_FUNCTIONS to add in a polyfill'); | |
| assert(Math.fround, 'This browser does not support Math.fround(), build with LEGACY_VM_SUPPORT or POLYFILL_OLD_MATH_FUNCTIONS to add in a polyfill'); | |
| assert(Math.clz32, 'This browser does not support Math.clz32(), build with LEGACY_VM_SUPPORT or POLYFILL_OLD_MATH_FUNCTIONS to add in a polyfill'); | |
| assert(Math.trunc, 'This browser does not support Math.trunc(), build with LEGACY_VM_SUPPORT or POLYFILL_OLD_MATH_FUNCTIONS to add in a polyfill'); | |
| // end include: runtime_math.js | |
| // A counter of dependencies for calling run(). If we need to | |
| // do asynchronous work before running, increment this and | |
| // decrement it. Incrementing must happen in a place like | |
| // Module.preRun (used by emcc to add file preloading). | |
| // Note that you can add dependencies in preRun, even though | |
| // it happens right before run - run will be postponed until | |
| // the dependencies are met. | |
| var runDependencies = 0; | |
| var runDependencyWatcher = null; | |
| var dependenciesFulfilled = null; // overridden to take different actions when all run dependencies are fulfilled | |
| var runDependencyTracking = {}; | |
| function getUniqueRunDependency(id) { | |
| var orig = id; | |
| while (1) { | |
| if (!runDependencyTracking[id]) return id; | |
| id = orig + Math.random(); | |
| } | |
| } | |
| function addRunDependency(id) { | |
| runDependencies++; | |
| if (Module['monitorRunDependencies']) { | |
| Module['monitorRunDependencies'](runDependencies); | |
| } | |
| if (id) { | |
| assert(!runDependencyTracking[id]); | |
| runDependencyTracking[id] = 1; | |
| if (runDependencyWatcher === null && typeof setInterval != 'undefined') { | |
| // Check for missing dependencies every few seconds | |
| runDependencyWatcher = setInterval(function() { | |
| if (ABORT) { | |
| clearInterval(runDependencyWatcher); | |
| runDependencyWatcher = null; | |
| return; | |
| } | |
| var shown = false; | |
| for (var dep in runDependencyTracking) { | |
| if (!shown) { | |
| shown = true; | |
| err('still waiting on run dependencies:'); | |
| } | |
| err('dependency: ' + dep); | |
| } | |
| if (shown) { | |
| err('(end of list)'); | |
| } | |
| }, 10000); | |
| } | |
| } else { | |
| err('warning: run dependency added without ID'); | |
| } | |
| } | |
| function removeRunDependency(id) { | |
| runDependencies--; | |
| if (Module['monitorRunDependencies']) { | |
| Module['monitorRunDependencies'](runDependencies); | |
| } | |
| if (id) { | |
| assert(runDependencyTracking[id]); | |
| delete runDependencyTracking[id]; | |
| } else { | |
| err('warning: run dependency removed without ID'); | |
| } | |
| if (runDependencies == 0) { | |
| if (runDependencyWatcher !== null) { | |
| clearInterval(runDependencyWatcher); | |
| runDependencyWatcher = null; | |
| } | |
| if (dependenciesFulfilled) { | |
| var callback = dependenciesFulfilled; | |
| dependenciesFulfilled = null; | |
| callback(); // can add another dependenciesFulfilled | |
| } | |
| } | |
| } | |
| /** @param {string|number=} what */ | |
| function abort(what) { | |
| if (Module['onAbort']) { | |
| Module['onAbort'](what); | |
| } | |
| what = 'Aborted(' + what + ')'; | |
| // TODO(sbc): Should we remove printing and leave it up to whoever | |
| // catches the exception? | |
| err(what); | |
| ABORT = true; | |
| EXITSTATUS = 1; | |
| // Use a wasm runtime error, because a JS error might be seen as a foreign | |
| // exception, which means we'd run destructors on it. We need the error to | |
| // simply make the program stop. | |
| // FIXME This approach does not work in Wasm EH because it currently does not assume | |
| // all RuntimeErrors are from traps; it decides whether a RuntimeError is from | |
| // a trap or not based on a hidden field within the object. So at the moment | |
| // we don't have a way of throwing a wasm trap from JS. TODO Make a JS API that | |
| // allows this in the wasm spec. | |
| // Suppress closure compiler warning here. Closure compiler's builtin extern | |
| // defintion for WebAssembly.RuntimeError claims it takes no arguments even | |
| // though it can. | |
| // TODO(https://github.com/google/closure-compiler/pull/3913): Remove if/when upstream closure gets fixed. | |
| /** @suppress {checkTypes} */ | |
| var e = new WebAssembly.RuntimeError(what); | |
| // Throw the error whether or not MODULARIZE is set because abort is used | |
| // in code paths apart from instantiation where an exception is expected | |
| // to be thrown when abort is called. | |
| throw e; | |
| } | |
| // {{MEM_INITIALIZER}} | |
| // include: memoryprofiler.js | |
| // end include: memoryprofiler.js | |
| // include: URIUtils.js | |
| // Prefix of data URIs emitted by SINGLE_FILE and related options. | |
| var dataURIPrefix = 'data:application/octet-stream;base64,'; | |
| // Indicates whether filename is a base64 data URI. | |
| function isDataURI(filename) { | |
| // Prefix of data URIs emitted by SINGLE_FILE and related options. | |
| return filename.startsWith(dataURIPrefix); | |
| } | |
| // Indicates whether filename is delivered via file protocol (as opposed to http/https) | |
| function isFileURI(filename) { | |
| return filename.startsWith('file://'); | |
| } | |
| // end include: URIUtils.js | |
| /** @param {boolean=} fixedasm */ | |
| function createExportWrapper(name, fixedasm) { | |
| return function() { | |
| var displayName = name; | |
| var asm = fixedasm; | |
| if (!fixedasm) { | |
| asm = Module['asm']; | |
| } | |
| assert(runtimeInitialized, 'native function `' + displayName + '` called before runtime initialization'); | |
| if (!asm[name]) { | |
| assert(asm[name], 'exported native function `' + displayName + '` not found'); | |
| } | |
| return asm[name].apply(null, arguments); | |
| }; | |
| } | |
| var wasmBinaryFile; | |
| wasmBinaryFile = 'llama2.wasm'; | |
| if (!isDataURI(wasmBinaryFile)) { | |
| wasmBinaryFile = locateFile(wasmBinaryFile); | |
| } | |
| function getBinary(file) { | |
| try { | |
| if (file == wasmBinaryFile && wasmBinary) { | |
| return new Uint8Array(wasmBinary); | |
| } | |
| if (readBinary) { | |
| return readBinary(file); | |
| } | |
| throw "both async and sync fetching of the wasm failed"; | |
| } | |
| catch (err) { | |
| abort(err); | |
| } | |
| } | |
| function getBinaryPromise() { | |
| console.log('getBinaryPromise'); | |
| // If we don't have the binary yet, try to to load it asynchronously. | |
| // Fetch has some additional restrictions over XHR, like it can't be used on a file:// url. | |
| // See https://github.com/github/fetch/pull/92#issuecomment-140665932 | |
| // Cordova or Electron apps are typically loaded from a file:// url. | |
| // So use fetch if it is available and the url is not a file, otherwise fall back to XHR. | |
| if (!wasmBinary && (ENVIRONMENT_IS_WEB || ENVIRONMENT_IS_WORKER)) { | |
| if (typeof fetch == 'function' | |
| && !isFileURI(wasmBinaryFile) | |
| ) { | |
| return fetch(wasmBinaryFile, { credentials: 'same-origin' }).then(function(response) { | |
| if (!response['ok']) { | |
| throw "failed to load wasm binary file at '" + wasmBinaryFile + "'"; | |
| } | |
| return response['arrayBuffer'](); | |
| }).catch(function () { | |
| return getBinary(wasmBinaryFile); | |
| }); | |
| } | |
| else { | |
| if (readAsync) { | |
| // fetch is not available or url is file => try XHR (readAsync uses XHR internally) | |
| return new Promise(function(resolve, reject) { | |
| readAsync(wasmBinaryFile, function(response) { resolve(new Uint8Array(/** @type{!ArrayBuffer} */(response))) }, reject) | |
| }); | |
| } | |
| } | |
| } | |
| // Otherwise, getBinary should be able to get it synchronously | |
| return Promise.resolve().then(function() { return getBinary(wasmBinaryFile); }); | |
| } | |
| // Create the wasm instance. | |
| // Receives the wasm imports, returns the exports. | |
| function createWasm() { | |
| // prepare imports | |
| var info = { | |
| 'env': asmLibraryArg, | |
| 'wasi_snapshot_preview1': asmLibraryArg, | |
| }; | |
| // Load the wasm module and create an instance of using native support in the JS engine. | |
| // handle a generated wasm instance, receiving its exports and | |
| // performing other necessary setup | |
| /** @param {WebAssembly.Module=} module*/ | |
| function receiveInstance(instance, module) { | |
| var exports = instance.exports; | |
| Module['asm'] = exports; | |
| wasmMemory = Module['asm']['memory']; | |
| assert(wasmMemory, "memory not found in wasm exports"); | |
| // This assertion doesn't hold when emscripten is run in --post-link | |
| // mode. | |
| // TODO(sbc): Read INITIAL_MEMORY out of the wasm file in post-link mode. | |
| //assert(wasmMemory.buffer.byteLength === 16777216); | |
| updateGlobalBufferAndViews(wasmMemory.buffer); | |
| wasmTable = Module['asm']['__indirect_function_table']; | |
| assert(wasmTable, "table not found in wasm exports"); | |
| addOnInit(Module['asm']['__wasm_call_ctors']); | |
| removeRunDependency('wasm-instantiate'); | |
| } | |
| // we can't run yet (except in a pthread, where we have a custom sync instantiator) | |
| addRunDependency('wasm-instantiate'); | |
| // Prefer streaming instantiation if available. | |
| // Async compilation can be confusing when an error on the page overwrites Module | |
| // (for example, if the order of elements is wrong, and the one defining Module is | |
| // later), so we save Module and check it later. | |
| var trueModule = Module; | |
| function receiveInstantiationResult(result) { | |
| // 'result' is a ResultObject object which has both the module and instance. | |
| // receiveInstance() will swap in the exports (to Module.asm) so they can be called | |
| assert(Module === trueModule, 'the Module object should not be replaced during async compilation - perhaps the order of HTML elements is wrong?'); | |
| trueModule = null; | |
| // TODO: Due to Closure regression https://github.com/google/closure-compiler/issues/3193, the above line no longer optimizes out down to the following line. | |
| // When the regression is fixed, can restore the above USE_PTHREADS-enabled path. | |
| receiveInstance(result['instance']); | |
| } | |
| function instantiateArrayBuffer(receiver) { | |
| return getBinaryPromise().then(function(binary) { | |
| return WebAssembly.instantiate(binary, info); | |
| }).then(function (instance) { | |
| return instance; | |
| }).then(receiver, function(reason) { | |
| err('failed to asynchronously prepare wasm: ' + reason); | |
| // Warn on some common problems. | |
| if (isFileURI(wasmBinaryFile)) { | |
| err('warning: Loading from a file URI (' + wasmBinaryFile + ') is not supported in most browsers. See https://emscripten.org/docs/getting_started/FAQ.html#how-do-i-run-a-local-webserver-for-testing-why-does-my-program-stall-in-downloading-or-preparing'); | |
| } | |
| abort(reason); | |
| }); | |
| } | |
| function instantiateAsync() { | |
| if (!wasmBinary && | |
| typeof WebAssembly.instantiateStreaming == 'function' && | |
| !isDataURI(wasmBinaryFile) && | |
| // Don't use streaming for file:// delivered objects in a webview, fetch them synchronously. | |
| !isFileURI(wasmBinaryFile) && | |
| // Avoid instantiateStreaming() on Node.js environment for now, as while | |
| // Node.js v18.1.0 implements it, it does not have a full fetch() | |
| // implementation yet. | |
| // | |
| // Reference: | |
| // https://github.com/emscripten-core/emscripten/pull/16917 | |
| !ENVIRONMENT_IS_NODE && | |
| typeof fetch == 'function') { | |
| return fetch(wasmBinaryFile, { credentials: 'same-origin' }).then(function(response) { | |
| // Suppress closure warning here since the upstream definition for | |
| // instantiateStreaming only allows Promise<Repsponse> rather than | |
| // an actual Response. | |
| // TODO(https://github.com/google/closure-compiler/pull/3913): Remove if/when upstream closure is fixed. | |
| /** @suppress {checkTypes} */ | |
| var result = WebAssembly.instantiateStreaming(response, info); | |
| return result.then( | |
| receiveInstantiationResult, | |
| function(reason) { | |
| // We expect the most common failure cause to be a bad MIME type for the binary, | |
| // in which case falling back to ArrayBuffer instantiation should work. | |
| err('wasm streaming compile failed: ' + reason); | |
| err('falling back to ArrayBuffer instantiation'); | |
| return instantiateArrayBuffer(receiveInstantiationResult); | |
| }); | |
| }); | |
| } else { | |
| return instantiateArrayBuffer(receiveInstantiationResult); | |
| } | |
| } | |
| // User shell pages can write their own Module.instantiateWasm = function(imports, successCallback) callback | |
| // to manually instantiate the Wasm module themselves. This allows pages to run the instantiation parallel | |
| // to any other async startup actions they are performing. | |
| // Also pthreads and wasm workers initialize the wasm instance through this path. | |
| if (Module['instantiateWasm']) { | |
| try { | |
| var exports = Module['instantiateWasm'](info, receiveInstance); | |
| return exports; | |
| } catch(e) { | |
| err('Module.instantiateWasm callback failed with error: ' + e); | |
| return false; | |
| } | |
| } | |
| instantiateAsync(); | |
| return {}; // no exports yet; we'll fill them in later | |
| } | |
| // Globals used by JS i64 conversions (see makeSetValue) | |
| var tempDouble; | |
| var tempI64; | |
| // === Body === | |
| var ASM_CONSTS = { | |
| }; | |
| /** @constructor */ | |
| function ExitStatus(status) { | |
| this.name = 'ExitStatus'; | |
| this.message = 'Program terminated with exit(' + status + ')'; | |
| this.status = status; | |
| } | |
| function callRuntimeCallbacks(callbacks) { | |
| while (callbacks.length > 0) { | |
| // Pass the module as the first argument. | |
| callbacks.shift()(Module); | |
| } | |
| } | |
| /** | |
| * @param {number} ptr | |
| * @param {string} type | |
| */ | |
| function getValue(ptr, type = 'i8') { | |
| if (type.endsWith('*')) type = '*'; | |
| switch (type) { | |
| case 'i1': return HEAP8[((ptr)>>0)]; | |
| case 'i8': return HEAP8[((ptr)>>0)]; | |
| case 'i16': return HEAP16[((ptr)>>1)]; | |
| case 'i32': return HEAP32[((ptr)>>2)]; | |
| case 'i64': return HEAP32[((ptr)>>2)]; | |
| case 'float': return HEAPF32[((ptr)>>2)]; | |
| case 'double': return HEAPF64[((ptr)>>3)]; | |
| case '*': return HEAPU32[((ptr)>>2)]; | |
| default: abort('invalid type for getValue: ' + type); | |
| } | |
| return null; | |
| } | |
| function ptrToString(ptr) { | |
| return '0x' + ptr.toString(16).padStart(8, '0'); | |
| } | |
| /** | |
| * @param {number} ptr | |
| * @param {number} value | |
| * @param {string} type | |
| */ | |
| function setValue(ptr, value, type = 'i8') { | |
| if (type.endsWith('*')) type = '*'; | |
| switch (type) { | |
| case 'i1': HEAP8[((ptr)>>0)] = value; break; | |
| case 'i8': HEAP8[((ptr)>>0)] = value; break; | |
| case 'i16': HEAP16[((ptr)>>1)] = value; break; | |
| case 'i32': HEAP32[((ptr)>>2)] = value; break; | |
| case 'i64': (tempI64 = [value>>>0,(tempDouble=value,(+(Math.abs(tempDouble))) >= 1.0 ? (tempDouble > 0.0 ? ((Math.min((+(Math.floor((tempDouble)/4294967296.0))), 4294967295.0))|0)>>>0 : (~~((+(Math.ceil((tempDouble - +(((~~(tempDouble)))>>>0))/4294967296.0)))))>>>0) : 0)],HEAP32[((ptr)>>2)] = tempI64[0],HEAP32[(((ptr)+(4))>>2)] = tempI64[1]); break; | |
| case 'float': HEAPF32[((ptr)>>2)] = value; break; | |
| case 'double': HEAPF64[((ptr)>>3)] = value; break; | |
| case '*': HEAPU32[((ptr)>>2)] = value; break; | |
| default: abort('invalid type for setValue: ' + type); | |
| } | |
| } | |
| function warnOnce(text) { | |
| if (!warnOnce.shown) warnOnce.shown = {}; | |
| if (!warnOnce.shown[text]) { | |
| warnOnce.shown[text] = 1; | |
| if (ENVIRONMENT_IS_NODE) text = 'warning: ' + text; | |
| err(text); | |
| } | |
| } | |
| function setErrNo(value) { | |
| HEAP32[((___errno_location())>>2)] = value; | |
| return value; | |
| } | |
| var PATH = {isAbs:(path) => path.charAt(0) === '/',splitPath:(filename) => { | |
| var splitPathRe = /^(\/?|)([\s\S]*?)((?:\.{1,2}|[^\/]+?|)(\.[^.\/]*|))(?:[\/]*)$/; | |
| return splitPathRe.exec(filename).slice(1); | |
| },normalizeArray:(parts, allowAboveRoot) => { | |
| // if the path tries to go above the root, `up` ends up > 0 | |
| var up = 0; | |
| for (var i = parts.length - 1; i >= 0; i--) { | |
| var last = parts[i]; | |
| if (last === '.') { | |
| parts.splice(i, 1); | |
| } else if (last === '..') { | |
| parts.splice(i, 1); | |
| up++; | |
| } else if (up) { | |
| parts.splice(i, 1); | |
| up--; | |
| } | |
| } | |
| // if the path is allowed to go above the root, restore leading ..s | |
| if (allowAboveRoot) { | |
| for (; up; up--) { | |
| parts.unshift('..'); | |
| } | |
| } | |
| return parts; | |
| },normalize:(path) => { | |
| var isAbsolute = PATH.isAbs(path), | |
| trailingSlash = path.substr(-1) === '/'; | |
| // Normalize the path | |
| path = PATH.normalizeArray(path.split('/').filter((p) => !!p), !isAbsolute).join('/'); | |
| if (!path && !isAbsolute) { | |
| path = '.'; | |
| } | |
| if (path && trailingSlash) { | |
| path += '/'; | |
| } | |
| return (isAbsolute ? '/' : '') + path; | |
| },dirname:(path) => { | |
| var result = PATH.splitPath(path), | |
| root = result[0], | |
| dir = result[1]; | |
| if (!root && !dir) { | |
| // No dirname whatsoever | |
| return '.'; | |
| } | |
| if (dir) { | |
| // It has a dirname, strip trailing slash | |
| dir = dir.substr(0, dir.length - 1); | |
| } | |
| return root + dir; | |
| },basename:(path) => { | |
| // EMSCRIPTEN return '/'' for '/', not an empty string | |
| if (path === '/') return '/'; | |
| path = PATH.normalize(path); | |
| path = path.replace(/\/$/, ""); | |
| var lastSlash = path.lastIndexOf('/'); | |
| if (lastSlash === -1) return path; | |
| return path.substr(lastSlash+1); | |
| },join:function() { | |
| var paths = Array.prototype.slice.call(arguments); | |
| return PATH.normalize(paths.join('/')); | |
| },join2:(l, r) => { | |
| return PATH.normalize(l + '/' + r); | |
| }}; | |
| function getRandomDevice() { | |
| if (typeof crypto == 'object' && typeof crypto['getRandomValues'] == 'function') { | |
| // for modern web browsers | |
| var randomBuffer = new Uint8Array(1); | |
| return () => { crypto.getRandomValues(randomBuffer); return randomBuffer[0]; }; | |
| } else | |
| if (ENVIRONMENT_IS_NODE) { | |
| // for nodejs with or without crypto support included | |
| try { | |
| var crypto_module = require('crypto'); | |
| // nodejs has crypto support | |
| return () => crypto_module['randomBytes'](1)[0]; | |
| } catch (e) { | |
| // nodejs doesn't have crypto support | |
| } | |
| } | |
| // we couldn't find a proper implementation, as Math.random() is not suitable for /dev/random, see emscripten-core/emscripten/pull/7096 | |
| return () => abort("no cryptographic support found for randomDevice. consider polyfilling it if you want to use something insecure like Math.random(), e.g. put this in a --pre-js: var crypto = { getRandomValues: function(array) { for (var i = 0; i < array.length; i++) array[i] = (Math.random()*256)|0 } };"); | |
| } | |
| var PATH_FS = {resolve:function() { | |
| var resolvedPath = '', | |
| resolvedAbsolute = false; | |
| for (var i = arguments.length - 1; i >= -1 && !resolvedAbsolute; i--) { | |
| var path = (i >= 0) ? arguments[i] : FS.cwd(); | |
| // Skip empty and invalid entries | |
| if (typeof path != 'string') { | |
| throw new TypeError('Arguments to path.resolve must be strings'); | |
| } else if (!path) { | |
| return ''; // an invalid portion invalidates the whole thing | |
| } | |
| resolvedPath = path + '/' + resolvedPath; | |
| resolvedAbsolute = PATH.isAbs(path); | |
| } | |
| // At this point the path should be resolved to a full absolute path, but | |
| // handle relative paths to be safe (might happen when process.cwd() fails) | |
| resolvedPath = PATH.normalizeArray(resolvedPath.split('/').filter((p) => !!p), !resolvedAbsolute).join('/'); | |
| return ((resolvedAbsolute ? '/' : '') + resolvedPath) || '.'; | |
| },relative:(from, to) => { | |
| from = PATH_FS.resolve(from).substr(1); | |
| to = PATH_FS.resolve(to).substr(1); | |
| function trim(arr) { | |
| var start = 0; | |
| for (; start < arr.length; start++) { | |
| if (arr[start] !== '') break; | |
| } | |
| var end = arr.length - 1; | |
| for (; end >= 0; end--) { | |
| if (arr[end] !== '') break; | |
| } | |
| if (start > end) return []; | |
| return arr.slice(start, end - start + 1); | |
| } | |
| var fromParts = trim(from.split('/')); | |
| var toParts = trim(to.split('/')); | |
| var length = Math.min(fromParts.length, toParts.length); | |
| var samePartsLength = length; | |
| for (var i = 0; i < length; i++) { | |
| if (fromParts[i] !== toParts[i]) { | |
| samePartsLength = i; | |
| break; | |
| } | |
| } | |
| var outputParts = []; | |
| for (var i = samePartsLength; i < fromParts.length; i++) { | |
| outputParts.push('..'); | |
| } | |
| outputParts = outputParts.concat(toParts.slice(samePartsLength)); | |
| return outputParts.join('/'); | |
| }}; | |
| /** @type {function(string, boolean=, number=)} */ | |
| function intArrayFromString(stringy, dontAddNull, length) { | |
| var len = length > 0 ? length : lengthBytesUTF8(stringy)+1; | |
| var u8array = new Array(len); | |
| var numBytesWritten = stringToUTF8Array(stringy, u8array, 0, u8array.length); | |
| if (dontAddNull) u8array.length = numBytesWritten; | |
| return u8array; | |
| } | |
| var TTY = {ttys:[],init:function () { | |
| // https://github.com/emscripten-core/emscripten/pull/1555 | |
| // if (ENVIRONMENT_IS_NODE) { | |
| // // currently, FS.init does not distinguish if process.stdin is a file or TTY | |
| // // device, it always assumes it's a TTY device. because of this, we're forcing | |
| // // process.stdin to UTF8 encoding to at least make stdin reading compatible | |
| // // with text files until FS.init can be refactored. | |
| // process['stdin']['setEncoding']('utf8'); | |
| // } | |
| },shutdown:function() { | |
| // https://github.com/emscripten-core/emscripten/pull/1555 | |
| // if (ENVIRONMENT_IS_NODE) { | |
| // // inolen: any idea as to why node -e 'process.stdin.read()' wouldn't exit immediately (with process.stdin being a tty)? | |
| // // isaacs: because now it's reading from the stream, you've expressed interest in it, so that read() kicks off a _read() which creates a ReadReq operation | |
| // // inolen: I thought read() in that case was a synchronous operation that just grabbed some amount of buffered data if it exists? | |
| // // isaacs: it is. but it also triggers a _read() call, which calls readStart() on the handle | |
| // // isaacs: do process.stdin.pause() and i'd think it'd probably close the pending call | |
| // process['stdin']['pause'](); | |
| // } | |
| },register:function(dev, ops) { | |
| TTY.ttys[dev] = { input: [], output: [], ops: ops }; | |
| FS.registerDevice(dev, TTY.stream_ops); | |
| },stream_ops:{open:function(stream) { | |
| var tty = TTY.ttys[stream.node.rdev]; | |
| if (!tty) { | |
| throw new FS.ErrnoError(43); | |
| } | |
| stream.tty = tty; | |
| stream.seekable = false; | |
| },close:function(stream) { | |
| // flush any pending line data | |
| stream.tty.ops.fsync(stream.tty); | |
| },fsync:function(stream) { | |
| stream.tty.ops.fsync(stream.tty); | |
| },read:function(stream, buffer, offset, length, pos /* ignored */) { | |
| if (!stream.tty || !stream.tty.ops.get_char) { | |
| throw new FS.ErrnoError(60); | |
| } | |
| var bytesRead = 0; | |
| for (var i = 0; i < length; i++) { | |
| var result; | |
| try { | |
| result = stream.tty.ops.get_char(stream.tty); | |
| } catch (e) { | |
| throw new FS.ErrnoError(29); | |
| } | |
| if (result === undefined && bytesRead === 0) { | |
| throw new FS.ErrnoError(6); | |
| } | |
| if (result === null || result === undefined) break; | |
| bytesRead++; | |
| buffer[offset+i] = result; | |
| } | |
| if (bytesRead) { | |
| stream.node.timestamp = Date.now(); | |
| } | |
| return bytesRead; | |
| },write:function(stream, buffer, offset, length, pos) { | |
| if (!stream.tty || !stream.tty.ops.put_char) { | |
| throw new FS.ErrnoError(60); | |
| } | |
| try { | |
| for (var i = 0; i < length; i++) { | |
| stream.tty.ops.put_char(stream.tty, buffer[offset+i]); | |
| } | |
| } catch (e) { | |
| throw new FS.ErrnoError(29); | |
| } | |
| if (length) { | |
| stream.node.timestamp = Date.now(); | |
| } | |
| return i; | |
| }},default_tty_ops:{get_char:function(tty) { | |
| if (!tty.input.length) { | |
| var result = null; | |
| if (ENVIRONMENT_IS_NODE) { | |
| // we will read data by chunks of BUFSIZE | |
| var BUFSIZE = 256; | |
| var buf = Buffer.alloc(BUFSIZE); | |
| var bytesRead = 0; | |
| try { | |
| bytesRead = fs.readSync(process.stdin.fd, buf, 0, BUFSIZE, -1); | |
| } catch(e) { | |
| // Cross-platform differences: on Windows, reading EOF throws an exception, but on other OSes, | |
| // reading EOF returns 0. Uniformize behavior by treating the EOF exception to return 0. | |
| if (e.toString().includes('EOF')) bytesRead = 0; | |
| else throw e; | |
| } | |
| if (bytesRead > 0) { | |
| result = buf.slice(0, bytesRead).toString('utf-8'); | |
| } else { | |
| result = null; | |
| } | |
| } else | |
| if (typeof window != 'undefined' && | |
| typeof window.prompt == 'function') { | |
| // Browser. | |
| result = window.prompt('Input: '); // returns null on cancel | |
| if (result !== null) { | |
| result += '\n'; | |
| } | |
| } else if (typeof readline == 'function') { | |
| // Command line. | |
| result = readline(); | |
| if (result !== null) { | |
| result += '\n'; | |
| } | |
| } | |
| if (!result) { | |
| return null; | |
| } | |
| tty.input = intArrayFromString(result, true); | |
| } | |
| return tty.input.shift(); | |
| },put_char:function(tty, val) { | |
| if (val === null || val === 10) { | |
| out(UTF8ArrayToString(tty.output, 0)); | |
| tty.output = []; | |
| } else { | |
| if (val != 0) tty.output.push(val); // val == 0 would cut text output off in the middle. | |
| } | |
| },fsync:function(tty) { | |
| if (tty.output && tty.output.length > 0) { | |
| out(UTF8ArrayToString(tty.output, 0)); | |
| tty.output = []; | |
| } | |
| }},default_tty1_ops:{put_char:function(tty, val) { | |
| if (val === null || val === 10) { | |
| err(UTF8ArrayToString(tty.output, 0)); | |
| tty.output = []; | |
| } else { | |
| if (val != 0) tty.output.push(val); | |
| } | |
| },fsync:function(tty) { | |
| if (tty.output && tty.output.length > 0) { | |
| err(UTF8ArrayToString(tty.output, 0)); | |
| tty.output = []; | |
| } | |
| }}}; | |
| function zeroMemory(address, size) { | |
| HEAPU8.fill(0, address, address + size); | |
| return address; | |
| } | |
| function alignMemory(size, alignment) { | |
| assert(alignment, "alignment argument is required"); | |
| return Math.ceil(size / alignment) * alignment; | |
| } | |
| function mmapAlloc(size) { | |
| abort('internal error: mmapAlloc called but `emscripten_builtin_memalign` native symbol not exported'); | |
| } | |
| var MEMFS = {ops_table:null,mount:function(mount) { | |
| return MEMFS.createNode(null, '/', 16384 | 511 /* 0777 */, 0); | |
| },createNode:function(parent, name, mode, dev) { | |
| if (FS.isBlkdev(mode) || FS.isFIFO(mode)) { | |
| // no supported | |
| throw new FS.ErrnoError(63); | |
| } | |
| if (!MEMFS.ops_table) { | |
| MEMFS.ops_table = { | |
| dir: { | |
| node: { | |
| getattr: MEMFS.node_ops.getattr, | |
| setattr: MEMFS.node_ops.setattr, | |
| lookup: MEMFS.node_ops.lookup, | |
| mknod: MEMFS.node_ops.mknod, | |
| rename: MEMFS.node_ops.rename, | |
| unlink: MEMFS.node_ops.unlink, | |
| rmdir: MEMFS.node_ops.rmdir, | |
| readdir: MEMFS.node_ops.readdir, | |
| symlink: MEMFS.node_ops.symlink | |
| }, | |
| stream: { | |
| llseek: MEMFS.stream_ops.llseek | |
| } | |
| }, | |
| file: { | |
| node: { | |
| getattr: MEMFS.node_ops.getattr, | |
| setattr: MEMFS.node_ops.setattr | |
| }, | |
| stream: { | |
| llseek: MEMFS.stream_ops.llseek, | |
| read: MEMFS.stream_ops.read, | |
| write: MEMFS.stream_ops.write, | |
| allocate: MEMFS.stream_ops.allocate, | |
| mmap: MEMFS.stream_ops.mmap, | |
| msync: MEMFS.stream_ops.msync | |
| } | |
| }, | |
| link: { | |
| node: { | |
| getattr: MEMFS.node_ops.getattr, | |
| setattr: MEMFS.node_ops.setattr, | |
| readlink: MEMFS.node_ops.readlink | |
| }, | |
| stream: {} | |
| }, | |
| chrdev: { | |
| node: { | |
| getattr: MEMFS.node_ops.getattr, | |
| setattr: MEMFS.node_ops.setattr | |
| }, | |
| stream: FS.chrdev_stream_ops | |
| } | |
| }; | |
| } | |
| var node = FS.createNode(parent, name, mode, dev); | |
| if (FS.isDir(node.mode)) { | |
| node.node_ops = MEMFS.ops_table.dir.node; | |
| node.stream_ops = MEMFS.ops_table.dir.stream; | |
| node.contents = {}; | |
| } else if (FS.isFile(node.mode)) { | |
| node.node_ops = MEMFS.ops_table.file.node; | |
| node.stream_ops = MEMFS.ops_table.file.stream; | |
| node.usedBytes = 0; // The actual number of bytes used in the typed array, as opposed to contents.length which gives the whole capacity. | |
| // When the byte data of the file is populated, this will point to either a typed array, or a normal JS array. Typed arrays are preferred | |
| // for performance, and used by default. However, typed arrays are not resizable like normal JS arrays are, so there is a small disk size | |
| // penalty involved for appending file writes that continuously grow a file similar to std::vector capacity vs used -scheme. | |
| node.contents = null; | |
| } else if (FS.isLink(node.mode)) { | |
| node.node_ops = MEMFS.ops_table.link.node; | |
| node.stream_ops = MEMFS.ops_table.link.stream; | |
| } else if (FS.isChrdev(node.mode)) { | |
| node.node_ops = MEMFS.ops_table.chrdev.node; | |
| node.stream_ops = MEMFS.ops_table.chrdev.stream; | |
| } | |
| node.timestamp = Date.now(); | |
| // add the new node to the parent | |
| if (parent) { | |
| parent.contents[name] = node; | |
| parent.timestamp = node.timestamp; | |
| } | |
| return node; | |
| },getFileDataAsTypedArray:function(node) { | |
| if (!node.contents) return new Uint8Array(0); | |
| if (node.contents.subarray) return node.contents.subarray(0, node.usedBytes); // Make sure to not return excess unused bytes. | |
| return new Uint8Array(node.contents); | |
| },expandFileStorage:function(node, newCapacity) { | |
| var prevCapacity = node.contents ? node.contents.length : 0; | |
| if (prevCapacity >= newCapacity) return; // No need to expand, the storage was already large enough. | |
| // Don't expand strictly to the given requested limit if it's only a very small increase, but instead geometrically grow capacity. | |
| // For small filesizes (<1MB), perform size*2 geometric increase, but for large sizes, do a much more conservative size*1.125 increase to | |
| // avoid overshooting the allocation cap by a very large margin. | |
| var CAPACITY_DOUBLING_MAX = 1024 * 1024; | |
| newCapacity = Math.max(newCapacity, (prevCapacity * (prevCapacity < CAPACITY_DOUBLING_MAX ? 2.0 : 1.125)) >>> 0); | |
| if (prevCapacity != 0) newCapacity = Math.max(newCapacity, 256); // At minimum allocate 256b for each file when expanding. | |
| var oldContents = node.contents; | |
| node.contents = new Uint8Array(newCapacity); // Allocate new storage. | |
| if (node.usedBytes > 0) node.contents.set(oldContents.subarray(0, node.usedBytes), 0); // Copy old data over to the new storage. | |
| },resizeFileStorage:function(node, newSize) { | |
| if (node.usedBytes == newSize) return; | |
| if (newSize == 0) { | |
| node.contents = null; // Fully decommit when requesting a resize to zero. | |
| node.usedBytes = 0; | |
| } else { | |
| var oldContents = node.contents; | |
| node.contents = new Uint8Array(newSize); // Allocate new storage. | |
| if (oldContents) { | |
| node.contents.set(oldContents.subarray(0, Math.min(newSize, node.usedBytes))); // Copy old data over to the new storage. | |
| } | |
| node.usedBytes = newSize; | |
| } | |
| },node_ops:{getattr:function(node) { | |
| var attr = {}; | |
| // device numbers reuse inode numbers. | |
| attr.dev = FS.isChrdev(node.mode) ? node.id : 1; | |
| attr.ino = node.id; | |
| attr.mode = node.mode; | |
| attr.nlink = 1; | |
| attr.uid = 0; | |
| attr.gid = 0; | |
| attr.rdev = node.rdev; | |
| if (FS.isDir(node.mode)) { | |
| attr.size = 4096; | |
| } else if (FS.isFile(node.mode)) { | |
| attr.size = node.usedBytes; | |
| } else if (FS.isLink(node.mode)) { | |
| attr.size = node.link.length; | |
| } else { | |
| attr.size = 0; | |
| } | |
| attr.atime = new Date(node.timestamp); | |
| attr.mtime = new Date(node.timestamp); | |
| attr.ctime = new Date(node.timestamp); | |
| // NOTE: In our implementation, st_blocks = Math.ceil(st_size/st_blksize), | |
| // but this is not required by the standard. | |
| attr.blksize = 4096; | |
| attr.blocks = Math.ceil(attr.size / attr.blksize); | |
| return attr; | |
| },setattr:function(node, attr) { | |
| if (attr.mode !== undefined) { | |
| node.mode = attr.mode; | |
| } | |
| if (attr.timestamp !== undefined) { | |
| node.timestamp = attr.timestamp; | |
| } | |
| if (attr.size !== undefined) { | |
| MEMFS.resizeFileStorage(node, attr.size); | |
| } | |
| },lookup:function(parent, name) { | |
| throw FS.genericErrors[44]; | |
| },mknod:function(parent, name, mode, dev) { | |
| return MEMFS.createNode(parent, name, mode, dev); | |
| },rename:function(old_node, new_dir, new_name) { | |
| // if we're overwriting a directory at new_name, make sure it's empty. | |
| if (FS.isDir(old_node.mode)) { | |
| var new_node; | |
| try { | |
| new_node = FS.lookupNode(new_dir, new_name); | |
| } catch (e) { | |
| } | |
| if (new_node) { | |
| for (var i in new_node.contents) { | |
| throw new FS.ErrnoError(55); | |
| } | |
| } | |
| } | |
| // do the internal rewiring | |
| delete old_node.parent.contents[old_node.name]; | |
| old_node.parent.timestamp = Date.now() | |
| old_node.name = new_name; | |
| new_dir.contents[new_name] = old_node; | |
| new_dir.timestamp = old_node.parent.timestamp; | |
| old_node.parent = new_dir; | |
| },unlink:function(parent, name) { | |
| delete parent.contents[name]; | |
| parent.timestamp = Date.now(); | |
| },rmdir:function(parent, name) { | |
| var node = FS.lookupNode(parent, name); | |
| for (var i in node.contents) { | |
| throw new FS.ErrnoError(55); | |
| } | |
| delete parent.contents[name]; | |
| parent.timestamp = Date.now(); | |
| },readdir:function(node) { | |
| var entries = ['.', '..']; | |
| for (var key in node.contents) { | |
| if (!node.contents.hasOwnProperty(key)) { | |
| continue; | |
| } | |
| entries.push(key); | |
| } | |
| return entries; | |
| },symlink:function(parent, newname, oldpath) { | |
| var node = MEMFS.createNode(parent, newname, 511 /* 0777 */ | 40960, 0); | |
| node.link = oldpath; | |
| return node; | |
| },readlink:function(node) { | |
| if (!FS.isLink(node.mode)) { | |
| throw new FS.ErrnoError(28); | |
| } | |
| return node.link; | |
| }},stream_ops:{read:function(stream, buffer, offset, length, position) { | |
| var contents = stream.node.contents; | |
| if (position >= stream.node.usedBytes) return 0; | |
| var size = Math.min(stream.node.usedBytes - position, length); | |
| assert(size >= 0); | |
| if (size > 8 && contents.subarray) { // non-trivial, and typed array | |
| buffer.set(contents.subarray(position, position + size), offset); | |
| } else { | |
| for (var i = 0; i < size; i++) buffer[offset + i] = contents[position + i]; | |
| } | |
| return size; | |
| },write:function(stream, buffer, offset, length, position, canOwn) { | |
| // The data buffer should be a typed array view | |
| assert(!(buffer instanceof ArrayBuffer)); | |
| // If the buffer is located in main memory (HEAP), and if | |
| // memory can grow, we can't hold on to references of the | |
| // memory buffer, as they may get invalidated. That means we | |
| // need to do copy its contents. | |
| if (buffer.buffer === HEAP8.buffer) { | |
| canOwn = false; | |
| } | |
| if (!length) return 0; | |
| var node = stream.node; | |
| node.timestamp = Date.now(); | |
| if (buffer.subarray && (!node.contents || node.contents.subarray)) { // This write is from a typed array to a typed array? | |
| if (canOwn) { | |
| assert(position === 0, 'canOwn must imply no weird position inside the file'); | |
| node.contents = buffer.subarray(offset, offset + length); | |
| node.usedBytes = length; | |
| return length; | |
| } else if (node.usedBytes === 0 && position === 0) { // If this is a simple first write to an empty file, do a fast set since we don't need to care about old data. | |
| node.contents = buffer.slice(offset, offset + length); | |
| node.usedBytes = length; | |
| return length; | |
| } else if (position + length <= node.usedBytes) { // Writing to an already allocated and used subrange of the file? | |
| node.contents.set(buffer.subarray(offset, offset + length), position); | |
| return length; | |
| } | |
| } | |
| // Appending to an existing file and we need to reallocate, or source data did not come as a typed array. | |
| MEMFS.expandFileStorage(node, position+length); | |
| if (node.contents.subarray && buffer.subarray) { | |
| // Use typed array write which is available. | |
| node.contents.set(buffer.subarray(offset, offset + length), position); | |
| } else { | |
| for (var i = 0; i < length; i++) { | |
| node.contents[position + i] = buffer[offset + i]; // Or fall back to manual write if not. | |
| } | |
| } | |
| node.usedBytes = Math.max(node.usedBytes, position + length); | |
| return length; | |
| },llseek:function(stream, offset, whence) { | |
| var position = offset; | |
| if (whence === 1) { | |
| position += stream.position; | |
| } else if (whence === 2) { | |
| if (FS.isFile(stream.node.mode)) { | |
| position += stream.node.usedBytes; | |
| } | |
| } | |
| if (position < 0) { | |
| throw new FS.ErrnoError(28); | |
| } | |
| return position; | |
| },allocate:function(stream, offset, length) { | |
| MEMFS.expandFileStorage(stream.node, offset + length); | |
| stream.node.usedBytes = Math.max(stream.node.usedBytes, offset + length); | |
| },mmap:function(stream, length, position, prot, flags) { | |
| if (!FS.isFile(stream.node.mode)) { | |
| throw new FS.ErrnoError(43); | |
| } | |
| var ptr; | |
| var allocated; | |
| var contents = stream.node.contents; | |
| // Only make a new copy when MAP_PRIVATE is specified. | |
| if (!(flags & 2) && contents.buffer === buffer) { | |
| // We can't emulate MAP_SHARED when the file is not backed by the buffer | |
| // we're mapping to (e.g. the HEAP buffer). | |
| allocated = false; | |
| ptr = contents.byteOffset; | |
| } else { | |
| // Try to avoid unnecessary slices. | |
| if (position > 0 || position + length < contents.length) { | |
| if (contents.subarray) { | |
| contents = contents.subarray(position, position + length); | |
| } else { | |
| contents = Array.prototype.slice.call(contents, position, position + length); | |
| } | |
| } | |
| allocated = true; | |
| ptr = mmapAlloc(length); | |
| if (!ptr) { | |
| throw new FS.ErrnoError(48); | |
| } | |
| HEAP8.set(contents, ptr); | |
| } | |
| return { ptr: ptr, allocated: allocated }; | |
| },msync:function(stream, buffer, offset, length, mmapFlags) { | |
| MEMFS.stream_ops.write(stream, buffer, 0, length, offset, false); | |
| // should we check if bytesWritten and length are the same? | |
| return 0; | |
| }}}; | |
| /** @param {boolean=} noRunDep */ | |
| function asyncLoad(url, onload, onerror, noRunDep) { | |
| var dep = !noRunDep ? getUniqueRunDependency('al ' + url) : ''; | |
| readAsync(url, (arrayBuffer) => { | |
| assert(arrayBuffer, 'Loading data file "' + url + '" failed (no arrayBuffer).'); | |
| onload(new Uint8Array(arrayBuffer)); | |
| if (dep) removeRunDependency(dep); | |
| }, (event) => { | |
| if (onerror) { | |
| onerror(); | |
| } else { | |
| throw 'Loading data file "' + url + '" failed.'; | |
| } | |
| }); | |
| if (dep) addRunDependency(dep); | |
| } | |
| var ERRNO_MESSAGES = {0:"Success",1:"Arg list too long",2:"Permission denied",3:"Address already in use",4:"Address not available",5:"Address family not supported by protocol family",6:"No more processes",7:"Socket already connected",8:"Bad file number",9:"Trying to read unreadable message",10:"Mount device busy",11:"Operation canceled",12:"No children",13:"Connection aborted",14:"Connection refused",15:"Connection reset by peer",16:"File locking deadlock error",17:"Destination address required",18:"Math arg out of domain of func",19:"Quota exceeded",20:"File exists",21:"Bad address",22:"File too large",23:"Host is unreachable",24:"Identifier removed",25:"Illegal byte sequence",26:"Connection already in progress",27:"Interrupted system call",28:"Invalid argument",29:"I/O error",30:"Socket is already connected",31:"Is a directory",32:"Too many symbolic links",33:"Too many open files",34:"Too many links",35:"Message too long",36:"Multihop attempted",37:"File or path name too long",38:"Network interface is not configured",39:"Connection reset by network",40:"Network is unreachable",41:"Too many open files in system",42:"No buffer space available",43:"No such device",44:"No such file or directory",45:"Exec format error",46:"No record locks available",47:"The link has been severed",48:"Not enough core",49:"No message of desired type",50:"Protocol not available",51:"No space left on device",52:"Function not implemented",53:"Socket is not connected",54:"Not a directory",55:"Directory not empty",56:"State not recoverable",57:"Socket operation on non-socket",59:"Not a typewriter",60:"No such device or address",61:"Value too large for defined data type",62:"Previous owner died",63:"Not super-user",64:"Broken pipe",65:"Protocol error",66:"Unknown protocol",67:"Protocol wrong type for socket",68:"Math result not representable",69:"Read only file system",70:"Illegal seek",71:"No such process",72:"Stale file handle",73:"Connection timed out",74:"Text file busy",75:"Cross-device link",100:"Device not a stream",101:"Bad font file fmt",102:"Invalid slot",103:"Invalid request code",104:"No anode",105:"Block device required",106:"Channel number out of range",107:"Level 3 halted",108:"Level 3 reset",109:"Link number out of range",110:"Protocol driver not attached",111:"No CSI structure available",112:"Level 2 halted",113:"Invalid exchange",114:"Invalid request descriptor",115:"Exchange full",116:"No data (for no delay io)",117:"Timer expired",118:"Out of streams resources",119:"Machine is not on the network",120:"Package not installed",121:"The object is remote",122:"Advertise error",123:"Srmount error",124:"Communication error on send",125:"Cross mount point (not really error)",126:"Given log. name not unique",127:"f.d. invalid for this operation",128:"Remote address changed",129:"Can access a needed shared lib",130:"Accessing a corrupted shared lib",131:".lib section in a.out corrupted",132:"Attempting to link in too many libs",133:"Attempting to exec a shared library",135:"Streams pipe error",136:"Too many users",137:"Socket type not supported",138:"Not supported",139:"Protocol family not supported",140:"Can't send after socket shutdown",141:"Too many references",142:"Host is down",148:"No medium (in tape drive)",156:"Level 2 not synchronized"}; | |
| var ERRNO_CODES = {}; | |
| function withStackSave(f) { | |
| var stack = stackSave(); | |
| var ret = f(); | |
| stackRestore(stack); | |
| return ret; | |
| } | |
| function demangle(func) { | |
| warnOnce('warning: build with -sDEMANGLE_SUPPORT to link in libcxxabi demangling'); | |
| return func; | |
| } | |
| function demangleAll(text) { | |
| var regex = | |
| /\b_Z[\w\d_]+/g; | |
| return text.replace(regex, | |
| function(x) { | |
| var y = demangle(x); | |
| return x === y ? x : (y + ' [' + x + ']'); | |
| }); | |
| } | |
| var FS = {root:null,mounts:[],devices:{},streams:[],nextInode:1,nameTable:null,currentPath:"/",initialized:false,ignorePermissions:true,ErrnoError:null,genericErrors:{},filesystems:null,syncFSRequests:0,lookupPath:(path, opts = {}) => { | |
| path = PATH_FS.resolve(path); | |
| if (!path) return { path: '', node: null }; | |
| var defaults = { | |
| follow_mount: true, | |
| recurse_count: 0 | |
| }; | |
| opts = Object.assign(defaults, opts) | |
| if (opts.recurse_count > 8) { // max recursive lookup of 8 | |
| throw new FS.ErrnoError(32); | |
| } | |
| // split the absolute path | |
| var parts = path.split('/').filter((p) => !!p); | |
| // start at the root | |
| var current = FS.root; | |
| var current_path = '/'; | |
| for (var i = 0; i < parts.length; i++) { | |
| var islast = (i === parts.length-1); | |
| if (islast && opts.parent) { | |
| // stop resolving | |
| break; | |
| } | |
| current = FS.lookupNode(current, parts[i]); | |
| current_path = PATH.join2(current_path, parts[i]); | |
| // jump to the mount's root node if this is a mountpoint | |
| if (FS.isMountpoint(current)) { | |
| if (!islast || (islast && opts.follow_mount)) { | |
| current = current.mounted.root; | |
| } | |
| } | |
| // by default, lookupPath will not follow a symlink if it is the final path component. | |
| // setting opts.follow = true will override this behavior. | |
| if (!islast || opts.follow) { | |
| var count = 0; | |
| while (FS.isLink(current.mode)) { | |
| var link = FS.readlink(current_path); | |
| current_path = PATH_FS.resolve(PATH.dirname(current_path), link); | |
| var lookup = FS.lookupPath(current_path, { recurse_count: opts.recurse_count + 1 }); | |
| current = lookup.node; | |
| if (count++ > 40) { // limit max consecutive symlinks to 40 (SYMLOOP_MAX). | |
| throw new FS.ErrnoError(32); | |
| } | |
| } | |
| } | |
| } | |
| return { path: current_path, node: current }; | |
| },getPath:(node) => { | |
| var path; | |
| while (true) { | |
| if (FS.isRoot(node)) { | |
| var mount = node.mount.mountpoint; | |
| if (!path) return mount; | |
| return mount[mount.length-1] !== '/' ? mount + '/' + path : mount + path; | |
| } | |
| path = path ? node.name + '/' + path : node.name; | |
| node = node.parent; | |
| } | |
| },hashName:(parentid, name) => { | |
| var hash = 0; | |
| for (var i = 0; i < name.length; i++) { | |
| hash = ((hash << 5) - hash + name.charCodeAt(i)) | 0; | |
| } | |
| return ((parentid + hash) >>> 0) % FS.nameTable.length; | |
| },hashAddNode:(node) => { | |
| var hash = FS.hashName(node.parent.id, node.name); | |
| node.name_next = FS.nameTable[hash]; | |
| FS.nameTable[hash] = node; | |
| },hashRemoveNode:(node) => { | |
| var hash = FS.hashName(node.parent.id, node.name); | |
| if (FS.nameTable[hash] === node) { | |
| FS.nameTable[hash] = node.name_next; | |
| } else { | |
| var current = FS.nameTable[hash]; | |
| while (current) { | |
| if (current.name_next === node) { | |
| current.name_next = node.name_next; | |
| break; | |
| } | |
| current = current.name_next; | |
| } | |
| } | |
| },lookupNode:(parent, name) => { | |
| var errCode = FS.mayLookup(parent); | |
| if (errCode) { | |
| throw new FS.ErrnoError(errCode, parent); | |
| } | |
| var hash = FS.hashName(parent.id, name); | |
| for (var node = FS.nameTable[hash]; node; node = node.name_next) { | |
| var nodeName = node.name; | |
| if (node.parent.id === parent.id && nodeName === name) { | |
| return node; | |
| } | |
| } | |
| // if we failed to find it in the cache, call into the VFS | |
| return FS.lookup(parent, name); | |
| },createNode:(parent, name, mode, rdev) => { | |
| assert(typeof parent == 'object') | |
| var node = new FS.FSNode(parent, name, mode, rdev); | |
| FS.hashAddNode(node); | |
| return node; | |
| },destroyNode:(node) => { | |
| FS.hashRemoveNode(node); | |
| },isRoot:(node) => { | |
| return node === node.parent; | |
| },isMountpoint:(node) => { | |
| return !!node.mounted; | |
| },isFile:(mode) => { | |
| return (mode & 61440) === 32768; | |
| },isDir:(mode) => { | |
| return (mode & 61440) === 16384; | |
| },isLink:(mode) => { | |
| return (mode & 61440) === 40960; | |
| },isChrdev:(mode) => { | |
| return (mode & 61440) === 8192; | |
| },isBlkdev:(mode) => { | |
| return (mode & 61440) === 24576; | |
| },isFIFO:(mode) => { | |
| return (mode & 61440) === 4096; | |
| },isSocket:(mode) => { | |
| return (mode & 49152) === 49152; | |
| },flagModes:{"r":0,"r+":2,"w":577,"w+":578,"a":1089,"a+":1090},modeStringToFlags:(str) => { | |
| var flags = FS.flagModes[str]; | |
| if (typeof flags == 'undefined') { | |
| throw new Error('Unknown file open mode: ' + str); | |
| } | |
| return flags; | |
| },flagsToPermissionString:(flag) => { | |
| var perms = ['r', 'w', 'rw'][flag & 3]; | |
| if ((flag & 512)) { | |
| perms += 'w'; | |
| } | |
| return perms; | |
| },nodePermissions:(node, perms) => { | |
| if (FS.ignorePermissions) { | |
| return 0; | |
| } | |
| // return 0 if any user, group or owner bits are set. | |
| if (perms.includes('r') && !(node.mode & 292)) { | |
| return 2; | |
| } else if (perms.includes('w') && !(node.mode & 146)) { | |
| return 2; | |
| } else if (perms.includes('x') && !(node.mode & 73)) { | |
| return 2; | |
| } | |
| return 0; | |
| },mayLookup:(dir) => { | |
| var errCode = FS.nodePermissions(dir, 'x'); | |
| if (errCode) return errCode; | |
| if (!dir.node_ops.lookup) return 2; | |
| return 0; | |
| },mayCreate:(dir, name) => { | |
| try { | |
| var node = FS.lookupNode(dir, name); | |
| return 20; | |
| } catch (e) { | |
| } | |
| return FS.nodePermissions(dir, 'wx'); | |
| },mayDelete:(dir, name, isdir) => { | |
| var node; | |
| try { | |
| node = FS.lookupNode(dir, name); | |
| } catch (e) { | |
| return e.errno; | |
| } | |
| var errCode = FS.nodePermissions(dir, 'wx'); | |
| if (errCode) { | |
| return errCode; | |
| } | |
| if (isdir) { | |
| if (!FS.isDir(node.mode)) { | |
| return 54; | |
| } | |
| if (FS.isRoot(node) || FS.getPath(node) === FS.cwd()) { | |
| return 10; | |
| } | |
| } else { | |
| if (FS.isDir(node.mode)) { | |
| return 31; | |
| } | |
| } | |
| return 0; | |
| },mayOpen:(node, flags) => { | |
| if (!node) { | |
| return 44; | |
| } | |
| if (FS.isLink(node.mode)) { | |
| return 32; | |
| } else if (FS.isDir(node.mode)) { | |
| if (FS.flagsToPermissionString(flags) !== 'r' || // opening for write | |
| (flags & 512)) { // TODO: check for O_SEARCH? (== search for dir only) | |
| return 31; | |
| } | |
| } | |
| return FS.nodePermissions(node, FS.flagsToPermissionString(flags)); | |
| },MAX_OPEN_FDS:4096,nextfd:(fd_start = 0, fd_end = FS.MAX_OPEN_FDS) => { | |
| for (var fd = fd_start; fd <= fd_end; fd++) { | |
| if (!FS.streams[fd]) { | |
| return fd; | |
| } | |
| } | |
| throw new FS.ErrnoError(33); | |
| },getStream:(fd) => FS.streams[fd],createStream:(stream, fd_start, fd_end) => { | |
| if (!FS.FSStream) { | |
| FS.FSStream = /** @constructor */ function() { | |
| this.shared = { }; | |
| }; | |
| FS.FSStream.prototype = {}; | |
| Object.defineProperties(FS.FSStream.prototype, { | |
| object: { | |
| /** @this {FS.FSStream} */ | |
| get: function() { return this.node; }, | |
| /** @this {FS.FSStream} */ | |
| set: function(val) { this.node = val; } | |
| }, | |
| isRead: { | |
| /** @this {FS.FSStream} */ | |
| get: function() { return (this.flags & 2097155) !== 1; } | |
| }, | |
| isWrite: { | |
| /** @this {FS.FSStream} */ | |
| get: function() { return (this.flags & 2097155) !== 0; } | |
| }, | |
| isAppend: { | |
| /** @this {FS.FSStream} */ | |
| get: function() { return (this.flags & 1024); } | |
| }, | |
| flags: { | |
| /** @this {FS.FSStream} */ | |
| get: function() { return this.shared.flags; }, | |
| /** @this {FS.FSStream} */ | |
| set: function(val) { this.shared.flags = val; }, | |
| }, | |
| position : { | |
| /** @this {FS.FSStream} */ | |
| get: function() { return this.shared.position; }, | |
| /** @this {FS.FSStream} */ | |
| set: function(val) { this.shared.position = val; }, | |
| }, | |
| }); | |
| } | |
| // clone it, so we can return an instance of FSStream | |
| stream = Object.assign(new FS.FSStream(), stream); | |
| var fd = FS.nextfd(fd_start, fd_end); | |
| stream.fd = fd; | |
| FS.streams[fd] = stream; | |
| return stream; | |
| },closeStream:(fd) => { | |
| FS.streams[fd] = null; | |
| },chrdev_stream_ops:{open:(stream) => { | |
| var device = FS.getDevice(stream.node.rdev); | |
| // override node's stream ops with the device's | |
| stream.stream_ops = device.stream_ops; | |
| // forward the open call | |
| if (stream.stream_ops.open) { | |
| stream.stream_ops.open(stream); | |
| } | |
| },llseek:() => { | |
| throw new FS.ErrnoError(70); | |
| }},major:(dev) => ((dev) >> 8),minor:(dev) => ((dev) & 0xff),makedev:(ma, mi) => ((ma) << 8 | (mi)),registerDevice:(dev, ops) => { | |
| FS.devices[dev] = { stream_ops: ops }; | |
| },getDevice:(dev) => FS.devices[dev],getMounts:(mount) => { | |
| var mounts = []; | |
| var check = [mount]; | |
| while (check.length) { | |
| var m = check.pop(); | |
| mounts.push(m); | |
| check.push.apply(check, m.mounts); | |
| } | |
| return mounts; | |
| },syncfs:(populate, callback) => { | |
| if (typeof populate == 'function') { | |
| callback = populate; | |
| populate = false; | |
| } | |
| FS.syncFSRequests++; | |
| if (FS.syncFSRequests > 1) { | |
| err('warning: ' + FS.syncFSRequests + ' FS.syncfs operations in flight at once, probably just doing extra work'); | |
| } | |
| var mounts = FS.getMounts(FS.root.mount); | |
| var completed = 0; | |
| function doCallback(errCode) { | |
| assert(FS.syncFSRequests > 0); | |
| FS.syncFSRequests--; | |
| return callback(errCode); | |
| } | |
| function done(errCode) { | |
| if (errCode) { | |
| if (!done.errored) { | |
| done.errored = true; | |
| return doCallback(errCode); | |
| } | |
| return; | |
| } | |
| if (++completed >= mounts.length) { | |
| doCallback(null); | |
| } | |
| }; | |
| // sync all mounts | |
| mounts.forEach((mount) => { | |
| if (!mount.type.syncfs) { | |
| return done(null); | |
| } | |
| mount.type.syncfs(mount, populate, done); | |
| }); | |
| },mount:(type, opts, mountpoint) => { | |
| if (typeof type == 'string') { | |
| // The filesystem was not included, and instead we have an error | |
| // message stored in the variable. | |
| throw type; | |
| } | |
| var root = mountpoint === '/'; | |
| var pseudo = !mountpoint; | |
| var node; | |
| if (root && FS.root) { | |
| throw new FS.ErrnoError(10); | |
| } else if (!root && !pseudo) { | |
| var lookup = FS.lookupPath(mountpoint, { follow_mount: false }); | |
| mountpoint = lookup.path; // use the absolute path | |
| node = lookup.node; | |
| if (FS.isMountpoint(node)) { | |
| throw new FS.ErrnoError(10); | |
| } | |
| if (!FS.isDir(node.mode)) { | |
| throw new FS.ErrnoError(54); | |
| } | |
| } | |
| var mount = { | |
| type: type, | |
| opts: opts, | |
| mountpoint: mountpoint, | |
| mounts: [] | |
| }; | |
| // create a root node for the fs | |
| var mountRoot = type.mount(mount); | |
| mountRoot.mount = mount; | |
| mount.root = mountRoot; | |
| if (root) { | |
| FS.root = mountRoot; | |
| } else if (node) { | |
| // set as a mountpoint | |
| node.mounted = mount; | |
| // add the new mount to the current mount's children | |
| if (node.mount) { | |
| node.mount.mounts.push(mount); | |
| } | |
| } | |
| return mountRoot; | |
| },unmount:(mountpoint) => { | |
| var lookup = FS.lookupPath(mountpoint, { follow_mount: false }); | |
| if (!FS.isMountpoint(lookup.node)) { | |
| throw new FS.ErrnoError(28); | |
| } | |
| // destroy the nodes for this mount, and all its child mounts | |
| var node = lookup.node; | |
| var mount = node.mounted; | |
| var mounts = FS.getMounts(mount); | |
| Object.keys(FS.nameTable).forEach((hash) => { | |
| var current = FS.nameTable[hash]; | |
| while (current) { | |
| var next = current.name_next; | |
| if (mounts.includes(current.mount)) { | |
| FS.destroyNode(current); | |
| } | |
| current = next; | |
| } | |
| }); | |
| // no longer a mountpoint | |
| node.mounted = null; | |
| // remove this mount from the child mounts | |
| var idx = node.mount.mounts.indexOf(mount); | |
| assert(idx !== -1); | |
| node.mount.mounts.splice(idx, 1); | |
| },lookup:(parent, name) => { | |
| return parent.node_ops.lookup(parent, name); | |
| },mknod:(path, mode, dev) => { | |
| var lookup = FS.lookupPath(path, { parent: true }); | |
| var parent = lookup.node; | |
| var name = PATH.basename(path); | |
| if (!name || name === '.' || name === '..') { | |
| throw new FS.ErrnoError(28); | |
| } | |
| var errCode = FS.mayCreate(parent, name); | |
| if (errCode) { | |
| throw new FS.ErrnoError(errCode); | |
| } | |
| if (!parent.node_ops.mknod) { | |
| throw new FS.ErrnoError(63); | |
| } | |
| return parent.node_ops.mknod(parent, name, mode, dev); | |
| },create:(path, mode) => { | |
| mode = mode !== undefined ? mode : 438 /* 0666 */; | |
| mode &= 4095; | |
| mode |= 32768; | |
| return FS.mknod(path, mode, 0); | |
| },mkdir:(path, mode) => { | |
| mode = mode !== undefined ? mode : 511 /* 0777 */; | |
| mode &= 511 | 512; | |
| mode |= 16384; | |
| return FS.mknod(path, mode, 0); | |
| },mkdirTree:(path, mode) => { | |
| var dirs = path.split('/'); | |
| var d = ''; | |
| for (var i = 0; i < dirs.length; ++i) { | |
| if (!dirs[i]) continue; | |
| d += '/' + dirs[i]; | |
| try { | |
| FS.mkdir(d, mode); | |
| } catch(e) { | |
| if (e.errno != 20) throw e; | |
| } | |
| } | |
| },mkdev:(path, mode, dev) => { | |
| if (typeof dev == 'undefined') { | |
| dev = mode; | |
| mode = 438 /* 0666 */; | |
| } | |
| mode |= 8192; | |
| return FS.mknod(path, mode, dev); | |
| },symlink:(oldpath, newpath) => { | |
| if (!PATH_FS.resolve(oldpath)) { | |
| throw new FS.ErrnoError(44); | |
| } | |
| var lookup = FS.lookupPath(newpath, { parent: true }); | |
| var parent = lookup.node; | |
| if (!parent) { | |
| throw new FS.ErrnoError(44); | |
| } | |
| var newname = PATH.basename(newpath); | |
| var errCode = FS.mayCreate(parent, newname); | |
| if (errCode) { | |
| throw new FS.ErrnoError(errCode); | |
| } | |
| if (!parent.node_ops.symlink) { | |
| throw new FS.ErrnoError(63); | |
| } | |
| return parent.node_ops.symlink(parent, newname, oldpath); | |
| },rename:(old_path, new_path) => { | |
| var old_dirname = PATH.dirname(old_path); | |
| var new_dirname = PATH.dirname(new_path); | |
| var old_name = PATH.basename(old_path); | |
| var new_name = PATH.basename(new_path); | |
| // parents must exist | |
| var lookup, old_dir, new_dir; | |
| // let the errors from non existant directories percolate up | |
| lookup = FS.lookupPath(old_path, { parent: true }); | |
| old_dir = lookup.node; | |
| lookup = FS.lookupPath(new_path, { parent: true }); | |
| new_dir = lookup.node; | |
| if (!old_dir || !new_dir) throw new FS.ErrnoError(44); | |
| // need to be part of the same mount | |
| if (old_dir.mount !== new_dir.mount) { | |
| throw new FS.ErrnoError(75); | |
| } | |
| // source must exist | |
| var old_node = FS.lookupNode(old_dir, old_name); | |
| // old path should not be an ancestor of the new path | |
| var relative = PATH_FS.relative(old_path, new_dirname); | |
| if (relative.charAt(0) !== '.') { | |
| throw new FS.ErrnoError(28); | |
| } | |
| // new path should not be an ancestor of the old path | |
| relative = PATH_FS.relative(new_path, old_dirname); | |
| if (relative.charAt(0) !== '.') { | |
| throw new FS.ErrnoError(55); | |
| } | |
| // see if the new path already exists | |
| var new_node; | |
| try { | |
| new_node = FS.lookupNode(new_dir, new_name); | |
| } catch (e) { | |
| // not fatal | |
| } | |
| // early out if nothing needs to change | |
| if (old_node === new_node) { | |
| return; | |
| } | |
| // we'll need to delete the old entry | |
| var isdir = FS.isDir(old_node.mode); | |
| var errCode = FS.mayDelete(old_dir, old_name, isdir); | |
| if (errCode) { | |
| throw new FS.ErrnoError(errCode); | |
| } | |
| // need delete permissions if we'll be overwriting. | |
| // need create permissions if new doesn't already exist. | |
| errCode = new_node ? | |
| FS.mayDelete(new_dir, new_name, isdir) : | |
| FS.mayCreate(new_dir, new_name); | |
| if (errCode) { | |
| throw new FS.ErrnoError(errCode); | |
| } | |
| if (!old_dir.node_ops.rename) { | |
| throw new FS.ErrnoError(63); | |
| } | |
| if (FS.isMountpoint(old_node) || (new_node && FS.isMountpoint(new_node))) { | |
| throw new FS.ErrnoError(10); | |
| } | |
| // if we are going to change the parent, check write permissions | |
| if (new_dir !== old_dir) { | |
| errCode = FS.nodePermissions(old_dir, 'w'); | |
| if (errCode) { | |
| throw new FS.ErrnoError(errCode); | |
| } | |
| } | |
| // remove the node from the lookup hash | |
| FS.hashRemoveNode(old_node); | |
| // do the underlying fs rename | |
| try { | |
| old_dir.node_ops.rename(old_node, new_dir, new_name); | |
| } catch (e) { | |
| throw e; | |
| } finally { | |
| // add the node back to the hash (in case node_ops.rename | |
| // changed its name) | |
| FS.hashAddNode(old_node); | |
| } | |
| },rmdir:(path) => { | |
| var lookup = FS.lookupPath(path, { parent: true }); | |
| var parent = lookup.node; | |
| var name = PATH.basename(path); | |
| var node = FS.lookupNode(parent, name); | |
| var errCode = FS.mayDelete(parent, name, true); | |
| if (errCode) { | |
| throw new FS.ErrnoError(errCode); | |
| } | |
| if (!parent.node_ops.rmdir) { | |
| throw new FS.ErrnoError(63); | |
| } | |
| if (FS.isMountpoint(node)) { | |
| throw new FS.ErrnoError(10); | |
| } | |
| parent.node_ops.rmdir(parent, name); | |
| FS.destroyNode(node); | |
| },readdir:(path) => { | |
| var lookup = FS.lookupPath(path, { follow: true }); | |
| var node = lookup.node; | |
| if (!node.node_ops.readdir) { | |
| throw new FS.ErrnoError(54); | |
| } | |
| return node.node_ops.readdir(node); | |
| },unlink:(path) => { | |
| var lookup = FS.lookupPath(path, { parent: true }); | |
| var parent = lookup.node; | |
| if (!parent) { | |
| throw new FS.ErrnoError(44); | |
| } | |
| var name = PATH.basename(path); | |
| var node = FS.lookupNode(parent, name); | |
| var errCode = FS.mayDelete(parent, name, false); | |
| if (errCode) { | |
| // According to POSIX, we should map EISDIR to EPERM, but | |
| // we instead do what Linux does (and we must, as we use | |
| // the musl linux libc). | |
| throw new FS.ErrnoError(errCode); | |
| } | |
| if (!parent.node_ops.unlink) { | |
| throw new FS.ErrnoError(63); | |
| } | |
| if (FS.isMountpoint(node)) { | |
| throw new FS.ErrnoError(10); | |
| } | |
| parent.node_ops.unlink(parent, name); | |
| FS.destroyNode(node); | |
| },readlink:(path) => { | |
| var lookup = FS.lookupPath(path); | |
| var link = lookup.node; | |
| if (!link) { | |
| throw new FS.ErrnoError(44); | |
| } | |
| if (!link.node_ops.readlink) { | |
| throw new FS.ErrnoError(28); | |
| } | |
| return PATH_FS.resolve(FS.getPath(link.parent), link.node_ops.readlink(link)); | |
| },stat:(path, dontFollow) => { | |
| var lookup = FS.lookupPath(path, { follow: !dontFollow }); | |
| var node = lookup.node; | |
| if (!node) { | |
| throw new FS.ErrnoError(44); | |
| } | |
| if (!node.node_ops.getattr) { | |
| throw new FS.ErrnoError(63); | |
| } | |
| return node.node_ops.getattr(node); | |
| },lstat:(path) => { | |
| return FS.stat(path, true); | |
| },chmod:(path, mode, dontFollow) => { | |
| var node; | |
| if (typeof path == 'string') { | |
| var lookup = FS.lookupPath(path, { follow: !dontFollow }); | |
| node = lookup.node; | |
| } else { | |
| node = path; | |
| } | |
| if (!node.node_ops.setattr) { | |
| throw new FS.ErrnoError(63); | |
| } | |
| node.node_ops.setattr(node, { | |
| mode: (mode & 4095) | (node.mode & ~4095), | |
| timestamp: Date.now() | |
| }); | |
| },lchmod:(path, mode) => { | |
| FS.chmod(path, mode, true); | |
| },fchmod:(fd, mode) => { | |
| var stream = FS.getStream(fd); | |
| if (!stream) { | |
| throw new FS.ErrnoError(8); | |
| } | |
| FS.chmod(stream.node, mode); | |
| },chown:(path, uid, gid, dontFollow) => { | |
| var node; | |
| if (typeof path == 'string') { | |
| var lookup = FS.lookupPath(path, { follow: !dontFollow }); | |
| node = lookup.node; | |
| } else { | |
| node = path; | |
| } | |
| if (!node.node_ops.setattr) { | |
| throw new FS.ErrnoError(63); | |
| } | |
| node.node_ops.setattr(node, { | |
| timestamp: Date.now() | |
| // we ignore the uid / gid for now | |
| }); | |
| },lchown:(path, uid, gid) => { | |
| FS.chown(path, uid, gid, true); | |
| },fchown:(fd, uid, gid) => { | |
| var stream = FS.getStream(fd); | |
| if (!stream) { | |
| throw new FS.ErrnoError(8); | |
| } | |
| FS.chown(stream.node, uid, gid); | |
| },truncate:(path, len) => { | |
| if (len < 0) { | |
| throw new FS.ErrnoError(28); | |
| } | |
| var node; | |
| if (typeof path == 'string') { | |
| var lookup = FS.lookupPath(path, { follow: true }); | |
| node = lookup.node; | |
| } else { | |
| node = path; | |
| } | |
| if (!node.node_ops.setattr) { | |
| throw new FS.ErrnoError(63); | |
| } | |
| if (FS.isDir(node.mode)) { | |
| throw new FS.ErrnoError(31); | |
| } | |
| if (!FS.isFile(node.mode)) { | |
| throw new FS.ErrnoError(28); | |
| } | |
| var errCode = FS.nodePermissions(node, 'w'); | |
| if (errCode) { | |
| throw new FS.ErrnoError(errCode); | |
| } | |
| node.node_ops.setattr(node, { | |
| size: len, | |
| timestamp: Date.now() | |
| }); | |
| },ftruncate:(fd, len) => { | |
| var stream = FS.getStream(fd); | |
| if (!stream) { | |
| throw new FS.ErrnoError(8); | |
| } | |
| if ((stream.flags & 2097155) === 0) { | |
| throw new FS.ErrnoError(28); | |
| } | |
| FS.truncate(stream.node, len); | |
| },utime:(path, atime, mtime) => { | |
| var lookup = FS.lookupPath(path, { follow: true }); | |
| var node = lookup.node; | |
| node.node_ops.setattr(node, { | |
| timestamp: Math.max(atime, mtime) | |
| }); | |
| },open:(path, flags, mode) => { | |
| if (path === "") { | |
| throw new FS.ErrnoError(44); | |
| } | |
| flags = typeof flags == 'string' ? FS.modeStringToFlags(flags) : flags; | |
| mode = typeof mode == 'undefined' ? 438 /* 0666 */ : mode; | |
| if ((flags & 64)) { | |
| mode = (mode & 4095) | 32768; | |
| } else { | |
| mode = 0; | |
| } | |
| var node; | |
| if (typeof path == 'object') { | |
| node = path; | |
| } else { | |
| path = PATH.normalize(path); | |
| try { | |
| var lookup = FS.lookupPath(path, { | |
| follow: !(flags & 131072) | |
| }); | |
| node = lookup.node; | |
| } catch (e) { | |
| // ignore | |
| } | |
| } | |
| // perhaps we need to create the node | |
| var created = false; | |
| if ((flags & 64)) { | |
| if (node) { | |
| // if O_CREAT and O_EXCL are set, error out if the node already exists | |
| if ((flags & 128)) { | |
| throw new FS.ErrnoError(20); | |
| } | |
| } else { | |
| // node doesn't exist, try to create it | |
| node = FS.mknod(path, mode, 0); | |
| created = true; | |
| } | |
| } | |
| if (!node) { | |
| throw new FS.ErrnoError(44); | |
| } | |
| // can't truncate a device | |
| if (FS.isChrdev(node.mode)) { | |
| flags &= ~512; | |
| } | |
| // if asked only for a directory, then this must be one | |
| if ((flags & 65536) && !FS.isDir(node.mode)) { | |
| throw new FS.ErrnoError(54); | |
| } | |
| // check permissions, if this is not a file we just created now (it is ok to | |
| // create and write to a file with read-only permissions; it is read-only | |
| // for later use) | |
| if (!created) { | |
| var errCode = FS.mayOpen(node, flags); | |
| if (errCode) { | |
| throw new FS.ErrnoError(errCode); | |
| } | |
| } | |
| // do truncation if necessary | |
| if ((flags & 512) && !created) { | |
| FS.truncate(node, 0); | |
| } | |
| // we've already handled these, don't pass down to the underlying vfs | |
| flags &= ~(128 | 512 | 131072); | |
| // register the stream with the filesystem | |
| var stream = FS.createStream({ | |
| node: node, | |
| path: FS.getPath(node), // we want the absolute path to the node | |
| flags: flags, | |
| seekable: true, | |
| position: 0, | |
| stream_ops: node.stream_ops, | |
| // used by the file family libc calls (fopen, fwrite, ferror, etc.) | |
| ungotten: [], | |
| error: false | |
| }); | |
| // call the new stream's open function | |
| if (stream.stream_ops.open) { | |
| stream.stream_ops.open(stream); | |
| } | |
| if (Module['logReadFiles'] && !(flags & 1)) { | |
| if (!FS.readFiles) FS.readFiles = {}; | |
| if (!(path in FS.readFiles)) { | |
| FS.readFiles[path] = 1; | |
| } | |
| } | |
| return stream; | |
| },close:(stream) => { | |
| if (FS.isClosed(stream)) { | |
| throw new FS.ErrnoError(8); | |
| } | |
| if (stream.getdents) stream.getdents = null; // free readdir state | |
| try { | |
| if (stream.stream_ops.close) { | |
| stream.stream_ops.close(stream); | |
| } | |
| } catch (e) { | |
| throw e; | |
| } finally { | |
| FS.closeStream(stream.fd); | |
| } | |
| stream.fd = null; | |
| },isClosed:(stream) => { | |
| return stream.fd === null; | |
| },llseek:(stream, offset, whence) => { | |
| if (FS.isClosed(stream)) { | |
| throw new FS.ErrnoError(8); | |
| } | |
| if (!stream.seekable || !stream.stream_ops.llseek) { | |
| throw new FS.ErrnoError(70); | |
| } | |
| if (whence != 0 && whence != 1 && whence != 2) { | |
| throw new FS.ErrnoError(28); | |
| } | |
| stream.position = stream.stream_ops.llseek(stream, offset, whence); | |
| stream.ungotten = []; | |
| return stream.position; | |
| },read:(stream, buffer, offset, length, position) => { | |
| if (length < 0 || position < 0) { | |
| throw new FS.ErrnoError(28); | |
| } | |
| if (FS.isClosed(stream)) { | |
| throw new FS.ErrnoError(8); | |
| } | |
| if ((stream.flags & 2097155) === 1) { | |
| throw new FS.ErrnoError(8); | |
| } | |
| if (FS.isDir(stream.node.mode)) { | |
| throw new FS.ErrnoError(31); | |
| } | |
| if (!stream.stream_ops.read) { | |
| throw new FS.ErrnoError(28); | |
| } | |
| var seeking = typeof position != 'undefined'; | |
| if (!seeking) { | |
| position = stream.position; | |
| } else if (!stream.seekable) { | |
| throw new FS.ErrnoError(70); | |
| } | |
| var bytesRead = stream.stream_ops.read(stream, buffer, offset, length, position); | |
| if (!seeking) stream.position += bytesRead; | |
| return bytesRead; | |
| },write:(stream, buffer, offset, length, position, canOwn) => { | |
| if (length < 0 || position < 0) { | |
| throw new FS.ErrnoError(28); | |
| } | |
| if (FS.isClosed(stream)) { | |
| throw new FS.ErrnoError(8); | |
| } | |
| if ((stream.flags & 2097155) === 0) { | |
| throw new FS.ErrnoError(8); | |
| } | |
| if (FS.isDir(stream.node.mode)) { | |
| throw new FS.ErrnoError(31); | |
| } | |
| if (!stream.stream_ops.write) { | |
| throw new FS.ErrnoError(28); | |
| } | |
| if (stream.seekable && stream.flags & 1024) { | |
| // seek to the end before writing in append mode | |
| FS.llseek(stream, 0, 2); | |
| } | |
| var seeking = typeof position != 'undefined'; | |
| if (!seeking) { | |
| position = stream.position; | |
| } else if (!stream.seekable) { | |
| throw new FS.ErrnoError(70); | |
| } | |
| var bytesWritten = stream.stream_ops.write(stream, buffer, offset, length, position, canOwn); | |
| if (!seeking) stream.position += bytesWritten; | |
| return bytesWritten; | |
| },allocate:(stream, offset, length) => { | |
| if (FS.isClosed(stream)) { | |
| throw new FS.ErrnoError(8); | |
| } | |
| if (offset < 0 || length <= 0) { | |
| throw new FS.ErrnoError(28); | |
| } | |
| if ((stream.flags & 2097155) === 0) { | |
| throw new FS.ErrnoError(8); | |
| } | |
| if (!FS.isFile(stream.node.mode) && !FS.isDir(stream.node.mode)) { | |
| throw new FS.ErrnoError(43); | |
| } | |
| if (!stream.stream_ops.allocate) { | |
| throw new FS.ErrnoError(138); | |
| } | |
| stream.stream_ops.allocate(stream, offset, length); | |
| },mmap:(stream, length, position, prot, flags) => { | |
| // User requests writing to file (prot & PROT_WRITE != 0). | |
| // Checking if we have permissions to write to the file unless | |
| // MAP_PRIVATE flag is set. According to POSIX spec it is possible | |
| // to write to file opened in read-only mode with MAP_PRIVATE flag, | |
| // as all modifications will be visible only in the memory of | |
| // the current process. | |
| if ((prot & 2) !== 0 | |
| && (flags & 2) === 0 | |
| && (stream.flags & 2097155) !== 2) { | |
| throw new FS.ErrnoError(2); | |
| } | |
| if ((stream.flags & 2097155) === 1) { | |
| throw new FS.ErrnoError(2); | |
| } | |
| if (!stream.stream_ops.mmap) { | |
| throw new FS.ErrnoError(43); | |
| } | |
| return stream.stream_ops.mmap(stream, length, position, prot, flags); | |
| },msync:(stream, buffer, offset, length, mmapFlags) => { | |
| if (!stream.stream_ops.msync) { | |
| return 0; | |
| } | |
| return stream.stream_ops.msync(stream, buffer, offset, length, mmapFlags); | |
| },munmap:(stream) => 0,ioctl:(stream, cmd, arg) => { | |
| if (!stream.stream_ops.ioctl) { | |
| throw new FS.ErrnoError(59); | |
| } | |
| return stream.stream_ops.ioctl(stream, cmd, arg); | |
| },readFile:(path, opts = {}) => { | |
| opts.flags = opts.flags || 0; | |
| opts.encoding = opts.encoding || 'binary'; | |
| if (opts.encoding !== 'utf8' && opts.encoding !== 'binary') { | |
| throw new Error('Invalid encoding type "' + opts.encoding + '"'); | |
| } | |
| var ret; | |
| var stream = FS.open(path, opts.flags); | |
| var stat = FS.stat(path); | |
| var length = stat.size; | |
| var buf = new Uint8Array(length); | |
| FS.read(stream, buf, 0, length, 0); | |
| if (opts.encoding === 'utf8') { | |
| ret = UTF8ArrayToString(buf, 0); | |
| } else if (opts.encoding === 'binary') { | |
| ret = buf; | |
| } | |
| FS.close(stream); | |
| return ret; | |
| },writeFile:(path, data, opts = {}) => { | |
| opts.flags = opts.flags || 577; | |
| var stream = FS.open(path, opts.flags, opts.mode); | |
| if (typeof data == 'string') { | |
| var buf = new Uint8Array(lengthBytesUTF8(data)+1); | |
| var actualNumBytes = stringToUTF8Array(data, buf, 0, buf.length); | |
| FS.write(stream, buf, 0, actualNumBytes, undefined, opts.canOwn); | |
| } else if (ArrayBuffer.isView(data)) { | |
| FS.write(stream, data, 0, data.byteLength, undefined, opts.canOwn); | |
| } else { | |
| throw new Error('Unsupported data type'); | |
| } | |
| FS.close(stream); | |
| },cwd:() => FS.currentPath,chdir:(path) => { | |
| var lookup = FS.lookupPath(path, { follow: true }); | |
| if (lookup.node === null) { | |
| throw new FS.ErrnoError(44); | |
| } | |
| if (!FS.isDir(lookup.node.mode)) { | |
| throw new FS.ErrnoError(54); | |
| } | |
| var errCode = FS.nodePermissions(lookup.node, 'x'); | |
| if (errCode) { | |
| throw new FS.ErrnoError(errCode); | |
| } | |
| FS.currentPath = lookup.path; | |
| },createDefaultDirectories:() => { | |
| FS.mkdir('/tmp'); | |
| FS.mkdir('/home'); | |
| FS.mkdir('/home/web_user'); | |
| },createDefaultDevices:() => { | |
| // create /dev | |
| FS.mkdir('/dev'); | |
| // setup /dev/null | |
| FS.registerDevice(FS.makedev(1, 3), { | |
| read: () => 0, | |
| write: (stream, buffer, offset, length, pos) => length, | |
| }); | |
| FS.mkdev('/dev/null', FS.makedev(1, 3)); | |
| // setup /dev/tty and /dev/tty1 | |
| // stderr needs to print output using err() rather than out() | |
| // so we register a second tty just for it. | |
| TTY.register(FS.makedev(5, 0), TTY.default_tty_ops); | |
| TTY.register(FS.makedev(6, 0), TTY.default_tty1_ops); | |
| FS.mkdev('/dev/tty', FS.makedev(5, 0)); | |
| FS.mkdev('/dev/tty1', FS.makedev(6, 0)); | |
| // setup /dev/[u]random | |
| var random_device = getRandomDevice(); | |
| FS.createDevice('/dev', 'random', random_device); | |
| FS.createDevice('/dev', 'urandom', random_device); | |
| // we're not going to emulate the actual shm device, | |
| // just create the tmp dirs that reside in it commonly | |
| FS.mkdir('/dev/shm'); | |
| FS.mkdir('/dev/shm/tmp'); | |
| },createSpecialDirectories:() => { | |
| // create /proc/self/fd which allows /proc/self/fd/6 => readlink gives the | |
| // name of the stream for fd 6 (see test_unistd_ttyname) | |
| FS.mkdir('/proc'); | |
| var proc_self = FS.mkdir('/proc/self'); | |
| FS.mkdir('/proc/self/fd'); | |
| FS.mount({ | |
| mount: () => { | |
| var node = FS.createNode(proc_self, 'fd', 16384 | 511 /* 0777 */, 73); | |
| node.node_ops = { | |
| lookup: (parent, name) => { | |
| var fd = +name; | |
| var stream = FS.getStream(fd); | |
| if (!stream) throw new FS.ErrnoError(8); | |
| var ret = { | |
| parent: null, | |
| mount: { mountpoint: 'fake' }, | |
| node_ops: { readlink: () => stream.path }, | |
| }; | |
| ret.parent = ret; // make it look like a simple root node | |
| return ret; | |
| } | |
| }; | |
| return node; | |
| } | |
| }, {}, '/proc/self/fd'); | |
| },createStandardStreams:() => { | |
| // TODO deprecate the old functionality of a single | |
| // input / output callback and that utilizes FS.createDevice | |
| // and instead require a unique set of stream ops | |
| // by default, we symlink the standard streams to the | |
| // default tty devices. however, if the standard streams | |
| // have been overwritten we create a unique device for | |
| // them instead. | |
| if (Module['stdin']) { | |
| FS.createDevice('/dev', 'stdin', Module['stdin']); | |
| } else { | |
| FS.symlink('/dev/tty', '/dev/stdin'); | |
| } | |
| if (Module['stdout']) { | |
| FS.createDevice('/dev', 'stdout', null, Module['stdout']); | |
| } else { | |
| FS.symlink('/dev/tty', '/dev/stdout'); | |
| } | |
| if (Module['stderr']) { | |
| FS.createDevice('/dev', 'stderr', null, Module['stderr']); | |
| } else { | |
| FS.symlink('/dev/tty1', '/dev/stderr'); | |
| } | |
| // open default streams for the stdin, stdout and stderr devices | |
| var stdin = FS.open('/dev/stdin', 0); | |
| var stdout = FS.open('/dev/stdout', 1); | |
| var stderr = FS.open('/dev/stderr', 1); | |
| assert(stdin.fd === 0, 'invalid handle for stdin (' + stdin.fd + ')'); | |
| assert(stdout.fd === 1, 'invalid handle for stdout (' + stdout.fd + ')'); | |
| assert(stderr.fd === 2, 'invalid handle for stderr (' + stderr.fd + ')'); | |
| },ensureErrnoError:() => { | |
| if (FS.ErrnoError) return; | |
| FS.ErrnoError = /** @this{Object} */ function ErrnoError(errno, node) { | |
| this.node = node; | |
| this.setErrno = /** @this{Object} */ function(errno) { | |
| this.errno = errno; | |
| for (var key in ERRNO_CODES) { | |
| if (ERRNO_CODES[key] === errno) { | |
| this.code = key; | |
| break; | |
| } | |
| } | |
| }; | |
| this.setErrno(errno); | |
| this.message = ERRNO_MESSAGES[errno]; | |
| // Try to get a maximally helpful stack trace. On Node.js, getting Error.stack | |
| // now ensures it shows what we want. | |
| if (this.stack) { | |
| // Define the stack property for Node.js 4, which otherwise errors on the next line. | |
| Object.defineProperty(this, "stack", { value: (new Error).stack, writable: true }); | |
| this.stack = demangleAll(this.stack); | |
| } | |
| }; | |
| FS.ErrnoError.prototype = new Error(); | |
| FS.ErrnoError.prototype.constructor = FS.ErrnoError; | |
| // Some errors may happen quite a bit, to avoid overhead we reuse them (and suffer a lack of stack info) | |
| [44].forEach((code) => { | |
| FS.genericErrors[code] = new FS.ErrnoError(code); | |
| FS.genericErrors[code].stack = '<generic error, no stack>'; | |
| }); | |
| },staticInit:() => { | |
| FS.ensureErrnoError(); | |
| FS.nameTable = new Array(4096); | |
| FS.mount(MEMFS, {}, '/'); | |
| FS.createDefaultDirectories(); | |
| FS.createDefaultDevices(); | |
| FS.createSpecialDirectories(); | |
| FS.filesystems = { | |
| 'MEMFS': MEMFS, | |
| }; | |
| },init:(input, output, error) => { | |
| assert(!FS.init.initialized, 'FS.init was previously called. If you want to initialize later with custom parameters, remove any earlier calls (note that one is automatically added to the generated code)'); | |
| FS.init.initialized = true; | |
| FS.ensureErrnoError(); | |
| // Allow Module.stdin etc. to provide defaults, if none explicitly passed to us here | |
| Module['stdin'] = input || Module['stdin']; | |
| Module['stdout'] = output || Module['stdout']; | |
| Module['stderr'] = error || Module['stderr']; | |
| FS.createStandardStreams(); | |
| },quit:() => { | |
| FS.init.initialized = false; | |
| // force-flush all streams, so we get musl std streams printed out | |
| _fflush(0); | |
| // close all of our streams | |
| for (var i = 0; i < FS.streams.length; i++) { | |
| var stream = FS.streams[i]; | |
| if (!stream) { | |
| continue; | |
| } | |
| FS.close(stream); | |
| } | |
| },getMode:(canRead, canWrite) => { | |
| var mode = 0; | |
| if (canRead) mode |= 292 | 73; | |
| if (canWrite) mode |= 146; | |
| return mode; | |
| },findObject:(path, dontResolveLastLink) => { | |
| var ret = FS.analyzePath(path, dontResolveLastLink); | |
| if (!ret.exists) { | |
| return null; | |
| } | |
| return ret.object; | |
| },analyzePath:(path, dontResolveLastLink) => { | |
| // operate from within the context of the symlink's target | |
| try { | |
| var lookup = FS.lookupPath(path, { follow: !dontResolveLastLink }); | |
| path = lookup.path; | |
| } catch (e) { | |
| } | |
| var ret = { | |
| isRoot: false, exists: false, error: 0, name: null, path: null, object: null, | |
| parentExists: false, parentPath: null, parentObject: null | |
| }; | |
| try { | |
| var lookup = FS.lookupPath(path, { parent: true }); | |
| ret.parentExists = true; | |
| ret.parentPath = lookup.path; | |
| ret.parentObject = lookup.node; | |
| ret.name = PATH.basename(path); | |
| lookup = FS.lookupPath(path, { follow: !dontResolveLastLink }); | |
| ret.exists = true; | |
| ret.path = lookup.path; | |
| ret.object = lookup.node; | |
| ret.name = lookup.node.name; | |
| ret.isRoot = lookup.path === '/'; | |
| } catch (e) { | |
| ret.error = e.errno; | |
| }; | |
| return ret; | |
| },createPath:(parent, path, canRead, canWrite) => { | |
| parent = typeof parent == 'string' ? parent : FS.getPath(parent); | |
| var parts = path.split('/').reverse(); | |
| while (parts.length) { | |
| var part = parts.pop(); | |
| if (!part) continue; | |
| var current = PATH.join2(parent, part); | |
| try { | |
| FS.mkdir(current); | |
| } catch (e) { | |
| // ignore EEXIST | |
| } | |
| parent = current; | |
| } | |
| return current; | |
| },createFile:(parent, name, properties, canRead, canWrite) => { | |
| var path = PATH.join2(typeof parent == 'string' ? parent : FS.getPath(parent), name); | |
| var mode = FS.getMode(canRead, canWrite); | |
| return FS.create(path, mode); | |
| },createDataFile:(parent, name, data, canRead, canWrite, canOwn) => { | |
| var path = name; | |
| if (parent) { | |
| parent = typeof parent == 'string' ? parent : FS.getPath(parent); | |
| path = name ? PATH.join2(parent, name) : parent; | |
| } | |
| var mode = FS.getMode(canRead, canWrite); | |
| var node = FS.create(path, mode); | |
| if (data) { | |
| if (typeof data == 'string') { | |
| var arr = new Array(data.length); | |
| for (var i = 0, len = data.length; i < len; ++i) arr[i] = data.charCodeAt(i); | |
| data = arr; | |
| } | |
| // make sure we can write to the file | |
| FS.chmod(node, mode | 146); | |
| var stream = FS.open(node, 577); | |
| FS.write(stream, data, 0, data.length, 0, canOwn); | |
| FS.close(stream); | |
| FS.chmod(node, mode); | |
| } | |
| return node; | |
| },createDevice:(parent, name, input, output) => { | |
| var path = PATH.join2(typeof parent == 'string' ? parent : FS.getPath(parent), name); | |
| var mode = FS.getMode(!!input, !!output); | |
| if (!FS.createDevice.major) FS.createDevice.major = 64; | |
| var dev = FS.makedev(FS.createDevice.major++, 0); | |
| // Create a fake device that a set of stream ops to emulate | |
| // the old behavior. | |
| FS.registerDevice(dev, { | |
| open: (stream) => { | |
| stream.seekable = false; | |
| }, | |
| close: (stream) => { | |
| // flush any pending line data | |
| if (output && output.buffer && output.buffer.length) { | |
| output(10); | |
| } | |
| }, | |
| read: (stream, buffer, offset, length, pos /* ignored */) => { | |
| var bytesRead = 0; | |
| for (var i = 0; i < length; i++) { | |
| var result; | |
| try { | |
| result = input(); | |
| } catch (e) { | |
| throw new FS.ErrnoError(29); | |
| } | |
| if (result === undefined && bytesRead === 0) { | |
| throw new FS.ErrnoError(6); | |
| } | |
| if (result === null || result === undefined) break; | |
| bytesRead++; | |
| buffer[offset+i] = result; | |
| } | |
| if (bytesRead) { | |
| stream.node.timestamp = Date.now(); | |
| } | |
| return bytesRead; | |
| }, | |
| write: (stream, buffer, offset, length, pos) => { | |
| for (var i = 0; i < length; i++) { | |
| try { | |
| output(buffer[offset+i]); | |
| } catch (e) { | |
| throw new FS.ErrnoError(29); | |
| } | |
| } | |
| if (length) { | |
| stream.node.timestamp = Date.now(); | |
| } | |
| return i; | |
| } | |
| }); | |
| return FS.mkdev(path, mode, dev); | |
| },forceLoadFile:(obj) => { | |
| if (obj.isDevice || obj.isFolder || obj.link || obj.contents) return true; | |
| if (typeof XMLHttpRequest != 'undefined') { | |
| throw new Error("Lazy loading should have been performed (contents set) in createLazyFile, but it was not. Lazy loading only works in web workers. Use --embed-file or --preload-file in emcc on the main thread."); | |
| } else if (read_) { | |
| // Command-line. | |
| try { | |
| // WARNING: Can't read binary files in V8's d8 or tracemonkey's js, as | |
| // read() will try to parse UTF8. | |
| obj.contents = intArrayFromString(read_(obj.url), true); | |
| obj.usedBytes = obj.contents.length; | |
| } catch (e) { | |
| throw new FS.ErrnoError(29); | |
| } | |
| } else { | |
| throw new Error('Cannot load without read() or XMLHttpRequest.'); | |
| } | |
| },createLazyFile:(parent, name, url, canRead, canWrite) => { | |
| // Lazy chunked Uint8Array (implements get and length from Uint8Array). Actual getting is abstracted away for eventual reuse. | |
| /** @constructor */ | |
| function LazyUint8Array() { | |
| this.lengthKnown = false; | |
| this.chunks = []; // Loaded chunks. Index is the chunk number | |
| } | |
| LazyUint8Array.prototype.get = /** @this{Object} */ function LazyUint8Array_get(idx) { | |
| if (idx > this.length-1 || idx < 0) { | |
| return undefined; | |
| } | |
| var chunkOffset = idx % this.chunkSize; | |
| var chunkNum = (idx / this.chunkSize)|0; | |
| return this.getter(chunkNum)[chunkOffset]; | |
| }; | |
| LazyUint8Array.prototype.setDataGetter = function LazyUint8Array_setDataGetter(getter) { | |
| this.getter = getter; | |
| }; | |
| LazyUint8Array.prototype.cacheLength = function LazyUint8Array_cacheLength() { | |
| // Find length | |
| var xhr = new XMLHttpRequest(); | |
| xhr.open('HEAD', url, false); | |
| xhr.send(null); | |
| if (!(xhr.status >= 200 && xhr.status < 300 || xhr.status === 304)) throw new Error("Couldn't load " + url + ". Status: " + xhr.status); | |
| var datalength = Number(xhr.getResponseHeader("Content-length")); | |
| var header; | |
| var hasByteServing = (header = xhr.getResponseHeader("Accept-Ranges")) && header === "bytes"; | |
| var usesGzip = (header = xhr.getResponseHeader("Content-Encoding")) && header === "gzip"; | |
| var chunkSize = 1024*1024; // Chunk size in bytes | |
| if (!hasByteServing) chunkSize = datalength; | |
| // Function to get a range from the remote URL. | |
| var doXHR = (from, to) => { | |
| if (from > to) throw new Error("invalid range (" + from + ", " + to + ") or no bytes requested!"); | |
| if (to > datalength-1) throw new Error("only " + datalength + " bytes available! programmer error!"); | |
| // TODO: Use mozResponseArrayBuffer, responseStream, etc. if available. | |
| var xhr = new XMLHttpRequest(); | |
| xhr.open('GET', url, false); | |
| if (datalength !== chunkSize) xhr.setRequestHeader("Range", "bytes=" + from + "-" + to); | |
| // Some hints to the browser that we want binary data. | |
| xhr.responseType = 'arraybuffer'; | |
| if (xhr.overrideMimeType) { | |
| xhr.overrideMimeType('text/plain; charset=x-user-defined'); | |
| } | |
| xhr.send(null); | |
| if (!(xhr.status >= 200 && xhr.status < 300 || xhr.status === 304)) throw new Error("Couldn't load " + url + ". Status: " + xhr.status); | |
| if (xhr.response !== undefined) { | |
| return new Uint8Array(/** @type{Array<number>} */(xhr.response || [])); | |
| } | |
| return intArrayFromString(xhr.responseText || '', true); | |
| }; | |
| var lazyArray = this; | |
| lazyArray.setDataGetter((chunkNum) => { | |
| var start = chunkNum * chunkSize; | |
| var end = (chunkNum+1) * chunkSize - 1; // including this byte | |
| end = Math.min(end, datalength-1); // if datalength-1 is selected, this is the last block | |
| if (typeof lazyArray.chunks[chunkNum] == 'undefined') { | |
| lazyArray.chunks[chunkNum] = doXHR(start, end); | |
| } | |
| if (typeof lazyArray.chunks[chunkNum] == 'undefined') throw new Error('doXHR failed!'); | |
| return lazyArray.chunks[chunkNum]; | |
| }); | |
| if (usesGzip || !datalength) { | |
| // if the server uses gzip or doesn't supply the length, we have to download the whole file to get the (uncompressed) length | |
| chunkSize = datalength = 1; // this will force getter(0)/doXHR do download the whole file | |
| datalength = this.getter(0).length; | |
| chunkSize = datalength; | |
| out("LazyFiles on gzip forces download of the whole file when length is accessed"); | |
| } | |
| this._length = datalength; | |
| this._chunkSize = chunkSize; | |
| this.lengthKnown = true; | |
| }; | |
| if (typeof XMLHttpRequest != 'undefined') { | |
| if (!ENVIRONMENT_IS_WORKER) throw 'Cannot do synchronous binary XHRs outside webworkers in modern browsers. Use --embed-file or --preload-file in emcc'; | |
| var lazyArray = new LazyUint8Array(); | |
| Object.defineProperties(lazyArray, { | |
| length: { | |
| get: /** @this{Object} */ function() { | |
| if (!this.lengthKnown) { | |
| this.cacheLength(); | |
| } | |
| return this._length; | |
| } | |
| }, | |
| chunkSize: { | |
| get: /** @this{Object} */ function() { | |
| if (!this.lengthKnown) { | |
| this.cacheLength(); | |
| } | |
| return this._chunkSize; | |
| } | |
| } | |
| }); | |
| var properties = { isDevice: false, contents: lazyArray }; | |
| } else { | |
| var properties = { isDevice: false, url: url }; | |
| } | |
| var node = FS.createFile(parent, name, properties, canRead, canWrite); | |
| // This is a total hack, but I want to get this lazy file code out of the | |
| // core of MEMFS. If we want to keep this lazy file concept I feel it should | |
| // be its own thin LAZYFS proxying calls to MEMFS. | |
| if (properties.contents) { | |
| node.contents = properties.contents; | |
| } else if (properties.url) { | |
| node.contents = null; | |
| node.url = properties.url; | |
| } | |
| // Add a function that defers querying the file size until it is asked the first time. | |
| Object.defineProperties(node, { | |
| usedBytes: { | |
| get: /** @this {FSNode} */ function() { return this.contents.length; } | |
| } | |
| }); | |
| // override each stream op with one that tries to force load the lazy file first | |
| var stream_ops = {}; | |
| var keys = Object.keys(node.stream_ops); | |
| keys.forEach((key) => { | |
| var fn = node.stream_ops[key]; | |
| stream_ops[key] = function forceLoadLazyFile() { | |
| FS.forceLoadFile(node); | |
| return fn.apply(null, arguments); | |
| }; | |
| }); | |
| function writeChunks(stream, buffer, offset, length, position) { | |
| var contents = stream.node.contents; | |
| if (position >= contents.length) | |
| return 0; | |
| var size = Math.min(contents.length - position, length); | |
| assert(size >= 0); | |
| if (contents.slice) { // normal array | |
| for (var i = 0; i < size; i++) { | |
| buffer[offset + i] = contents[position + i]; | |
| } | |
| } else { | |
| for (var i = 0; i < size; i++) { // LazyUint8Array from sync binary XHR | |
| buffer[offset + i] = contents.get(position + i); | |
| } | |
| } | |
| return size; | |
| } | |
| // use a custom read function | |
| stream_ops.read = (stream, buffer, offset, length, position) => { | |
| FS.forceLoadFile(node); | |
| return writeChunks(stream, buffer, offset, length, position) | |
| }; | |
| // use a custom mmap function | |
| stream_ops.mmap = (stream, length, position, prot, flags) => { | |
| FS.forceLoadFile(node); | |
| var ptr = mmapAlloc(length); | |
| if (!ptr) { | |
| throw new FS.ErrnoError(48); | |
| } | |
| writeChunks(stream, HEAP8, ptr, length, position); | |
| return { ptr: ptr, allocated: true }; | |
| }; | |
| node.stream_ops = stream_ops; | |
| return node; | |
| },createPreloadedFile:(parent, name, url, canRead, canWrite, onload, onerror, dontCreateFile, canOwn, preFinish) => { | |
| // TODO we should allow people to just pass in a complete filename instead | |
| // of parent and name being that we just join them anyways | |
| var fullname = name ? PATH_FS.resolve(PATH.join2(parent, name)) : parent; | |
| var dep = getUniqueRunDependency('cp ' + fullname); // might have several active requests for the same fullname | |
| function processData(byteArray) { | |
| function finish(byteArray) { | |
| if (preFinish) preFinish(); | |
| if (!dontCreateFile) { | |
| FS.createDataFile(parent, name, byteArray, canRead, canWrite, canOwn); | |
| } | |
| if (onload) onload(); | |
| removeRunDependency(dep); | |
| } | |
| if (Browser.handledByPreloadPlugin(byteArray, fullname, finish, () => { | |
| if (onerror) onerror(); | |
| removeRunDependency(dep); | |
| })) { | |
| return; | |
| } | |
| finish(byteArray); | |
| } | |
| addRunDependency(dep); | |
| if (typeof url == 'string') { | |
| asyncLoad(url, (byteArray) => processData(byteArray), onerror); | |
| } else { | |
| processData(url); | |
| } | |
| },indexedDB:() => { | |
| return window.indexedDB || window.mozIndexedDB || window.webkitIndexedDB || window.msIndexedDB; | |
| },DB_NAME:() => { | |
| return 'EM_FS_' + window.location.pathname; | |
| },DB_VERSION:20,DB_STORE_NAME:"FILE_DATA",saveFilesToDB:(paths, onload, onerror) => { | |
| onload = onload || (() => {}); | |
| onerror = onerror || (() => {}); | |
| var indexedDB = FS.indexedDB(); | |
| try { | |
| var openRequest = indexedDB.open(FS.DB_NAME(), FS.DB_VERSION); | |
| } catch (e) { | |
| return onerror(e); | |
| } | |
| openRequest.onupgradeneeded = () => { | |
| out('creating db'); | |
| var db = openRequest.result; | |
| db.createObjectStore(FS.DB_STORE_NAME); | |
| }; | |
| openRequest.onsuccess = () => { | |
| var db = openRequest.result; | |
| var transaction = db.transaction([FS.DB_STORE_NAME], 'readwrite'); | |
| var files = transaction.objectStore(FS.DB_STORE_NAME); | |
| var ok = 0, fail = 0, total = paths.length; | |
| function finish() { | |
| if (fail == 0) onload(); else onerror(); | |
| } | |
| paths.forEach((path) => { | |
| var putRequest = files.put(FS.analyzePath(path).object.contents, path); | |
| putRequest.onsuccess = () => { ok++; if (ok + fail == total) finish() }; | |
| putRequest.onerror = () => { fail++; if (ok + fail == total) finish() }; | |
| }); | |
| transaction.onerror = onerror; | |
| }; | |
| openRequest.onerror = onerror; | |
| },loadFilesFromDB:(paths, onload, onerror) => { | |
| onload = onload || (() => {}); | |
| onerror = onerror || (() => {}); | |
| var indexedDB = FS.indexedDB(); | |
| try { | |
| var openRequest = indexedDB.open(FS.DB_NAME(), FS.DB_VERSION); | |
| } catch (e) { | |
| return onerror(e); | |
| } | |
| openRequest.onupgradeneeded = onerror; // no database to load from | |
| openRequest.onsuccess = () => { | |
| var db = openRequest.result; | |
| try { | |
| var transaction = db.transaction([FS.DB_STORE_NAME], 'readonly'); | |
| } catch(e) { | |
| onerror(e); | |
| return; | |
| } | |
| var files = transaction.objectStore(FS.DB_STORE_NAME); | |
| var ok = 0, fail = 0, total = paths.length; | |
| function finish() { | |
| if (fail == 0) onload(); else onerror(); | |
| } | |
| paths.forEach((path) => { | |
| var getRequest = files.get(path); | |
| getRequest.onsuccess = () => { | |
| if (FS.analyzePath(path).exists) { | |
| FS.unlink(path); | |
| } | |
| FS.createDataFile(PATH.dirname(path), PATH.basename(path), getRequest.result, true, true, true); | |
| ok++; | |
| if (ok + fail == total) finish(); | |
| }; | |
| getRequest.onerror = () => { fail++; if (ok + fail == total) finish() }; | |
| }); | |
| transaction.onerror = onerror; | |
| }; | |
| openRequest.onerror = onerror; | |
| },absolutePath:() => { | |
| abort('FS.absolutePath has been removed; use PATH_FS.resolve instead'); | |
| },createFolder:() => { | |
| abort('FS.createFolder has been removed; use FS.mkdir instead'); | |
| },createLink:() => { | |
| abort('FS.createLink has been removed; use FS.symlink instead'); | |
| },joinPath:() => { | |
| abort('FS.joinPath has been removed; use PATH.join instead'); | |
| },mmapAlloc:() => { | |
| abort('FS.mmapAlloc has been replaced by the top level function mmapAlloc'); | |
| },standardizePath:() => { | |
| abort('FS.standardizePath has been removed; use PATH.normalize instead'); | |
| }}; | |
| var SYSCALLS = {DEFAULT_POLLMASK:5,calculateAt:function(dirfd, path, allowEmpty) { | |
| if (PATH.isAbs(path)) { | |
| return path; | |
| } | |
| // relative path | |
| var dir; | |
| if (dirfd === -100) { | |
| dir = FS.cwd(); | |
| } else { | |
| var dirstream = SYSCALLS.getStreamFromFD(dirfd); | |
| dir = dirstream.path; | |
| } | |
| if (path.length == 0) { | |
| if (!allowEmpty) { | |
| throw new FS.ErrnoError(44);; | |
| } | |
| return dir; | |
| } | |
| return PATH.join2(dir, path); | |
| },doStat:function(func, path, buf) { | |
| try { | |
| var stat = func(path); | |
| } catch (e) { | |
| if (e && e.node && PATH.normalize(path) !== PATH.normalize(FS.getPath(e.node))) { | |
| // an error occurred while trying to look up the path; we should just report ENOTDIR | |
| return -54; | |
| } | |
| throw e; | |
| } | |
| HEAP32[((buf)>>2)] = stat.dev; | |
| HEAP32[(((buf)+(8))>>2)] = stat.ino; | |
| HEAP32[(((buf)+(12))>>2)] = stat.mode; | |
| HEAPU32[(((buf)+(16))>>2)] = stat.nlink; | |
| HEAP32[(((buf)+(20))>>2)] = stat.uid; | |
| HEAP32[(((buf)+(24))>>2)] = stat.gid; | |
| HEAP32[(((buf)+(28))>>2)] = stat.rdev; | |
| (tempI64 = [stat.size>>>0,(tempDouble=stat.size,(+(Math.abs(tempDouble))) >= 1.0 ? (tempDouble > 0.0 ? ((Math.min((+(Math.floor((tempDouble)/4294967296.0))), 4294967295.0))|0)>>>0 : (~~((+(Math.ceil((tempDouble - +(((~~(tempDouble)))>>>0))/4294967296.0)))))>>>0) : 0)],HEAP32[(((buf)+(40))>>2)] = tempI64[0],HEAP32[(((buf)+(44))>>2)] = tempI64[1]); | |
| HEAP32[(((buf)+(48))>>2)] = 4096; | |
| HEAP32[(((buf)+(52))>>2)] = stat.blocks; | |
| (tempI64 = [Math.floor(stat.atime.getTime() / 1000)>>>0,(tempDouble=Math.floor(stat.atime.getTime() / 1000),(+(Math.abs(tempDouble))) >= 1.0 ? (tempDouble > 0.0 ? ((Math.min((+(Math.floor((tempDouble)/4294967296.0))), 4294967295.0))|0)>>>0 : (~~((+(Math.ceil((tempDouble - +(((~~(tempDouble)))>>>0))/4294967296.0)))))>>>0) : 0)],HEAP32[(((buf)+(56))>>2)] = tempI64[0],HEAP32[(((buf)+(60))>>2)] = tempI64[1]); | |
| HEAPU32[(((buf)+(64))>>2)] = 0; | |
| (tempI64 = [Math.floor(stat.mtime.getTime() / 1000)>>>0,(tempDouble=Math.floor(stat.mtime.getTime() / 1000),(+(Math.abs(tempDouble))) >= 1.0 ? (tempDouble > 0.0 ? ((Math.min((+(Math.floor((tempDouble)/4294967296.0))), 4294967295.0))|0)>>>0 : (~~((+(Math.ceil((tempDouble - +(((~~(tempDouble)))>>>0))/4294967296.0)))))>>>0) : 0)],HEAP32[(((buf)+(72))>>2)] = tempI64[0],HEAP32[(((buf)+(76))>>2)] = tempI64[1]); | |
| HEAPU32[(((buf)+(80))>>2)] = 0; | |
| (tempI64 = [Math.floor(stat.ctime.getTime() / 1000)>>>0,(tempDouble=Math.floor(stat.ctime.getTime() / 1000),(+(Math.abs(tempDouble))) >= 1.0 ? (tempDouble > 0.0 ? ((Math.min((+(Math.floor((tempDouble)/4294967296.0))), 4294967295.0))|0)>>>0 : (~~((+(Math.ceil((tempDouble - +(((~~(tempDouble)))>>>0))/4294967296.0)))))>>>0) : 0)],HEAP32[(((buf)+(88))>>2)] = tempI64[0],HEAP32[(((buf)+(92))>>2)] = tempI64[1]); | |
| HEAPU32[(((buf)+(96))>>2)] = 0; | |
| (tempI64 = [stat.ino>>>0,(tempDouble=stat.ino,(+(Math.abs(tempDouble))) >= 1.0 ? (tempDouble > 0.0 ? ((Math.min((+(Math.floor((tempDouble)/4294967296.0))), 4294967295.0))|0)>>>0 : (~~((+(Math.ceil((tempDouble - +(((~~(tempDouble)))>>>0))/4294967296.0)))))>>>0) : 0)],HEAP32[(((buf)+(104))>>2)] = tempI64[0],HEAP32[(((buf)+(108))>>2)] = tempI64[1]); | |
| return 0; | |
| },doMsync:function(addr, stream, len, flags, offset) { | |
| if (!FS.isFile(stream.node.mode)) { | |
| throw new FS.ErrnoError(43); | |
| } | |
| if (flags & 2) { | |
| // MAP_PRIVATE calls need not to be synced back to underlying fs | |
| return 0; | |
| } | |
| var buffer = HEAPU8.slice(addr, addr + len); | |
| FS.msync(stream, buffer, offset, len, flags); | |
| },varargs:undefined,get:function() { | |
| assert(SYSCALLS.varargs != undefined); | |
| SYSCALLS.varargs += 4; | |
| var ret = HEAP32[(((SYSCALLS.varargs)-(4))>>2)]; | |
| return ret; | |
| },getStr:function(ptr) { | |
| var ret = UTF8ToString(ptr); | |
| return ret; | |
| },getStreamFromFD:function(fd) { | |
| var stream = FS.getStream(fd); | |
| if (!stream) throw new FS.ErrnoError(8); | |
| return stream; | |
| }}; | |
| function ___syscall_fcntl64(fd, cmd, varargs) { | |
| SYSCALLS.varargs = varargs; | |
| try { | |
| var stream = SYSCALLS.getStreamFromFD(fd); | |
| switch (cmd) { | |
| case 0: { | |
| var arg = SYSCALLS.get(); | |
| if (arg < 0) { | |
| return -28; | |
| } | |
| var newStream; | |
| newStream = FS.createStream(stream, arg); | |
| return newStream.fd; | |
| } | |
| case 1: | |
| case 2: | |
| return 0; // FD_CLOEXEC makes no sense for a single process. | |
| case 3: | |
| return stream.flags; | |
| case 4: { | |
| var arg = SYSCALLS.get(); | |
| stream.flags |= arg; | |
| return 0; | |
| } | |
| case 5: | |
| /* case 5: Currently in musl F_GETLK64 has same value as F_GETLK, so omitted to avoid duplicate case blocks. If that changes, uncomment this */ { | |
| var arg = SYSCALLS.get(); | |
| var offset = 0; | |
| // We're always unlocked. | |
| HEAP16[(((arg)+(offset))>>1)] = 2; | |
| return 0; | |
| } | |
| case 6: | |
| case 7: | |
| /* case 6: Currently in musl F_SETLK64 has same value as F_SETLK, so omitted to avoid duplicate case blocks. If that changes, uncomment this */ | |
| /* case 7: Currently in musl F_SETLKW64 has same value as F_SETLKW, so omitted to avoid duplicate case blocks. If that changes, uncomment this */ | |
| return 0; // Pretend that the locking is successful. | |
| case 16: | |
| case 8: | |
| return -28; // These are for sockets. We don't have them fully implemented yet. | |
| case 9: | |
| // musl trusts getown return values, due to a bug where they must be, as they overlap with errors. just return -1 here, so fcntl() returns that, and we set errno ourselves. | |
| setErrNo(28); | |
| return -1; | |
| default: { | |
| return -28; | |
| } | |
| } | |
| } catch (e) { | |
| if (typeof FS == 'undefined' || !(e instanceof FS.ErrnoError)) throw e; | |
| return -e.errno; | |
| } | |
| } | |
| function ___syscall_ioctl(fd, op, varargs) { | |
| SYSCALLS.varargs = varargs; | |
| try { | |
| var stream = SYSCALLS.getStreamFromFD(fd); | |
| switch (op) { | |
| case 21509: | |
| case 21505: { | |
| if (!stream.tty) return -59; | |
| return 0; | |
| } | |
| case 21510: | |
| case 21511: | |
| case 21512: | |
| case 21506: | |
| case 21507: | |
| case 21508: { | |
| if (!stream.tty) return -59; | |
| return 0; // no-op, not actually adjusting terminal settings | |
| } | |
| case 21519: { | |
| if (!stream.tty) return -59; | |
| var argp = SYSCALLS.get(); | |
| HEAP32[((argp)>>2)] = 0; | |
| return 0; | |
| } | |
| case 21520: { | |
| if (!stream.tty) return -59; | |
| return -28; // not supported | |
| } | |
| case 21531: { | |
| var argp = SYSCALLS.get(); | |
| return FS.ioctl(stream, op, argp); | |
| } | |
| case 21523: { | |
| // TODO: in theory we should write to the winsize struct that gets | |
| // passed in, but for now musl doesn't read anything on it | |
| if (!stream.tty) return -59; | |
| return 0; | |
| } | |
| case 21524: { | |
| // TODO: technically, this ioctl call should change the window size. | |
| // but, since emscripten doesn't have any concept of a terminal window | |
| // yet, we'll just silently throw it away as we do TIOCGWINSZ | |
| if (!stream.tty) return -59; | |
| return 0; | |
| } | |
| default: return -28; // not supported | |
| } | |
| } catch (e) { | |
| if (typeof FS == 'undefined' || !(e instanceof FS.ErrnoError)) throw e; | |
| return -e.errno; | |
| } | |
| } | |
| function ___syscall_openat(dirfd, path, flags, varargs) { | |
| SYSCALLS.varargs = varargs; | |
| try { | |
| path = SYSCALLS.getStr(path); | |
| path = SYSCALLS.calculateAt(dirfd, path); | |
| var mode = varargs ? SYSCALLS.get() : 0; | |
| return FS.open(path, flags, mode).fd; | |
| } catch (e) { | |
| if (typeof FS == 'undefined' || !(e instanceof FS.ErrnoError)) throw e; | |
| return -e.errno; | |
| } | |
| } | |
| function _emscripten_date_now() { | |
| return Date.now(); | |
| } | |
| function _emscripten_memcpy_big(dest, src, num) { | |
| HEAPU8.copyWithin(dest, src, src + num); | |
| } | |
| function getHeapMax() { | |
| // Stay one Wasm page short of 4GB: while e.g. Chrome is able to allocate | |
| // full 4GB Wasm memories, the size will wrap back to 0 bytes in Wasm side | |
| // for any code that deals with heap sizes, which would require special | |
| // casing all heap size related code to treat 0 specially. | |
| return 2147483648; | |
| } | |
| function emscripten_realloc_buffer(size) { | |
| try { | |
| // round size grow request up to wasm page size (fixed 64KB per spec) | |
| wasmMemory.grow((size - buffer.byteLength + 65535) >>> 16); // .grow() takes a delta compared to the previous size | |
| updateGlobalBufferAndViews(wasmMemory.buffer); | |
| return 1 /*success*/; | |
| } catch(e) { | |
| err('emscripten_realloc_buffer: Attempted to grow heap from ' + buffer.byteLength + ' bytes to ' + size + ' bytes, but got error: ' + e); | |
| } | |
| // implicit 0 return to save code size (caller will cast "undefined" into 0 | |
| // anyhow) | |
| } | |
| function _emscripten_resize_heap(requestedSize) { | |
| var oldSize = HEAPU8.length; | |
| requestedSize = requestedSize >>> 0; | |
| // With multithreaded builds, races can happen (another thread might increase the size | |
| // in between), so return a failure, and let the caller retry. | |
| assert(requestedSize > oldSize); | |
| // Memory resize rules: | |
| // 1. Always increase heap size to at least the requested size, rounded up | |
| // to next page multiple. | |
| // 2a. If MEMORY_GROWTH_LINEAR_STEP == -1, excessively resize the heap | |
| // geometrically: increase the heap size according to | |
| // MEMORY_GROWTH_GEOMETRIC_STEP factor (default +20%), At most | |
| // overreserve by MEMORY_GROWTH_GEOMETRIC_CAP bytes (default 96MB). | |
| // 2b. If MEMORY_GROWTH_LINEAR_STEP != -1, excessively resize the heap | |
| // linearly: increase the heap size by at least | |
| // MEMORY_GROWTH_LINEAR_STEP bytes. | |
| // 3. Max size for the heap is capped at 2048MB-WASM_PAGE_SIZE, or by | |
| // MAXIMUM_MEMORY, or by ASAN limit, depending on which is smallest | |
| // 4. If we were unable to allocate as much memory, it may be due to | |
| // over-eager decision to excessively reserve due to (3) above. | |
| // Hence if an allocation fails, cut down on the amount of excess | |
| // growth, in an attempt to succeed to perform a smaller allocation. | |
| // A limit is set for how much we can grow. We should not exceed that | |
| // (the wasm binary specifies it, so if we tried, we'd fail anyhow). | |
| var maxHeapSize = getHeapMax(); | |
| if (requestedSize > maxHeapSize) { | |
| err('Cannot enlarge memory, asked to go up to ' + requestedSize + ' bytes, but the limit is ' + maxHeapSize + ' bytes!'); | |
| return false; | |
| } | |
| let alignUp = (x, multiple) => x + (multiple - x % multiple) % multiple; | |
| // Loop through potential heap size increases. If we attempt a too eager | |
| // reservation that fails, cut down on the attempted size and reserve a | |
| // smaller bump instead. (max 3 times, chosen somewhat arbitrarily) | |
| for (var cutDown = 1; cutDown <= 4; cutDown *= 2) { | |
| var overGrownHeapSize = oldSize * (1 + 0.2 / cutDown); // ensure geometric growth | |
| // but limit overreserving (default to capping at +96MB overgrowth at most) | |
| overGrownHeapSize = Math.min(overGrownHeapSize, requestedSize + 100663296 ); | |
| var newSize = Math.min(maxHeapSize, alignUp(Math.max(requestedSize, overGrownHeapSize), 65536)); | |
| var replacement = emscripten_realloc_buffer(newSize); | |
| if (replacement) { | |
| return true; | |
| } | |
| } | |
| err('Failed to grow the heap from ' + oldSize + ' bytes to ' + newSize + ' bytes, not enough memory!'); | |
| return false; | |
| } | |
| function handleException(e) { | |
| // Certain exception types we do not treat as errors since they are used for | |
| // internal control flow. | |
| // 1. ExitStatus, which is thrown by exit() | |
| // 2. "unwind", which is thrown by emscripten_unwind_to_js_event_loop() and others | |
| // that wish to return to JS event loop. | |
| if (e instanceof ExitStatus || e == 'unwind') { | |
| return EXITSTATUS; | |
| } | |
| checkStackCookie(); | |
| if (e instanceof WebAssembly.RuntimeError) { | |
| if (_emscripten_stack_get_current() <= 0) { | |
| err('Stack overflow detected. You can try increasing -sSTACK_SIZE (currently set to ' + STACK_SIZE + ')'); | |
| } | |
| } | |
| quit_(1, e); | |
| } | |
| function callUserCallback(func) { | |
| if (ABORT) { | |
| err('user callback triggered after runtime exited or application aborted. Ignoring.'); | |
| return; | |
| } | |
| try { | |
| func(); | |
| } catch (e) { | |
| handleException(e); | |
| } | |
| } | |
| /** @param {number=} timeout */ | |
| function safeSetTimeout(func, timeout) { | |
| return setTimeout(function() { | |
| callUserCallback(func); | |
| }, timeout); | |
| } | |
| var Browser = {mainLoop:{running:false,scheduler:null,method:"",currentlyRunningMainloop:0,func:null,arg:0,timingMode:0,timingValue:0,currentFrameNumber:0,queue:[],pause:function() { | |
| Browser.mainLoop.scheduler = null; | |
| // Incrementing this signals the previous main loop that it's now become old, and it must return. | |
| Browser.mainLoop.currentlyRunningMainloop++; | |
| },resume:function() { | |
| Browser.mainLoop.currentlyRunningMainloop++; | |
| var timingMode = Browser.mainLoop.timingMode; | |
| var timingValue = Browser.mainLoop.timingValue; | |
| var func = Browser.mainLoop.func; | |
| Browser.mainLoop.func = null; | |
| // do not set timing and call scheduler, we will do it on the next lines | |
| setMainLoop(func, 0, false, Browser.mainLoop.arg, true); | |
| _emscripten_set_main_loop_timing(timingMode, timingValue); | |
| Browser.mainLoop.scheduler(); | |
| },updateStatus:function() { | |
| if (Module['setStatus']) { | |
| var message = Module['statusMessage'] || 'Please wait...'; | |
| var remaining = Browser.mainLoop.remainingBlockers; | |
| var expected = Browser.mainLoop.expectedBlockers; | |
| if (remaining) { | |
| if (remaining < expected) { | |
| Module['setStatus'](message + ' (' + (expected - remaining) + '/' + expected + ')'); | |
| } else { | |
| Module['setStatus'](message); | |
| } | |
| } else { | |
| Module['setStatus'](''); | |
| } | |
| } | |
| },runIter:function(func) { | |
| if (ABORT) return; | |
| if (Module['preMainLoop']) { | |
| var preRet = Module['preMainLoop'](); | |
| if (preRet === false) { | |
| return; // |return false| skips a frame | |
| } | |
| } | |
| callUserCallback(func); | |
| if (Module['postMainLoop']) Module['postMainLoop'](); | |
| }},isFullscreen:false,pointerLock:false,moduleContextCreatedCallbacks:[],workers:[],init:function() { | |
| if (!Module["preloadPlugins"]) Module["preloadPlugins"] = []; // needs to exist even in workers | |
| if (Browser.initted) return; | |
| Browser.initted = true; | |
| try { | |
| new Blob(); | |
| Browser.hasBlobConstructor = true; | |
| } catch(e) { | |
| Browser.hasBlobConstructor = false; | |
| err("warning: no blob constructor, cannot create blobs with mimetypes"); | |
| } | |
| Browser.BlobBuilder = typeof MozBlobBuilder != "undefined" ? MozBlobBuilder : (typeof WebKitBlobBuilder != "undefined" ? WebKitBlobBuilder : (!Browser.hasBlobConstructor ? err("warning: no BlobBuilder") : null)); | |
| Browser.URLObject = typeof window != "undefined" ? (window.URL ? window.URL : window.webkitURL) : undefined; | |
| if (!Module.noImageDecoding && typeof Browser.URLObject == 'undefined') { | |
| err("warning: Browser does not support creating object URLs. Built-in browser image decoding will not be available."); | |
| Module.noImageDecoding = true; | |
| } | |
| // Support for plugins that can process preloaded files. You can add more of these to | |
| // your app by creating and appending to Module.preloadPlugins. | |
| // | |
| // Each plugin is asked if it can handle a file based on the file's name. If it can, | |
| // it is given the file's raw data. When it is done, it calls a callback with the file's | |
| // (possibly modified) data. For example, a plugin might decompress a file, or it | |
| // might create some side data structure for use later (like an Image element, etc.). | |
| var imagePlugin = {}; | |
| imagePlugin['canHandle'] = function imagePlugin_canHandle(name) { | |
| return !Module.noImageDecoding && /\.(jpg|jpeg|png|bmp)$/i.test(name); | |
| }; | |
| imagePlugin['handle'] = function imagePlugin_handle(byteArray, name, onload, onerror) { | |
| var b = null; | |
| if (Browser.hasBlobConstructor) { | |
| try { | |
| b = new Blob([byteArray], { type: Browser.getMimetype(name) }); | |
| if (b.size !== byteArray.length) { // Safari bug #118630 | |
| // Safari's Blob can only take an ArrayBuffer | |
| b = new Blob([(new Uint8Array(byteArray)).buffer], { type: Browser.getMimetype(name) }); | |
| } | |
| } catch(e) { | |
| warnOnce('Blob constructor present but fails: ' + e + '; falling back to blob builder'); | |
| } | |
| } | |
| if (!b) { | |
| var bb = new Browser.BlobBuilder(); | |
| bb.append((new Uint8Array(byteArray)).buffer); // we need to pass a buffer, and must copy the array to get the right data range | |
| b = bb.getBlob(); | |
| } | |
| var url = Browser.URLObject.createObjectURL(b); | |
| assert(typeof url == 'string', 'createObjectURL must return a url as a string'); | |
| var img = new Image(); | |
| img.onload = () => { | |
| assert(img.complete, 'Image ' + name + ' could not be decoded'); | |
| var canvas = /** @type {!HTMLCanvasElement} */ (document.createElement('canvas')); | |
| canvas.width = img.width; | |
| canvas.height = img.height; | |
| var ctx = canvas.getContext('2d'); | |
| ctx.drawImage(img, 0, 0); | |
| preloadedImages[name] = canvas; | |
| Browser.URLObject.revokeObjectURL(url); | |
| if (onload) onload(byteArray); | |
| }; | |
| img.onerror = (event) => { | |
| out('Image ' + url + ' could not be decoded'); | |
| if (onerror) onerror(); | |
| }; | |
| img.src = url; | |
| }; | |
| Module['preloadPlugins'].push(imagePlugin); | |
| var audioPlugin = {}; | |
| audioPlugin['canHandle'] = function audioPlugin_canHandle(name) { | |
| return !Module.noAudioDecoding && name.substr(-4) in { '.ogg': 1, '.wav': 1, '.mp3': 1 }; | |
| }; | |
| audioPlugin['handle'] = function audioPlugin_handle(byteArray, name, onload, onerror) { | |
| var done = false; | |
| function finish(audio) { | |
| if (done) return; | |
| done = true; | |
| preloadedAudios[name] = audio; | |
| if (onload) onload(byteArray); | |
| } | |
| function fail() { | |
| if (done) return; | |
| done = true; | |
| preloadedAudios[name] = new Audio(); // empty shim | |
| if (onerror) onerror(); | |
| } | |
| if (Browser.hasBlobConstructor) { | |
| try { | |
| var b = new Blob([byteArray], { type: Browser.getMimetype(name) }); | |
| } catch(e) { | |
| return fail(); | |
| } | |
| var url = Browser.URLObject.createObjectURL(b); // XXX we never revoke this! | |
| assert(typeof url == 'string', 'createObjectURL must return a url as a string'); | |
| var audio = new Audio(); | |
| audio.addEventListener('canplaythrough', () => finish(audio), false); // use addEventListener due to chromium bug 124926 | |
| audio.onerror = function audio_onerror(event) { | |
| if (done) return; | |
| err('warning: browser could not fully decode audio ' + name + ', trying slower base64 approach'); | |
| function encode64(data) { | |
| var BASE = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/'; | |
| var PAD = '='; | |
| var ret = ''; | |
| var leftchar = 0; | |
| var leftbits = 0; | |
| for (var i = 0; i < data.length; i++) { | |
| leftchar = (leftchar << 8) | data[i]; | |
| leftbits += 8; | |
| while (leftbits >= 6) { | |
| var curr = (leftchar >> (leftbits-6)) & 0x3f; | |
| leftbits -= 6; | |
| ret += BASE[curr]; | |
| } | |
| } | |
| if (leftbits == 2) { | |
| ret += BASE[(leftchar&3) << 4]; | |
| ret += PAD + PAD; | |
| } else if (leftbits == 4) { | |
| ret += BASE[(leftchar&0xf) << 2]; | |
| ret += PAD; | |
| } | |
| return ret; | |
| } | |
| audio.src = 'data:audio/x-' + name.substr(-3) + ';base64,' + encode64(byteArray); | |
| finish(audio); // we don't wait for confirmation this worked - but it's worth trying | |
| }; | |
| audio.src = url; | |
| // workaround for chrome bug 124926 - we do not always get oncanplaythrough or onerror | |
| safeSetTimeout(function() { | |
| finish(audio); // try to use it even though it is not necessarily ready to play | |
| }, 10000); | |
| } else { | |
| return fail(); | |
| } | |
| }; | |
| Module['preloadPlugins'].push(audioPlugin); | |
| // Canvas event setup | |
| function pointerLockChange() { | |
| Browser.pointerLock = document['pointerLockElement'] === Module['canvas'] || | |
| document['mozPointerLockElement'] === Module['canvas'] || | |
| document['webkitPointerLockElement'] === Module['canvas'] || | |
| document['msPointerLockElement'] === Module['canvas']; | |
| } | |
| var canvas = Module['canvas']; | |
| if (canvas) { | |
| // forced aspect ratio can be enabled by defining 'forcedAspectRatio' on Module | |
| // Module['forcedAspectRatio'] = 4 / 3; | |
| canvas.requestPointerLock = canvas['requestPointerLock'] || | |
| canvas['mozRequestPointerLock'] || | |
| canvas['webkitRequestPointerLock'] || | |
| canvas['msRequestPointerLock'] || | |
| (() => {}); | |
| canvas.exitPointerLock = document['exitPointerLock'] || | |
| document['mozExitPointerLock'] || | |
| document['webkitExitPointerLock'] || | |
| document['msExitPointerLock'] || | |
| (() => {}); // no-op if function does not exist | |
| canvas.exitPointerLock = canvas.exitPointerLock.bind(document); | |
| document.addEventListener('pointerlockchange', pointerLockChange, false); | |
| document.addEventListener('mozpointerlockchange', pointerLockChange, false); | |
| document.addEventListener('webkitpointerlockchange', pointerLockChange, false); | |
| document.addEventListener('mspointerlockchange', pointerLockChange, false); | |
| if (Module['elementPointerLock']) { | |
| canvas.addEventListener("click", (ev) => { | |
| if (!Browser.pointerLock && Module['canvas'].requestPointerLock) { | |
| Module['canvas'].requestPointerLock(); | |
| ev.preventDefault(); | |
| } | |
| }, false); | |
| } | |
| } | |
| },handledByPreloadPlugin:function(byteArray, fullname, finish, onerror) { | |
| // Ensure plugins are ready. | |
| Browser.init(); | |
| var handled = false; | |
| Module['preloadPlugins'].forEach(function(plugin) { | |
| if (handled) return; | |
| if (plugin['canHandle'](fullname)) { | |
| plugin['handle'](byteArray, fullname, finish, onerror); | |
| handled = true; | |
| } | |
| }); | |
| return handled; | |
| },createContext:function(/** @type {HTMLCanvasElement} */ canvas, useWebGL, setInModule, webGLContextAttributes) { | |
| if (useWebGL && Module.ctx && canvas == Module.canvas) return Module.ctx; // no need to recreate GL context if it's already been created for this canvas. | |
| var ctx; | |
| var contextHandle; | |
| if (useWebGL) { | |
| // For GLES2/desktop GL compatibility, adjust a few defaults to be different to WebGL defaults, so that they align better with the desktop defaults. | |
| var contextAttributes = { | |
| antialias: false, | |
| alpha: false, | |
| majorVersion: 1, | |
| }; | |
| if (webGLContextAttributes) { | |
| for (var attribute in webGLContextAttributes) { | |
| contextAttributes[attribute] = webGLContextAttributes[attribute]; | |
| } | |
| } | |
| // This check of existence of GL is here to satisfy Closure compiler, which yells if variable GL is referenced below but GL object is not | |
| // actually compiled in because application is not doing any GL operations. TODO: Ideally if GL is not being used, this function | |
| // Browser.createContext() should not even be emitted. | |
| if (typeof GL != 'undefined') { | |
| contextHandle = GL.createContext(canvas, contextAttributes); | |
| if (contextHandle) { | |
| ctx = GL.getContext(contextHandle).GLctx; | |
| } | |
| } | |
| } else { | |
| ctx = canvas.getContext('2d'); | |
| } | |
| if (!ctx) return null; | |
| if (setInModule) { | |
| if (!useWebGL) assert(typeof GLctx == 'undefined', 'cannot set in module if GLctx is used, but we are a non-GL context that would replace it'); | |
| Module.ctx = ctx; | |
| if (useWebGL) GL.makeContextCurrent(contextHandle); | |
| Module.useWebGL = useWebGL; | |
| Browser.moduleContextCreatedCallbacks.forEach(function(callback) { callback() }); | |
| Browser.init(); | |
| } | |
| return ctx; | |
| },destroyContext:function(canvas, useWebGL, setInModule) {},fullscreenHandlersInstalled:false,lockPointer:undefined,resizeCanvas:undefined,requestFullscreen:function(lockPointer, resizeCanvas) { | |
| Browser.lockPointer = lockPointer; | |
| Browser.resizeCanvas = resizeCanvas; | |
| if (typeof Browser.lockPointer == 'undefined') Browser.lockPointer = true; | |
| if (typeof Browser.resizeCanvas == 'undefined') Browser.resizeCanvas = false; | |
| var canvas = Module['canvas']; | |
| function fullscreenChange() { | |
| Browser.isFullscreen = false; | |
| var canvasContainer = canvas.parentNode; | |
| if ((document['fullscreenElement'] || document['mozFullScreenElement'] || | |
| document['msFullscreenElement'] || document['webkitFullscreenElement'] || | |
| document['webkitCurrentFullScreenElement']) === canvasContainer) { | |
| canvas.exitFullscreen = Browser.exitFullscreen; | |
| if (Browser.lockPointer) canvas.requestPointerLock(); | |
| Browser.isFullscreen = true; | |
| if (Browser.resizeCanvas) { | |
| Browser.setFullscreenCanvasSize(); | |
| } else { | |
| Browser.updateCanvasDimensions(canvas); | |
| } | |
| } else { | |
| // remove the full screen specific parent of the canvas again to restore the HTML structure from before going full screen | |
| canvasContainer.parentNode.insertBefore(canvas, canvasContainer); | |
| canvasContainer.parentNode.removeChild(canvasContainer); | |
| if (Browser.resizeCanvas) { | |
| Browser.setWindowedCanvasSize(); | |
| } else { | |
| Browser.updateCanvasDimensions(canvas); | |
| } | |
| } | |
| if (Module['onFullScreen']) Module['onFullScreen'](Browser.isFullscreen); | |
| if (Module['onFullscreen']) Module['onFullscreen'](Browser.isFullscreen); | |
| } | |
| if (!Browser.fullscreenHandlersInstalled) { | |
| Browser.fullscreenHandlersInstalled = true; | |
| document.addEventListener('fullscreenchange', fullscreenChange, false); | |
| document.addEventListener('mozfullscreenchange', fullscreenChange, false); | |
| document.addEventListener('webkitfullscreenchange', fullscreenChange, false); | |
| document.addEventListener('MSFullscreenChange', fullscreenChange, false); | |
| } | |
| // create a new parent to ensure the canvas has no siblings. this allows browsers to optimize full screen performance when its parent is the full screen root | |
| var canvasContainer = document.createElement("div"); | |
| canvas.parentNode.insertBefore(canvasContainer, canvas); | |
| canvasContainer.appendChild(canvas); | |
| // use parent of canvas as full screen root to allow aspect ratio correction (Firefox stretches the root to screen size) | |
| canvasContainer.requestFullscreen = canvasContainer['requestFullscreen'] || | |
| canvasContainer['mozRequestFullScreen'] || | |
| canvasContainer['msRequestFullscreen'] || | |
| (canvasContainer['webkitRequestFullscreen'] ? () => canvasContainer['webkitRequestFullscreen'](Element['ALLOW_KEYBOARD_INPUT']) : null) || | |
| (canvasContainer['webkitRequestFullScreen'] ? () => canvasContainer['webkitRequestFullScreen'](Element['ALLOW_KEYBOARD_INPUT']) : null); | |
| canvasContainer.requestFullscreen(); | |
| },requestFullScreen:function() { | |
| abort('Module.requestFullScreen has been replaced by Module.requestFullscreen (without a capital S)'); | |
| },exitFullscreen:function() { | |
| // This is workaround for chrome. Trying to exit from fullscreen | |
| // not in fullscreen state will cause "TypeError: Document not active" | |
| // in chrome. See https://github.com/emscripten-core/emscripten/pull/8236 | |
| if (!Browser.isFullscreen) { | |
| return false; | |
| } | |
| var CFS = document['exitFullscreen'] || | |
| document['cancelFullScreen'] || | |
| document['mozCancelFullScreen'] || | |
| document['msExitFullscreen'] || | |
| document['webkitCancelFullScreen'] || | |
| (function() {}); | |
| CFS.apply(document, []); | |
| return true; | |
| },nextRAF:0,fakeRequestAnimationFrame:function(func) { | |
| // try to keep 60fps between calls to here | |
| var now = Date.now(); | |
| if (Browser.nextRAF === 0) { | |
| Browser.nextRAF = now + 1000/60; | |
| } else { | |
| while (now + 2 >= Browser.nextRAF) { // fudge a little, to avoid timer jitter causing us to do lots of delay:0 | |
| Browser.nextRAF += 1000/60; | |
| } | |
| } | |
| var delay = Math.max(Browser.nextRAF - now, 0); | |
| setTimeout(func, delay); | |
| },requestAnimationFrame:function(func) { | |
| if (typeof requestAnimationFrame == 'function') { | |
| requestAnimationFrame(func); | |
| return; | |
| } | |
| var RAF = Browser.fakeRequestAnimationFrame; | |
| RAF(func); | |
| },safeSetTimeout:function(func, timeout) { | |
| // Legacy function, this is used by the SDL2 port so we need to keep it | |
| // around at least until that is updated. | |
| // See https://github.com/libsdl-org/SDL/pull/6304 | |
| return safeSetTimeout(func, timeout); | |
| },safeRequestAnimationFrame:function(func) { | |
| return Browser.requestAnimationFrame(function() { | |
| callUserCallback(func); | |
| }); | |
| },getMimetype:function(name) { | |
| return { | |
| 'jpg': 'image/jpeg', | |
| 'jpeg': 'image/jpeg', | |
| 'png': 'image/png', | |
| 'bmp': 'image/bmp', | |
| 'ogg': 'audio/ogg', | |
| 'wav': 'audio/wav', | |
| 'mp3': 'audio/mpeg' | |
| }[name.substr(name.lastIndexOf('.')+1)]; | |
| },getUserMedia:function(func) { | |
| if (!window.getUserMedia) { | |
| window.getUserMedia = navigator['getUserMedia'] || | |
| navigator['mozGetUserMedia']; | |
| } | |
| window.getUserMedia(func); | |
| },getMovementX:function(event) { | |
| return event['movementX'] || | |
| event['mozMovementX'] || | |
| event['webkitMovementX'] || | |
| 0; | |
| },getMovementY:function(event) { | |
| return event['movementY'] || | |
| event['mozMovementY'] || | |
| event['webkitMovementY'] || | |
| 0; | |
| },getMouseWheelDelta:function(event) { | |
| var delta = 0; | |
| switch (event.type) { | |
| case 'DOMMouseScroll': | |
| // 3 lines make up a step | |
| delta = event.detail / 3; | |
| break; | |
| case 'mousewheel': | |
| // 120 units make up a step | |
| delta = event.wheelDelta / 120; | |
| break; | |
| case 'wheel': | |
| delta = event.deltaY | |
| switch (event.deltaMode) { | |
| case 0: | |
| // DOM_DELTA_PIXEL: 100 pixels make up a step | |
| delta /= 100; | |
| break; | |
| case 1: | |
| // DOM_DELTA_LINE: 3 lines make up a step | |
| delta /= 3; | |
| break; | |
| case 2: | |
| // DOM_DELTA_PAGE: A page makes up 80 steps | |
| delta *= 80; | |
| break; | |
| default: | |
| throw 'unrecognized mouse wheel delta mode: ' + event.deltaMode; | |
| } | |
| break; | |
| default: | |
| throw 'unrecognized mouse wheel event: ' + event.type; | |
| } | |
| return delta; | |
| },mouseX:0,mouseY:0,mouseMovementX:0,mouseMovementY:0,touches:{},lastTouches:{},calculateMouseEvent:function(event) { // event should be mousemove, mousedown or mouseup | |
| if (Browser.pointerLock) { | |
| // When the pointer is locked, calculate the coordinates | |
| // based on the movement of the mouse. | |
| // Workaround for Firefox bug 764498 | |
| if (event.type != 'mousemove' && | |
| ('mozMovementX' in event)) { | |
| Browser.mouseMovementX = Browser.mouseMovementY = 0; | |
| } else { | |
| Browser.mouseMovementX = Browser.getMovementX(event); | |
| Browser.mouseMovementY = Browser.getMovementY(event); | |
| } | |
| // check if SDL is available | |
| if (typeof SDL != "undefined") { | |
| Browser.mouseX = SDL.mouseX + Browser.mouseMovementX; | |
| Browser.mouseY = SDL.mouseY + Browser.mouseMovementY; | |
| } else { | |
| // just add the mouse delta to the current absolut mouse position | |
| // FIXME: ideally this should be clamped against the canvas size and zero | |
| Browser.mouseX += Browser.mouseMovementX; | |
| Browser.mouseY += Browser.mouseMovementY; | |
| } | |
| } else { | |
| // Otherwise, calculate the movement based on the changes | |
| // in the coordinates. | |
| var rect = Module["canvas"].getBoundingClientRect(); | |
| var cw = Module["canvas"].width; | |
| var ch = Module["canvas"].height; | |
| // Neither .scrollX or .pageXOffset are defined in a spec, but | |
| // we prefer .scrollX because it is currently in a spec draft. | |
| // (see: http://www.w3.org/TR/2013/WD-cssom-view-20131217/) | |
| var scrollX = ((typeof window.scrollX != 'undefined') ? window.scrollX : window.pageXOffset); | |
| var scrollY = ((typeof window.scrollY != 'undefined') ? window.scrollY : window.pageYOffset); | |
| // If this assert lands, it's likely because the browser doesn't support scrollX or pageXOffset | |
| // and we have no viable fallback. | |
| assert((typeof scrollX != 'undefined') && (typeof scrollY != 'undefined'), 'Unable to retrieve scroll position, mouse positions likely broken.'); | |
| if (event.type === 'touchstart' || event.type === 'touchend' || event.type === 'touchmove') { | |
| var touch = event.touch; | |
| if (touch === undefined) { | |
| return; // the "touch" property is only defined in SDL | |
| } | |
| var adjustedX = touch.pageX - (scrollX + rect.left); | |
| var adjustedY = touch.pageY - (scrollY + rect.top); | |
| adjustedX = adjustedX * (cw / rect.width); | |
| adjustedY = adjustedY * (ch / rect.height); | |
| var coords = { x: adjustedX, y: adjustedY }; | |
| if (event.type === 'touchstart') { | |
| Browser.lastTouches[touch.identifier] = coords; | |
| Browser.touches[touch.identifier] = coords; | |
| } else if (event.type === 'touchend' || event.type === 'touchmove') { | |
| var last = Browser.touches[touch.identifier]; | |
| if (!last) last = coords; | |
| Browser.lastTouches[touch.identifier] = last; | |
| Browser.touches[touch.identifier] = coords; | |
| } | |
| return; | |
| } | |
| var x = event.pageX - (scrollX + rect.left); | |
| var y = event.pageY - (scrollY + rect.top); | |
| // the canvas might be CSS-scaled compared to its backbuffer; | |
| // SDL-using content will want mouse coordinates in terms | |
| // of backbuffer units. | |
| x = x * (cw / rect.width); | |
| y = y * (ch / rect.height); | |
| Browser.mouseMovementX = x - Browser.mouseX; | |
| Browser.mouseMovementY = y - Browser.mouseY; | |
| Browser.mouseX = x; | |
| Browser.mouseY = y; | |
| } | |
| },resizeListeners:[],updateResizeListeners:function() { | |
| var canvas = Module['canvas']; | |
| Browser.resizeListeners.forEach(function(listener) { | |
| listener(canvas.width, canvas.height); | |
| }); | |
| },setCanvasSize:function(width, height, noUpdates) { | |
| var canvas = Module['canvas']; | |
| Browser.updateCanvasDimensions(canvas, width, height); | |
| if (!noUpdates) Browser.updateResizeListeners(); | |
| },windowedWidth:0,windowedHeight:0,setFullscreenCanvasSize:function() { | |
| // check if SDL is available | |
| if (typeof SDL != "undefined") { | |
| var flags = HEAPU32[((SDL.screen)>>2)]; | |
| flags = flags | 0x00800000; // set SDL_FULLSCREEN flag | |
| HEAP32[((SDL.screen)>>2)] = flags; | |
| } | |
| Browser.updateCanvasDimensions(Module['canvas']); | |
| Browser.updateResizeListeners(); | |
| },setWindowedCanvasSize:function() { | |
| // check if SDL is available | |
| if (typeof SDL != "undefined") { | |
| var flags = HEAPU32[((SDL.screen)>>2)]; | |
| flags = flags & ~0x00800000; // clear SDL_FULLSCREEN flag | |
| HEAP32[((SDL.screen)>>2)] = flags; | |
| } | |
| Browser.updateCanvasDimensions(Module['canvas']); | |
| Browser.updateResizeListeners(); | |
| },updateCanvasDimensions:function(canvas, wNative, hNative) { | |
| if (wNative && hNative) { | |
| canvas.widthNative = wNative; | |
| canvas.heightNative = hNative; | |
| } else { | |
| wNative = canvas.widthNative; | |
| hNative = canvas.heightNative; | |
| } | |
| var w = wNative; | |
| var h = hNative; | |
| if (Module['forcedAspectRatio'] && Module['forcedAspectRatio'] > 0) { | |
| if (w/h < Module['forcedAspectRatio']) { | |
| w = Math.round(h * Module['forcedAspectRatio']); | |
| } else { | |
| h = Math.round(w / Module['forcedAspectRatio']); | |
| } | |
| } | |
| if (((document['fullscreenElement'] || document['mozFullScreenElement'] || | |
| document['msFullscreenElement'] || document['webkitFullscreenElement'] || | |
| document['webkitCurrentFullScreenElement']) === canvas.parentNode) && (typeof screen != 'undefined')) { | |
| var factor = Math.min(screen.width / w, screen.height / h); | |
| w = Math.round(w * factor); | |
| h = Math.round(h * factor); | |
| } | |
| if (Browser.resizeCanvas) { | |
| if (canvas.width != w) canvas.width = w; | |
| if (canvas.height != h) canvas.height = h; | |
| if (typeof canvas.style != 'undefined') { | |
| canvas.style.removeProperty( "width"); | |
| canvas.style.removeProperty("height"); | |
| } | |
| } else { | |
| if (canvas.width != wNative) canvas.width = wNative; | |
| if (canvas.height != hNative) canvas.height = hNative; | |
| if (typeof canvas.style != 'undefined') { | |
| if (w != wNative || h != hNative) { | |
| canvas.style.setProperty( "width", w + "px", "important"); | |
| canvas.style.setProperty("height", h + "px", "important"); | |
| } else { | |
| canvas.style.removeProperty( "width"); | |
| canvas.style.removeProperty("height"); | |
| } | |
| } | |
| } | |
| }}; | |
| function _emscripten_set_main_loop_timing(mode, value) { | |
| Browser.mainLoop.timingMode = mode; | |
| Browser.mainLoop.timingValue = value; | |
| if (!Browser.mainLoop.func) { | |
| err('emscripten_set_main_loop_timing: Cannot set timing mode for main loop since a main loop does not exist! Call emscripten_set_main_loop first to set one up.'); | |
| return 1; // Return non-zero on failure, can't set timing mode when there is no main loop. | |
| } | |
| if (!Browser.mainLoop.running) { | |
| Browser.mainLoop.running = true; | |
| } | |
| if (mode == 0 /*EM_TIMING_SETTIMEOUT*/) { | |
| Browser.mainLoop.scheduler = function Browser_mainLoop_scheduler_setTimeout() { | |
| var timeUntilNextTick = Math.max(0, Browser.mainLoop.tickStartTime + value - _emscripten_get_now())|0; | |
| setTimeout(Browser.mainLoop.runner, timeUntilNextTick); // doing this each time means that on exception, we stop | |
| }; | |
| Browser.mainLoop.method = 'timeout'; | |
| } else if (mode == 1 /*EM_TIMING_RAF*/) { | |
| Browser.mainLoop.scheduler = function Browser_mainLoop_scheduler_rAF() { | |
| Browser.requestAnimationFrame(Browser.mainLoop.runner); | |
| }; | |
| Browser.mainLoop.method = 'rAF'; | |
| } else if (mode == 2 /*EM_TIMING_SETIMMEDIATE*/) { | |
| if (typeof setImmediate == 'undefined') { | |
| // Emulate setImmediate. (note: not a complete polyfill, we don't emulate clearImmediate() to keep code size to minimum, since not needed) | |
| var setImmediates = []; | |
| var emscriptenMainLoopMessageId = 'setimmediate'; | |
| /** @param {Event} event */ | |
| var Browser_setImmediate_messageHandler = (event) => { | |
| // When called in current thread or Worker, the main loop ID is structured slightly different to accommodate for --proxy-to-worker runtime listening to Worker events, | |
| // so check for both cases. | |
| if (event.data === emscriptenMainLoopMessageId || event.data.target === emscriptenMainLoopMessageId) { | |
| event.stopPropagation(); | |
| setImmediates.shift()(); | |
| } | |
| }; | |
| addEventListener("message", Browser_setImmediate_messageHandler, true); | |
| setImmediate = /** @type{function(function(): ?, ...?): number} */(function Browser_emulated_setImmediate(func) { | |
| setImmediates.push(func); | |
| if (ENVIRONMENT_IS_WORKER) { | |
| if (Module['setImmediates'] === undefined) Module['setImmediates'] = []; | |
| Module['setImmediates'].push(func); | |
| postMessage({target: emscriptenMainLoopMessageId}); // In --proxy-to-worker, route the message via proxyClient.js | |
| } else postMessage(emscriptenMainLoopMessageId, "*"); // On the main thread, can just send the message to itself. | |
| }) | |
| } | |
| Browser.mainLoop.scheduler = function Browser_mainLoop_scheduler_setImmediate() { | |
| setImmediate(Browser.mainLoop.runner); | |
| }; | |
| Browser.mainLoop.method = 'immediate'; | |
| } | |
| return 0; | |
| } | |
| var _emscripten_get_now;if (ENVIRONMENT_IS_NODE) { | |
| _emscripten_get_now = () => { | |
| var t = process['hrtime'](); | |
| return t[0] * 1e3 + t[1] / 1e6; | |
| }; | |
| } else _emscripten_get_now = () => performance.now(); | |
| ; | |
| function _proc_exit(code) { | |
| EXITSTATUS = code; | |
| if (!keepRuntimeAlive()) { | |
| if (Module['onExit']) Module['onExit'](code); | |
| ABORT = true; | |
| } | |
| quit_(code, new ExitStatus(code)); | |
| } | |
| /** @param {boolean|number=} implicit */ | |
| function exitJS(status, implicit) { | |
| EXITSTATUS = status; | |
| checkUnflushedContent(); | |
| // if exit() was called explicitly, warn the user if the runtime isn't actually being shut down | |
| if (keepRuntimeAlive() && !implicit) { | |
| var msg = 'program exited (with status: ' + status + '), but EXIT_RUNTIME is not set, so halting execution but not exiting the runtime or preventing further async execution (build with EXIT_RUNTIME=1, if you want a true shutdown)'; | |
| err(msg); | |
| } | |
| _proc_exit(status); | |
| } | |
| var _exit = exitJS; | |
| function maybeExit() { | |
| } | |
| /** | |
| * @param {number=} arg | |
| * @param {boolean=} noSetTiming | |
| */ | |
| function setMainLoop(browserIterationFunc, fps, simulateInfiniteLoop, arg, noSetTiming) { | |
| assert(!Browser.mainLoop.func, 'emscripten_set_main_loop: there can only be one main loop function at once: call emscripten_cancel_main_loop to cancel the previous one before setting a new one with different parameters.'); | |
| Browser.mainLoop.func = browserIterationFunc; | |
| Browser.mainLoop.arg = arg; | |
| var thisMainLoopId = Browser.mainLoop.currentlyRunningMainloop; | |
| function checkIsRunning() { | |
| if (thisMainLoopId < Browser.mainLoop.currentlyRunningMainloop) { | |
| maybeExit(); | |
| return false; | |
| } | |
| return true; | |
| } | |
| // We create the loop runner here but it is not actually running until | |
| // _emscripten_set_main_loop_timing is called (which might happen a | |
| // later time). This member signifies that the current runner has not | |
| // yet been started so that we can call runtimeKeepalivePush when it | |
| // gets it timing set for the first time. | |
| Browser.mainLoop.running = false; | |
| Browser.mainLoop.runner = function Browser_mainLoop_runner() { | |
| if (ABORT) return; | |
| if (Browser.mainLoop.queue.length > 0) { | |
| var start = Date.now(); | |
| var blocker = Browser.mainLoop.queue.shift(); | |
| blocker.func(blocker.arg); | |
| if (Browser.mainLoop.remainingBlockers) { | |
| var remaining = Browser.mainLoop.remainingBlockers; | |
| var next = remaining%1 == 0 ? remaining-1 : Math.floor(remaining); | |
| if (blocker.counted) { | |
| Browser.mainLoop.remainingBlockers = next; | |
| } else { | |
| // not counted, but move the progress along a tiny bit | |
| next = next + 0.5; // do not steal all the next one's progress | |
| Browser.mainLoop.remainingBlockers = (8*remaining + next)/9; | |
| } | |
| } | |
| out('main loop blocker "' + blocker.name + '" took ' + (Date.now() - start) + ' ms'); //, left: ' + Browser.mainLoop.remainingBlockers); | |
| Browser.mainLoop.updateStatus(); | |
| // catches pause/resume main loop from blocker execution | |
| if (!checkIsRunning()) return; | |
| setTimeout(Browser.mainLoop.runner, 0); | |
| return; | |
| } | |
| // catch pauses from non-main loop sources | |
| if (!checkIsRunning()) return; | |
| // Implement very basic swap interval control | |
| Browser.mainLoop.currentFrameNumber = Browser.mainLoop.currentFrameNumber + 1 | 0; | |
| if (Browser.mainLoop.timingMode == 1/*EM_TIMING_RAF*/ && Browser.mainLoop.timingValue > 1 && Browser.mainLoop.currentFrameNumber % Browser.mainLoop.timingValue != 0) { | |
| // Not the scheduled time to render this frame - skip. | |
| Browser.mainLoop.scheduler(); | |
| return; | |
| } else if (Browser.mainLoop.timingMode == 0/*EM_TIMING_SETTIMEOUT*/) { | |
| Browser.mainLoop.tickStartTime = _emscripten_get_now(); | |
| } | |
| // Signal GL rendering layer that processing of a new frame is about to start. This helps it optimize | |
| // VBO double-buffering and reduce GPU stalls. | |
| if (Browser.mainLoop.method === 'timeout' && Module.ctx) { | |
| warnOnce('Looks like you are rendering without using requestAnimationFrame for the main loop. You should use 0 for the frame rate in emscripten_set_main_loop in order to use requestAnimationFrame, as that can greatly improve your frame rates!'); | |
| Browser.mainLoop.method = ''; // just warn once per call to set main loop | |
| } | |
| Browser.mainLoop.runIter(browserIterationFunc); | |
| checkStackCookie(); | |
| // catch pauses from the main loop itself | |
| if (!checkIsRunning()) return; | |
| // Queue new audio data. This is important to be right after the main loop invocation, so that we will immediately be able | |
| // to queue the newest produced audio samples. | |
| // TODO: Consider adding pre- and post- rAF callbacks so that GL.newRenderingFrameStarted() and SDL.audio.queueNewAudioData() | |
| // do not need to be hardcoded into this function, but can be more generic. | |
| if (typeof SDL == 'object' && SDL.audio && SDL.audio.queueNewAudioData) SDL.audio.queueNewAudioData(); | |
| Browser.mainLoop.scheduler(); | |
| } | |
| if (!noSetTiming) { | |
| if (fps && fps > 0) _emscripten_set_main_loop_timing(0/*EM_TIMING_SETTIMEOUT*/, 1000.0 / fps); | |
| else _emscripten_set_main_loop_timing(1/*EM_TIMING_RAF*/, 1); // Do rAF by rendering each frame (no decimating) | |
| Browser.mainLoop.scheduler(); | |
| } | |
| if (simulateInfiniteLoop) { | |
| throw 'unwind'; | |
| } | |
| } | |
| var wasmTableMirror = []; | |
| function getWasmTableEntry(funcPtr) { | |
| var func = wasmTableMirror[funcPtr]; | |
| if (!func) { | |
| if (funcPtr >= wasmTableMirror.length) wasmTableMirror.length = funcPtr + 1; | |
| wasmTableMirror[funcPtr] = func = wasmTable.get(funcPtr); | |
| } | |
| assert(wasmTable.get(funcPtr) == func, "JavaScript-side Wasm function table mirror is out of date!"); | |
| return func; | |
| } | |
| function _emscripten_set_main_loop_arg(func, arg, fps, simulateInfiniteLoop) { | |
| var browserIterationFunc = () => getWasmTableEntry(func)(arg); | |
| setMainLoop(browserIterationFunc, fps, simulateInfiniteLoop, arg); | |
| } | |
| function _fd_close(fd) { | |
| try { | |
| var stream = SYSCALLS.getStreamFromFD(fd); | |
| FS.close(stream); | |
| return 0; | |
| } catch (e) { | |
| if (typeof FS == 'undefined' || !(e instanceof FS.ErrnoError)) throw e; | |
| return e.errno; | |
| } | |
| } | |
| /** @param {number=} offset */ | |
| function doReadv(stream, iov, iovcnt, offset) { | |
| var ret = 0; | |
| for (var i = 0; i < iovcnt; i++) { | |
| var ptr = HEAPU32[((iov)>>2)]; | |
| var len = HEAPU32[(((iov)+(4))>>2)]; | |
| iov += 8; | |
| var curr = FS.read(stream, HEAP8,ptr, len, offset); | |
| if (curr < 0) return -1; | |
| ret += curr; | |
| if (curr < len) break; // nothing more to read | |
| } | |
| return ret; | |
| } | |
| function _fd_read(fd, iov, iovcnt, pnum) { | |
| try { | |
| var stream = SYSCALLS.getStreamFromFD(fd); | |
| var num = doReadv(stream, iov, iovcnt); | |
| HEAPU32[((pnum)>>2)] = num; | |
| return 0; | |
| } catch (e) { | |
| if (typeof FS == 'undefined' || !(e instanceof FS.ErrnoError)) throw e; | |
| return e.errno; | |
| } | |
| } | |
| function convertI32PairToI53Checked(lo, hi) { | |
| assert(lo == (lo >>> 0) || lo == (lo|0)); // lo should either be a i32 or a u32 | |
| assert(hi === (hi|0)); // hi should be a i32 | |
| return ((hi + 0x200000) >>> 0 < 0x400001 - !!lo) ? (lo >>> 0) + hi * 4294967296 : NaN; | |
| } | |
| function _fd_seek(fd, offset_low, offset_high, whence, newOffset) { | |
| try { | |
| var offset = convertI32PairToI53Checked(offset_low, offset_high); if (isNaN(offset)) return 61; | |
| var stream = SYSCALLS.getStreamFromFD(fd); | |
| FS.llseek(stream, offset, whence); | |
| (tempI64 = [stream.position>>>0,(tempDouble=stream.position,(+(Math.abs(tempDouble))) >= 1.0 ? (tempDouble > 0.0 ? ((Math.min((+(Math.floor((tempDouble)/4294967296.0))), 4294967295.0))|0)>>>0 : (~~((+(Math.ceil((tempDouble - +(((~~(tempDouble)))>>>0))/4294967296.0)))))>>>0) : 0)],HEAP32[((newOffset)>>2)] = tempI64[0],HEAP32[(((newOffset)+(4))>>2)] = tempI64[1]); | |
| if (stream.getdents && offset === 0 && whence === 0) stream.getdents = null; // reset readdir state | |
| return 0; | |
| } catch (e) { | |
| if (typeof FS == 'undefined' || !(e instanceof FS.ErrnoError)) throw e; | |
| return e.errno; | |
| } | |
| } | |
| /** @param {number=} offset */ | |
| function doWritev(stream, iov, iovcnt, offset) { | |
| var ret = 0; | |
| for (var i = 0; i < iovcnt; i++) { | |
| var ptr = HEAPU32[((iov)>>2)]; | |
| var len = HEAPU32[(((iov)+(4))>>2)]; | |
| iov += 8; | |
| var curr = FS.write(stream, HEAP8,ptr, len, offset); | |
| if (curr < 0) return -1; | |
| ret += curr; | |
| } | |
| return ret; | |
| } | |
| function _fd_write(fd, iov, iovcnt, pnum) { | |
| try { | |
| var stream = SYSCALLS.getStreamFromFD(fd); | |
| var num = doWritev(stream, iov, iovcnt); | |
| HEAPU32[((pnum)>>2)] = num; | |
| return 0; | |
| } catch (e) { | |
| if (typeof FS == 'undefined' || !(e instanceof FS.ErrnoError)) throw e; | |
| return e.errno; | |
| } | |
| } | |
| function getCFunc(ident) { | |
| var func = Module['_' + ident]; // closure exported function | |
| assert(func, 'Cannot call unknown function ' + ident + ', make sure it is exported'); | |
| return func; | |
| } | |
| function writeArrayToMemory(array, buffer) { | |
| assert(array.length >= 0, 'writeArrayToMemory array must have a length (should be an array or typed array)') | |
| HEAP8.set(array, buffer); | |
| } | |
| /** | |
| * @param {string|null=} returnType | |
| * @param {Array=} argTypes | |
| * @param {Arguments|Array=} args | |
| * @param {Object=} opts | |
| */ | |
| function ccall(ident, returnType, argTypes, args, opts) { | |
| // For fast lookup of conversion functions | |
| var toC = { | |
| 'string': (str) => { | |
| var ret = 0; | |
| if (str !== null && str !== undefined && str !== 0) { // null string | |
| // at most 4 bytes per UTF-8 code point, +1 for the trailing '\0' | |
| var len = (str.length << 2) + 1; | |
| ret = stackAlloc(len); | |
| stringToUTF8(str, ret, len); | |
| } | |
| return ret; | |
| }, | |
| 'array': (arr) => { | |
| var ret = stackAlloc(arr.length); | |
| writeArrayToMemory(arr, ret); | |
| return ret; | |
| } | |
| }; | |
| function convertReturnValue(ret) { | |
| if (returnType === 'string') { | |
| return UTF8ToString(ret); | |
| } | |
| if (returnType === 'boolean') return Boolean(ret); | |
| return ret; | |
| } | |
| var func = getCFunc(ident); | |
| var cArgs = []; | |
| var stack = 0; | |
| assert(returnType !== 'array', 'Return type should not be "array".'); | |
| if (args) { | |
| for (var i = 0; i < args.length; i++) { | |
| var converter = toC[argTypes[i]]; | |
| if (converter) { | |
| if (stack === 0) stack = stackSave(); | |
| cArgs[i] = converter(args[i]); | |
| } else { | |
| cArgs[i] = args[i]; | |
| } | |
| } | |
| } | |
| var ret = func.apply(null, cArgs); | |
| function onDone(ret) { | |
| if (stack !== 0) stackRestore(stack); | |
| return convertReturnValue(ret); | |
| } | |
| ret = onDone(ret); | |
| return ret; | |
| } | |
| var FSNode = /** @constructor */ function(parent, name, mode, rdev) { | |
| if (!parent) { | |
| parent = this; // root node sets parent to itself | |
| } | |
| this.parent = parent; | |
| this.mount = parent.mount; | |
| this.mounted = null; | |
| this.id = FS.nextInode++; | |
| this.name = name; | |
| this.mode = mode; | |
| this.node_ops = {}; | |
| this.stream_ops = {}; | |
| this.rdev = rdev; | |
| }; | |
| var readMode = 292/*292*/ | 73/*73*/; | |
| var writeMode = 146/*146*/; | |
| Object.defineProperties(FSNode.prototype, { | |
| read: { | |
| get: /** @this{FSNode} */function() { | |
| return (this.mode & readMode) === readMode; | |
| }, | |
| set: /** @this{FSNode} */function(val) { | |
| val ? this.mode |= readMode : this.mode &= ~readMode; | |
| } | |
| }, | |
| write: { | |
| get: /** @this{FSNode} */function() { | |
| return (this.mode & writeMode) === writeMode; | |
| }, | |
| set: /** @this{FSNode} */function(val) { | |
| val ? this.mode |= writeMode : this.mode &= ~writeMode; | |
| } | |
| }, | |
| isFolder: { | |
| get: /** @this{FSNode} */function() { | |
| return FS.isDir(this.mode); | |
| } | |
| }, | |
| isDevice: { | |
| get: /** @this{FSNode} */function() { | |
| return FS.isChrdev(this.mode); | |
| } | |
| } | |
| }); | |
| FS.FSNode = FSNode; | |
| FS.staticInit();Module["FS_createPath"] = FS.createPath;Module["FS_createDataFile"] = FS.createDataFile;Module["FS_createPreloadedFile"] = FS.createPreloadedFile;Module["FS_unlink"] = FS.unlink;Module["FS_createLazyFile"] = FS.createLazyFile;Module["FS_createDevice"] = FS.createDevice;; | |
| ERRNO_CODES = { | |
| 'EPERM': 63, | |
| 'ENOENT': 44, | |
| 'ESRCH': 71, | |
| 'EINTR': 27, | |
| 'EIO': 29, | |
| 'ENXIO': 60, | |
| 'E2BIG': 1, | |
| 'ENOEXEC': 45, | |
| 'EBADF': 8, | |
| 'ECHILD': 12, | |
| 'EAGAIN': 6, | |
| 'EWOULDBLOCK': 6, | |
| 'ENOMEM': 48, | |
| 'EACCES': 2, | |
| 'EFAULT': 21, | |
| 'ENOTBLK': 105, | |
| 'EBUSY': 10, | |
| 'EEXIST': 20, | |
| 'EXDEV': 75, | |
| 'ENODEV': 43, | |
| 'ENOTDIR': 54, | |
| 'EISDIR': 31, | |
| 'EINVAL': 28, | |
| 'ENFILE': 41, | |
| 'EMFILE': 33, | |
| 'ENOTTY': 59, | |
| 'ETXTBSY': 74, | |
| 'EFBIG': 22, | |
| 'ENOSPC': 51, | |
| 'ESPIPE': 70, | |
| 'EROFS': 69, | |
| 'EMLINK': 34, | |
| 'EPIPE': 64, | |
| 'EDOM': 18, | |
| 'ERANGE': 68, | |
| 'ENOMSG': 49, | |
| 'EIDRM': 24, | |
| 'ECHRNG': 106, | |
| 'EL2NSYNC': 156, | |
| 'EL3HLT': 107, | |
| 'EL3RST': 108, | |
| 'ELNRNG': 109, | |
| 'EUNATCH': 110, | |
| 'ENOCSI': 111, | |
| 'EL2HLT': 112, | |
| 'EDEADLK': 16, | |
| 'ENOLCK': 46, | |
| 'EBADE': 113, | |
| 'EBADR': 114, | |
| 'EXFULL': 115, | |
| 'ENOANO': 104, | |
| 'EBADRQC': 103, | |
| 'EBADSLT': 102, | |
| 'EDEADLOCK': 16, | |
| 'EBFONT': 101, | |
| 'ENOSTR': 100, | |
| 'ENODATA': 116, | |
| 'ETIME': 117, | |
| 'ENOSR': 118, | |
| 'ENONET': 119, | |
| 'ENOPKG': 120, | |
| 'EREMOTE': 121, | |
| 'ENOLINK': 47, | |
| 'EADV': 122, | |
| 'ESRMNT': 123, | |
| 'ECOMM': 124, | |
| 'EPROTO': 65, | |
| 'EMULTIHOP': 36, | |
| 'EDOTDOT': 125, | |
| 'EBADMSG': 9, | |
| 'ENOTUNIQ': 126, | |
| 'EBADFD': 127, | |
| 'EREMCHG': 128, | |
| 'ELIBACC': 129, | |
| 'ELIBBAD': 130, | |
| 'ELIBSCN': 131, | |
| 'ELIBMAX': 132, | |
| 'ELIBEXEC': 133, | |
| 'ENOSYS': 52, | |
| 'ENOTEMPTY': 55, | |
| 'ENAMETOOLONG': 37, | |
| 'ELOOP': 32, | |
| 'EOPNOTSUPP': 138, | |
| 'EPFNOSUPPORT': 139, | |
| 'ECONNRESET': 15, | |
| 'ENOBUFS': 42, | |
| 'EAFNOSUPPORT': 5, | |
| 'EPROTOTYPE': 67, | |
| 'ENOTSOCK': 57, | |
| 'ENOPROTOOPT': 50, | |
| 'ESHUTDOWN': 140, | |
| 'ECONNREFUSED': 14, | |
| 'EADDRINUSE': 3, | |
| 'ECONNABORTED': 13, | |
| 'ENETUNREACH': 40, | |
| 'ENETDOWN': 38, | |
| 'ETIMEDOUT': 73, | |
| 'EHOSTDOWN': 142, | |
| 'EHOSTUNREACH': 23, | |
| 'EINPROGRESS': 26, | |
| 'EALREADY': 7, | |
| 'EDESTADDRREQ': 17, | |
| 'EMSGSIZE': 35, | |
| 'EPROTONOSUPPORT': 66, | |
| 'ESOCKTNOSUPPORT': 137, | |
| 'EADDRNOTAVAIL': 4, | |
| 'ENETRESET': 39, | |
| 'EISCONN': 30, | |
| 'ENOTCONN': 53, | |
| 'ETOOMANYREFS': 141, | |
| 'EUSERS': 136, | |
| 'EDQUOT': 19, | |
| 'ESTALE': 72, | |
| 'ENOTSUP': 138, | |
| 'ENOMEDIUM': 148, | |
| 'EILSEQ': 25, | |
| 'EOVERFLOW': 61, | |
| 'ECANCELED': 11, | |
| 'ENOTRECOVERABLE': 56, | |
| 'EOWNERDEAD': 62, | |
| 'ESTRPIPE': 135, | |
| };; | |
| // exports | |
| Module["requestFullscreen"] = function Module_requestFullscreen(lockPointer, resizeCanvas) { Browser.requestFullscreen(lockPointer, resizeCanvas) }; | |
| Module["requestFullScreen"] = function Module_requestFullScreen() { Browser.requestFullScreen() }; | |
| Module["requestAnimationFrame"] = function Module_requestAnimationFrame(func) { Browser.requestAnimationFrame(func) }; | |
| Module["setCanvasSize"] = function Module_setCanvasSize(width, height, noUpdates) { Browser.setCanvasSize(width, height, noUpdates) }; | |
| Module["pauseMainLoop"] = function Module_pauseMainLoop() { Browser.mainLoop.pause() }; | |
| Module["resumeMainLoop"] = function Module_resumeMainLoop() { Browser.mainLoop.resume() }; | |
| Module["getUserMedia"] = function Module_getUserMedia() { Browser.getUserMedia() }; | |
| Module["createContext"] = function Module_createContext(canvas, useWebGL, setInModule, webGLContextAttributes) { return Browser.createContext(canvas, useWebGL, setInModule, webGLContextAttributes) }; | |
| var preloadedImages = {}; | |
| var preloadedAudios = {};; | |
| var ASSERTIONS = true; | |
| // Copied from https://github.com/strophe/strophejs/blob/e06d027/src/polyfills.js#L149 | |
| // This code was written by Tyler Akins and has been placed in the | |
| // public domain. It would be nice if you left this header intact. | |
| // Base64 code from Tyler Akins -- http://rumkin.com | |
| /** | |
| * Decodes a base64 string. | |
| * @param {string} input The string to decode. | |
| */ | |
| var decodeBase64 = typeof atob == 'function' ? atob : function (input) { | |
| var keyStr = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/='; | |
| var output = ''; | |
| var chr1, chr2, chr3; | |
| var enc1, enc2, enc3, enc4; | |
| var i = 0; | |
| // remove all characters that are not A-Z, a-z, 0-9, +, /, or = | |
| input = input.replace(/[^A-Za-z0-9\+\/\=]/g, ''); | |
| do { | |
| enc1 = keyStr.indexOf(input.charAt(i++)); | |
| enc2 = keyStr.indexOf(input.charAt(i++)); | |
| enc3 = keyStr.indexOf(input.charAt(i++)); | |
| enc4 = keyStr.indexOf(input.charAt(i++)); | |
| chr1 = (enc1 << 2) | (enc2 >> 4); | |
| chr2 = ((enc2 & 15) << 4) | (enc3 >> 2); | |
| chr3 = ((enc3 & 3) << 6) | enc4; | |
| output = output + String.fromCharCode(chr1); | |
| if (enc3 !== 64) { | |
| output = output + String.fromCharCode(chr2); | |
| } | |
| if (enc4 !== 64) { | |
| output = output + String.fromCharCode(chr3); | |
| } | |
| } while (i < input.length); | |
| return output; | |
| }; | |
| // Converts a string of base64 into a byte array. | |
| // Throws error on invalid input. | |
| function intArrayFromBase64(s) { | |
| if (typeof ENVIRONMENT_IS_NODE == 'boolean' && ENVIRONMENT_IS_NODE) { | |
| var buf = Buffer.from(s, 'base64'); | |
| return new Uint8Array(buf['buffer'], buf['byteOffset'], buf['byteLength']); | |
| } | |
| try { | |
| var decoded = decodeBase64(s); | |
| var bytes = new Uint8Array(decoded.length); | |
| for (var i = 0 ; i < decoded.length ; ++i) { | |
| bytes[i] = decoded.charCodeAt(i); | |
| } | |
| return bytes; | |
| } catch (_) { | |
| throw new Error('Converting base64 string to bytes failed.'); | |
| } | |
| } | |
| // If filename is a base64 data URI, parses and returns data (Buffer on node, | |
| // Uint8Array otherwise). If filename is not a base64 data URI, returns undefined. | |
| function tryParseAsDataURI(filename) { | |
| if (!isDataURI(filename)) { | |
| return; | |
| } | |
| return intArrayFromBase64(filename.slice(dataURIPrefix.length)); | |
| } | |
| function checkIncomingModuleAPI() { | |
| ignoredModuleProp('fetchSettings'); | |
| } | |
| var asmLibraryArg = { | |
| "__syscall_fcntl64": ___syscall_fcntl64, | |
| "__syscall_ioctl": ___syscall_ioctl, | |
| "__syscall_openat": ___syscall_openat, | |
| "emscripten_date_now": _emscripten_date_now, | |
| "emscripten_memcpy_big": _emscripten_memcpy_big, | |
| "emscripten_resize_heap": _emscripten_resize_heap, | |
| "emscripten_set_main_loop_arg": _emscripten_set_main_loop_arg, | |
| "exit": _exit, | |
| "fd_close": _fd_close, | |
| "fd_read": _fd_read, | |
| "fd_seek": _fd_seek, | |
| "fd_write": _fd_write | |
| }; | |
| var asm = createWasm(); | |
| /** @type {function(...*):?} */ | |
| var ___wasm_call_ctors = Module["___wasm_call_ctors"] = createExportWrapper("__wasm_call_ctors"); | |
| /** @type {function(...*):?} */ | |
| var _free = Module["_free"] = createExportWrapper("free"); | |
| /** @type {function(...*):?} */ | |
| var _main_loop = Module["_main_loop"] = createExportWrapper("main_loop"); | |
| /** @type {function(...*):?} */ | |
| var _fflush = Module["_fflush"] = createExportWrapper("fflush"); | |
| /** @type {function(...*):?} */ | |
| var _malloc = Module["_malloc"] = createExportWrapper("malloc"); | |
| /** @type {function(...*):?} */ | |
| var _main = Module["_main"] = createExportWrapper("main"); | |
| /** @type {function(...*):?} */ | |
| var ___errno_location = Module["___errno_location"] = createExportWrapper("__errno_location"); | |
| /** @type {function(...*):?} */ | |
| var _emscripten_stack_init = Module["_emscripten_stack_init"] = function() { | |
| return (_emscripten_stack_init = Module["_emscripten_stack_init"] = Module["asm"]["emscripten_stack_init"]).apply(null, arguments); | |
| }; | |
| /** @type {function(...*):?} */ | |
| var _emscripten_stack_get_free = Module["_emscripten_stack_get_free"] = function() { | |
| return (_emscripten_stack_get_free = Module["_emscripten_stack_get_free"] = Module["asm"]["emscripten_stack_get_free"]).apply(null, arguments); | |
| }; | |
| /** @type {function(...*):?} */ | |
| var _emscripten_stack_get_base = Module["_emscripten_stack_get_base"] = function() { | |
| return (_emscripten_stack_get_base = Module["_emscripten_stack_get_base"] = Module["asm"]["emscripten_stack_get_base"]).apply(null, arguments); | |
| }; | |
| /** @type {function(...*):?} */ | |
| var _emscripten_stack_get_end = Module["_emscripten_stack_get_end"] = function() { | |
| return (_emscripten_stack_get_end = Module["_emscripten_stack_get_end"] = Module["asm"]["emscripten_stack_get_end"]).apply(null, arguments); | |
| }; | |
| /** @type {function(...*):?} */ | |
| var stackSave = Module["stackSave"] = createExportWrapper("stackSave"); | |
| /** @type {function(...*):?} */ | |
| var stackRestore = Module["stackRestore"] = createExportWrapper("stackRestore"); | |
| /** @type {function(...*):?} */ | |
| var stackAlloc = Module["stackAlloc"] = createExportWrapper("stackAlloc"); | |
| /** @type {function(...*):?} */ | |
| var _emscripten_stack_get_current = Module["_emscripten_stack_get_current"] = function() { | |
| return (_emscripten_stack_get_current = Module["_emscripten_stack_get_current"] = Module["asm"]["emscripten_stack_get_current"]).apply(null, arguments); | |
| }; | |
| /** @type {function(...*):?} */ | |
| var dynCall_jiji = Module["dynCall_jiji"] = createExportWrapper("dynCall_jiji"); | |
| // === Auto-generated postamble setup entry stuff === | |
| Module["addRunDependency"] = addRunDependency; | |
| Module["removeRunDependency"] = removeRunDependency; | |
| Module["FS_createPath"] = FS.createPath; | |
| Module["FS_createDataFile"] = FS.createDataFile; | |
| Module["FS_createPreloadedFile"] = FS.createPreloadedFile; | |
| Module["FS_createLazyFile"] = FS.createLazyFile; | |
| Module["FS_createDevice"] = FS.createDevice; | |
| Module["FS_unlink"] = FS.unlink; | |
| Module["ccall"] = ccall; | |
| var unexportedRuntimeSymbols = [ | |
| 'run', | |
| 'UTF8ArrayToString', | |
| 'UTF8ToString', | |
| 'stringToUTF8Array', | |
| 'stringToUTF8', | |
| 'lengthBytesUTF8', | |
| 'addOnPreRun', | |
| 'addOnInit', | |
| 'addOnPreMain', | |
| 'addOnExit', | |
| 'addOnPostRun', | |
| 'FS_createFolder', | |
| 'FS_createLink', | |
| 'getLEB', | |
| 'getFunctionTables', | |
| 'alignFunctionTables', | |
| 'registerFunctions', | |
| 'prettyPrint', | |
| 'getCompilerSetting', | |
| 'out', | |
| 'err', | |
| 'callMain', | |
| 'abort', | |
| 'keepRuntimeAlive', | |
| 'wasmMemory', | |
| 'stackAlloc', | |
| 'stackSave', | |
| 'stackRestore', | |
| 'getTempRet0', | |
| 'setTempRet0', | |
| 'writeStackCookie', | |
| 'checkStackCookie', | |
| 'ptrToString', | |
| 'zeroMemory', | |
| 'stringToNewUTF8', | |
| 'exitJS', | |
| 'getHeapMax', | |
| 'emscripten_realloc_buffer', | |
| 'ENV', | |
| 'ERRNO_CODES', | |
| 'ERRNO_MESSAGES', | |
| 'setErrNo', | |
| 'inetPton4', | |
| 'inetNtop4', | |
| 'inetPton6', | |
| 'inetNtop6', | |
| 'readSockaddr', | |
| 'writeSockaddr', | |
| 'DNS', | |
| 'getHostByName', | |
| 'Protocols', | |
| 'Sockets', | |
| 'getRandomDevice', | |
| 'warnOnce', | |
| 'traverseStack', | |
| 'UNWIND_CACHE', | |
| 'convertPCtoSourceLocation', | |
| 'readEmAsmArgsArray', | |
| 'readEmAsmArgs', | |
| 'runEmAsmFunction', | |
| 'runMainThreadEmAsm', | |
| 'jstoi_q', | |
| 'jstoi_s', | |
| 'getExecutableName', | |
| 'listenOnce', | |
| 'autoResumeAudioContext', | |
| 'dynCallLegacy', | |
| 'getDynCaller', | |
| 'dynCall', | |
| 'handleException', | |
| 'runtimeKeepalivePush', | |
| 'runtimeKeepalivePop', | |
| 'callUserCallback', | |
| 'maybeExit', | |
| 'safeSetTimeout', | |
| 'asmjsMangle', | |
| 'asyncLoad', | |
| 'alignMemory', | |
| 'mmapAlloc', | |
| 'writeI53ToI64', | |
| 'writeI53ToI64Clamped', | |
| 'writeI53ToI64Signaling', | |
| 'writeI53ToU64Clamped', | |
| 'writeI53ToU64Signaling', | |
| 'readI53FromI64', | |
| 'readI53FromU64', | |
| 'convertI32PairToI53', | |
| 'convertI32PairToI53Checked', | |
| 'convertU32PairToI53', | |
| 'getCFunc', | |
| 'cwrap', | |
| 'uleb128Encode', | |
| 'sigToWasmTypes', | |
| 'generateFuncType', | |
| 'convertJsFunctionToWasm', | |
| 'freeTableIndexes', | |
| 'functionsInTableMap', | |
| 'getEmptyTableSlot', | |
| 'updateTableMap', | |
| 'addFunction', | |
| 'removeFunction', | |
| 'reallyNegative', | |
| 'unSign', | |
| 'strLen', | |
| 'reSign', | |
| 'formatString', | |
| 'setValue', | |
| 'getValue', | |
| 'PATH', | |
| 'PATH_FS', | |
| 'intArrayFromString', | |
| 'intArrayToString', | |
| 'AsciiToString', | |
| 'stringToAscii', | |
| 'UTF16Decoder', | |
| 'UTF16ToString', | |
| 'stringToUTF16', | |
| 'lengthBytesUTF16', | |
| 'UTF32ToString', | |
| 'stringToUTF32', | |
| 'lengthBytesUTF32', | |
| 'allocateUTF8', | |
| 'allocateUTF8OnStack', | |
| 'writeStringToMemory', | |
| 'writeArrayToMemory', | |
| 'writeAsciiToMemory', | |
| 'SYSCALLS', | |
| 'getSocketFromFD', | |
| 'getSocketAddress', | |
| 'JSEvents', | |
| 'registerKeyEventCallback', | |
| 'specialHTMLTargets', | |
| 'maybeCStringToJsString', | |
| 'findEventTarget', | |
| 'findCanvasEventTarget', | |
| 'getBoundingClientRect', | |
| 'fillMouseEventData', | |
| 'registerMouseEventCallback', | |
| 'registerWheelEventCallback', | |
| 'registerUiEventCallback', | |
| 'registerFocusEventCallback', | |
| 'fillDeviceOrientationEventData', | |
| 'registerDeviceOrientationEventCallback', | |
| 'fillDeviceMotionEventData', | |
| 'registerDeviceMotionEventCallback', | |
| 'screenOrientation', | |
| 'fillOrientationChangeEventData', | |
| 'registerOrientationChangeEventCallback', | |
| 'fillFullscreenChangeEventData', | |
| 'registerFullscreenChangeEventCallback', | |
| 'JSEvents_requestFullscreen', | |
| 'JSEvents_resizeCanvasForFullscreen', | |
| 'registerRestoreOldStyle', | |
| 'hideEverythingExceptGivenElement', | |
| 'restoreHiddenElements', | |
| 'setLetterbox', | |
| 'currentFullscreenStrategy', | |
| 'restoreOldWindowedStyle', | |
| 'softFullscreenResizeWebGLRenderTarget', | |
| 'doRequestFullscreen', | |
| 'fillPointerlockChangeEventData', | |
| 'registerPointerlockChangeEventCallback', | |
| 'registerPointerlockErrorEventCallback', | |
| 'requestPointerLock', | |
| 'fillVisibilityChangeEventData', | |
| 'registerVisibilityChangeEventCallback', | |
| 'registerTouchEventCallback', | |
| 'fillGamepadEventData', | |
| 'registerGamepadEventCallback', | |
| 'registerBeforeUnloadEventCallback', | |
| 'fillBatteryEventData', | |
| 'battery', | |
| 'registerBatteryEventCallback', | |
| 'setCanvasElementSize', | |
| 'getCanvasElementSize', | |
| 'demangle', | |
| 'demangleAll', | |
| 'jsStackTrace', | |
| 'stackTrace', | |
| 'ExitStatus', | |
| 'getEnvStrings', | |
| 'checkWasiClock', | |
| 'doReadv', | |
| 'doWritev', | |
| 'dlopenMissingError', | |
| 'createDyncallWrapper', | |
| 'setImmediateWrapped', | |
| 'clearImmediateWrapped', | |
| 'polyfillSetImmediate', | |
| 'uncaughtExceptionCount', | |
| 'exceptionLast', | |
| 'exceptionCaught', | |
| 'ExceptionInfo', | |
| 'exception_addRef', | |
| 'exception_decRef', | |
| 'Browser', | |
| 'setMainLoop', | |
| 'wget', | |
| 'FS', | |
| 'MEMFS', | |
| 'TTY', | |
| 'PIPEFS', | |
| 'SOCKFS', | |
| '_setNetworkCallback', | |
| 'tempFixedLengthArray', | |
| 'miniTempWebGLFloatBuffers', | |
| 'heapObjectForWebGLType', | |
| 'heapAccessShiftForWebGLHeap', | |
| 'GL', | |
| 'emscriptenWebGLGet', | |
| 'computeUnpackAlignedImageSize', | |
| 'emscriptenWebGLGetTexPixelData', | |
| 'emscriptenWebGLGetUniform', | |
| 'webglGetUniformLocation', | |
| 'webglPrepareUniformLocationsBeforeFirstUse', | |
| 'webglGetLeftBracePos', | |
| 'emscriptenWebGLGetVertexAttrib', | |
| 'writeGLArray', | |
| 'AL', | |
| 'SDL_unicode', | |
| 'SDL_ttfContext', | |
| 'SDL_audio', | |
| 'SDL', | |
| 'SDL_gfx', | |
| 'GLUT', | |
| 'EGL', | |
| 'GLFW_Window', | |
| 'GLFW', | |
| 'GLEW', | |
| 'IDBStore', | |
| 'runAndAbortIfError', | |
| 'ALLOC_NORMAL', | |
| 'ALLOC_STACK', | |
| 'allocate', | |
| ]; | |
| unexportedRuntimeSymbols.forEach(unexportedRuntimeSymbol); | |
| var missingLibrarySymbols = [ | |
| 'stringToNewUTF8', | |
| 'inetPton4', | |
| 'inetNtop4', | |
| 'inetPton6', | |
| 'inetNtop6', | |
| 'readSockaddr', | |
| 'writeSockaddr', | |
| 'getHostByName', | |
| 'traverseStack', | |
| 'convertPCtoSourceLocation', | |
| 'readEmAsmArgs', | |
| 'runEmAsmFunction', | |
| 'runMainThreadEmAsm', | |
| 'jstoi_q', | |
| 'jstoi_s', | |
| 'getExecutableName', | |
| 'listenOnce', | |
| 'autoResumeAudioContext', | |
| 'dynCallLegacy', | |
| 'getDynCaller', | |
| 'dynCall', | |
| 'runtimeKeepalivePush', | |
| 'runtimeKeepalivePop', | |
| 'asmjsMangle', | |
| 'writeI53ToI64', | |
| 'writeI53ToI64Clamped', | |
| 'writeI53ToI64Signaling', | |
| 'writeI53ToU64Clamped', | |
| 'writeI53ToU64Signaling', | |
| 'readI53FromI64', | |
| 'readI53FromU64', | |
| 'convertI32PairToI53', | |
| 'convertU32PairToI53', | |
| 'cwrap', | |
| 'uleb128Encode', | |
| 'sigToWasmTypes', | |
| 'generateFuncType', | |
| 'convertJsFunctionToWasm', | |
| 'getEmptyTableSlot', | |
| 'updateTableMap', | |
| 'addFunction', | |
| 'removeFunction', | |
| 'reallyNegative', | |
| 'unSign', | |
| 'strLen', | |
| 'reSign', | |
| 'formatString', | |
| 'intArrayToString', | |
| 'AsciiToString', | |
| 'stringToAscii', | |
| 'UTF16ToString', | |
| 'stringToUTF16', | |
| 'lengthBytesUTF16', | |
| 'UTF32ToString', | |
| 'stringToUTF32', | |
| 'lengthBytesUTF32', | |
| 'allocateUTF8', | |
| 'allocateUTF8OnStack', | |
| 'writeStringToMemory', | |
| 'writeAsciiToMemory', | |
| 'getSocketFromFD', | |
| 'getSocketAddress', | |
| 'registerKeyEventCallback', | |
| 'maybeCStringToJsString', | |
| 'findEventTarget', | |
| 'findCanvasEventTarget', | |
| 'getBoundingClientRect', | |
| 'fillMouseEventData', | |
| 'registerMouseEventCallback', | |
| 'registerWheelEventCallback', | |
| 'registerUiEventCallback', | |
| 'registerFocusEventCallback', | |
| 'fillDeviceOrientationEventData', | |
| 'registerDeviceOrientationEventCallback', | |
| 'fillDeviceMotionEventData', | |
| 'registerDeviceMotionEventCallback', | |
| 'screenOrientation', | |
| 'fillOrientationChangeEventData', | |
| 'registerOrientationChangeEventCallback', | |
| 'fillFullscreenChangeEventData', | |
| 'registerFullscreenChangeEventCallback', | |
| 'JSEvents_requestFullscreen', | |
| 'JSEvents_resizeCanvasForFullscreen', | |
| 'registerRestoreOldStyle', | |
| 'hideEverythingExceptGivenElement', | |
| 'restoreHiddenElements', | |
| 'setLetterbox', | |
| 'softFullscreenResizeWebGLRenderTarget', | |
| 'doRequestFullscreen', | |
| 'fillPointerlockChangeEventData', | |
| 'registerPointerlockChangeEventCallback', | |
| 'registerPointerlockErrorEventCallback', | |
| 'requestPointerLock', | |
| 'fillVisibilityChangeEventData', | |
| 'registerVisibilityChangeEventCallback', | |
| 'registerTouchEventCallback', | |
| 'fillGamepadEventData', | |
| 'registerGamepadEventCallback', | |
| 'registerBeforeUnloadEventCallback', | |
| 'fillBatteryEventData', | |
| 'battery', | |
| 'registerBatteryEventCallback', | |
| 'setCanvasElementSize', | |
| 'getCanvasElementSize', | |
| 'jsStackTrace', | |
| 'stackTrace', | |
| 'getEnvStrings', | |
| 'checkWasiClock', | |
| 'createDyncallWrapper', | |
| 'setImmediateWrapped', | |
| 'clearImmediateWrapped', | |
| 'polyfillSetImmediate', | |
| 'ExceptionInfo', | |
| 'exception_addRef', | |
| 'exception_decRef', | |
| '_setNetworkCallback', | |
| 'heapObjectForWebGLType', | |
| 'heapAccessShiftForWebGLHeap', | |
| 'emscriptenWebGLGet', | |
| 'computeUnpackAlignedImageSize', | |
| 'emscriptenWebGLGetTexPixelData', | |
| 'emscriptenWebGLGetUniform', | |
| 'webglGetUniformLocation', | |
| 'webglPrepareUniformLocationsBeforeFirstUse', | |
| 'webglGetLeftBracePos', | |
| 'emscriptenWebGLGetVertexAttrib', | |
| 'writeGLArray', | |
| 'SDL_unicode', | |
| 'SDL_ttfContext', | |
| 'SDL_audio', | |
| 'GLFW_Window', | |
| 'runAndAbortIfError', | |
| 'ALLOC_NORMAL', | |
| 'ALLOC_STACK', | |
| 'allocate', | |
| ]; | |
| missingLibrarySymbols.forEach(missingLibrarySymbol) | |
| var calledRun; | |
| dependenciesFulfilled = function runCaller() { | |
| // If run has never been called, and we should call run (INVOKE_RUN is true, and Module.noInitialRun is not false) | |
| if (!calledRun) run(); | |
| if (!calledRun) dependenciesFulfilled = runCaller; // try this again later, after new deps are fulfilled | |
| }; | |
| function callMain(args) { | |
| assert(runDependencies == 0, 'cannot call main when async dependencies remain! (listen on Module["onRuntimeInitialized"])'); | |
| assert(__ATPRERUN__.length == 0, 'cannot call main when preRun functions remain to be called'); | |
| var entryFunction = Module['_main']; | |
| var argc = 0; | |
| var argv = 0; | |
| try { | |
| var ret = entryFunction(argc, argv); | |
| // In PROXY_TO_PTHREAD builds, we should never exit the runtime below, as | |
| // execution is asynchronously handed off to a pthread. | |
| // if we're not running an evented main loop, it's time to exit | |
| exitJS(ret, /* implicit = */ true); | |
| return ret; | |
| } | |
| catch (e) { | |
| return handleException(e); | |
| } | |
| } | |
| function stackCheckInit() { | |
| // This is normally called automatically during __wasm_call_ctors but need to | |
| // get these values before even running any of the ctors so we call it redundantly | |
| // here. | |
| _emscripten_stack_init(); | |
| // TODO(sbc): Move writeStackCookie to native to to avoid this. | |
| writeStackCookie(); | |
| } | |
| /** @type {function(Array=)} */ | |
| function run(args) { | |
| args = args || arguments_; | |
| if (runDependencies > 0) { | |
| return; | |
| } | |
| stackCheckInit(); | |
| preRun(); | |
| // a preRun added a dependency, run will be called later | |
| if (runDependencies > 0) { | |
| return; | |
| } | |
| function doRun() { | |
| // run may have just been called through dependencies being fulfilled just in this very frame, | |
| // or while the async setStatus time below was happening | |
| if (calledRun) return; | |
| calledRun = true; | |
| Module['calledRun'] = true; | |
| if (ABORT) return; | |
| initRuntime(); | |
| preMain(); | |
| if (Module['onRuntimeInitialized']) Module['onRuntimeInitialized'](); | |
| if (shouldRunNow) callMain(args); | |
| postRun(); | |
| } | |
| if (Module['setStatus']) { | |
| Module['setStatus']('Running...'); | |
| setTimeout(function() { | |
| setTimeout(function() { | |
| Module['setStatus'](''); | |
| }, 1); | |
| doRun(); | |
| }, 1); | |
| } else | |
| { | |
| doRun(); | |
| } | |
| checkStackCookie(); | |
| } | |
| function checkUnflushedContent() { | |
| // Compiler settings do not allow exiting the runtime, so flushing | |
| // the streams is not possible. but in ASSERTIONS mode we check | |
| // if there was something to flush, and if so tell the user they | |
| // should request that the runtime be exitable. | |
| // Normally we would not even include flush() at all, but in ASSERTIONS | |
| // builds we do so just for this check, and here we see if there is any | |
| // content to flush, that is, we check if there would have been | |
| // something a non-ASSERTIONS build would have not seen. | |
| // How we flush the streams depends on whether we are in SYSCALLS_REQUIRE_FILESYSTEM=0 | |
| // mode (which has its own special function for this; otherwise, all | |
| // the code is inside libc) | |
| var oldOut = out; | |
| var oldErr = err; | |
| var has = false; | |
| out = err = (x) => { | |
| has = true; | |
| } | |
| try { // it doesn't matter if it fails | |
| _fflush(0); | |
| // also flush in the JS FS layer | |
| ['stdout', 'stderr'].forEach(function(name) { | |
| var info = FS.analyzePath('/dev/' + name); | |
| if (!info) return; | |
| var stream = info.object; | |
| var rdev = stream.rdev; | |
| var tty = TTY.ttys[rdev]; | |
| if (tty && tty.output && tty.output.length) { | |
| has = true; | |
| } | |
| }); | |
| } catch(e) {} | |
| out = oldOut; | |
| err = oldErr; | |
| if (has) { | |
| warnOnce('stdio streams had content in them that was not flushed. you should set EXIT_RUNTIME to 1 (see the FAQ), or make sure to emit a newline when you printf etc.'); | |
| } | |
| } | |
| if (Module['preInit']) { | |
| if (typeof Module['preInit'] == 'function') Module['preInit'] = [Module['preInit']]; | |
| while (Module['preInit'].length > 0) { | |
| Module['preInit'].pop()(); | |
| } | |
| } | |
| // shouldRunNow refers to calling main(), not run(). | |
| var shouldRunNow = true; | |
| if (Module['noInitialRun']) shouldRunNow = false; | |
| run(); | |