From 237fcfbd61a9895326538a274f025d9ed57a3903 Mon Sep 17 00:00:00 2001
From: ame <ameliasquires@disroot.org>
Date: Sat, 25 May 2024 04:08:59 -0500
Subject: fixed deepcopy

---
 src/thread.c | 97 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++---
 1 file changed, 93 insertions(+), 4 deletions(-)

(limited to 'src/thread.c')

diff --git a/src/thread.c b/src/thread.c
index dd4052a..dec9ceb 100644
--- a/src/thread.c
+++ b/src/thread.c
@@ -9,6 +9,7 @@
 #include "util.h"
 
 #include "types/larray.h"
+#include "hash/fnv.h"
 
 struct thread_info {
     str* function;
@@ -96,7 +97,7 @@ int l_res(lua_State* L){
         int ot = lua_gettop(L);
 
         lua_pushvalue(L, 2 + i);
-        i_dcopy(L, info->L, NULL);
+        luaI_deepcopy(L, info->L, NULL, 0);
 
         lua_settop(L, ot);
     }
@@ -148,7 +149,7 @@ int l_await(lua_State* L){
         int ot = lua_gettop(info->L);
 
         lua_pushvalue(info->L, ot - info->return_count + i);
-        i_dcopy(info->L, L, NULL);
+        luaI_deepcopy(info->L, L, NULL, 0);
         
         lua_settop(info->L, ot);
     }
@@ -177,10 +178,10 @@ int l_clean(lua_State* L){
 int l_async(lua_State* oL){
    lua_State* L = luaL_newstate(); 
 
-  luaL_openlibs(L);
+  //luaL_openlibs(L);
 
   lua_getglobal(oL, "_G");
-  i_dcopy(oL, L, NULL);
+  luaI_deepcopy(oL, L, NULL, 0);
   lua_set_global_table(L);
 
   struct thread_info* args = calloc(1, sizeof * args);
@@ -211,3 +212,91 @@ int l_async(lua_State* oL){
   lua_pushvalue(oL, res_idx);
   return 1;
 }
+
+struct thread_buffer {
+  lua_State* L;
+  pthread_mutex_t lock;
+};
+
+int _buffer_get(lua_State* L){
+  struct thread_buffer *buffer = lua_touserdata(L, 1);
+  pthread_mutex_lock(&buffer->lock);
+  luaI_deepcopy(buffer->L, L, NULL, 0);
+  pthread_mutex_unlock(&buffer->lock);
+  return 1;
+}
+
+int _buffer_set(lua_State* L){
+  struct thread_buffer *buffer = lua_touserdata(L, 1);
+  pthread_mutex_lock(&buffer->lock);
+  lua_settop(buffer->L, 0);
+  luaI_deepcopy(L, buffer->L, NULL, 0);
+  pthread_mutex_unlock(&buffer->lock);
+  return 1;
+}
+
+int _buffer_mod(lua_State* L){
+  struct thread_buffer *buffer = lua_touserdata(L, 1);
+  pthread_mutex_lock(&buffer->lock);
+  luaI_deepcopy(buffer->L, L, NULL, 0);
+  int item = lua_gettop(L);
+  lua_pushvalue(L, 2);
+  lua_pushvalue(L, item);
+  lua_call(L, 1, 1);
+
+  if(lua_type(L, -1) != LUA_TNIL){
+    lua_settop(buffer->L, 0);
+    luaI_deepcopy(L, buffer->L, NULL, 0);
+  }
+  pthread_mutex_unlock(&buffer->lock);
+  return 1;
+}
+
+
+int l_buffer_index(lua_State* L){
+  uint64_t len, hash;
+  const char* str = luaL_tolstring(L, 2, &len);
+
+  hash = fnv_1((uint8_t*)str, len, v_1);
+
+  switch(hash){
+    case 0xd8c8ad186b9ed323: //get
+      lua_pushcfunction(L, _buffer_get);
+      break;
+    case 0xd89f9d186b7bb367: //set
+      lua_pushcfunction(L, _buffer_set);
+      break;
+    case 0xd8b3c7186b8ca31f: //mod
+      lua_pushcfunction(L, _buffer_mod);
+      break;
+    default:
+      lua_pushnil(L);
+      break;
+  }
+  return 1;
+}
+
+int l_buffer(lua_State* L){
+  struct thread_buffer *buffer = malloc(sizeof * buffer);
+  buffer->L = luaL_newstate();
+  pthread_mutex_init(&buffer->lock, NULL);
+  luaI_deepcopy(L, buffer->L, NULL, 0);
+
+  lua_newtable(L);
+  int meta_idx = lua_gettop(L);
+  luaI_tsetcf(L, meta_idx, "__index", l_buffer_index);
+
+  lua_pushlightuserdata(L, buffer);
+  lua_pushvalue(L, meta_idx);
+  lua_setmetatable(L, -2);
+
+  return 1;
+}
+
+int l_testcopy(lua_State* L){
+  lua_State* temp = luaL_newstate();
+  luaI_deepcopy(L, temp, NULL, 0);
+  luaI_deepcopy(temp, L, NULL, 0);
+
+  return 1;
+}
-- 
cgit v1.2.3