| 2233 | } |
| 2234 | |
| 2235 | static apr_status_t lua_websocket_readbytes(conn_rec* c, |
| 2236 | apr_bucket_brigade *brigade, |
| 2237 | char* buffer, apr_off_t len) |
| 2238 | { |
| 2239 | apr_size_t delivered; |
| 2240 | apr_status_t rv; |
| 2241 | |
| 2242 | rv = ap_get_brigade(c->input_filters, brigade, AP_MODE_READBYTES, |
| 2243 | APR_BLOCK_READ, len); |
| 2244 | if (rv == APR_SUCCESS) { |
| 2245 | delivered = len; |
| 2246 | rv = apr_brigade_flatten(brigade, buffer, &delivered); |
| 2247 | if ((rv == APR_SUCCESS) && (delivered < len)) { |
| 2248 | rv = APR_INCOMPLETE; |
| 2249 | } |
| 2250 | } |
| 2251 | apr_brigade_cleanup(brigade); |
| 2252 | return rv; |
| 2253 | } |
| 2254 | |
| 2255 | static int lua_websocket_peek(lua_State *L) |
| 2256 | { |
no test coverage detected