gfwleak/tango-tfe
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修正流式构建HTTP响应时，重新申请write_ctx的问题

Browse Source
This commit is contained in:
Lu Qiuwen
2018-10-16 17:24:52 +08:00
parent f567fba70b
commit 01ec332844
1 changed files with 15 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
plugin/protocol/http/src/http_entry.cpp
View File

@@ -61,9 +61,17 @@ static int __write_http_half(struct http_half_private * hf_private,
unsigned char * __to_write = evbuffer_pullup(hf_private->evbuf_raw, __to_write_len);
/* Write the data to stream, UPSTREAM is the incoming direction for response */
int ret = tfe_stream_write(stream, dir, __to_write, __to_write_len);
if (unlikely(ret < 0)) { assert(0); }
int ret = 0;
if (hf_private->write_ctx)
{
ret = tfe_stream_write_frag(hf_private->write_ctx, __to_write, __to_write_len);
}
else
{
ret = tfe_stream_write(stream, dir, __to_write, __to_write_len);
}
if (unlikely(ret < 0)) { assert(0); }
evbuffer_drain(hf_private->evbuf_raw, __to_write_len);
return ret;
}
@@ -327,6 +335,11 @@ enum tfe_stream_action __http_connection_entry_on_response(const struct tfe_stre
hf_private_destory(hf_private_resp_user);
hs_private->hf_private_resp_user = NULL;
}
if (hf_private_resp_in->stream_action == ACTION_DEFER_DATA)
{
hf_private_resp_in->stream_action = ACTION_DROP_DATA;
}
}
__stream_action = hf_private_resp_in->stream_action;