Mercurial > luaevent-prosody / file comparison
comparison: src/buffer_event.c
src/buffer_event.c
- changeset 96
- 570e309a8d3e
- parent 93
- f0f5046ba1b0
- child 97
- dfe23f13242d
equal
deleted
inserted
replaced
| 95:e29759773705 | 96:570e309a8d3e |
|---|---|
| 169 ev->ev->wm_write.low = low; | 169 ev->ev->wm_write.low = low; |
| 170 ev->ev->wm_write.high = high; | 170 ev->ev->wm_write.high = high; |
| 171 return 0; | 171 return 0; |
| 172 } | 172 } |
| 173 | 173 |
| 174 static int buffer_event_get_read_watermarks(lua_State* L) { | |
| 175 le_bufferevent* ev = buffer_event_get(L, 1); | |
| 176 if(!ev->ev) return 0; | |
| 177 | |
| 178 lua_pushinteger(L, ev->ev->wm_read.low); | |
| 179 lua_pushinteger(L, ev->ev->wm_read.high); | |
| 180 return 2; | |
| 181 } | |
| 182 | |
| 183 static int buffer_event_get_write_watermarks(lua_State* L) { | |
| 184 le_bufferevent* ev = buffer_event_get(L, 1); | |
| 185 if(!ev->ev) return 0; | |
| 186 | |
| 187 lua_pushinteger(L, ev->ev->wm_write.low); | |
| 188 lua_pushinteger(L, ev->ev->wm_write.high); | |
| 189 return 2; | |
| 190 } | |
| 191 | |
| 192 static int buffer_event_set_timeouts(lua_State* L) { | 174 static int buffer_event_set_timeouts(lua_State* L) { |
| 193 int timeout_read, timeout_write; | 175 int timeout_read, timeout_write; |
| 194 le_bufferevent* ev = buffer_event_get(L, 1); | 176 le_bufferevent* ev = buffer_event_get(L, 1); |
| 195 if(!ev->ev) return 0; | 177 if(!ev->ev) return 0; |
| 196 | 178 |
| 197 timeout_read = lua_tointeger(L, 2); | 179 timeout_read = lua_tointeger(L, 2); |
| 198 timeout_write = lua_tointeger(L, 3); | 180 timeout_write = lua_tointeger(L, 3); |
| 199 | 181 |
| 200 bufferevent_settimeout(ev->ev, timeout_read, timeout_write); | 182 bufferevent_settimeout(ev->ev, timeout_read, timeout_write); |
| 201 return 0; | 183 return 0; |
| 202 } | |
| 203 | |
| 204 static int buffer_event_get_timeouts(lua_State* L) { | |
| 205 le_bufferevent* ev = buffer_event_get(L, 1); | |
| 206 if(!ev->ev) return 0; | |
| 207 | |
| 208 #if LIBEVENT_VERSION_NUMBER >= 0x02000000 | |
| 209 lua_pushinteger(L, (ev->ev->timeout_read).tv_sec); | |
| 210 lua_pushinteger(L, (ev->ev->timeout_write).tv_sec); | |
| 211 #else | |
| 212 lua_pushinteger(L, ev->ev->timeout_read); | |
| 213 lua_pushinteger(L, ev->ev->timeout_write); | |
| 214 #endif | |
| 215 return 2; | |
| 216 } | 184 } |
| 217 | 185 |
| 218 static int buffer_event_enable(lua_State* L) { | 186 static int buffer_event_enable(lua_State* L) { |
| 219 le_bufferevent* ev = buffer_event_get(L, 1); | 187 le_bufferevent* ev = buffer_event_get(L, 1); |
| 220 if(!ev->ev) return 0; | 188 if(!ev->ev) return 0; |
| 234 static luaL_Reg buffer_event_funcs[] = { | 202 static luaL_Reg buffer_event_funcs[] = { |
| 235 {"get_read", buffer_event_get_read}, | 203 {"get_read", buffer_event_get_read}, |
| 236 {"get_write", buffer_event_get_write}, | 204 {"get_write", buffer_event_get_write}, |
| 237 {"set_read_watermarks", buffer_event_set_read_watermarks}, | 205 {"set_read_watermarks", buffer_event_set_read_watermarks}, |
| 238 {"set_write_watermarks", buffer_event_set_write_watermarks}, | 206 {"set_write_watermarks", buffer_event_set_write_watermarks}, |
| 239 {"get_read_watermarks", buffer_event_get_read_watermarks}, | |
| 240 {"get_write_watermarks", buffer_event_get_write_watermarks}, | |
| 241 {"set_timeouts", buffer_event_set_timeouts}, | 207 {"set_timeouts", buffer_event_set_timeouts}, |
| 242 {"get_timeouts", buffer_event_get_timeouts}, | |
| 243 {"enable", buffer_event_enable}, | 208 {"enable", buffer_event_enable}, |
| 244 {"disable", buffer_event_disable}, | 209 {"disable", buffer_event_disable}, |
| 245 {NULL, NULL} | 210 {NULL, NULL} |
| 246 }; | 211 }; |
| 247 | 212 |
