Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
86 changes: 78 additions & 8 deletions core/iwasm/libraries/lib-wasi-threads/lib_wasi_threads_wrapper.c
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,14 @@ static const char *THREAD_START_FUNCTION = "wasi_thread_start";

static korp_mutex thread_id_lock;

// Stack data structure to track available thread identifiers
#define AVAIL_TIDS_INIT_SIZE CLUSTER_MAX_THREAD_NUM
typedef struct {
int32 *ids;
uint32 pos, size;
} AvailableThreadIds;
static AvailableThreadIds avail_tids;

typedef struct {
/* app's entry function */
wasm_function_inst_t start_func;
Expand All @@ -30,16 +38,56 @@ typedef struct {
static int32
allocate_thread_id()
{
static int32 thread_id = 0;

int32 id;
int32 id = -1;

os_mutex_lock(&thread_id_lock);
id = thread_id++;
if (avail_tids.pos == 0) { // Resize stack and push new thread ids
uint32 old_size = avail_tids.size;
uint32 new_size = avail_tids.size * 2;
if (new_size / 2 != avail_tids.size) {

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

[minor] you might just compare old_size with the new_size to avoid additional division.

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I used the division to make it similar to L54. I'm not sure a simple comparison would work for L54 (maybe when overflowing/wrapping the result can be bigger than the initial value?)

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

yes, one way to detect integer overflow here is to check if new_size < avail_tids.size. It's not a major callout though.

LOG_ERROR("Overflow detected during new size calculation");
goto return_id;
}

size_t realloc_size = new_size * sizeof(int32);
if (realloc_size / sizeof(int32) != new_size) {
LOG_ERROR("Overflow detected during realloc");
goto return_id;
}
int32 *tmp =
(int32 *)wasm_runtime_realloc(avail_tids.ids, realloc_size);

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

you don't need a cast

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Should I get rid of it? I put it (and same for the malloc) for consistency with the rest of the codebase

if (tmp == NULL) {
LOG_ERROR("Thread ID allocator realloc failed");
goto return_id;
}

avail_tids.size = new_size;
avail_tids.pos = old_size;
avail_tids.ids = tmp;
for (uint32 i = 0; i < old_size; i++)
avail_tids.ids[i] = new_size - i;
}

// Pop available thread identifier from `avail_tids` stack
id = avail_tids.ids[--avail_tids.pos];

return_id:
os_mutex_unlock(&thread_id_lock);
return id;
}

void
deallocate_thread_id(int32 thread_id)
{
os_mutex_lock(&thread_id_lock);

// Release thread identifier by pushing it into `avail_tids` stack
bh_assert(avail_tids.pos < avail_tids.size);
avail_tids.ids[avail_tids.pos++] = thread_id;

os_mutex_unlock(&thread_id_lock);
}

static void *
thread_start(void *arg)
{
Expand All @@ -57,6 +105,8 @@ thread_start(void *arg)
wasm_cluster_spread_exception(exec_env);
}

// Routine exit
deallocate_thread_id(thread_arg->thread_id);
wasm_runtime_free(thread_arg);
exec_env->thread_arg = NULL;

Expand Down Expand Up @@ -101,23 +151,26 @@ thread_spawn_wrapper(wasm_exec_env_t exec_env, uint32 start_arg)
if (!start_func) {
LOG_ERROR("Failed to find thread start function %s",
THREAD_START_FUNCTION);
goto thread_spawn_fail;
goto thread_preparation_fail;
}

if (!(thread_start_arg = wasm_runtime_malloc(sizeof(ThreadStartArg)))) {
LOG_ERROR("Runtime args allocation failed");
goto thread_spawn_fail;
goto thread_preparation_fail;
}

thread_start_arg->thread_id = thread_id = allocate_thread_id();
if (thread_id < 0) {
LOG_ERROR("Failed to get thread identifier");
goto thread_preparation_fail;
}
thread_start_arg->arg = start_arg;
thread_start_arg->start_func = start_func;

os_mutex_lock(&exec_env->wait_lock);
ret = wasm_cluster_create_thread(exec_env, new_module_inst, thread_start,
thread_start_arg);
if (ret != 0) {
os_mutex_unlock(&exec_env->wait_lock);
LOG_ERROR("Failed to spawn a new thread");
goto thread_spawn_fail;
}
Expand All @@ -126,9 +179,12 @@ thread_spawn_wrapper(wasm_exec_env_t exec_env, uint32 start_arg)
return thread_id;

thread_spawn_fail:
os_mutex_unlock(&exec_env->wait_lock);
Comment thread
wenyongh marked this conversation as resolved.
deallocate_thread_id(thread_id);

thread_preparation_fail:
if (new_module_inst)
wasm_runtime_deinstantiate_internal(new_module_inst, true);

if (thread_start_arg)
wasm_runtime_free(thread_start_arg);

Expand Down Expand Up @@ -156,11 +212,25 @@ lib_wasi_threads_init(void)
if (0 != os_mutex_init(&thread_id_lock))
return false;

// Initialize stack to store thread identifiers
avail_tids.size = AVAIL_TIDS_INIT_SIZE;
avail_tids.pos = avail_tids.size;
avail_tids.ids =
(int32 *)wasm_runtime_malloc(avail_tids.size * sizeof(int32));
if (avail_tids.ids == NULL) {
os_mutex_destroy(&thread_id_lock);
return false;
}
for (uint32 i = 0; i < avail_tids.size; i++)
avail_tids.ids[i] = avail_tids.size - i;

return true;
}

void
lib_wasi_threads_destroy(void)
{
wasm_runtime_free(avail_tids.ids);
avail_tids.ids = NULL;
os_mutex_destroy(&thread_id_lock);
}