summaryrefslogtreecommitdiff
path: root/core/src/xmake/thread/queue_init.c
diff options
context:
space:
mode:
authorruki <[email protected]>2025-11-10 06:35:04 +0800
committerGitHub <[email protected]>2025-11-10 06:35:04 +0800
commit2b01e46fcf619aaecb8435b0fac975e3aff0587f (patch)
tree8f005a8dfc3272e9f027560e5e1b5881a7a8bc70 /core/src/xmake/thread/queue_init.c
parenta1b0ec856e2c22aac84022feb05b6687912e3d6e (diff)
parent2c387895657ae13cd717d7f42f5baed5eb028a8e (diff)
Merge pull request #7008 from xmake-io/format
format code
Diffstat (limited to 'core/src/xmake/thread/queue_init.c')
-rw-r--r--core/src/xmake/thread/queue_init.c43
1 files changed, 19 insertions, 24 deletions
diff --git a/core/src/xmake/thread/queue_init.c b/core/src/xmake/thread/queue_init.c
index 0c8af884d..a0d683dd3 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,13 @@
/* //////////////////////////////////////////////////////////////////////////////////////
* 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 +49,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 +68,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;
}