Adding more tests (work-in-progress)

Author: cwoffenden

test/webaudio/audioworklet_emscripten_locks.c

@@ -5,36 +5,90 @@
 #include <stdlib.h>
 #include <assert.h>
 
-// Tests that these audio worklet compatible functions work:
+// Tests that these audio worklet compatible functions work, details in comments below.
 // - emscripten_thread_supports_atomics_wait()
 // - emscripten_lock_init()
+// - emscripten_lock_try_acquire()
 // - emscripten_lock_busyspin_wait_acquire()
 // - emscripten_lock_busyspin_waitinf_acquire()
-// - emscripten_lock_try_acquire()
 // - emscripten_lock_release()
-// - emscripten_get_now() does not crash in a Wasm Audio Worklet.
+// - emscripten_get_now()
+
+typedef enum {
+  // No wait support in audio worklets
+  TEST_HAS_WAIT,
+  // Acquired in main, fail in process
+  TEST_TRY_ACQUIRE,
+  // Keep acquired so time-out
+  TEST_WAIT_ACQUIRE_FAIL,
+  // Release in main, succeed in process
+  TEST_WAIT_ACQUIRE,
+  // Release in process after above
+  TEST_RELEASE,
+  // Released in process above, spin in main
+  TEST_WAIT_INFINTE_1,
+  // Release in process to stop spinning in main
+  TEST_WAIT_INFINTE_2,
+  // Call emscripten_get_now() in process
+  TEST_GET_NOW,
+  // Test finished
+  TEST_DONE
+} Test;
 
 emscripten_lock_t testLock = EMSCRIPTEN_LOCK_T_STATIC_INITIALIZER;
