format code

1 files changed, 18 insertions, 24 deletions

diff --git a/core/src/xmake/thread/queue_init.c b/core/src/xmake/thread/queue_init.c
index 0c8af884d..20c08ce50 100644
--- a/core/src/xmake/thread/queue_init.c
+++ b/core/src/xmake/thread/queue_init.c
@@ -22,8 +22,8 @@
 /* //////////////////////////////////////////////////////////////////////////////////////
  * trace
  */
-#define TB_TRACE_MODULE_NAME                "thread_queue"
-#define TB_TRACE_MODULE_DEBUG               (0)
+#define TB_TRACE_MODULE_NAME "thread_queue"
+#define TB_TRACE_MODULE_DEBUG (0)
 
 /* //////////////////////////////////////////////////////////////////////////////////////
  * includes
@@ -33,14 +33,12 @@
 /* //////////////////////////////////////////////////////////////////////////////////////
  * private implementation
  */
-static tb_void_t xm_thread_value_free(tb_element_ref_t element, tb_pointer_t buff)
-{
-    xm_thread_value_t* item = (xm_thread_value_t*)buff;
-    if (item)
-    {
-        if (item->kind == XM_THREAD_VALUE_STR)
-        {
-            if (item->u.string) tb_free((tb_pointer_t)item->u.string);
+static tb_void_t xm_thread_value_free(tb_element_ref_t element, tb_pointer_t buff) {
+    xm_thread_value_t *item = (xm_thread_value_t *)buff;
+    if (item) {
+        if (item->kind == XM_THREAD_VALUE_STR) {
+            if (item->u.string)
+                tb_free((tb_pointer_t)item->u.string);
             item->u.string = tb_null;
         }
         item->size = 0;
@@ -50,19 +48,18 @@ static tb_void_t xm_thread_value_free(tb_element_ref_t element, tb_pointer_t buf
 /* //////////////////////////////////////////////////////////////////////////////////////
  * implementation
  */
-tb_int_t xm_thread_queue_init(lua_State* lua)
-{
+tb_int_t xm_thread_queue_init(lua_State *lua) {
     tb_assert_and_check_return_val(lua, 0);
 
-    tb_bool_t ok = tb_false;
-    xm_thread_queue_t* thread_queue = tb_null;
-    do
-    {
+    tb_bool_t          ok           = tb_false;
+    xm_thread_queue_t *thread_queue = tb_null;
+    do {
         thread_queue = tb_malloc0_type(xm_thread_queue_t);
         tb_assert_and_check_break(thread_queue);
 
-        thread_queue->refn = 1;
-        thread_queue->handle = tb_queue_init(0, tb_element_mem(sizeof(xm_thread_value_t), xm_thread_value_free, tb_null));
+        thread_queue->refn   = 1;
+        thread_queue->handle = tb_queue_init(0,
+                                             tb_element_mem(sizeof(xm_thread_value_t), xm_thread_value_free, tb_null));
         tb_assert_and_check_break(thread_queue->handle);
 
         xm_lua_pushpointer(lua, (tb_pointer_t)thread_queue);
@@ -70,12 +67,9 @@ tb_int_t xm_thread_queue_init(lua_State* lua)
 
     } while (0);
 
-    if (!ok)
-    {
-        if (thread_queue)
-        {
-            if (thread_queue->handle)
-            {
+    if (!ok) {
+        if (thread_queue) {
+            if (thread_queue->handle) {
                 tb_queue_exit(thread_queue->handle);
                 thread_queue->handle = tb_null;
             }