Jofthomas HF staff commited on
Commit
b43432d
1 Parent(s): 39db52d

Upload 9 files

Browse files
Files changed (10) hide show
  1. .gitattributes +1 -0
  2. index.apple-touch-icon.png +0 -0
  3. index.audio.worklet.js +213 -0
  4. index.html +266 -13
  5. index.icon.png +0 -0
  6. index.js +0 -0
  7. index.pck +3 -0
  8. index.png +0 -0
  9. index.wasm +3 -0
  10. index.worker.js +158 -0
.gitattributes CHANGED
@@ -33,3 +33,4 @@ saved_model/**/* filter=lfs diff=lfs merge=lfs -text
33
  *.zip filter=lfs diff=lfs merge=lfs -text
34
  *.zst filter=lfs diff=lfs merge=lfs -text
35
  *tfevents* filter=lfs diff=lfs merge=lfs -text
 
 
33
  *.zip filter=lfs diff=lfs merge=lfs -text
34
  *.zst filter=lfs diff=lfs merge=lfs -text
35
  *tfevents* filter=lfs diff=lfs merge=lfs -text
36
+ index.pck filter=lfs diff=lfs merge=lfs -text
index.apple-touch-icon.png ADDED
index.audio.worklet.js ADDED
@@ -0,0 +1,213 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ /**************************************************************************/
2
+ /* audio.worklet.js */
3
+ /**************************************************************************/
4
+ /* This file is part of: */
5
+ /* GODOT ENGINE */
6
+ /* https://godotengine.org */
7
+ /**************************************************************************/
8
+ /* Copyright (c) 2014-present Godot Engine contributors (see AUTHORS.md). */
9
+ /* Copyright (c) 2007-2014 Juan Linietsky, Ariel Manzur. */
10
+ /* */
11
+ /* Permission is hereby granted, free of charge, to any person obtaining */
12
+ /* a copy of this software and associated documentation files (the */
13
+ /* "Software"), to deal in the Software without restriction, including */
14
+ /* without limitation the rights to use, copy, modify, merge, publish, */
15
+ /* distribute, sublicense, and/or sell copies of the Software, and to */
16
+ /* permit persons to whom the Software is furnished to do so, subject to */
17
+ /* the following conditions: */
18
+ /* */
19
+ /* The above copyright notice and this permission notice shall be */
20
+ /* included in all copies or substantial portions of the Software. */
21
+ /* */
22
+ /* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, */
23
+ /* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF */
24
+ /* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. */
25
+ /* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY */
26
+ /* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, */
27
+ /* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */
28
+ /* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */
29
+ /**************************************************************************/
30
+
31
+ class RingBuffer {
32
+ constructor(p_buffer, p_state, p_threads) {
33
+ this.buffer = p_buffer;
34
+ this.avail = p_state;
35
+ this.threads = p_threads;
36
+ this.rpos = 0;
37
+ this.wpos = 0;
38
+ }
39
+
40
+ data_left() {
41
+ return this.threads ? Atomics.load(this.avail, 0) : this.avail;
42
+ }
43
+
44
+ space_left() {
45
+ return this.buffer.length - this.data_left();
46
+ }
47
+
48
+ read(output) {
49
+ const size = this.buffer.length;
50
+ let from = 0;
51
+ let to_write = output.length;
52
+ if (this.rpos + to_write > size) {
53
+ const high = size - this.rpos;
54
+ output.set(this.buffer.subarray(this.rpos, size));
55
+ from = high;
56
+ to_write -= high;
57
+ this.rpos = 0;
58
+ }
59
+ if (to_write) {
60
+ output.set(this.buffer.subarray(this.rpos, this.rpos + to_write), from);
61
+ }
62
+ this.rpos += to_write;
63
+ if (this.threads) {
64
+ Atomics.add(this.avail, 0, -output.length);
65
+ Atomics.notify(this.avail, 0);
66
+ } else {
67
+ this.avail -= output.length;
68
+ }
69
+ }
70
+
71
+ write(p_buffer) {
72
+ const to_write = p_buffer.length;
73
+ const mw = this.buffer.length - this.wpos;
74
+ if (mw >= to_write) {
75
+ this.buffer.set(p_buffer, this.wpos);
76
+ this.wpos += to_write;
77
+ if (mw === to_write) {
78
+ this.wpos = 0;
79
+ }
80
+ } else {
81
+ const high = p_buffer.subarray(0, mw);
82
+ const low = p_buffer.subarray(mw);
83
+ this.buffer.set(high, this.wpos);
84
+ this.buffer.set(low);
85
+ this.wpos = low.length;
86
+ }
87
+ if (this.threads) {
88
+ Atomics.add(this.avail, 0, to_write);
89
+ Atomics.notify(this.avail, 0);
90
+ } else {
91
+ this.avail += to_write;
92
+ }
93
+ }
94
+ }
95
+
96
+ class GodotProcessor extends AudioWorkletProcessor {
97
+ constructor() {
98
+ super();
99
+ this.threads = false;
100
+ this.running = true;
101
+ this.lock = null;
102
+ this.notifier = null;
103
+ this.output = null;
104
+ this.output_buffer = new Float32Array();
105
+ this.input = null;
106
+ this.input_buffer = new Float32Array();
107
+ this.port.onmessage = (event) => {
108
+ const cmd = event.data['cmd'];
109
+ const data = event.data['data'];
110
+ this.parse_message(cmd, data);
111
+ };
112
+ }
113
+
114
+ process_notify() {
115
+ if (this.notifier) {
116
+ Atomics.add(this.notifier, 0, 1);
117
+ Atomics.notify(this.notifier, 0);
118
+ }
119
+ }
120
+
121
+ parse_message(p_cmd, p_data) {
122
+ if (p_cmd === 'start' && p_data) {
123
+ const state = p_data[0];
124
+ let idx = 0;
125
+ this.threads = true;
126
+ this.lock = state.subarray(idx, ++idx);
127
+ this.notifier = state.subarray(idx, ++idx);
128
+ const avail_in = state.subarray(idx, ++idx);
129
+ const avail_out = state.subarray(idx, ++idx);
130
+ this.input = new RingBuffer(p_data[1], avail_in, true);
131
+ this.output = new RingBuffer(p_data[2], avail_out, true);
132
+ } else if (p_cmd === 'stop') {
133
+ this.running = false;
134
+ this.output = null;
135
+ this.input = null;
136
+ this.lock = null;
137
+ this.notifier = null;
138
+ } else if (p_cmd === 'start_nothreads') {
139
+ this.output = new RingBuffer(p_data[0], p_data[0].length, false);
140
+ } else if (p_cmd === 'chunk') {
141
+ this.output.write(p_data);
142
+ }
143
+ }
144
+
145
+ static array_has_data(arr) {
146
+ return arr.length && arr[0].length && arr[0][0].length;
147
+ }
148
+
149
+ process(inputs, outputs, parameters) {
150
+ if (!this.running) {
151
+ return false; // Stop processing.
152
+ }
153
+ if (this.output === null) {
154
+ return true; // Not ready yet, keep processing.
155
+ }
156
+ const process_input = GodotProcessor.array_has_data(inputs);
157
+ if (process_input) {
158
+ const input = inputs[0];
159
+ const chunk = input[0].length * input.length;
160
+ if (this.input_buffer.length !== chunk) {
161
+ this.input_buffer = new Float32Array(chunk);
162
+ }
163
+ if (!this.threads) {
164
+ GodotProcessor.write_input(this.input_buffer, input);
165
+ this.port.postMessage({ 'cmd': 'input', 'data': this.input_buffer });
166
+ } else if (this.input.space_left() >= chunk) {
167
+ GodotProcessor.write_input(this.input_buffer, input);
168
+ this.input.write(this.input_buffer);
169
+ } else {
170
+ // this.port.postMessage('Input buffer is full! Skipping input frame.'); // Uncomment this line to debug input buffer.
171
+ }
172
+ }
173
+ const process_output = GodotProcessor.array_has_data(outputs);
174
+ if (process_output) {
175
+ const output = outputs[0];
176
+ const chunk = output[0].length * output.length;
177
+ if (this.output_buffer.length !== chunk) {
178
+ this.output_buffer = new Float32Array(chunk);
179
+ }
180
+ if (this.output.data_left() >= chunk) {
181
+ this.output.read(this.output_buffer);
182
+ GodotProcessor.write_output(output, this.output_buffer);
183
+ if (!this.threads) {
184
+ this.port.postMessage({ 'cmd': 'read', 'data': chunk });
185
+ }
186
+ } else {
187
+ // this.port.postMessage('Output buffer has not enough frames! Skipping output frame.'); // Uncomment this line to debug output buffer.
188
+ }
189
+ }
190
+ this.process_notify();
191
+ return true;
192
+ }
193
+
194
+ static write_output(dest, source) {
195
+ const channels = dest.length;
196
+ for (let ch = 0; ch < channels; ch++) {
197
+ for (let sample = 0; sample < dest[ch].length; sample++) {
198
+ dest[ch][sample] = source[sample * channels + ch];
199
+ }
200
+ }
201
+ }
202
+
203
+ static write_input(dest, source) {
204
+ const channels = source.length;
205
+ for (let ch = 0; ch < channels; ch++) {
206
+ for (let sample = 0; sample < source[ch].length; sample++) {
207
+ dest[sample * channels + ch] = source[ch][sample];
208
+ }
209
+ }
210
+ }
211
+ }
212
+
213
+ registerProcessor('godot-processor', GodotProcessor);
index.html CHANGED
@@ -1,19 +1,272 @@
1
- <!doctype html>
2
- <html>
3
  <head>
