destroy mailboxes on thread exit

scripts/core/engine.js

@@ -24,6 +24,10 @@ prosperon.dispatch = function(type, data) {
 var os = use_embed('os')
 var js = use_embed('js')
 
+prosperon.on('exit', _ => {
+  os.mailbox_destroy(prosperon.id);
+})
+
 prosperon.on('SIGINT', function() {
   os.exit(1)
 })
@@ -851,7 +855,6 @@ function handle_actor_disconnect(id) {
 }
 
 function handle_local(msg) {
-  console.log(`got an arraybuffer of length ${msg.byteLength}`)
   handle_message(wota.decode(msg))
 }
 

source/jsffi.c

@@ -7176,7 +7176,7 @@ JSC_CCALL(os_mailbox_push,
 
   if (!buf) return JS_ThrowInternalError(js, "Could not get data from arraybuffer.");
 
-  void *data = malloc(size);
+  void *data = js_malloc_rt(JS_GetRuntime(js), size);
   if (!data) return JS_ThrowInternalError(js, "Memory allocation failed.");
   
   memcpy(data,buf,size);
@@ -7248,6 +7248,31 @@ JSC_CCALL(os_mailbox_start,
   JS_FreeCString(js, id);
 )
 
+JSC_CCALL(os_mailbox_destroy,
+  if (argc < 1) return JS_ThrowInternalError(js, "Need an actor/mailbox ID to destroy");
+  
+  const char *id = JS_ToCString(js, argv[0]);
+  int mailbox_index = shgeti(mailboxes, id);
+  JS_FreeCString(js, id);
+
+  if (mailbox_index != -1) {
+    mailbox *mb = &mailboxes[mailbox_index].value;
+    SDL_LockMutex(mb->mutex);
+
+    int count = arrlen(mb->messages);
+    for (int i = 0; i < count; i++)
+      js_free_rt(JS_GetRuntime(js), mb->messages[i].data);
+    arrfree(mb->messages);
+    SDL_UnlockMutex(mb->mutex);
+
+    SDL_DestroyMutex(mb->mutex);
+
+    SDL_LockMutex(mailboxes_mutex);
+    shdel(mailboxes, id);
+    SDL_UnlockMutex(mailboxes_mutex);
+  }
+)
+
 JSC_CCALL(os_waitevent,
   SDL_Event event;
   double secs;
@@ -7311,6 +7336,7 @@ static const JSCFunctionListEntry js_os_funcs[] = {
   MIST_FUNC_DEF(os, mailbox_service, 2),
   MIST_FUNC_DEF(os, mailbox_start, 1),
   MIST_FUNC_DEF(os, mailbox_exist, 1),
+  MIST_FUNC_DEF(os, mailbox_destroy, 1),
   MIST_FUNC_DEF(os, createthread, 1),
 };