Changeset bd9df97


Ignore:
Timestamp:
2012-02-15 12:02:18 (2 years ago)
Author:
Poul-Henning Kamp <phk@…>
Branches:
master, 4.0, experimental-ims
Children:
071f86
Parents:
af2bfa
git-author:
Poul-Henning Kamp <phk@…> (2012-02-15 12:02:18)
git-committer:
Poul-Henning Kamp <phk@…> (2012-02-15 12:02:18)
Message:

The VGZ api does not need a worker, it just needs a vsl_log

Location:
bin/varnishd/cache
Files:
5 edited

Legend:

Unmodified
Added
Removed
  • bin/varnishd/cache/cache.h

    raf2bfa rbd9df97  
    769769 
    770770enum vgz_flag { VGZ_NORMAL, VGZ_ALIGN, VGZ_RESET, VGZ_FINISH }; 
    771 struct vgz *VGZ_NewUngzip(struct worker *wrk, const char *id); 
    772 struct vgz *VGZ_NewGzip(struct worker *wrk, const char *id); 
     771struct vgz *VGZ_NewUngzip(struct vsl_log *vsl, const char *id); 
     772struct vgz *VGZ_NewGzip(struct vsl_log *vsl, const char *id); 
    773773void VGZ_Ibuf(struct vgz *, const void *, ssize_t len); 
    774774int VGZ_IbufEmpty(const struct vgz *vg); 
     
    778778int VGZ_Gzip(struct vgz *, const void **, size_t *len, enum vgz_flag); 
    779779int VGZ_Gunzip(struct vgz *, const void **, size_t *len); 
    780 int VGZ_Destroy(struct vgz **, int vsl_id); 
     780int VGZ_Destroy(struct vgz **); 
    781781void VGZ_UpdateObj(const struct vgz*, struct object *); 
    782782 
  • bin/varnishd/cache/cache_esi_deliver.c

    re9e3e2 rbd9df97  
    259259 
    260260        if (isgzip && !sp->req->gzip_resp) { 
    261                 vgz = VGZ_NewUngzip(sp->wrk, "U D E"); 
     261                vgz = VGZ_NewUngzip(sp->wrk->vsl, "U D E"); 
    262262                AZ(VGZ_WrwInit(vgz)); 
    263263 
     
    391391        if (vgz != NULL) { 
    392392                VGZ_WrwFlush(sp->wrk, vgz); 
    393                 (void)VGZ_Destroy(&vgz, sp->vsl_id); 
     393                (void)VGZ_Destroy(&vgz); 
    394394        } 
    395395        if (sp->req->gzip_resp && sp->req->esi_level == 0) { 
  • bin/varnishd/cache/cache_esi_fetch.c

    r2d4971 rbd9df97  
    314314        AZ(bo->vgz_rx); 
    315315        if (bo->is_gzip && bo->do_gunzip) { 
    316                 bo->vgz_rx = VGZ_NewUngzip(wrk, "U F E"); 
     316                bo->vgz_rx = VGZ_NewUngzip(wrk->vsl, "U F E"); 
    317317                VEP_Init(wrk, NULL); 
    318318                vef->ibuf_sz = cache_param->gzip_buffer; 
    319319        } else if (bo->is_gunzip && bo->do_gzip) { 
    320                 vef->vgz = VGZ_NewGzip(wrk, "G F E"); 
     320                vef->vgz = VGZ_NewGzip(wrk->vsl, "G F E"); 
    321321                VEP_Init(wrk, vfp_vep_callback); 
    322322                vef->ibuf_sz = cache_param->gzip_buffer; 
    323323        } else if (bo->is_gzip) { 
    324                 bo->vgz_rx = VGZ_NewUngzip(wrk, "U F E"); 
    325                 vef->vgz = VGZ_NewGzip(wrk, "G F E"); 
     324                bo->vgz_rx = VGZ_NewUngzip(wrk->vsl, "U F E"); 
     325                vef->vgz = VGZ_NewGzip(wrk->vsl, "G F E"); 
    326326                VEP_Init(wrk, vfp_vep_callback); 
    327327                vef->ibuf_sz = cache_param->gzip_buffer; 
     
    387387        retval = bo->fetch_failed; 
    388388 
    389         if (bo->vgz_rx != NULL && VGZ_Destroy(&bo->vgz_rx, -1) != VGZ_END) 
     389        if (bo->vgz_rx != NULL && VGZ_Destroy(&bo->vgz_rx) != VGZ_END) 
    390390                retval = FetchError(bo, "Gunzip+ESI Failed at the very end"); 
    391391 
     
    415415        if (vef->vgz != NULL) { 
    416416                VGZ_UpdateObj(vef->vgz, bo->fetch_obj); 
    417                 if (VGZ_Destroy(&vef->vgz,  -1) != VGZ_END) 
     417                if (VGZ_Destroy(&vef->vgz) != VGZ_END) 
    418418                        retval = FetchError(bo, 
    419419                            "ESI+Gzip Failed at the very end"); 
  • bin/varnishd/cache/cache_gzip.c

    r2d4971 rbd9df97  
    5050#define VGZ_MAGIC               0x162df0cb 
    5151        enum {VGZ_GZ,VGZ_UN}    dir; 
    52         struct worker           *wrk; 
     52        struct vsl_log          *vsl; 
    5353        const char              *id; 
    5454        struct ws               *tmp; 
     
    7171 
    7272static struct vgz * 
    73 vgz_alloc_vgz(struct worker *wrk, const char *id) 
    74 { 
    75         struct vgz *vg; 
    76  
    77         CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC); 
     73vgz_alloc_vgz(struct vsl_log *vsl, const char *id) 
     74{ 
     75        struct vgz *vg; 
     76 
    7877        ALLOC_OBJ(vg, VGZ_MAGIC); 
    7978        AN(vg); 
    80         vg->wrk = wrk; 
     79        vg->vsl = vsl; 
    8180        vg->id = id; 
    8281        return (vg); 
     
    8483 
    8584struct vgz * 
    86 VGZ_NewUngzip(struct worker *wrk, const char *id) 
    87 { 
    88         struct vgz *vg; 
    89  
    90         CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC); 
    91         vg = vgz_alloc_vgz(wrk, id); 
     85VGZ_NewUngzip(struct vsl_log *vsl, const char *id) 
     86{ 
     87        struct vgz *vg; 
     88 
     89        vg = vgz_alloc_vgz(vsl, id); 
    9290        vg->dir = VGZ_UN; 
    9391        VSC_C_main->n_gunzip++; 
     
    104102 
    105103struct vgz * 
    106 VGZ_NewGzip(struct worker *wrk, const char *id) 
     104VGZ_NewGzip(struct vsl_log *vsl, const char *id) 
    107105{ 
    108106        struct vgz *vg; 
    109107        int i; 
    110108 
    111         CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC); 
    112         vg = vgz_alloc_vgz(wrk, id); 
     109        vg = vgz_alloc_vgz(vsl, id); 
    113110        vg->dir = VGZ_GZ; 
    114111        VSC_C_main->n_gzip++; 
     
    390387 
    391388int 
    392 VGZ_Destroy(struct vgz **vgp, int vsl_id) 
     389VGZ_Destroy(struct vgz **vgp) 
    393390{ 
    394391        struct vgz *vg; 
     
    399396        *vgp = NULL; 
    400397 
    401         if (vsl_id < 0) 
    402                 VSLB(vg->wrk->busyobj, SLT_Gzip, "%s %jd %jd %jd %jd %jd", 
    403                     vg->id, 
    404                     (intmax_t)vg->vz.total_in, 
    405                     (intmax_t)vg->vz.total_out, 
    406                     (intmax_t)vg->vz.start_bit, 
    407                     (intmax_t)vg->vz.last_bit, 
    408                     (intmax_t)vg->vz.stop_bit); 
    409         else 
    410                 WSL(vg->wrk->vsl, SLT_Gzip, vsl_id, "%s %jd %jd %jd %jd %jd", 
    411                     vg->id, 
    412                     (intmax_t)vg->vz.total_in, 
    413                     (intmax_t)vg->vz.total_out, 
    414                     (intmax_t)vg->vz.start_bit, 
    415                     (intmax_t)vg->vz.last_bit, 
    416                     (intmax_t)vg->vz.stop_bit); 
     398        WSL(vg->vsl, SLT_Gzip, -1, "%s %jd %jd %jd %jd %jd", 
     399            vg->id, 
     400            (intmax_t)vg->vz.total_in, 
     401            (intmax_t)vg->vz.total_out, 
     402            (intmax_t)vg->vz.start_bit, 
     403            (intmax_t)vg->vz.last_bit, 
     404            (intmax_t)vg->vz.stop_bit); 
    417405        if (vg->tmp != NULL) 
    418406                WS_Reset(vg->tmp, vg->tmp_snapshot); 
     
    448436        CHECK_OBJ_NOTNULL(wrk->busyobj, BUSYOBJ_MAGIC); 
    449437        AZ(wrk->busyobj->vgz_rx); 
    450         wrk->busyobj->vgz_rx = VGZ_NewUngzip(wrk, "U F -"); 
     438        wrk->busyobj->vgz_rx = VGZ_NewUngzip(wrk->vsl, "U F -"); 
    451439        XXXAZ(vgz_getmbuf(wrk->busyobj->vgz_rx)); 
    452440} 
     
    503491        CHECK_OBJ_NOTNULL(vg, VGZ_MAGIC); 
    504492        if (wrk->busyobj->fetch_failed) { 
    505                 (void)VGZ_Destroy(&vg, -1); 
     493                (void)VGZ_Destroy(&vg); 
    506494                return(0); 
    507495        } 
    508         if (VGZ_Destroy(&vg, -1) != VGZ_END) 
     496        if (VGZ_Destroy(&vg) != VGZ_END) 
    509497                return(FetchError(wrk->busyobj, 
    510498                    "Gunzip error at the very end")); 
     
    532520        CHECK_OBJ_NOTNULL(wrk->busyobj, BUSYOBJ_MAGIC); 
    533521        AZ(wrk->busyobj->vgz_rx); 
    534         wrk->busyobj->vgz_rx = VGZ_NewGzip(wrk, "G F -"); 
     522        wrk->busyobj->vgz_rx = VGZ_NewGzip(wrk->vsl, "G F -"); 
    535523        XXXAZ(vgz_getmbuf(wrk->busyobj->vgz_rx)); 
    536524} 
     
    587575        wrk->busyobj->vgz_rx = NULL; 
    588576        if (wrk->busyobj->fetch_failed) { 
    589                 (void)VGZ_Destroy(&vg, -1); 
     577                (void)VGZ_Destroy(&vg); 
    590578                return(0); 
    591579        } 
     
    600588                RES_StreamPoll(wrk); 
    601589        VGZ_UpdateObj(vg, wrk->busyobj->fetch_obj); 
    602         if (VGZ_Destroy(&vg, -1) != VGZ_END) 
     590        if (VGZ_Destroy(&vg) != VGZ_END) 
    603591                return(FetchError(wrk->busyobj, "Gzip error at the very end")); 
    604592        return (0); 
     
    624612        CHECK_OBJ_NOTNULL(wrk->busyobj, BUSYOBJ_MAGIC); 
    625613        (void)estimate; 
    626         wrk->busyobj->vgz_rx = VGZ_NewUngzip(wrk, "u F -"); 
     614        wrk->busyobj->vgz_rx = VGZ_NewUngzip(wrk->vsl, "u F -"); 
    627615        CHECK_OBJ_NOTNULL(wrk->busyobj->vgz_rx, VGZ_MAGIC); 
    628616        XXXAZ(vgz_getmbuf(wrk->busyobj->vgz_rx)); 
     
    688676        CHECK_OBJ_NOTNULL(vg, VGZ_MAGIC); 
    689677        if (wrk->busyobj->fetch_failed) { 
    690                 (void)VGZ_Destroy(&vg, -1); 
     678                (void)VGZ_Destroy(&vg); 
    691679                return(0); 
    692680        } 
    693681        VGZ_UpdateObj(vg, wrk->busyobj->fetch_obj); 
    694         if (VGZ_Destroy(&vg, -1) != VGZ_END) 
     682        if (VGZ_Destroy(&vg) != VGZ_END) 
    695683                return(FetchError(wrk->busyobj, 
    696684                    "TestGunzip error at the very end")); 
  • bin/varnishd/cache/cache_response.c

    re9e3e2 rbd9df97  
    161161        CHECK_OBJ_NOTNULL(sp, SESS_MAGIC); 
    162162 
    163         vg = VGZ_NewUngzip(sp->wrk, "U D -"); 
     163        vg = VGZ_NewUngzip(sp->wrk->vsl, "U D -"); 
    164164        AZ(VGZ_WrwInit(vg)); 
    165165 
     
    176176        } 
    177177        VGZ_WrwFlush(sp->wrk, vg); 
    178         (void)VGZ_Destroy(&vg, sp->vsl_id); 
     178        (void)VGZ_Destroy(&vg); 
    179179        assert(u == sp->req->obj->len); 
    180180} 
     
    326326 
    327327        if (req->res_mode & RES_GUNZIP) { 
    328                 req->stream_vgz = VGZ_NewUngzip(sp->wrk, "U S -"); 
     328                req->stream_vgz = VGZ_NewUngzip(sp->wrk->vsl, "U S -"); 
    329329                AZ(VGZ_WrwInit(req->stream_vgz)); 
    330330                http_Unset(req->resp, H_Content_Encoding); 
     
    408408                AN(req->stream_vgz); 
    409409                VGZ_WrwFlush(sp->wrk, req->stream_vgz); 
    410                 (void)VGZ_Destroy(&req->stream_vgz, sp->vsl_id); 
     410                (void)VGZ_Destroy(&req->stream_vgz); 
    411411        } 
    412412        if (req->res_mode & RES_CHUNKED && !(req->res_mode & RES_ESI_CHILD)) 
Note: See TracChangeset for help on using the changeset viewer.