33 static handler_t mod_echo_request_body(request_st * const r) {  in mod_echo_request_body()  argument
34     chunkqueue * const cq = &r->reqbody_queue;  in mod_echo_request_body()
37     if ((r->conf.stream_response_body & FDEVENT_STREAM_RESPONSE_BUFMIN)  in mod_echo_request_body()
38         && r->resp_body_started) {  in mod_echo_request_body()
39         if (chunkqueue_length(&r->write_queue) > 65536 - 4096) {  in mod_echo_request_body()
46                 joblist_append(r->con);  in mod_echo_request_body()
51     if (0 != http_chunk_transfer_cqlen(r, cq, (size_t)cqlen))  in mod_echo_request_body()
54     if (cq->bytes_out == (off_t)r->reqbody_length) {  in mod_echo_request_body()
56         http_response_backend_done(r);  in mod_echo_request_body()
61     if (cq->bytes_in != (off_t)r->reqbody_length && cqlen < 65536 - 16384) {  in mod_echo_request_body()
63         if (!(r->conf.stream_request_body & FDEVENT_STREAM_REQUEST_POLLIN)) {  in mod_echo_request_body()
64             r->conf.stream_request_body |= FDEVENT_STREAM_REQUEST_POLLIN;  in mod_echo_request_body()
65             r->con->is_readable = 1; /* trigger optimistic read from client */  in mod_echo_request_body()
74     handler_t rc = mod_echo_request_body(r);  in SUBREQUEST_FUNC()
77     chunkqueue * const cq = &r->reqbody_queue;  in SUBREQUEST_FUNC()
78     if (cq->bytes_in != (off_t)r->reqbody_length) {  in SUBREQUEST_FUNC()
82             && (r->conf.stream_request_body & FDEVENT_STREAM_REQUEST_BUFMIN)) {  in SUBREQUEST_FUNC()
83             r->conf.stream_request_body &= ~FDEVENT_STREAM_REQUEST_POLLIN;  in SUBREQUEST_FUNC()
87             rc = r->con->reqbody_read(r);  in SUBREQUEST_FUNC()
90             if (-1 == r->reqbody_length  in SUBREQUEST_FUNC()
91                 && !(r->conf.stream_request_body & FDEVENT_STREAM_REQUEST))  in SUBREQUEST_FUNC()
96     return mod_echo_request_body(r);  in SUBREQUEST_FUNC()
104     handler_t rc = r->con->reqbody_read(r);  in SUBREQUEST_FUNC()
107     chunkqueue * const cq = &r->reqbody_queue;  in SUBREQUEST_FUNC()
108     if (0 != http_chunk_transfer_cqlen(r, cq, chunkqueue_length(cq)))  in SUBREQUEST_FUNC()
111     if (cq->bytes_out == (off_t)r->reqbody_length) {  in SUBREQUEST_FUNC()
112         http_response_backend_done(r);  in SUBREQUEST_FUNC()
122     if (NULL == r->handler_module  in URIHANDLER_FUNC()
123         && buffer_eq_slen(&r->uri.path, CONST_STR_LEN("/echo"))) {  in URIHANDLER_FUNC()
124         r->handler_module = p->self;  in URIHANDLER_FUNC()
125         r->resp_body_started = 1;  in URIHANDLER_FUNC()
127         if (0 == r->reqbody_length) {  in URIHANDLER_FUNC()
128             r->resp_body_finished = 1;  in URIHANDLER_FUNC()