summaryrefslogtreecommitdiff
path: root/core/src/xmake/thread/queue_pop.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_pop.c
parenta1b0ec856e2c22aac84022feb05b6687912e3d6e (diff)
parent2c387895657ae13cd717d7f42f5baed5eb028a8e (diff)
Merge pull request #7008 from xmake-io/format
format code
Diffstat (limited to 'core/src/xmake/thread/queue_pop.c')
-rw-r--r--core/src/xmake/thread/queue_pop.c29
1 files changed, 13 insertions, 16 deletions
diff --git a/core/src/xmake/thread/queue_pop.c b/core/src/xmake/thread/queue_pop.c
index c666a85dd..256cb151e 100644
--- a/core/src/xmake/thread/queue_pop.c
+++ b/core/src/xmake/thread/queue_pop.c
@@ -15,15 +15,15 @@
* Copyright (C) 2015-present, Xmake Open Source Community.
*
* @author ruki
- * @file thread_queue_pop.c
+ * @file queue_pop.c
*
*/
/* //////////////////////////////////////////////////////////////////////////////////////
* 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,30 +33,29 @@
/* //////////////////////////////////////////////////////////////////////////////////////
* implementation
*/
-tb_int_t xm_thread_queue_pop(lua_State* lua)
-{
+tb_int_t xm_thread_queue_pop(lua_State *lua) {
tb_assert_and_check_return_val(lua, 0);
- xm_thread_queue_t* thread_queue = xm_thread_queue_get(lua, 1);
+ xm_thread_queue_t *thread_queue = xm_thread_queue_get(lua, 1);
tb_assert_and_check_return_val(thread_queue && thread_queue->handle, 0);
- if (tb_queue_null(thread_queue->handle))
- {
+ if (tb_queue_null(thread_queue->handle)) {
lua_pushnil(lua);
lua_pushliteral(lua, "the thread queue is empty");
return 2;
}
- xm_thread_value_t* item = (xm_thread_value_t*)tb_queue_get(thread_queue->handle);
+ xm_thread_value_t *item = (xm_thread_value_t *)tb_queue_get(thread_queue->handle);
tb_assert_and_check_return_val(item, 0);
tb_bool_t ok = tb_false;
- switch (item->kind)
- {
+ switch (item->kind) {
case XM_THREAD_VALUE_STR:
- if (item->size)
+ if (item->size) {
lua_pushlstring(lua, item->u.string, item->size);
- else lua_pushliteral(lua, "");
+ } else {
+ lua_pushliteral(lua, "");
+ }
ok = tb_true;
break;
case XM_THREAD_VALUE_INT:
@@ -79,8 +78,7 @@ tb_int_t xm_thread_queue_pop(lua_State* lua)
break;
}
- if (!ok)
- {
+ if (!ok) {
lua_pushnil(lua);
lua_pushliteral(lua, "invalid thread queue item");
return 2;
@@ -89,4 +87,3 @@ tb_int_t xm_thread_queue_pop(lua_State* lua)
tb_queue_pop(thread_queue->handle);
return 1;
}
-