summaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorruki <[email protected]>2019-10-14 22:33:43 +0800
committerruki <[email protected]>2019-10-14 09:22:22 +0800
commit91bad8e2dbbe495f93cc14b56742d1af55c6d51b (patch)
tree0d79e3110ec26c26dc0729c524b097ef5476275d /core
parent5166d62948768bf3bac371816eb113f4cd490965 (diff)
improve socket apis
Diffstat (limited to 'core')
-rw-r--r--core/src/xmake/io/socket_listen.c58
-rw-r--r--core/src/xmake/io/socket_wait.c2
-rw-r--r--core/src/xmake/machine.c2
-rw-r--r--core/src/xmake/makefile1
4 files changed, 62 insertions, 1 deletions
diff --git a/core/src/xmake/io/socket_listen.c b/core/src/xmake/io/socket_listen.c
new file mode 100644
index 000000000..c075bcb67
--- /dev/null
+++ b/core/src/xmake/io/socket_listen.c
@@ -0,0 +1,58 @@
+/*!A cross-platform build utility based on Lua
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * Copyright (C) 2015 - 2019, TBOOX Open Source Group.
+ *
+ * @author ruki
+ * @file socket_listen.c
+ *
+ */
+
+/* //////////////////////////////////////////////////////////////////////////////////////
+ * trace
+ */
+#define TB_TRACE_MODULE_NAME "socket_listen"
+#define TB_TRACE_MODULE_DEBUG (0)
+
+/* //////////////////////////////////////////////////////////////////////////////////////
+ * includes
+ */
+#include "prefix.h"
+
+/* //////////////////////////////////////////////////////////////////////////////////////
+ * interfaces
+ */
+
+// io.socket_listen(sock, backlog)
+tb_int_t xm_io_socket_listen(lua_State* lua)
+{
+ // check
+ tb_assert_and_check_return_val(lua, 0);
+
+ // is user data?
+ if (!lua_isuserdata(lua, 1))
+ return 0;
+
+ // get socket
+ tb_socket_ref_t sock = (tb_socket_ref_t)lua_touserdata(lua, 1);
+ tb_check_return_val(sock, 0);
+
+ // get backlog
+ tb_size_t backlog = (tb_size_t)luaL_checknumber(lua, 2);
+
+ // listen socket
+ lua_pushnumber(lua, (tb_int_t)tb_socket_listen(sock, backlog));
+ return 1;
+}
+
diff --git a/core/src/xmake/io/socket_wait.c b/core/src/xmake/io/socket_wait.c
index 982afb60b..d9b845785 100644
--- a/core/src/xmake/io/socket_wait.c
+++ b/core/src/xmake/io/socket_wait.c
@@ -34,7 +34,7 @@
* interfaces
*/
-// io.socket_wait(sock, addr, port, family)
+// io.socket_wait(sock, events, timeout)
tb_int_t xm_io_socket_wait(lua_State* lua)
{
// check
diff --git a/core/src/xmake/machine.c b/core/src/xmake/machine.c
index d22647728..c1b1686b5 100644
--- a/core/src/xmake/machine.c
+++ b/core/src/xmake/machine.c
@@ -114,6 +114,7 @@ tb_int_t xm_io_socket_open(lua_State* lua);
tb_int_t xm_io_socket_rawfd(lua_State* lua);
tb_int_t xm_io_socket_wait(lua_State* lua);
tb_int_t xm_io_socket_bind(lua_State* lua);
+tb_int_t xm_io_socket_listen(lua_State* lua);
tb_int_t xm_io_socket_connect(lua_State* lua);
tb_int_t xm_io_socket_close(lua_State* lua);
@@ -253,6 +254,7 @@ static luaL_Reg const g_io_functions[] =
, { "socket_rawfd", xm_io_socket_rawfd }
, { "socket_wait", xm_io_socket_wait }
, { "socket_bind", xm_io_socket_bind }
+, { "socket_listen", xm_io_socket_listen }
, { "socket_connect", xm_io_socket_connect }
, { "socket_close", xm_io_socket_close }
, { tb_null, tb_null }
diff --git a/core/src/xmake/makefile b/core/src/xmake/makefile
index fa9131d05..79618ea4f 100644
--- a/core/src/xmake/makefile
+++ b/core/src/xmake/makefile
@@ -64,6 +64,7 @@ xmake_C_FILES += \
io/socket_rawfd \
io/socket_wait \
io/socket_bind \
+ io/socket_listen \
io/socket_connect \
io/socket_close \
path/relative \