wasm_async_guard.h

Go to the documentation of this file.

#ifndef YAZE_APP_PLATFORM_WASM_WASM_ASYNC_GUARD_H_
#define YAZE_APP_PLATFORM_WASM_WASM_ASYNC_GUARD_H_
 
#ifdef __EMSCRIPTEN__
 
#include <atomic>
 
#include <emscripten.h>
 
namespace yaze {
namespace platform {
 
class WasmAsyncGuard {
 public:
  static bool TryAcquire() {
    bool expected = false;
    return in_async_op_.compare_exchange_strong(expected, true);
  }
 
  static void Release() { in_async_op_.store(false); }
 
  static bool IsInProgress() { return in_async_op_.load(); }
 
  class ScopedGuard {
   public:
    ScopedGuard() : acquired_(TryAcquire()) {
      if (!acquired_) {
        emscripten_log(
            EM_LOG_WARN,
            "[WasmAsyncGuard] Async operation already in progress, "
            "request will be queued by JS async queue");
      }
    }
 
    ~ScopedGuard() {
      if (acquired_) {
        Release();
      }
    }
 
    // Non-copyable
    ScopedGuard(const ScopedGuard&) = delete;
    ScopedGuard& operator=(const ScopedGuard&) = delete;
 
    bool acquired() const { return acquired_; }
 
   private:
    bool acquired_;
  };
 
 private:
  static std::atomic<bool> in_async_op_;
};
 
}  // namespace platform
}  // namespace yaze
 
#endif  // __EMSCRIPTEN__
 
#endif  // YAZE_APP_PLATFORM_WASM_WASM_ASYNC_GUARD_H_