src/store_swapmeta.cc

   1
   2 /*
   3  * $Id$
   4  *
   5  * DEBUG: section 20    Storage Manager Swapfile Metadata
   6  * AUTHOR: Kostas Anagnostakis
   7  *
   8  * SQUID Web Proxy Cache          http://www.squid-cache.org/
   9  * ----------------------------------------------------------
  10  *
  11  *  Squid is the result of efforts by numerous individuals from
  12  *  the Internet community; see the CONTRIBUTORS file for full
  13  *  details.   Many organizations have provided support for Squid's
  14  *  development; see the SPONSORS file for full details.  Squid is
  15  *  Copyrighted (C) 2001 by the Regents of the University of
  16  *  California; see the COPYRIGHT file for full details.  Squid
  17  *  incorporates software developed and/or copyrighted by other
  18  *  sources; see the CREDITS file for full details.
  19  *
  20  *  This program is free software; you can redistribute it and/or modify
  21  *  it under the terms of the GNU General Public License as published by
  22  *  the Free Software Foundation; either version 2 of the License, or
  23  *  (at your option) any later version.
  24  *
  25  *  This program is distributed in the hope that it will be useful,
  26  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  27  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  28  *  GNU General Public License for more details.
  29  *
  30  *  You should have received a copy of the GNU General Public License
  31  *  along with this program; if not, write to the Free Software
  32  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111, USA.
  33  *
  34  */
  35
  36 #include "squid-old.h"
  37 #include "Store.h"
  38 #include "MemObject.h"
  39 #include "StoreMeta.h"
  40 #include "StoreMetaUnpacker.h"
  41
  42 void
  43 storeSwapTLVFree(tlv * n)
  44 {
  45     tlv *t;
  46
  47     while ((t = n) != NULL) {
  48         n = t->next;
  49         xfree(t->value);
  50         delete t;
  51     }
  52 }
  53
  54 /*
  55  * Build a TLV list for a StoreEntry
  56  */
  57 tlv *
  58 storeSwapMetaBuild(StoreEntry * e)
  59 {
  60     tlv *TLV = NULL;            /* we'll return this */
  61     tlv **T = &TLV;
  62     const char *url;
  63     const char *vary;
  64     assert(e->mem_obj != NULL);
  65     const int64_t objsize = e->mem_obj->expectedReplySize();
  66     assert(e->swap_status == SWAPOUT_WRITING);
  67     url = e->url();
  68     debugs(20, 3, "storeSwapMetaBuild: " << url  );
  69     tlv *t = StoreMeta::Factory (STORE_META_KEY,SQUID_MD5_DIGEST_LENGTH, e->key);
  70
  71     if (!t) {
  72         storeSwapTLVFree(TLV);
  73         return NULL;
  74     }
  75
  76     T = StoreMeta::Add(T, t);
  77     t = StoreMeta::Factory(STORE_META_STD_LFS,STORE_HDR_METASIZE,&e->timestamp);
  78
  79     if (!t) {
  80         storeSwapTLVFree(TLV);
  81         return NULL;
  82     }
  83
  84     T = StoreMeta::Add(T, t);
  85     t = StoreMeta::Factory(STORE_META_URL, strlen(url) + 1, url);
  86
  87     if (!t) {
  88         storeSwapTLVFree(TLV);
  89         return NULL;
  90     }
  91
  92
  93     if (objsize >= 0) {
  94         T = StoreMeta::Add(T, t);
  95         t = StoreMeta::Factory(STORE_META_OBJSIZE, sizeof(objsize), &objsize);
  96
  97         if (!t) {
  98             storeSwapTLVFree(TLV);
  99             return NULL;
 100         }
 101     }
 102
 103     T = StoreMeta::Add(T, t);
 104     vary = e->mem_obj->vary_headers;
 105
 106     if (vary) {
 107         t =StoreMeta::Factory(STORE_META_VARY_HEADERS, strlen(vary) + 1, vary);
 108
 109         if (!t) {
 110             storeSwapTLVFree(TLV);
 111             return NULL;
 112         }
 113
 114         StoreMeta::Add (T, t);
 115     }
 116
 117     return TLV;
 118 }
 119
 120 char *
 121 storeSwapMetaPack(tlv * tlv_list, int *length)
 122 {
 123     int buflen = 0;
 124     tlv *t;
 125     int j = 0;
 126     char *buf;
 127     assert(length != NULL);
 128     buflen++;                   /* STORE_META_OK */
 129     buflen += sizeof(int);      /* size of header to follow */
 130
 131     for (t = tlv_list; t; t = t->next)
 132         buflen += sizeof(char) + sizeof(int) + t->length;
 133
 134     buf = (char *)xmalloc(buflen);
 135
 136     buf[j++] = (char) STORE_META_OK;
 137
 138     memcpy(&buf[j], &buflen, sizeof(int));
 139
 140     j += sizeof(int);
 141
 142     for (t = tlv_list; t; t = t->next) {
 143         buf[j++] = t->getType();
 144         memcpy(&buf[j], &t->length, sizeof(int));
 145         j += sizeof(int);
 146         memcpy(&buf[j], t->value, t->length);
 147         j += t->length;
 148     }
 149
 150     assert((int) j == buflen);
 151     *length = buflen;
 152     return buf;
 153 }