在http block中,http response body事件调用tfe_http_session_kill关闭会话。
This commit is contained in:
@@ -353,7 +353,6 @@ static void __conn_private_destory_with_ssl(struct event_base * ev_base,
|
|||||||
static void __stream_bev_passthrough_readcb(struct bufferevent * bev, void * arg)
|
static void __stream_bev_passthrough_readcb(struct bufferevent * bev, void * arg)
|
||||||
{
|
{
|
||||||
struct tfe_stream_private * _stream = (struct tfe_stream_private *) arg;
|
struct tfe_stream_private * _stream = (struct tfe_stream_private *) arg;
|
||||||
struct tfe_proxy * _proxy = _stream->proxy_ref;
|
|
||||||
struct tfe_conn_private * peer_conn = __peer_conn(_stream, __bev_dir(_stream, bev));
|
struct tfe_conn_private * peer_conn = __peer_conn(_stream, __bev_dir(_stream, bev));
|
||||||
|
|
||||||
struct evbuffer * __input_buffer = bufferevent_get_input(bev);
|
struct evbuffer * __input_buffer = bufferevent_get_input(bev);
|
||||||
|
|||||||
@@ -884,7 +884,8 @@ static void http_reject(const struct tfe_http_session * session, enum tfe_http_e
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
//TODO: close http session.
|
to_write_sess = tfe_http_session_allow_write(session);
|
||||||
|
tfe_http_session_kill(to_write_sess);
|
||||||
}
|
}
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user