debug test_async

Author: waruqi

core/src/tbox/tbox

@@ -45,6 +45,7 @@ tb_int_t xm_thread_event_exit(lua_State* lua)
         if (thread_event->handle)
         {
             tb_event_exit(thread_event->handle);
+            tb_trace_i("tb_event_exit %p", thread_event->handle);
             thread_event->handle = tb_null;
         }
         tb_free(thread_event);

core/src/xmake/thread/event_exit.c

@@ -46,6 +46,7 @@ tb_int_t xm_thread_event_init(lua_State* lua)
 
         thread_event->refn = 1;
         thread_event->handle = tb_event_init();
+        tb_trace_i("tb_event_init: %p", thread_event->handle);
         tb_assert_and_check_break(thread_event->handle);
 
         xm_lua_pushpointer(lua, (tb_pointer_t)thread_event);

core/src/xmake/thread/event_init.c

@@ -41,6 +41,7 @@ tb_int_t xm_thread_event_post(lua_State* lua)
     tb_assert_and_check_return_val(thread_event && thread_event->handle, 0);
 
     lua_pushboolean(lua, tb_event_post(thread_event->handle));
+        tb_trace_i("tb_event_post: %p ok", thread_event->handle);
     return 1;
 }
 

core/src/xmake/thread/event_post.c

@@ -41,7 +41,9 @@ tb_int_t xm_thread_event_wait(lua_State* lua)
     tb_assert_and_check_return_val(thread_event && thread_event->handle, 0);
 
     tb_long_t timeout = (tb_long_t)luaL_checknumber(lua, 2);
-    lua_pushinteger(lua, tb_event_wait(thread_event->handle, timeout));
+    tb_long_t wait = tb_event_wait(thread_event->handle, timeout);
+        tb_trace_i("tb_event_wait: %p, %ld %ld", thread_event->handle, wait, timeout);
+    lua_pushinteger(lua, wait);
     return 1;
 }
 

core/src/xmake/thread/event_wait.c

@@ -155,6 +155,7 @@ function test_async(t)
     io.writefile(path.join(tmpdir, "foo.txt"), "foo")
     io.writefile(path.join(tmpdir, "bar.txt"), "bar")
     local files = os.files(path.join(tmpdir, "*.txt"), {async = true})
+    print("files", files)
     t:require(files and #files == 2)
 
     os.cp(tmpdir, tmpdir2, {async = true, detach = true})

tests/modules/os/test.lua

@@ -6,7 +6,7 @@ local test_assert = { print_error = import("print_error", { anonymous = true }).
 
 function test_assert:require(value)
     if not value then
-        self:print_error(vformat("require ${green}true${reset} but got ${red}%s${reset}", value), self.filename)
+        self:print_error(vformat("require ${green}true${reset} but got ${red}%s${reset}", tostring(value)), self.filename)
     end
 end
 

tests/test_utils/test_assert.lua

@@ -43,8 +43,10 @@ local sharedata_pool = {}
 -- get event from pool or create new one
 function async_task._get_event()
     local event = table.remove(event_pool)
+    print("get event", event)
     if not event then
         event = thread.event()
+        print("new", event)
     end
     return event
 end
@@ -231,6 +233,7 @@ end
 function async_task._post_task(cmd, is_detach, return_data)
     local cmd_event, cmd_result
 
+    print("post task")
     -- create event and result for non-detach mode
     if not is_detach then
         cmd_event = async_task._get_event()
@@ -255,10 +258,13 @@ function async_task._post_task(cmd, is_detach, return_data)
     else
         -- wait for completion
         task_event:post()
+        print("wait event")
         cmd_event:wait(-1)
+        print("wait ok")
         local result = cmd_result:get()
         async_task._put_event(cmd_event)
         async_task._put_sharedata(cmd_result)
+        print("return", result, return_data)
         if result and result.ok then
             if return_data then
                 return result.data, #result.data

xmake/core/base/private/async_task.lua

@@ -388,6 +388,7 @@ end
 -- @return          ok, errors
 --
 function _event:post()
+    print("event post", self, debug.traceback())
     local ok, errors = self:_ensure_opened()
     if not ok then
         return false, errors
@@ -401,6 +402,7 @@ end
 
 -- wait event
 function _event:wait(timeout)
+    print("event wait", self)
     local ok, errors = self:_ensure_opened()
     if not ok then
         return false, errors