aboutsummaryrefslogtreecommitdiff
path: root/src/libjin-lua/modules/net/l_socket.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/libjin-lua/modules/net/l_socket.cpp')
-rw-r--r--src/libjin-lua/modules/net/l_socket.cpp204
1 files changed, 102 insertions, 102 deletions
diff --git a/src/libjin-lua/modules/net/l_socket.cpp b/src/libjin-lua/modules/net/l_socket.cpp
index 1e86ea9..c5ed2b4 100644
--- a/src/libjin-lua/modules/net/l_socket.cpp
+++ b/src/libjin-lua/modules/net/l_socket.cpp
@@ -8,116 +8,116 @@ using namespace JinEngine::Lua::Net;
namespace JinEngine
{
- namespace Lua
- {
+ namespace Lua
+ {
- const char* Jin_Lua_Socket = "Socket";
+ const char* Jin_Lua_Socket = "Socket";
- const int BUFFER_SIZE = 1024;
+ const int BUFFER_SIZE = 1024;
- LUA_IMPLEMENT inline Socket* checkSocket(lua_State* L, int pos = 1)
- {
- LuaObject* luaObj = (LuaObject*)luax_checktype(L, pos, Jin_Lua_Socket);
- return luaObj->getObject<Socket>();
- }
+ LUA_IMPLEMENT inline Socket* checkSocket(lua_State* L, int pos = 1)
+ {
+ LuaObject* luaObj = (LuaObject*)luax_checktype(L, pos, Jin_Lua_Socket);
+ return luaObj->getObject<Socket>();
+ }
- LUA_IMPLEMENT inline Buffer* checkNetBuffer(lua_State* L, int pos = 1)
- {
- LuaObject* luaObj = (LuaObject*)luax_checktype(L, pos, Jin_Lua_Buffer);
- return luaObj->getObject<Buffer>();
- }
+ LUA_IMPLEMENT inline Buffer* checkNetBuffer(lua_State* L, int pos = 1)
+ {
+ LuaObject* luaObj = (LuaObject*)luax_checktype(L, pos, Jin_Lua_Buffer);
+ return luaObj->getObject<Buffer>();
+ }
- // return net.Socket
- LUA_IMPLEMENT int l_accept(lua_State* L)
- {
- Socket* socket = checkSocket(L);
- Socket* client = socket->accept();
- LuaObject* luaObj = luax_newinstance(L, Jin_Lua_Socket, new Shared(client));
- return 1;
- }
-
- // return net.Buffer
- LUA_IMPLEMENT int l_receive(lua_State* L)
- {
- Socket* socket = checkSocket(L);
- char buffer[BUFFER_SIZE] = {0};
- int size = socket->receive(buffer, BUFFER_SIZE);
- Net::Buffer* netBuffer = new Net::Buffer(buffer, size);
- LuaObject* luaObj = luax_newinstance(L, Jin_Lua_Buffer, new Shared(netBuffer));
- return 1;
- }
-
- // Socket:receiveFrom(address, port)
- LUA_IMPLEMENT int l_receiveFrom(lua_State* L)
- {
- Socket* socket = checkSocket(L);
- int address = luax_checkinteger(L, 2);
- int port = luax_checkinteger(L, 3);
- char buffer[BUFFER_SIZE];
- int size = socket->receiveFrom(buffer, BUFFER_SIZE, address, port);
- Net::Buffer* netBuffer = new Net::Buffer(buffer, size);
- LuaObject* luaObj = luax_newinstance(L, Jin_Lua_Buffer, new Shared(netBuffer));
- return 1;
- }
+ // return net.Socket
+ LUA_IMPLEMENT int l_accept(lua_State* L)
+ {
+ Socket* socket = checkSocket(L);
+ Socket* client = socket->accept();
+ LuaObject* luaObj = luax_newinstance(L, Jin_Lua_Socket, new Shared(client));
+ return 1;
+ }
+
+ // return net.Buffer
+ LUA_IMPLEMENT int l_receive(lua_State* L)
+ {
+ Socket* socket = checkSocket(L);
+ char buffer[BUFFER_SIZE] = {0};
+ int size = socket->receive(buffer, BUFFER_SIZE);
+ Net::Buffer* netBuffer = new Net::Buffer(buffer, size);
+ LuaObject* luaObj = luax_newinstance(L, Jin_Lua_Buffer, new Shared(netBuffer));
+ return 1;
+ }
+
+ // Socket:receiveFrom(address, port)
+ LUA_IMPLEMENT int l_receiveFrom(lua_State* L)
+ {
+ Socket* socket = checkSocket(L);
+ int address = luax_checkinteger(L, 2);
+ int port = luax_checkinteger(L, 3);
+ char buffer[BUFFER_SIZE];
+ int size = socket->receiveFrom(buffer, BUFFER_SIZE, address, port);
+ Net::Buffer* netBuffer = new Net::Buffer(buffer, size);
+ LuaObject* luaObj = luax_newinstance(L, Jin_Lua_Buffer, new Shared(netBuffer));
+ return 1;
+ }
- // Socket:send(net.Buffer) -> data_length
- LUA_IMPLEMENT int l_send(lua_State* L)
- {
- Socket* socket = checkSocket(L);
- Buffer* buffer = checkNetBuffer(L, 2);
- int len = socket->send(buffer->buffer, buffer->size);
- luax_pushinteger(L, len);
- return 1;
- }
-
- // Socket:sendTo(address, port, net.Buffer)
- LUA_IMPLEMENT int l_sendTo(lua_State* L)
- {
- Socket* socket = checkSocket(L);
- int address = luax_checkinteger(L, 2);
- int port = luax_checkinteger(L, 3);
- Buffer* buffer = checkNetBuffer(L, 4);
- socket->sendTo(buffer->buffer, buffer->size, address, port);
- return 0;
- }
-
- LUA_IMPLEMENT int l_close(lua_State* L)
- {
- Socket* socket = checkSocket(L);
- socket->close();
- return 0;
- }
+ // Socket:send(net.Buffer) -> data_length
+ LUA_IMPLEMENT int l_send(lua_State* L)
+ {
+ Socket* socket = checkSocket(L);
+ Buffer* buffer = checkNetBuffer(L, 2);
+ int len = socket->send(buffer->buffer, buffer->size);
+ luax_pushinteger(L, len);
+ return 1;
+ }
+
+ // Socket:sendTo(address, port, net.Buffer)
+ LUA_IMPLEMENT int l_sendTo(lua_State* L)
+ {
+ Socket* socket = checkSocket(L);
+ int address = luax_checkinteger(L, 2);
+ int port = luax_checkinteger(L, 3);
+ Buffer* buffer = checkNetBuffer(L, 4);
+ socket->sendTo(buffer->buffer, buffer->size, address, port);
+ return 0;
+ }
+
+ LUA_IMPLEMENT int l_close(lua_State* L)
+ {
+ Socket* socket = checkSocket(L);
+ socket->close();
+ return 0;
+ }
- LUA_IMPLEMENT int l_configBlocking(lua_State* L)
- {
- Socket* socket = checkSocket(L);
- bool blocking = luax_checkbool(L, 2);
- socket->configureBlocking(blocking);
- return 0;
- }
+ LUA_IMPLEMENT int l_configBlocking(lua_State* L)
+ {
+ Socket* socket = checkSocket(L);
+ bool blocking = luax_checkbool(L, 2);
+ socket->configureBlocking(blocking);
+ return 0;
+ }
- LUA_IMPLEMENT int l_gc(lua_State* L)
- {
- LuaObject* luaObj = (LuaObject*)luax_checktype(L, 1, Jin_Lua_Socket);
- luaObj->release();
- return 0;
- }
+ LUA_IMPLEMENT int l_gc(lua_State* L)
+ {
+ LuaObject* luaObj = (LuaObject*)luax_checktype(L, 1, Jin_Lua_Socket);
+ luaObj->release();
+ return 0;
+ }
- LUA_EXPORT void luaopen_Socket(lua_State* L)
- {
- luaL_Reg socket_function[] = {
- { "__gc", l_gc },
- { "accept", l_accept },
- { "receive", l_receive },
- { "receiveFrom", l_receiveFrom },
- { "send", l_send },
- { "sendTo", l_sendTo },
- { "close", l_close },
- { "configBlocking", l_configBlocking },
- { 0, 0 }
- };
- luax_newtype(L, Jin_Lua_Socket, socket_function);
- }
+ LUA_EXPORT void luaopen_Socket(lua_State* L)
+ {
+ luaL_Reg socket_function[] = {
+ { "__gc", l_gc },
+ { "accept", l_accept },
+ { "receive", l_receive },
+ { "receiveFrom", l_receiveFrom },
+ { "send", l_send },
+ { "sendTo", l_sendTo },
+ { "close", l_close },
+ { "configBlocking", l_configBlocking },
+ { 0, 0 }
+ };
+ luax_newtype(L, Jin_Lua_Socket, socket_function);
+ }
- } // namespace Lua
+ } // namespace Lua
} // namespace JinEngine \ No newline at end of file