Ignore:
Timestamp:
2012-01-30 14:03:06 (2 years ago)
Author:
Poul-Henning Kamp <phk@…>
Branches:
master, 4.0, experimental-ims
Children:
ac35cc, a18ff4
Parents:
e815d5
git-author:
Poul-Henning Kamp <phk@…> (2012-01-30 14:03:06)
git-committer:
Poul-Henning Kamp <phk@…> (2012-01-30 14:03:06)
Message:

s/wrk->busyobj->/bo->/ in cnt_fetchbody() (with a few notable exceptions.)

File:
1 edited

Legend:

Unmodified
Added
Removed
  • bin/varnishd/cache/cache_center.c

    re815d5 r58e4a2  
    711711        struct vsb *vary = NULL; 
    712712        int varyl = 0, pass; 
     713        struct busyobj *bo; 
    713714 
    714715        CHECK_OBJ_NOTNULL(sp, SESS_MAGIC); 
    715716        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC); 
    716717        CHECK_OBJ_NOTNULL(req, REQ_MAGIC); 
    717         CHECK_OBJ_NOTNULL(wrk->busyobj, BUSYOBJ_MAGIC); 
     718        bo = wrk->busyobj; 
     719        CHECK_OBJ_NOTNULL(bo, BUSYOBJ_MAGIC); 
    718720 
    719721        assert(req->handling == VCL_RET_DELIVER); 
     
    723725                pass = 1; 
    724726                /* VCL may have fiddled this, but that doesn't help */ 
    725                 wrk->busyobj->exp.ttl = -1.; 
    726         } else if (wrk->busyobj->do_pass) { 
    727                         pass = 1; 
     727                bo->exp.ttl = -1.; 
     728        } else if (bo->do_pass) { 
     729                pass = 1; 
    728730        } else { 
    729731                /* regular object */ 
     
    746748        /* We do nothing unless the param is set */ 
    747749        if (!cache_param->http_gzip_support) 
    748                 wrk->busyobj->do_gzip = wrk->busyobj->do_gunzip = 0; 
    749  
    750         wrk->busyobj->is_gzip = 
    751             http_HdrIs(wrk->busyobj->beresp, H_Content_Encoding, "gzip"); 
    752  
    753         wrk->busyobj->is_gunzip = 
    754             !http_GetHdr(wrk->busyobj->beresp, H_Content_Encoding, NULL); 
     750                bo->do_gzip = bo->do_gunzip = 0; 
     751 
     752        bo->is_gzip = http_HdrIs(bo->beresp, H_Content_Encoding, "gzip"); 
     753 
     754        bo->is_gunzip = !http_GetHdr(bo->beresp, H_Content_Encoding, NULL); 
    755755 
    756756        /* It can't be both */ 
    757         assert(wrk->busyobj->is_gzip == 0 || wrk->busyobj->is_gunzip == 0); 
     757        assert(bo->is_gzip == 0 || bo->is_gunzip == 0); 
    758758 
    759759        /* We won't gunzip unless it is gzip'ed */ 
    760         if (wrk->busyobj->do_gunzip && !wrk->busyobj->is_gzip) 
    761                 wrk->busyobj->do_gunzip = 0; 
     760        if (bo->do_gunzip && !bo->is_gzip) 
     761                bo->do_gunzip = 0; 
    762762 
    763763        /* If we do gunzip, remove the C-E header */ 
    764         if (wrk->busyobj->do_gunzip) 
    765                 http_Unset(wrk->busyobj->beresp, H_Content_Encoding); 
     764        if (bo->do_gunzip) 
     765                http_Unset(bo->beresp, H_Content_Encoding); 
    766766 
    767767        /* We wont gzip unless it is ungziped */ 
    768         if (wrk->busyobj->do_gzip && !wrk->busyobj->is_gunzip) 
    769                 wrk->busyobj->do_gzip = 0; 
     768        if (bo->do_gzip && !bo->is_gunzip) 
     769                bo->do_gzip = 0; 
    770770 
    771771        /* If we do gzip, add the C-E header */ 
    772         if (wrk->busyobj->do_gzip) 
    773                 http_SetHeader(wrk, sp->vsl_id, wrk->busyobj->beresp, 
     772        if (bo->do_gzip) 
     773                http_SetHeader(wrk, sp->vsl_id, bo->beresp, 
    774774                    "Content-Encoding: gzip"); 
    775775 
    776776        /* But we can't do both at the same time */ 
    777         assert(wrk->busyobj->do_gzip == 0 || wrk->busyobj->do_gunzip == 0); 
     777        assert(bo->do_gzip == 0 || bo->do_gunzip == 0); 
    778778 
    779779        /* ESI takes precedence and handles gzip/gunzip itself */ 
    780         if (wrk->busyobj->do_esi) 
    781                 wrk->busyobj->vfp = &vfp_esi; 
    782         else if (wrk->busyobj->do_gunzip) 
    783                 wrk->busyobj->vfp = &vfp_gunzip; 
    784         else if (wrk->busyobj->do_gzip) 
    785                 wrk->busyobj->vfp = &vfp_gzip; 
    786         else if (wrk->busyobj->is_gzip) 
    787                 wrk->busyobj->vfp = &vfp_testgzip; 
    788  
    789         if (wrk->busyobj->do_esi || req->esi_level > 0) 
    790                 wrk->busyobj->do_stream = 0; 
     780        if (bo->do_esi) 
     781                bo->vfp = &vfp_esi; 
     782        else if (bo->do_gunzip) 
     783                bo->vfp = &vfp_gunzip; 
     784        else if (bo->do_gzip) 
     785                bo->vfp = &vfp_gzip; 
     786        else if (bo->is_gzip) 
     787                bo->vfp = &vfp_testgzip; 
     788 
     789        if (bo->do_esi || req->esi_level > 0) 
     790                bo->do_stream = 0; 
    791791        if (!req->wantbody) 
    792                 wrk->busyobj->do_stream = 0; 
     792                bo->do_stream = 0; 
    793793 
    794794        /* No reason to try streaming a non-existing body */ 
    795         if (wrk->busyobj->body_status == BS_NONE) 
    796                 wrk->busyobj->do_stream = 0; 
    797  
    798         l = http_EstimateWS(wrk->busyobj->beresp, 
     795        if (bo->body_status == BS_NONE) 
     796                bo->do_stream = 0; 
     797 
     798        l = http_EstimateWS(bo->beresp, 
    799799            pass ? HTTPH_R_PASS : HTTPH_A_INS, &nhttp); 
    800800 
     
    802802        if (req->objcore != NULL) { 
    803803                CHECK_OBJ_NOTNULL(req->objcore, OBJCORE_MAGIC); 
    804                 vary = VRY_Create(sp, wrk->busyobj->beresp); 
     804                vary = VRY_Create(sp, bo->beresp); 
    805805                if (vary != NULL) { 
    806806                        varyl = VSB_len(vary); 
     
    816816        l += strlen("Content-Length: XxxXxxXxxXxxXxxXxx") + sizeof(void *); 
    817817 
    818         if (wrk->busyobj->exp.ttl < cache_param->shortlived || 
     818        if (bo->exp.ttl < cache_param->shortlived || 
    819819            req->objcore == NULL) 
    820820                req->storage_hint = TRANSIENT_STORAGE; 
     
    827827                 */ 
    828828                req->obj = STV_NewObject(wrk, TRANSIENT_STORAGE, l, nhttp); 
    829                 if (wrk->busyobj->exp.ttl > cache_param->shortlived) 
    830                         wrk->busyobj->exp.ttl = cache_param->shortlived; 
    831                 wrk->busyobj->exp.grace = 0.0; 
    832                 wrk->busyobj->exp.keep = 0.0; 
     829                if (bo->exp.ttl > cache_param->shortlived) 
     830                        bo->exp.ttl = cache_param->shortlived; 
     831                bo->exp.grace = 0.0; 
     832                bo->exp.keep = 0.0; 
    833833        } 
    834834        if (req->obj == NULL) { 
    835835                req->err_code = 503; 
    836836                sp->step = STP_ERROR; 
    837                 VDI_CloseFd(wrk, &wrk->busyobj->vbc); 
     837                VDI_CloseFd(wrk, &bo->vbc); 
    838838                VBO_DerefBusyObj(wrk, &wrk->busyobj); 
    839839                return (0); 
     
    843843        req->storage_hint = NULL; 
    844844 
    845         if (wrk->busyobj->do_gzip || 
    846             (wrk->busyobj->is_gzip && !wrk->busyobj->do_gunzip)) 
     845        if (bo->do_gzip || 
     846            (bo->is_gzip && !bo->do_gunzip)) 
    847847                req->obj->gziped = 1; 
    848848 
     
    860860 
    861861        /* Filter into object */ 
    862         hp = wrk->busyobj->beresp; 
     862        hp = bo->beresp; 
    863863        hp2 = req->obj->http; 
    864864 
     
    870870                req->obj->last_modified = VTIM_parse(b); 
    871871        else 
    872                 req->obj->last_modified = floor(wrk->busyobj->exp.entered); 
     872                req->obj->last_modified = floor(bo->exp.entered); 
    873873 
    874874        assert(WRW_IsReleased(wrk)); 
     
    882882            req->http->conds && 
    883883            RFC2616_Do_Cond(sp)) 
    884                 wrk->busyobj->do_stream = 0; 
     884                bo->do_stream = 0; 
    885885 
    886886        AssertObjCorePassOrBusy(req->obj->objcore); 
    887887 
    888         if (wrk->busyobj->do_stream) { 
     888        if (bo->do_stream) { 
    889889                sp->step = STP_PREPRESP; 
    890890                return (0); 
     
    894894        i = FetchBody(wrk, req->obj); 
    895895 
    896         http_Setup(wrk->busyobj->bereq, NULL); 
    897         http_Setup(wrk->busyobj->beresp, NULL); 
    898         wrk->busyobj->vfp = NULL; 
     896        http_Setup(bo->bereq, NULL); 
     897        http_Setup(bo->beresp, NULL); 
     898        bo->vfp = NULL; 
    899899        assert(WRW_IsReleased(wrk)); 
    900         AZ(wrk->busyobj->vbc); 
     900        AZ(bo->vbc); 
    901901        AN(req->director); 
    902902 
Note: See TracChangeset for help on using the changeset viewer.