feat: add auto accept

planglib/std/libuv.pi

@@ -114,7 +114,7 @@ pub fn set_data_for_handle<H|T> (handle:*H, data:*T) void {
 /// # get_data_for_handle
 /// 
 /// This function is used to get the data of the handle.
-/// It will undo the pinning and keep-alive of the data
+/// It will undo the keep-alive of the data
 /// 
 /// For more information, see the `set_data_for_handle` function.
 pub fn get_data_for_handle<H|T> (handle:*H) *T {
@@ -124,3 +124,17 @@ pub fn get_data_for_handle<H|T> (handle:*H) *T {
 }
 
 
+/// # get_data_for_handle_raw
+/// 
+/// This function is used to get the data of the handle.
+/// 
+/// Unlike the `get_data_for_handle` function, this function
+/// has no side effect, can be used to get the data without
+/// undoing the keep-alive.
+pub fn get_data_for_handle_raw<H|T> (handle:*H) *T {
+    let re = uv_handle_get_data(unsafe_cast<()>(handle));
+    // gc::rm_alive_pinned(re);
+    return unsafe_cast<T>(re);
+}
+
+

planglib/std/task/reactor.pi

@@ -56,7 +56,10 @@ fn close_cb(handle:*()) void {
 
 
 fn conn_cb(server:*libuv::uv_stream_t, status:u32) void {
-    let on_conn = libuv::get_data_for_handle<libuv::uv_stream_t|||=>void>(server);
+    let client = libuv::new_uv_tcp_t();
+    libuv::uv_tcp_init(GLOBAL_REACTOR.loop, unsafe_cast<libuv::uv_tcp_t>(client));
+    libuv::uv_accept(server, unsafe_cast<libuv::uv_stream_t>(client));
+    let on_conn = libuv::get_data_for_handle_raw<libuv::uv_stream_t|||=>void>(server);
     (*on_conn)();
     return;
 }