4
- <meta charset="utf-8" />
5
- <meta name="viewport" content="width=device-width" />
6
- <title>My static Space</title>
7
- <link rel="stylesheet" href="style.css" />
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
8
  </head>
9
  <body>
10
- <div class="card">
11
- <h1>Welcome to your static Space!</h1>
12
- <p>You can modify this app directly by editing <i>index.html</i> in the Files and versions tab.</p>
13
- <p>
14
- Also don't forget to check the
15
- <a href="https://huggingface.co/docs/hub/spaces" target="_blank">Spaces documentation</a>.
16
- </p>
 
 
 
 
 
 
 
 
 
 
 
 
17
  </div>
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
18
  </body>
19
  </html>
 
 
1
+ <!DOCTYPE html>
2
+ <html lang="en">
3
  <head>
4
+ <meta charset="utf-8">
5
+ <meta name="viewport" content="width=device-width, user-scalable=no">
6
+ <title>Everchanging Quest</title>
7
+ <style>
8
+ body {
9
+ touch-action: none;
10
+ margin: 0;
11
+ border: 0 none;
12
+ padding: 0;
13
+ text-align: center;
14
+ background-color: black;
15
+ }
16
+
17
+ #canvas {
18
+ display: block;
19
+ margin: 0;
20
+ color: white;
21
+ }
22
+
23
+ #canvas:focus {
24
+ outline: none;
25
+ }
26
+
27
+ .godot {
28
+ font-family: 'Noto Sans', 'Droid Sans', Arial, sans-serif;
29
+ color: #e0e0e0;
30
+ background-color: #3b3943;
31
+ background-image: linear-gradient(to bottom, #403e48, #35333c);
32
+ border: 1px solid #45434e;
33
+ box-shadow: 0 0 1px 1px #2f2d35;
34
+ }
35
+
36
+ /* Status display */
37
+
38
+ #status {
39
+ position: absolute;
40
+ left: 0;
41
+ top: 0;
42
+ right: 0;
43
+ bottom: 0;
44
+ display: flex;
45
+ justify-content: center;
46
+ align-items: center;
47
+ /* don't consume click events - make children visible explicitly */
48
+ visibility: hidden;
49
+ }
50
+
51
+ #status-progress {
52
+ width: 366px;
53
+ height: 7px;
54
+ background-color: #38363A;
55
+ border: 1px solid #444246;
56
+ padding: 1px;
57
+ box-shadow: 0 0 2px 1px #1B1C22;
58
+ border-radius: 2px;
59
+ visibility: visible;
60
+ }
61
+
62
+ @media only screen and (orientation:portrait) {
63
+ #status-progress {
64
+ width: 61.8%;
65
+ }
66
+ }
67
+
68
+ #status-progress-inner {
69
+ height: 100%;
70
+ width: 0;
71
+ box-sizing: border-box;
72
+ transition: width 0.5s linear;
73
+ background-color: #202020;
74
+ border: 1px solid #222223;
75
+ box-shadow: 0 0 1px 1px #27282E;
76
+ border-radius: 3px;
77
+ }
78
+
79
+ #status-indeterminate {
80
+ height: 42px;
81
+ visibility: visible;
82
+ position: relative;
83
+ }
84
+
85
+ #status-indeterminate > div {
86
+ width: 4.5px;
87
+ height: 0;
88
+ border-style: solid;
89
+ border-width: 9px 3px 0 3px;
90
+ border-color: #2b2b2b transparent transparent transparent;
91
+ transform-origin: center 21px;
92
+ position: absolute;
93
+ }
94
+
95
+ #status-indeterminate > div:nth-child(1) { transform: rotate( 22.5deg); }
96
+ #status-indeterminate > div:nth-child(2) { transform: rotate( 67.5deg); }
97
+ #status-indeterminate > div:nth-child(3) { transform: rotate(112.5deg); }
98
+ #status-indeterminate > div:nth-child(4) { transform: rotate(157.5deg); }
99
+ #status-indeterminate > div:nth-child(5) { transform: rotate(202.5deg); }
100
+ #status-indeterminate > div:nth-child(6) { transform: rotate(247.5deg); }
101
+ #status-indeterminate > div:nth-child(7) { transform: rotate(292.5deg); }
102
+ #status-indeterminate > div:nth-child(8) { transform: rotate(337.5deg); }
103
+
104
+ #status-notice {
105
+ margin: 0 100px;
106
+ line-height: 1.3;
107
+ visibility: visible;
108
+ padding: 4px 6px;
109
+ visibility: visible;
110
+ }
111
+ </style>
112
+ <link id='-gd-engine-icon' rel='icon' type='image/png' href='index.icon.png' />
113
+ <link rel='apple-touch-icon' href='index.apple-touch-icon.png'/>
114
+
115
  </head>
