Fix bugs & Add test codes

Author: f0cii

moxt/libnet.cpp

@@ -1,5 +1,6 @@
 #include "libnet.hpp"
 
+#include "common.hpp"
 #include "libthread.hpp"
 #include "moxt/httpx/asio_ioc.hpp"
 #include "moxt/httpx/httpbase.hpp"
@@ -64,6 +65,10 @@ SEQ_FUNC void seq_websocket_set_on_message(WebSocket *p,
     p->set_on_message(callback);
 }
 
+SEQ_FUNC AsioIOC *seq_asio_ioc() { return &AsioIOC::default_pool(); }
+
+SEQ_FUNC void seq_asio_ioc_poll(AsioIOC *ioc) { ioc->poll(); }
+
 void *coro_net_run(void *arg) {
     auto &pool = AsioIOC::default_pool();
     for (;;) {

moxt/libthread.cpp

@@ -6,6 +6,9 @@
 #include <chrono>
 #include <cmath>
 #include <csignal>
+#include <cstddef>
+#include <cstdio>
+#include <future>
 #include <photon/common/alog.h>
 #include <photon/common/lockfree_queue.h>
 #include <photon/io/signal.h>
@@ -501,3 +504,48 @@ SEQ_FUNC bool seq_lockfree_queue_pop(CLockfreeSPSCRingQueueHandle handle,
     auto queue = static_cast<LockfreeSPSCRingQueue<iovec, capacity> *>(handle);
     return queue->pop(*data);
 }
+
+// ¶¨Òå sample_callback_
+sample_callback sample_callback_ = nullptr;
+
+SEQ_FUNC void seq_set_sample_callback(sample_callback callback) {
+    sample_callback_ = callback;
+}
+
+SEQ_FUNC void seq_sample_test() {
+    if (sample_callback_) {
+        sample_callback_();
+    }
+}
+
+// entry
+static void *entry(void *arg) {
+    printf("entry\n");
+    if (sample_callback_) {
+        sample_callback_();
+    }
+    printf("entry done\n");
+    return nullptr;
+}
+
+static void e() {
+    printf("e\n");
+    if (sample_callback_) {
+        sample_callback_();
+    }
+    printf("e done\n");
+}
+
+SEQ_FUNC void seq_sample_coro_test() {
+    printf("seq_sample_coro_test\n");
+    if (work_pool == nullptr) {
+        printf("work_pool is nullptr\n");
+        return;
+    }
+    // work_pool->thread_migrate(photon::thread_create(entry, nullptr));
+
+    // Æô¶¯stdÏß³Ì(·ÇphotonÏß³Ì)
+    std::thread *t = new std::thread(e);
+    t->join();
+    printf("seq_sample_coro_test done\n");
+}

moxt/libthread.hpp

@@ -168,4 +168,6 @@ SEQ_FUNC bool seq_lockfree_queue_push(CLockfreeSPSCRingQueueHandle handle,
 SEQ_FUNC bool seq_lockfree_queue_pop(CLockfreeSPSCRingQueueHandle handle,
                                      iovec *data);
 
+typedef void (*sample_callback)();
+
 #endif