Merge v2 codecs (#844)

* wip * doh, whitespace * Updating emscripten, restoring export name * Updating oxipng * Build wasm * Fix oxipng; upgrade Rust * More v2-codec integration * AVIF now working * Non-working JXL * Build hqx with Rust 1.40; refactor build-rust*.sh * Set web target * wp2 wip * wp2 decode options * Better logo height when loading the logo into squoosh * Build oxi * JAKE IS AN IDIOT * wip oxipng * Fixing case sensitive imports * adding log * another log * Abort tasks when compress component removed * Adding progressive option to JXL * Fix bug going to & from original image * Exposing epf in jxl * logs * Bypass initial CSS plugin * Revert "logs" * Adding root * Fix for finding TSC on Windows * Use spawn again * Converting to module paths * Remove spawnP * silly * oops * logs * Fixing glob paths in CSS plugin * Path normalising * Normalise paths for CSS plugin * Normalise again * Use correct func * Adding lossless mode and near lossless (but hidden in UI) * Removing useless comments * Some logging * Update JXL to v0.1. (#846) * Rebuild JXL * Adding slight loss option Co-authored-by: Ingvar Stepanyan <rreverser@google.com> Co-authored-by: Luca Versari <veluca93@gmail.com>
2025-11-17 03:00:13 +00:00 · 2020-11-19 10:55:43 +00:00
parent 39ca054112
commit 7346511fa1
98 changed files with 20085 additions and 1884 deletions
--- a/codecs/avif/enc/avif_enc_mt.worker.js
+++ b/codecs/avif/enc/avif_enc_mt.worker.js
@@ -0,0 +1,103 @@
+var threadInfoStruct = 0;
+var selfThreadId = 0;
+var parentThreadId = 0;
+var initializedJS = false;
+var Module = {};
+function threadPrintErr() {
+  var text = Array.prototype.slice.call(arguments).join(' ');
+  console.error(text);
+}
+function threadAlert() {
+  var text = Array.prototype.slice.call(arguments).join(' ');
+  postMessage({ cmd: 'alert', text: text, threadId: selfThreadId });
+}
+var err = threadPrintErr;
+this.alert = threadAlert;
+Module['instantiateWasm'] = function (info, receiveInstance) {
+  var instance = new WebAssembly.Instance(Module['wasmModule'], info);
+  Module['wasmModule'] = null;
+  receiveInstance(instance);
+  return instance.exports;
+};
+this.onmessage = function (e) {
+  try {
+    if (e.data.cmd === 'load') {
+      Module['wasmModule'] = e.data.wasmModule;
+      Module['wasmMemory'] = e.data.wasmMemory;
+      Module['buffer'] = Module['wasmMemory'].buffer;
+      Module['ENVIRONMENT_IS_PTHREAD'] = true;
+      import(e.data.urlOrBlob)
+        .then(function (avif_enc_mt) {
+          return avif_enc_mt.default(Module);
+        })
+        .then(function (instance) {
+          Module = instance;
+          postMessage({ cmd: 'loaded' });
+        });
+    } else if (e.data.cmd === 'objectTransfer') {
+      Module['PThread'].receiveObjectTransfer(e.data);
+    } else if (e.data.cmd === 'run') {
+      Module['__performance_now_clock_drift'] = performance.now() - e.data.time;
+      threadInfoStruct = e.data.threadInfoStruct;
+      Module['registerPthreadPtr'](
+        threadInfoStruct,
+        /*isMainBrowserThread=*/ 0,
+        /*isMainRuntimeThread=*/ 0,
+      );
+      selfThreadId = e.data.selfThreadId;
+      parentThreadId = e.data.parentThreadId;
+      var max = e.data.stackBase;
+      var top = e.data.stackBase + e.data.stackSize;
+      Module['establishStackSpace'](top, max);
+      Module['_emscripten_tls_init']();
+      Module['PThread'].receiveObjectTransfer(e.data);
+      Module['PThread'].setThreadStatus(Module['_pthread_self'](), 1);
+      if (!initializedJS) {
+        Module['___embind_register_native_and_builtin_types']();
+        initializedJS = true;
+      }
+      try {
+        var result = Module['dynCall']('ii', e.data.start_routine, [
+          e.data.arg,
+        ]);
+        if (!Module['getNoExitRuntime']()) Module['PThread'].threadExit(result);
+      } catch (ex) {
+        if (ex === 'Canceled!') {
+          Module['PThread'].threadCancel();
+        } else if (ex != 'unwind') {
+          Atomics.store(
+            Module['HEAPU32'],
+            (threadInfoStruct + 4) >> /*C_STRUCTS.pthread.threadExitCode*/ 2,
+            ex instanceof Module['ExitStatus'] ? ex.status : -2,
+          );
+          /*A custom entry specific to Emscripten denoting that the thread crashed.*/ Atomics.store(
+            Module['HEAPU32'],
+            (threadInfoStruct + 0) >> /*C_STRUCTS.pthread.threadStatus*/ 2,
+            1,
+          );
+          Module['_emscripten_futex_wake'](
+            threadInfoStruct + 0,
+            /*C_STRUCTS.pthread.threadStatus*/ 2147483647,
+          );
+          if (!(ex instanceof Module['ExitStatus'])) throw ex;
+        }
+      }
+    } else if (e.data.cmd === 'cancel') {
+      if (threadInfoStruct) {
+        Module['PThread'].threadCancel();
+      }
+    } else if (e.data.target === 'setimmediate') {
+    } else if (e.data.cmd === 'processThreadQueue') {
+      if (threadInfoStruct) {
+        Module['_emscripten_current_thread_process_queued_calls']();
+      }
+    } else {
+      err('worker.js received unknown command ' + e.data.cmd);
+      err(e.data);
+    }
+  } catch (ex) {
+    err('worker.js onmessage() captured an uncaught exception: ' + ex);
+    if (ex && ex.stack) err(ex.stack);
+    throw ex;
+  }
+};