aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorThomas Harning Jr <harningt@gmail.com>2007-09-07 00:00:59 -0400
committerThomas Harning Jr <harningt@gmail.com>2007-09-07 00:00:59 -0400
commit4afd8b5a3404aeba1999bff1054a777aaf9a423d (patch)
tree6e0bc92294e9cf972f440087201e109dae34ac61 /src
parent978194f3f80a1e7c47903ee076ef98f9ac439675 (diff)
downloadluaevent-prosody-4afd8b5a3404aeba1999bff1054a777aaf9a423d.tar.gz
luaevent-prosody-4afd8b5a3404aeba1999bff1054a777aaf9a423d.zip
Documented event_buffer functions
Diffstat (limited to 'src')
-rw-r--r--src/event_buffer.c25
1 files changed, 25 insertions, 0 deletions
diff --git a/src/event_buffer.c b/src/event_buffer.c
index b778e2f..e34f885 100644
--- a/src/event_buffer.c
+++ b/src/event_buffer.c
@@ -8,15 +8,22 @@
#define BUFFER_ADD_CHECK_INPUT_FIRST 1
+/* Obtains an le_buffer structure from a given index */
static le_buffer* event_buffer_get(lua_State* L, int idx) {
return (le_buffer*)luaL_checkudata(L, idx, EVENT_BUFFER_MT);
}
+
+/* Obtains an le_buffer structure from a given index
+ AND checks that it hadn't been prematurely freed
+*/
static le_buffer* event_buffer_check(lua_State* L, int idx) {
le_buffer* buf = (le_buffer*)luaL_checkudata(L, idx, EVENT_BUFFER_MT);
if(!buf->buffer)
luaL_argerror(L, idx, "Attempt to use closed event_buffer object");
return buf;
}
+
+/* Checks if the given index contains an le_buffer object */
static int is_event_buffer(lua_State* L, int idx) {
int ret;
lua_getmetatable(L, idx);
@@ -27,6 +34,7 @@ static int is_event_buffer(lua_State* L, int idx) {
}
/* TODO: Use lightuserdata mapping to locate hanging object instances */
+/* Pushes the specified evbuffer object onto the stack, attaching a metatable to it */
static int event_buffer_push(lua_State* L, struct evbuffer* buffer) {
le_buffer *buf = (le_buffer*)lua_newuserdata(L, sizeof(le_buffer));
buf->buffer = buffer;
@@ -35,10 +43,16 @@ static int event_buffer_push(lua_State* L, struct evbuffer* buffer) {
return 1;
}
+/* LUA: new()
+ Pushes a new evbuffer instance on the stack
+*/
static int event_buffer_push_new(lua_State* L) {
return event_buffer_push(L, evbuffer_new());
}
+/* LUA: __gc and buffer:close()
+ Releases the buffer resources
+*/
static int event_buffer_gc(lua_State* L) {
le_buffer* buf = event_buffer_get(L, 1);
if(buf->buffer) {
@@ -83,6 +97,9 @@ static int event_buffer_add(lua_State* L) {
return 1;
}
+/* LUA: buffer:length()
+ Returns the length of the buffer contents
+*/
static int event_buffer_get_length(lua_State* L) {
le_buffer* buf = event_buffer_check(L, 1);
lua_pushinteger(L, EVBUFFER_LENGTH(buf->buffer));
@@ -90,6 +107,11 @@ static int event_buffer_get_length(lua_State* L) {
}
/* MAYBE: Could add caching */
+/* LUA: buffer:get_data
+ () - Returns all data in buffer
+ (len) - Returns data up to 'len' bytes long
+ (begin,len) - Returns data beginning at 'begin' up to 'len' bytes long
+*/
static int event_buffer_get_data(lua_State* L) {
le_buffer* buf = event_buffer_check(L, 1);
int begin, len;
@@ -119,6 +141,9 @@ static int event_buffer_get_data(lua_State* L) {
return 1;
}
+/* LUA: buffer:drain(amt)
+ Drains 'amt' bytes from the buffer
+*/
static int event_buffer_drain(lua_State* L) {
le_buffer* buf = event_buffer_check(L, 1);
size_t len = luaL_checkinteger(L, 2);