-int testSuccess = 0;
+_Atomic Test whichTest = TEST_HAS_WAIT;
+double startTime = 0;
 
 bool ProcessAudio(int numInputs, const AudioSampleFrame *inputs, int numOutputs, AudioSampleFrame *outputs, int numParams, const AudioParamFrame *params, void *userData) {
-  // We're in the audio worklet so no wait support
-  int supportsAtomicWait = emscripten_thread_supports_atomics_wait();
-  printf("supportsAtomicWait: %d\n", supportsAtomicWait);
-  assert(!supportsAtomicWait);
-
-  // Fail to grab the lock 
-  int tryLock = emscripten_lock_try_acquire(&testLock);
-  printf("emscripten_lock_try_acquire: %d\n", tryLock);
-  assert(!tryLock);
-
-  //emscripten_futex_wake(&futexLocation, 1);
-  printf("%f\n", emscripten_get_now());
-
-  //emscripten_futex_wait(&futexLocation, 1, /*maxWaitMs=*/2);
-  testSuccess = 1;
+  int result = 0;
+  switch (whichTest) {
+  case TEST_HAS_WAIT:
+    // Should not have wait support here
+    result = emscripten_thread_supports_atomics_wait();
+    printf("TEST_HAS_WAIT: %d\n", result);
+    assert(!result);
+    whichTest = TEST_TRY_ACQUIRE;
+    break;
+  case TEST_TRY_ACQUIRE:
+    // Was locked after init, should fail to acquire
+    result = emscripten_lock_try_acquire(&testLock);
+    printf("TEST_TRY_ACQUIRE: %d\n", result);
+    assert(!result);
+    whichTest = TEST_WAIT_ACQUIRE_FAIL;
+    break;
+  case TEST_WAIT_ACQUIRE_FAIL:
+    // Still locked so we fail to acquire
+    result = emscripten_lock_busyspin_wait_acquire(&testLock, 100);
+    printf("TEST_WAIT_ACQUIRE_FAIL: %d\n", result);
+    assert(!result);
+    whichTest = TEST_WAIT_ACQUIRE;
+  case TEST_WAIT_ACQUIRE:
+    // Will get unlocked in main, so should quickly acquire
+    result = emscripten_lock_busyspin_wait_acquire(&testLock, 100);
+    printf("TEST_WAIT_ACQUIRE: %d\n", result);
+    assert(result);
+    whichTest = TEST_RELEASE;
+    break;
+  case TEST_RELEASE:
+    // Unlock, check the result
+    emscripten_lock_release(&testLock);
+    result = emscripten_lock_try_acquire(&testLock);
+    printf("TEST_RELEASE: %d\n", result);
+    assert(result);
+    whichTest = TEST_WAIT_INFINTE_1;
+    break;
+  case TEST_WAIT_INFINTE_1:
+    // Still locked when we enter here
+  case TEST_GET_NOW:
+    result = (int) (emscripten_get_now() - startTime);
+    printf("TEST_GET_NOW: %d\n", result);
+    assert(result);
+    whichTest = TEST_DONE;
+  default:
+    break;
+  }
 
-  return false;
+  return true;
 }
 
 EM_JS(void, InitHtmlUi, (EMSCRIPTEN_WEBAUDIO_T audioContext), {
@@ -48,28 +102,35 @@ EM_JS(void, InitHtmlUi, (EMSCRIPTEN_WEBAUDIO_T audioContext), {
   };
 });
 
-bool PollTestSuccess(double time, void* data) {
-  if (testSuccess) {
-    printf("Test success!\n");
-#ifdef REPORT_RESULT
-    REPORT_RESULT(0);
-#endif
-    return false;
+bool MainLoop(double time, void* data) {
+  int result = 0;
+  switch (whichTest) {
+  case TEST_WAIT_ACQUIRE:
+    // Release here to acquire in process
+    emscripten_lock_release(&testLock);
+    break;
+  case TEST_WAIT_INFINTE_1:
+    // Spin here until released in process
+    emscripten_lock_busyspin_waitinf_acquire(&testLock);
+    whichTest = TEST_DONE;
+    break;
+  default:
+    break;
   }
   return true;
 }
 
 void AudioWorkletProcessorCreated(EMSCRIPTEN_WEBAUDIO_T audioContext, bool success, void *userData) {
   int outputChannelCounts[1] = { 1 };
   EmscriptenAudioWorkletNodeCreateOptions options = { .numberOfInputs = 0, .numberOfOutputs = 1, .outputChannelCounts = outputChannelCounts };
-  EMSCRIPTEN_AUDIO_WORKLET_NODE_T wasmAudioWorklet = emscripten_create_wasm_audio_worklet_node(audioContext, "noise-generator", &options, &ProcessAudio, 0);
+  EMSCRIPTEN_AUDIO_WORKLET_NODE_T wasmAudioWorklet = emscripten_create_wasm_audio_worklet_node(audioContext, "noise-generator", &options, &ProcessAudio, NULL);
   emscripten_audio_node_connect(wasmAudioWorklet, audioContext, 0, 0);
   InitHtmlUi(audioContext);
 }
 
 void WebAudioWorkletThreadInitialized(EMSCRIPTEN_WEBAUDIO_T audioContext, bool success, void *userData) {
   WebAudioWorkletProcessorCreateOptions opts = { .name = "noise-generator" };
-  emscripten_create_wasm_audio_worklet_processor_async(audioContext, &opts, AudioWorkletProcessorCreated, 0);
+  emscripten_create_wasm_audio_worklet_processor_async(audioContext, &opts, AudioWorkletProcessorCreated, NULL);
 }
 
 uint8_t wasmAudioWorkletStack[4096];
@@ -80,7 +141,9 @@ int main() {
   int hasLock = emscripten_lock_busyspin_wait_acquire(&testLock, 0);
   assert(hasLock);
 
-  emscripten_set_timeout_loop(PollTestSuccess, 10, 0);
-  EMSCRIPTEN_WEBAUDIO_T context = emscripten_create_audio_context(0);
-  emscripten_start_wasm_audio_worklet_thread_async(context, wasmAudioWorkletStack, sizeof(wasmAudioWorkletStack), WebAudioWorkletThreadInitialized, 0);
+  startTime = emscripten_get_now();
+
+  emscripten_set_timeout_loop(MainLoop, 10, NULL);
+  EMSCRIPTEN_WEBAUDIO_T context = emscripten_create_audio_context(NULL);
+  emscripten_start_wasm_audio_worklet_thread_async(context, wasmAudioWorkletStack, sizeof(wasmAudioWorkletStack), WebAudioWorkletThreadInitialized, NULL);
 }