Commit 7221cf79 authored by Poul-Henning Kamp's avatar Poul-Henning Kamp

Rename REQ_BODY_ modes to WITH[OUT]_LEN rather than transmission mode.

parent fdee70d7
...@@ -1111,7 +1111,7 @@ void SES_Delete(struct sess *sp, enum sess_close reason, double now); ...@@ -1111,7 +1111,7 @@ void SES_Delete(struct sess *sp, enum sess_close reason, double now);
struct sesspool *SES_NewPool(struct pool *pp, unsigned pool_no); struct sesspool *SES_NewPool(struct pool *pp, unsigned pool_no);
void SES_DeletePool(struct sesspool *sp); void SES_DeletePool(struct sesspool *sp);
int SES_ScheduleReq(struct req *); int SES_ScheduleReq(struct req *);
struct req *SES_GetReq(struct worker *, struct sess *); struct req *SES_GetReq(const struct worker *, struct sess *);
void SES_Handle(struct sess *sp, double now); void SES_Handle(struct sess *sp, double now);
void SES_ReleaseReq(struct req *); void SES_ReleaseReq(struct req *);
pool_func_t SES_pool_accept_task; pool_func_t SES_pool_accept_task;
......
...@@ -139,7 +139,7 @@ V1F_fetch_hdr(struct worker *wrk, struct busyobj *bo, struct req *req) ...@@ -139,7 +139,7 @@ V1F_fetch_hdr(struct worker *wrk, struct busyobj *bo, struct req *req)
if (!http_GetHdr(bo->bereq, H_Host, NULL)) if (!http_GetHdr(bo->bereq, H_Host, NULL))
VDI_AddHostHeader(bo->bereq, vc); VDI_AddHostHeader(bo->bereq, vc);
if (req != NULL && req->req_body_status == REQ_BODY_CHUNKED) { if (req != NULL && req->req_body_status == REQ_BODY_WITHOUT_LEN) {
http_PrintfHeader(hp, "Transfer-Encoding: chunked"); http_PrintfHeader(hp, "Transfer-Encoding: chunked");
do_chunked = 1; do_chunked = 1;
} }
......
...@@ -298,13 +298,13 @@ http1_dissect(struct worker *wrk, struct req *req) ...@@ -298,13 +298,13 @@ http1_dissect(struct worker *wrk, struct req *req)
assert (req->req_body_status == REQ_BODY_INIT); assert (req->req_body_status == REQ_BODY_INIT);
if (req->htc->body_status == BS_CHUNKED) { if (req->htc->body_status == BS_CHUNKED) {
req->req_body_status = REQ_BODY_CHUNKED; req->req_body_status = REQ_BODY_WITHOUT_LEN;
} else if (req->htc->body_status == BS_LENGTH) { } else if (req->htc->body_status == BS_LENGTH) {
req->req_body_status = REQ_BODY_PRESENT; req->req_body_status = REQ_BODY_WITH_LEN;
} else if (req->htc->body_status == BS_NONE) { } else if (req->htc->body_status == BS_NONE) {
req->req_body_status = REQ_BODY_NONE; req->req_body_status = REQ_BODY_NONE;
} else if (req->htc->body_status == BS_EOF) { } else if (req->htc->body_status == BS_EOF) {
req->req_body_status = REQ_BODY_CHUNKED; req->req_body_status = REQ_BODY_WITHOUT_LEN;
} else { } else {
WRONG("Unknown req.body_length situation"); WRONG("Unknown req.body_length situation");
} }
...@@ -462,8 +462,8 @@ HTTP1_IterateReqBody(struct req *req, req_body_iter_f *func, void *priv) ...@@ -462,8 +462,8 @@ HTTP1_IterateReqBody(struct req *req, req_body_iter_f *func, void *priv)
return (0); return (0);
case REQ_BODY_NONE: case REQ_BODY_NONE:
return (0); return (0);
case REQ_BODY_PRESENT: case REQ_BODY_WITH_LEN:
case REQ_BODY_CHUNKED: case REQ_BODY_WITHOUT_LEN:
break; break;
case REQ_BODY_TAKEN: case REQ_BODY_TAKEN:
VSLb(req->vsl, SLT_VCL_Error, VSLb(req->vsl, SLT_VCL_Error,
...@@ -477,8 +477,8 @@ HTTP1_IterateReqBody(struct req *req, req_body_iter_f *func, void *priv) ...@@ -477,8 +477,8 @@ HTTP1_IterateReqBody(struct req *req, req_body_iter_f *func, void *priv)
WRONG("Wrong req_body_status in HTTP1_IterateReqBody()"); WRONG("Wrong req_body_status in HTTP1_IterateReqBody()");
} }
Lck_Lock(&req->sp->mtx); Lck_Lock(&req->sp->mtx);
if (req->req_body_status == REQ_BODY_PRESENT || if (req->req_body_status == REQ_BODY_WITH_LEN ||
req->req_body_status == REQ_BODY_CHUNKED) { req->req_body_status == REQ_BODY_WITHOUT_LEN) {
req->req_body_status = REQ_BODY_TAKEN; req->req_body_status = REQ_BODY_TAKEN;
i = 0; i = 0;
} else } else
...@@ -545,8 +545,8 @@ int ...@@ -545,8 +545,8 @@ int
HTTP1_DiscardReqBody(struct req *req) HTTP1_DiscardReqBody(struct req *req)
{ {
if (req->req_body_status == REQ_BODY_PRESENT || if (req->req_body_status == REQ_BODY_WITH_LEN ||
req->req_body_status == REQ_BODY_CHUNKED) req->req_body_status == REQ_BODY_WITHOUT_LEN)
(void)HTTP1_IterateReqBody(req, httpq_req_body_discard, NULL); (void)HTTP1_IterateReqBody(req, httpq_req_body_discard, NULL);
return(0); return(0);
} }
...@@ -575,8 +575,8 @@ HTTP1_CacheReqBody(struct req *req, ssize_t maxsize) ...@@ -575,8 +575,8 @@ HTTP1_CacheReqBody(struct req *req, ssize_t maxsize)
return (-1); return (-1);
case REQ_BODY_NONE: case REQ_BODY_NONE:
return (0); return (0);
case REQ_BODY_CHUNKED: case REQ_BODY_WITHOUT_LEN:
case REQ_BODY_PRESENT: case REQ_BODY_WITH_LEN:
break; break;
default: default:
WRONG("Wrong req_body_status in HTTP1_CacheReqBody()"); WRONG("Wrong req_body_status in HTTP1_CacheReqBody()");
......
...@@ -315,7 +315,7 @@ SES_Delete(struct sess *sp, enum sess_close reason, double now) ...@@ -315,7 +315,7 @@ SES_Delete(struct sess *sp, enum sess_close reason, double now)
*/ */
struct req * struct req *
SES_GetReq(struct worker *wrk, struct sess *sp) SES_GetReq(const struct worker *wrk, struct sess *sp)
{ {
struct sesspool *pp; struct sesspool *pp;
struct req *req; struct req *req;
......
...@@ -11,7 +11,7 @@ varnish v1 -vcl+backend { ...@@ -11,7 +11,7 @@ varnish v1 -vcl+backend {
logexpect l1 -v v1 -g request { logexpect l1 -v v1 -g request {
expect 0 1001 Begin expect 0 1001 Begin
expect * = ReqStart expect * = ReqStart
expect * = End expect * = End
} -start } -start
client c1 { client c1 {
......
...@@ -30,8 +30,8 @@ ...@@ -30,8 +30,8 @@
/*lint -save -e525 -e539 */ /*lint -save -e525 -e539 */
REQ_BODY(INIT) REQ_BODY(INIT)
REQ_BODY(PRESENT) REQ_BODY(WITHOUT_LEN)
REQ_BODY(CHUNKED) REQ_BODY(WITH_LEN)
REQ_BODY(TAKEN) REQ_BODY(TAKEN)
REQ_BODY(CACHED) REQ_BODY(CACHED)
REQ_BODY(FAIL) REQ_BODY(FAIL)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment