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

在流式发送应答时，不使用GZIP压缩

Browse Source
This commit is contained in:
Lu Qiuwen
2018-10-16 16:37:27 +08:00
parent 2bc366fb13
commit 95c57fe8a5
2 changed files with 15 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -75,8 +75,9 @@ static int __write_http_half_to_line(const struct tfe_stream * stream,
if (hf_private->is_setup_by_stream) if (hf_private->is_setup_by_stream)
{ {
/* By stream, first time to write http request/response, construct the header */ /* By stream, first time to write http request/response,
if (hf_private->write_ctx == NULL) * and has been call body_begin, construct the header */
if (hf_private->evbuf_body != NULL && hf_private->write_ctx == NULL)
{ {
ret = __write_http_half(hf_private, stream, dir); ret = __write_http_half(hf_private, stream, dir);
if (unlikely(ret < 0)) return ret; if (unlikely(ret < 0)) return ret;

20
plugin/protocol/http/src/http_half.cpp
View File

@@ -587,15 +587,19 @@ int hf_ops_append_body(struct tfe_http_half * half, char * buff, size_t size, in
int hf_ops_body_begin(struct tfe_http_half * half, int by_stream) int hf_ops_body_begin(struct tfe_http_half * half, int by_stream)
{ {
struct http_half_private * hf_private = to_hf_private(half); struct http_half_private * hf_private = to_hf_private(half);
assert(hf_private->evbuf_body == NULL); assert(hf_private->evbuf_body == NULL);
if (hf_private->evbuf_body != NULL)
{
evbuffer_free(hf_private->evbuf_body);
}
if (by_stream) if (by_stream)
{ {
/* By stream, we do not support content-encoding for now,
* send body directly without compression */
if(hf_private->cv_compress_object != NULL)
{
hf_content_compress_destroy(hf_private->cv_compress_object);
hf_private->cv_compress_object = NULL;
}
hf_private->content_encoding = HTTP_ACCEPT_ENCODING_NONE;
hf_private->is_setup_by_stream = true; hf_private->is_setup_by_stream = true;
} }
@@ -682,9 +686,9 @@ struct tfe_http_half_ops __http_half_ops =
.ops_http_allow_write = hf_ops_allow_write, .ops_http_allow_write = hf_ops_allow_write,
.ops_http_field_iterate = hf_ops_field_iterate, .ops_http_field_iterate = hf_ops_field_iterate,
.ops_append_body = hf_ops_append_body, .ops_append_body = hf_ops_append_body,
.ops_body_begin = NULL, .ops_body_begin = hf_ops_body_begin,
.ops_body_data = NULL, .ops_body_data = hf_ops_body_data,
.ops_body_end = NULL, .ops_body_end = hf_ops_body_end,
.ops_free = hf_ops_free .ops_free = hf_ops_free
}; };