diff options
Diffstat (limited to 'src/buffer.c')
-rw-r--r-- | src/buffer.c | 19 |
1 files changed, 7 insertions, 12 deletions
diff --git a/src/buffer.c b/src/buffer.c index 357730a..ac5c531 100644 --- a/src/buffer.c +++ b/src/buffer.c | |||
@@ -3,11 +3,6 @@ | |||
3 | * LuaSocket toolkit | 3 | * LuaSocket toolkit |
4 | \*=========================================================================*/ | 4 | \*=========================================================================*/ |
5 | #include "luasocket.h" | 5 | #include "luasocket.h" |
6 | |||
7 | #include "lua.h" | ||
8 | #include "lauxlib.h" | ||
9 | #include "compat.h" | ||
10 | |||
11 | #include "buffer.h" | 6 | #include "buffer.h" |
12 | 7 | ||
13 | /*=========================================================================*\ | 8 | /*=========================================================================*\ |
@@ -34,7 +29,7 @@ static int sendraw(p_buffer buf, const char *data, size_t count, size_t *sent); | |||
34 | /*-------------------------------------------------------------------------*\ | 29 | /*-------------------------------------------------------------------------*\ |
35 | * Initializes module | 30 | * Initializes module |
36 | \*-------------------------------------------------------------------------*/ | 31 | \*-------------------------------------------------------------------------*/ |
37 | LUASOCKET_PRIVATE int buffer_open(lua_State *L) { | 32 | int buffer_open(lua_State *L) { |
38 | (void) L; | 33 | (void) L; |
39 | return 0; | 34 | return 0; |
40 | } | 35 | } |
@@ -42,7 +37,7 @@ LUASOCKET_PRIVATE int buffer_open(lua_State *L) { | |||
42 | /*-------------------------------------------------------------------------*\ | 37 | /*-------------------------------------------------------------------------*\ |
43 | * Initializes C structure | 38 | * Initializes C structure |
44 | \*-------------------------------------------------------------------------*/ | 39 | \*-------------------------------------------------------------------------*/ |
45 | LUASOCKET_PRIVATE void buffer_init(p_buffer buf, p_io io, p_timeout tm) { | 40 | void buffer_init(p_buffer buf, p_io io, p_timeout tm) { |
46 | buf->first = buf->last = 0; | 41 | buf->first = buf->last = 0; |
47 | buf->io = io; | 42 | buf->io = io; |
48 | buf->tm = tm; | 43 | buf->tm = tm; |
@@ -53,7 +48,7 @@ LUASOCKET_PRIVATE void buffer_init(p_buffer buf, p_io io, p_timeout tm) { | |||
53 | /*-------------------------------------------------------------------------*\ | 48 | /*-------------------------------------------------------------------------*\ |
54 | * object:getstats() interface | 49 | * object:getstats() interface |
55 | \*-------------------------------------------------------------------------*/ | 50 | \*-------------------------------------------------------------------------*/ |
56 | LUASOCKET_PRIVATE int buffer_meth_getstats(lua_State *L, p_buffer buf) { | 51 | int buffer_meth_getstats(lua_State *L, p_buffer buf) { |
57 | lua_pushnumber(L, (lua_Number) buf->received); | 52 | lua_pushnumber(L, (lua_Number) buf->received); |
58 | lua_pushnumber(L, (lua_Number) buf->sent); | 53 | lua_pushnumber(L, (lua_Number) buf->sent); |
59 | lua_pushnumber(L, timeout_gettime() - buf->birthday); | 54 | lua_pushnumber(L, timeout_gettime() - buf->birthday); |
@@ -63,7 +58,7 @@ LUASOCKET_PRIVATE int buffer_meth_getstats(lua_State *L, p_buffer buf) { | |||
63 | /*-------------------------------------------------------------------------*\ | 58 | /*-------------------------------------------------------------------------*\ |
64 | * object:setstats() interface | 59 | * object:setstats() interface |
65 | \*-------------------------------------------------------------------------*/ | 60 | \*-------------------------------------------------------------------------*/ |
66 | LUASOCKET_PRIVATE int buffer_meth_setstats(lua_State *L, p_buffer buf) { | 61 | int buffer_meth_setstats(lua_State *L, p_buffer buf) { |
67 | buf->received = (long) luaL_optnumber(L, 2, (lua_Number) buf->received); | 62 | buf->received = (long) luaL_optnumber(L, 2, (lua_Number) buf->received); |
68 | buf->sent = (long) luaL_optnumber(L, 3, (lua_Number) buf->sent); | 63 | buf->sent = (long) luaL_optnumber(L, 3, (lua_Number) buf->sent); |
69 | if (lua_isnumber(L, 4)) buf->birthday = timeout_gettime() - lua_tonumber(L, 4); | 64 | if (lua_isnumber(L, 4)) buf->birthday = timeout_gettime() - lua_tonumber(L, 4); |
@@ -74,7 +69,7 @@ LUASOCKET_PRIVATE int buffer_meth_setstats(lua_State *L, p_buffer buf) { | |||
74 | /*-------------------------------------------------------------------------*\ | 69 | /*-------------------------------------------------------------------------*\ |
75 | * object:send() interface | 70 | * object:send() interface |
76 | \*-------------------------------------------------------------------------*/ | 71 | \*-------------------------------------------------------------------------*/ |
77 | LUASOCKET_PRIVATE int buffer_meth_send(lua_State *L, p_buffer buf) { | 72 | int buffer_meth_send(lua_State *L, p_buffer buf) { |
78 | int top = lua_gettop(L); | 73 | int top = lua_gettop(L); |
79 | int err = IO_DONE; | 74 | int err = IO_DONE; |
80 | size_t size = 0, sent = 0; | 75 | size_t size = 0, sent = 0; |
@@ -107,7 +102,7 @@ LUASOCKET_PRIVATE int buffer_meth_send(lua_State *L, p_buffer buf) { | |||
107 | /*-------------------------------------------------------------------------*\ | 102 | /*-------------------------------------------------------------------------*\ |
108 | * object:receive() interface | 103 | * object:receive() interface |
109 | \*-------------------------------------------------------------------------*/ | 104 | \*-------------------------------------------------------------------------*/ |
110 | LUASOCKET_PRIVATE int buffer_meth_receive(lua_State *L, p_buffer buf) { | 105 | int buffer_meth_receive(lua_State *L, p_buffer buf) { |
111 | int err = IO_DONE, top = lua_gettop(L); | 106 | int err = IO_DONE, top = lua_gettop(L); |
112 | luaL_Buffer b; | 107 | luaL_Buffer b; |
113 | size_t size; | 108 | size_t size; |
@@ -156,7 +151,7 @@ LUASOCKET_PRIVATE int buffer_meth_receive(lua_State *L, p_buffer buf) { | |||
156 | /*-------------------------------------------------------------------------*\ | 151 | /*-------------------------------------------------------------------------*\ |
157 | * Determines if there is any data in the read buffer | 152 | * Determines if there is any data in the read buffer |
158 | \*-------------------------------------------------------------------------*/ | 153 | \*-------------------------------------------------------------------------*/ |
159 | LUASOCKET_PRIVATE int buffer_isempty(p_buffer buf) { | 154 | int buffer_isempty(p_buffer buf) { |
160 | return buf->first >= buf->last; | 155 | return buf->first >= buf->last; |
161 | } | 156 | } |
162 | 157 | ||