static void proxy_wstunnel_callback(void *b);
-static int proxy_wstunnel_pump(ws_baton_t *baton, apr_time_t timeout, int try_poll) {
+static int proxy_wstunnel_pump(ws_baton_t *baton, apr_time_t timeout, int try_poll)
+{
request_rec *r = baton->r;
conn_rec *c = r->connection;
proxy_conn_rec *conn = baton->proxy_connrec;
}
}
-static void proxy_wstunnel_finish(ws_baton_t *baton) {
+static void proxy_wstunnel_finish(ws_baton_t *baton)
+{
ap_log_rerror(APLOG_MARK, APLOG_TRACE1, 0, baton->r, "proxy_wstunnel_finish");
baton->proxy_connrec->close = 1; /* new handshake expected on each back-conn */
baton->r->connection->keepalive = AP_CONN_CLOSE;
static void proxy_wstunnel_cancel_callback(void *b)
{
ws_baton_t *baton = (ws_baton_t*)b;
- ap_log_rerror(APLOG_MARK, APLOG_TRACE1, 0, baton->r, "proxy_wstunnel_cancel_callback, IO timed out");
+ ap_log_rerror(APLOG_MARK, APLOG_TRACE1, 0, baton->r,
+ "proxy_wstunnel_cancel_callback, IO timed out");
proxy_wstunnel_finish(baton);
- return;
}
/* Invoked by the event loop when data is ready on either end.
* We don't need the invoke_mtx, since we never put multiple callback events
* in the queue.
*/
-static void proxy_wstunnel_callback(void *b) {
+static void proxy_wstunnel_callback(void *b)
+{
int status;
ws_baton_t *baton = (ws_baton_t*)b;
proxyws_dir_conf *dconf = ap_get_module_config(baton->r->per_dir_config, &proxy_wstunnel_module);
return "ProxyWebsocketIdleTimeout timeout has wrong format";
return NULL;
}
+
static const char * proxyws_set_aysnch_delay(cmd_parms *cmd, void *conf, const char *val)
{
proxyws_dir_conf *dconf = conf;
static const command_rec ws_proxy_cmds[] =
{
- AP_INIT_TAKE1("ProxyWebsocketIdleTimeout", proxyws_set_idle, NULL, RSRC_CONF|ACCESS_CONF,
- "timeout for activity in either direction, unlimited by default"),
+ AP_INIT_TAKE1("ProxyWebsocketIdleTimeout", proxyws_set_idle, NULL,
+ RSRC_CONF|ACCESS_CONF,
+ "timeout for activity in either direction, unlimited by default"),
- AP_INIT_TAKE1("ProxyWebsocketAsyncDelay", proxyws_set_aysnch_delay, NULL, RSRC_CONF|ACCESS_CONF,
+ AP_INIT_TAKE1("ProxyWebsocketAsyncDelay", proxyws_set_aysnch_delay, NULL,
+ RSRC_CONF|ACCESS_CONF,
"amount of time to poll before going asynchronous"),
{NULL}
};