diff options
author | Thomas Harning Jr <harningt@gmail.com> | 2007-09-05 23:33:46 -0400 |
---|---|---|
committer | Thomas Harning Jr <harningt@gmail.com> | 2007-09-05 23:33:46 -0400 |
commit | fb5f78f8c75ce907ae2796d4300c7f8053d20732 (patch) | |
tree | b4ba07932f35e29e431af481165812efab48769b /src/luaevent.c | |
parent | 3bf12e614c65f22f012b35a19eafad28ad3d4ed5 (diff) | |
download | luaevent-prosody-fb5f78f8c75ce907ae2796d4300c7f8053d20732.tar.gz luaevent-prosody-fb5f78f8c75ce907ae2796d4300c7f8053d20732.zip |
Added support for timeouts and timers.
Diffstat (limited to 'src/luaevent.c')
-rw-r--r-- | src/luaevent.c | 24 |
1 files changed, 21 insertions, 3 deletions
diff --git a/src/luaevent.c b/src/luaevent.c index 4cadbb5..596e4e1 100644 --- a/src/luaevent.c +++ b/src/luaevent.c @@ -45,16 +45,33 @@ int getSocketFd(lua_State* L, int idx) { return fd; } -/* sock, event, callback */ +void load_timeval(double time, struct timeval *tv) { + tv->sec = (int)time; + tv->usec = (time * 1000000) % 1000000; +} + +/* sock, event, callback, timeout */ static int luaevent_addevent(lua_State* L) { int fd, event; le_callback* arg = event_callback_push(L, 1, 4); - fd = getSocketFd(L, 2); + struct timeval *tv = &arg->timeout; + if(lua_isnil(L, 2) && lua_isnumber(L, 5)) { + fd = -1; /* Per event_timer_set.... */ + } else { + fd = getSocketFd(L, 2); + } event = luaL_checkinteger(L, 3); + if(lua_isnumber(L, 5)) { + double time = lua_tonumber(L, 5); + load_timeval(time, tv); + } else { + tv = NULL; + } + /* Setup event... */ event_set(&arg->ev, fd, event | EV_PERSIST, luaevent_callback, arg); event_base_set(arg->base->base, &arg->ev); - event_add(&arg->ev, NULL); + event_add(&arg->ev, tv); return 1; } @@ -86,6 +103,7 @@ static namedInteger consts[] = { {"LEAVE", -1}, {"EV_READ", EV_READ}, {"EV_WRITE", EV_WRITE}, + {"EV_TIMEOUT", EV_TIMEOUT}, {NULL, 0} }; |