implement atomics opcodes for interpreter

core/iwasm/common/wasm_shared_memory.c

@@ -397,7 +397,7 @@ wasm_runtime_atomic_wait(WASMModuleInstanceCommon *module, void *address,
     return is_timeout ? 2 : 0;
 }
 
-uint8
+uint32
 wasm_runtime_atomic_notify(WASMModuleInstanceCommon *module,
                            void *address, uint32 count)
 {

core/iwasm/common/wasm_shared_memory.h

@@ -57,7 +57,7 @@ uint32
 wasm_runtime_atomic_wait(WASMModuleInstanceCommon *module, void *address,
                          uint64 expect, int64 timeout, bool wait64);
 
-uint8
+uint32
 wasm_runtime_atomic_notify(WASMModuleInstanceCommon *module,
                            void *address, uint32 count);
 

core/iwasm/interpreter/wasm_loader.c

@@ -6596,6 +6596,9 @@ wasm_loader_prepare_bytecode(WASMModule *module, WASMFunction *func,
                                                   error_buf_size)) {
                         goto fail;
                     }
+#if WASM_ENABLE_FAST_INTERP != 0
+                    emit_uint32(loader_ctx, mem_offset);
+#endif
                 }
                 switch (opcode) {
                     case WASM_OP_ATOMIC_NOTIFY:

core/iwasm/interpreter/wasm_mini_loader.c

@@ -5348,6 +5348,9 @@ wasm_loader_prepare_bytecode(WASMModule *module, WASMFunction *func,
                     CHECK_MEMORY();
                     read_leb_uint32(p, p_end, align); /* align */
                     read_leb_uint32(p, p_end, mem_offset); /* offset */
+#if WASM_ENABLE_FAST_INTERP != 0
+                    emit_uint32(loader_ctx, mem_offset);
+#endif
                 }
                 switch (opcode) {
                     case WASM_OP_ATOMIC_NOTIFY:

core/iwasm/interpreter/wasm_opcode.h

@@ -369,6 +369,15 @@ typedef enum WASMAtomicEXTOpcode {
 }
 #endif
 
+/* Opcode prefix controlled by features */
+#if WASM_ENABLE_SHARED_MEMORY != 0
+#define DEF_ATOMIC_PREFIX_HANDLE(_name)                      \
+  _name[WASM_OP_ATOMIC_PREFIX] =                             \
+    HANDLE_OPCODE (WASM_OP_ATOMIC_PREFIX);   /* 0xfe */
+#else
+#define DEF_ATOMIC_PREFIX_HANDLE(_name)
+#endif
+
 /*
  * Macro used to generate computed goto tables for the C interpreter.
  */
@@ -591,5 +600,6 @@ static type _name[WASM_INSTRUCTION_NUM] = {                  \
 do {                                                         \
   _name[WASM_OP_MISC_PREFIX] =                               \
     HANDLE_OPCODE (WASM_OP_MISC_PREFIX);     /* 0xfc */      \
+  DEF_ATOMIC_PREFIX_HANDLE(_name)                            \
 } while (0)
 #endif /* end of _WASM_OPCODE_H */

core/iwasm/interpreter/wasm_runtime.c

@@ -91,6 +91,7 @@ memories_deinstantiate(WASMModuleInstance *module_inst,
                     continue;
 #endif
 #if WASM_ENABLE_SHARED_MEMORY != 0
+                os_mutex_destroy(&memories[0]->mem_lock);
                 if (memories[i]->is_shared) {
                     int32 ref_count =
                         shared_memory_dec_reference(
@@ -192,6 +193,11 @@ memory_instantiate(WASMModuleInstance *module_inst,
     memory->heap_base_offset = -(int32)heap_size;
 
 #if WASM_ENABLE_SHARED_MEMORY != 0
+    if (0 != os_mutex_init(&memory->mem_lock)) {
+        mem_allocator_destroy(memory->heap_handle);
+        wasm_runtime_free(memory);
+        return NULL;
+    }
     if (is_shared_memory) {
         memory->is_shared = true;
         if (!shared_memory_set_memory_inst(
@@ -200,6 +206,8 @@ memory_instantiate(WASMModuleInstance *module_inst,
             set_error_buf(error_buf, error_buf_size,
                           "Instantiate memory failed:"
                           "allocate memory failed.");
+            os_mutex_destroy(&memory->mem_lock);
+            mem_allocator_destroy(memory->heap_handle);
             wasm_runtime_free(memory);
             return NULL;
         }

core/iwasm/interpreter/wasm_runtime.h

@@ -50,6 +50,12 @@ typedef struct WASMMemoryInstance {
     /* to indicate which module instance create it */
     WASMModuleInstance *owner;
 #endif
+
+#if WASM_ENABLE_SHARED_MEMORY != 0
+    /* mutex lock for the memory, used in atomic operation */
+    korp_mutex mem_lock;
+#endif
+
     /* Base address, the layout is:
        heap_data + memory data
        memory data init size is: num_bytes_per_page * cur_page_count

doc/pthread_library.md

@@ -67,7 +67,6 @@ You can also build this program with WASI, but we need to make some changes to w
     ```
 > Note: </br>
 >1. Remember to back up the original sysroot files
->2. wasi-sdk 9.0 or above are not supported, please use 7.0 or 8.0
 
 Then build the program with this command:
 ``` bash