116
  <body>
117
+ <canvas id="canvas">
118
+ HTML5 canvas appears to be unsupported in the current browser.<br >
119
+ Please try updating or use a different browser.
120
+ </canvas>
121
+ <div id="status">
122
+ <div id="status-progress" style="display: none;" oncontextmenu="event.preventDefault();">
123
+ <div id ="status-progress-inner"></div>
124
+ </div>
125
+ <div id="status-indeterminate" style="display: none;" oncontextmenu="event.preventDefault();">
126
+ <div></div>
127
+ <div></div>
128
+ <div></div>
129
+ <div></div>
130
+ <div></div>
131
+ <div></div>
132
+ <div></div>
133
+ <div></div>
134
+ </div>
135
+ <div id="status-notice" class="godot" style="display: none;"></div>
136
  </div>
137
+
138
+ <script src="index.js"></script>
139
+ <script>
140
+ const GODOT_CONFIG = {"args":[],"canvasResizePolicy":2,"ensureCrossOriginIsolationHeaders":true,"executable":"index","experimentalVK":false,"fileSizes":{"index.pck":95632528,"index.wasm":47894344},"focusCanvas":true,"gdextensionLibs":[]};
141
+ const GODOT_THREADS_ENABLED = true;
142
+ const engine = new Engine(GODOT_CONFIG);
143
+
144
+ (function () {
145
+ const INDETERMINATE_STATUS_STEP_MS = 100;
146
+ const statusProgress = document.getElementById('status-progress');
147
+ const statusProgressInner = document.getElementById('status-progress-inner');
148
+ const statusIndeterminate = document.getElementById('status-indeterminate');
149
+ const statusNotice = document.getElementById('status-notice');
150
+
151
+ let initializing = true;
152
+ let statusMode = 'hidden';
153
+
154
+ let animationCallbacks = [];
155
+ function animate(time) {
156
+ animationCallbacks.forEach((callback) => callback(time));
157
+ requestAnimationFrame(animate);
158
+ }
159
+ requestAnimationFrame(animate);
160
+
161
+ function animateStatusIndeterminate(ms) {
162
+ const i = Math.floor((ms / INDETERMINATE_STATUS_STEP_MS) % 8);
163
+ if (statusIndeterminate.children[i].style.borderTopColor === '') {
164
+ Array.prototype.slice.call(statusIndeterminate.children).forEach((child) => {
165
+ child.style.borderTopColor = '';
166
+ });
167
+ statusIndeterminate.children[i].style.borderTopColor = '#dfdfdf';
168
+ }
169
+ }
170
+
171
+ function setStatusMode(mode) {
172
+ if (statusMode === mode || !initializing) {
173
+ return;
174
+ }
175
+ [statusProgress, statusIndeterminate, statusNotice].forEach((elem) => {
176
+ elem.style.display = 'none';
177
+ });
178
+ animationCallbacks = animationCallbacks.filter(function (value) {
179
+ return (value !== animateStatusIndeterminate);
180
+ });
181
+ switch (mode) {
182
+ case 'progress':
183
+ statusProgress.style.display = 'block';
184
+ break;
185
+ case 'indeterminate':
186
+ statusIndeterminate.style.display = 'block';
187
+ animationCallbacks.push(animateStatusIndeterminate);
188
+ break;
189
+ case 'notice':
190
+ statusNotice.style.display = 'block';
191
+ break;
192
+ case 'hidden':
193
+ break;
194
+ default:
195
+ throw new Error('Invalid status mode');
196
+ }
197
+ statusMode = mode;
198
+ }
199
+
200
+ function setStatusNotice(text) {
201
+ while (statusNotice.lastChild) {
202
+ statusNotice.removeChild(statusNotice.lastChild);
203
+ }
204
+ const lines = text.split('\n');
205
+ lines.forEach((line) => {
206
+ statusNotice.appendChild(document.createTextNode(line));
207
+ statusNotice.appendChild(document.createElement('br'));
208
+ });
209
+ }
210
+
211
+ function displayFailureNotice(err) {
212
+ const msg = err.message || err;
213
+ console.error(msg);
214
+ setStatusNotice(msg);
215
+ setStatusMode('notice');
216
+ initializing = false;
217
+ }
218
+
219
+ const missing = Engine.getMissingFeatures({
220
+ threads: GODOT_THREADS_ENABLED,
221
+ });
222
+ if (missing.length !== 0) {
223
+ if (GODOT_CONFIG['serviceWorker'] && GODOT_CONFIG['ensureCrossOriginIsolationHeaders'] && 'serviceWorker' in navigator) {
224
+ // There's a chance that installing the service worker would fix the issue
225
+ Promise.race([
226
+ navigator.serviceWorker.getRegistration().then((registration) => {
227
+ if (registration != null) {
228
+ return Promise.reject(new Error('Service worker already exists.'));
229
+ }
230
+ return registration;
231
+ }).then(() => engine.installServiceWorker()),
232
+ // For some reason, `getRegistration()` can stall
233
+ new Promise((resolve) => {
234
+ setTimeout(() => resolve(), 2000);
235
+ }),
236
+ ]).catch((err) => {
237
+ console.error('Error while registering service worker:', err);
238
+ }).then(() => {
239
+ window.location.reload();
240
+ });
241
+ } else {
242
+ // Display the message as usual
243
+ const missingMsg = 'Error\nThe following features required to run Godot projects on the Web are missing:\n';
244
+ displayFailureNotice(missingMsg + missing.join('\n'));
245
+ }
246
+ } else {
247
+ setStatusMode('indeterminate');
248
+ engine.startGame({
249
+ 'onProgress': function (current, total) {
250
+ if (total > 0) {
251
+ statusProgressInner.style.width = `${(current / total) * 100}%`;
252
+ setStatusMode('progress');
253
+ if (current === total) {
254
+ // wait for progress bar animation
255
+ setTimeout(() => {
256
+ setStatusMode('indeterminate');
257
+ }, 500);
258
+ }
259
+ } else {
260
+ setStatusMode('indeterminate');
261
+ }
262
+ },
263
+ }).then(() => {
264
+ setStatusMode('hidden');
265
+ initializing = false;
266
+ }, displayFailureNotice);
267
+ }
268
+ }());
269
+ </script>
270
  </body>
