dany/antd-fcgi-plugin
1
0
Fork 0
mirror of https://github.com/lxsang/antd-fcgi-plugin.git synced 2024-12-26 05:08:22 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: allow using default server compression policy

Browse Source
This commit is contained in:
DanyLE 2023-01-26 00:15:35 +01:00
parent 31fc0beddc
commit 1dbcf32592
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
fcgi.c
View File

@ -389,7 +389,7 @@ static int read_header(antd_client_t* cl, antd_request_t* rq)
antd_send_header(rq->client, &rhd); antd_send_header(rq->client, &rhd);
if(ret > 0) if(ret > 0)
{ {
if(antd_send(rq->client,ptr, ret) != ret) if(antd_send(rq->client,ptr, ret) != ret && rq->client->z_level == ANTD_CNONE)
{ {
(void)fcgi_abort_request(cl, cl->sock); (void)fcgi_abort_request(cl, cl->sock);
ERROR("Error atnd_send(): %s", strerror(errno)); ERROR("Error atnd_send(): %s", strerror(errno));
@ -477,7 +477,13 @@ static int read_data(antd_client_t* cl, antd_request_t* rq)
// write data to the other side // write data to the other side
if(payload && ret > 0) if(payload && ret > 0)
{ {
if(antd_send(rq->client,payload, ret) != ret) /**
* antd_send may return fewer bytes than `ret`
* this does not mean error, as the output stream
* maybe compressed by gzip
*
*/
if(antd_send(rq->client,payload, ret) != ret && rq->client->z_level == ANTD_CNONE)
{ {
(void)fcgi_abort_request(cl, cl->sock); (void)fcgi_abort_request(cl, cl->sock);
ERROR("Error atnd_send(): %s", strerror(errno)); ERROR("Error atnd_send(): %s", strerror(errno));
@ -769,7 +775,7 @@ void* handle(void* data)
cl->z_status = 0; cl->z_status = 0;
cl->z_level = ANTD_CNONE; cl->z_level = ANTD_CNONE;
cl->zstream = NULL; cl->zstream = NULL;
rq->client->z_level = ANTD_CNONE; //rq->client->z_level = ANTD_CNONE;
// start the request // start the request