www/apache
1
0
Fork 0
mirror of https://github.com/apache/httpd.git synced 2025-08-05 16:55:50 +03:00
Code Activity

mod_lua: Add r:wspeek for checking if data is available to be read.

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/httpd/httpd/trunk@1570208 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Daniel Gruno
2014-02-20 14:46:38 +00:00
parent 185985970c
commit c92f2cf0ad
3 changed files with 38 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
modules/lua/lua_request.c
View File

@@ -2152,6 +2152,27 @@ static apr_status_t lua_websocket_readbytes(conn_rec* c, char* buffer,
return rv;
}
static int lua_websocket_peek(lua_State *L)
{
apr_status_t rv;
apr_bucket_brigade *brigade;
request_rec *r = ap_lua_check_request_rec(L, 1);
brigade = apr_brigade_create(r->connection->pool,
r->connection->bucket_alloc);
rv = ap_get_brigade(r->connection->input_filters, brigade,
AP_MODE_READBYTES, APR_NONBLOCK_READ, 1);
if (rv == APR_SUCCESS) {
lua_pushboolean(L, 1);
}
else {
lua_pushboolean(L, 0);
}
apr_brigade_cleanup(brigade);
return 1;
}
static int lua_websocket_read(lua_State *L)
{
apr_socket_t *sock;
@@ -2789,6 +2810,8 @@ void ap_lua_load_request_lmodule(lua_State *L, apr_pool_t *p)
makefun(&lua_websocket_greet, APL_REQ_FUNTYPE_LUACFUN, p));
apr_hash_set(dispatch, "wsread", APR_HASH_KEY_STRING,
makefun(&lua_websocket_read, APL_REQ_FUNTYPE_LUACFUN, p));
apr_hash_set(dispatch, "wspeek", APR_HASH_KEY_STRING,
makefun(&lua_websocket_peek, APL_REQ_FUNTYPE_LUACFUN, p));
apr_hash_set(dispatch, "wswrite", APR_HASH_KEY_STRING,
makefun(&lua_websocket_write, APL_REQ_FUNTYPE_LUACFUN, p));
apr_hash_set(dispatch, "wsclose", APR_HASH_KEY_STRING,