271
  </html>
272
+
index.icon.png ADDED
index.js ADDED
The diff for this file is too large to render. See raw diff
 
index.pck ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:b137999db2162aa17156f74f9565a83f042c58304fb9057452020349a382b6aa
3
+ size 95632528
index.png ADDED
index.wasm ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:440664461663955a377f9be03d3f5342da00eb7600bf3cbe37ffbfe77e2eee63
3
+ size 47894344
index.worker.js ADDED
@@ -0,0 +1,158 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ /**
2
+ * @license
3
+ * Copyright 2015 The Emscripten Authors
4
+ * SPDX-License-Identifier: MIT
5
+ */
6
+
7
+ // Pthread Web Worker startup routine:
8
+ // This is the entry point file that is loaded first by each Web Worker
9
+ // that executes pthreads on the Emscripten application.
10
+
11
+ 'use strict';
12
+
13
+ var Module = {};
14
+
15
+ // Thread-local guard variable for one-time init of the JS state
16
+ var initializedJS = false;
17
+
18
+ function assert(condition, text) {
19
+ if (!condition) abort('Assertion failed: ' + text);
20
+ }
21
+
22
+ function threadPrintErr() {
23
+ var text = Array.prototype.slice.call(arguments).join(' ');
24
+ console.error(text);
25
+ }
26
+ function threadAlert() {
27
+ var text = Array.prototype.slice.call(arguments).join(' ');
28
+ postMessage({cmd: 'alert', text, threadId: Module['_pthread_self']()});
29
+ }
30
+ // We don't need out() for now, but may need to add it if we want to use it
31
+ // here. Or, if this code all moves into the main JS, that problem will go
32
+ // away. (For now, adding it here increases code size for no benefit.)
33
+ var out = () => { throw 'out() is not defined in worker.js.'; }
34
+ var err = threadPrintErr;
35
+ self.alert = threadAlert;
36
+ var dbg = threadPrintErr;
37
+
38
+ Module['instantiateWasm'] = (info, receiveInstance) => {
39
+ // Instantiate from the module posted from the main thread.
40
+ // We can just use sync instantiation in the worker.
41
+ var module = Module['wasmModule'];
42
+ // We don't need the module anymore; new threads will be spawned from the main thread.
43
+ Module['wasmModule'] = null;
44
+ var instance = new WebAssembly.Instance(module, info);
45
+ // TODO: Due to Closure regression https://github.com/google/closure-compiler/issues/3193,
46
+ // the above line no longer optimizes out down to the following line.
47
+ // When the regression is fixed, we can remove this if/else.
48
+ return receiveInstance(instance);
49
+ }
50
+
51
+ // Turn unhandled rejected promises into errors so that the main thread will be
52
+ // notified about them.
53
+ self.onunhandledrejection = (e) => {
54
+ throw e.reason || e;
55
+ };
56
+
57
+ function handleMessage(e) {
58
+ try {
59
+ if (e.data.cmd === 'load') { // Preload command that is called once per worker to parse and load the Emscripten code.
60
+
61
+ // Until we initialize the runtime, queue up any further incoming messages.
62
+ let messageQueue = [];
63
+ self.onmessage = (e) => messageQueue.push(e);
64
+
65
+ // And add a callback for when the runtime is initialized.
66
+ self.startWorker = (instance) => {
67
+ Module = instance;
68
+ // Notify the main thread that this thread has loaded.
69
+ postMessage({ 'cmd': 'loaded' });
70
+ // Process any messages that were queued before the thread was ready.
71
+ for (let msg of messageQueue) {
72
+ handleMessage(msg);
73
+ }
74
+ // Restore the real message handler.
75
+ self.onmessage = handleMessage;
76
+ };
77
+
78
+ // Module and memory were sent from main thread
79
+ Module['wasmModule'] = e.data.wasmModule;
80
+
81
+ // Use `const` here to ensure that the variable is scoped only to
82
+ // that iteration, allowing safe reference from a closure.
83
+ for (const handler of e.data.handlers) {
84
+ Module[handler] = (...args) => {
85
+ postMessage({ cmd: 'callHandler', handler, args: args });
86
+ }
87
+ }
88
+
89
+ Module['wasmMemory'] = e.data.wasmMemory;
90
+
91
+ Module['buffer'] = Module['wasmMemory'].buffer;
92
+
93
+ Module['workerID'] = e.data.workerID;
94
+
95
+ Module['ENVIRONMENT_IS_PTHREAD'] = true;
96
+
97
+ if (typeof e.data.urlOrBlob == 'string') {
98
+ importScripts(e.data.urlOrBlob);
99
+ } else {
100
+ var objectUrl = URL.createObjectURL(e.data.urlOrBlob);
101
+ importScripts(objectUrl);
102
+ URL.revokeObjectURL(objectUrl);
103
+ }
104
+ Godot(Module);
105
+ } else if (e.data.cmd === 'run') {
106
+ // Pass the thread address to wasm to store it for fast access.
107
+ Module['__emscripten_thread_init'](e.data.pthread_ptr, /*is_main=*/0, /*is_runtime=*/0, /*can_block=*/1);
108
+
109
+ // Await mailbox notifications with `Atomics.waitAsync` so we can start
110
+ // using the fast `Atomics.notify` notification path.
111
+ Module['__emscripten_thread_mailbox_await'](e.data.pthread_ptr);
112
+
113
+ assert(e.data.pthread_ptr);
114
+ // Also call inside JS module to set up the stack frame for this pthread in JS module scope
115
+ Module['establishStackSpace']();
116
+ Module['PThread'].receiveObjectTransfer(e.data);
117
+ Module['PThread'].threadInitTLS();
118
+
119
+ if (!initializedJS) {
120
+ initializedJS = true;
121
+ }
122
+
123
+ try {
124
+ Module['invokeEntryPoint'](e.data.start_routine, e.data.arg);
125
+ } catch(ex) {
126
+ if (ex != 'unwind') {
127
+ // The pthread "crashed". Do not call `_emscripten_thread_exit` (which
128
+ // would make this thread joinable). Instead, re-throw the exception
129
+ // and let the top level handler propagate it back to the main thread.
130
+ throw ex;
131
+ }
132
+ }
133
+ } else if (e.data.cmd === 'cancel') { // Main thread is asking for a pthread_cancel() on this thread.
134
+ if (Module['_pthread_self']()) {
135
+ Module['__emscripten_thread_exit'](-1);
136
+ }
137
+ } else if (e.data.target === 'setimmediate') {
138
+ // no-op
139
+ } else if (e.data.cmd === 'checkMailbox') {
140
+ if (initializedJS) {
141
+ Module['checkMailbox']();
142
+ }
143
+ } else if (e.data.cmd) {
144
+ // The received message looks like something that should be handled by this message
145
+ // handler, (since there is a e.data.cmd field present), but is not one of the
146
+ // recognized commands:
147
+ err(`worker.js received unknown command ${e.data.cmd}`);
148
+ err(e.data);
149
+ }
150
+ } catch(ex) {
151
+ err(`worker.js onmessage() captured an uncaught exception: ${ex}`);
152
+ if (ex?.stack) err(ex.stack);
153
+ Module['__emscripten_thread_crashed']?.();
154
+ throw ex;
155
+ }
156
+ };
157
+
158
+ self.onmessage = handleMessage;