src/store_swapmeta.cc

   1 /*
   2  * Copyright (C) 1996-2020 The Squid Software Foundation and contributors
   3  *
   4  * Squid software is distributed under GPLv2+ license and includes
   5  * contributions from numerous individuals and organizations.
   6  * Please see the COPYING and CONTRIBUTORS files for details.
   7  */
   8
   9 /* DEBUG: section 20    Storage Manager Swapfile Metadata */
  10
  11 #include "squid.h"
  12 #include "md5.h"
  13 #include "MemObject.h"
  14 #include "Store.h"
  15 #include "StoreMeta.h"
  16 #include "StoreMetaUnpacker.h"
  17
  18 #if HAVE_SYS_WAIT_H
  19 #include <sys/wait.h>
  20 #endif
  21
  22 void
  23 storeSwapTLVFree(tlv * n)
  24 {
  25     tlv *t;
  26
  27     while ((t = n) != NULL) {
  28         n = t->next;
  29         xfree(t->value);
  30         delete t;
  31     }
  32 }
  33
  34 /*
  35  * Build a TLV list for a StoreEntry
  36  */
  37 tlv *
  38 storeSwapMetaBuild(const StoreEntry *e)
  39 {
  40     tlv *TLV = NULL;        /* we'll return this */
  41     tlv **T = &TLV;
  42     assert(e->mem_obj != NULL);
  43     const int64_t objsize = e->mem_obj->expectedReplySize();
  44
  45     // e->mem_obj->request may be nil in this context
  46     SBuf url;
  47     if (e->mem_obj->request)
  48         url = e->mem_obj->request->storeId();
  49     else
  50         url = e->url();
  51
  52     debugs(20, 3, "storeSwapMetaBuild URL: " << url);
  53
  54     tlv *t = StoreMeta::Factory (STORE_META_KEY,SQUID_MD5_DIGEST_LENGTH, e->key);
  55
  56     if (!t) {
  57         storeSwapTLVFree(TLV);
  58         return NULL;
  59     }
  60
  61     T = StoreMeta::Add(T, t);
  62     t = StoreMeta::Factory(STORE_META_STD_LFS,STORE_HDR_METASIZE,&e->timestamp);
  63
  64     if (!t) {
  65         storeSwapTLVFree(TLV);
  66         return NULL;
  67     }
  68
  69     // XXX: do TLV without the c_str() termination. check readers first though
  70     T = StoreMeta::Add(T, t);
  71     t = StoreMeta::Factory(STORE_META_URL, url.length()+1, url.c_str());
  72
  73     if (!t) {
  74         storeSwapTLVFree(TLV);
  75         return NULL;
  76     }
  77
  78     if (objsize >= 0) {
  79         T = StoreMeta::Add(T, t);
  80         t = StoreMeta::Factory(STORE_META_OBJSIZE, sizeof(objsize), &objsize);
  81
  82         if (!t) {
  83             storeSwapTLVFree(TLV);
  84             return NULL;
  85         }
  86     }
  87
  88     T = StoreMeta::Add(T, t);
  89     SBuf vary(e->mem_obj->vary_headers);
  90
  91     if (!vary.isEmpty()) {
  92         t = StoreMeta::Factory(STORE_META_VARY_HEADERS, vary.length(), vary.c_str());
  93
  94         if (!t) {
  95             storeSwapTLVFree(TLV);
  96             return NULL;
  97         }
  98
  99         StoreMeta::Add (T, t);
 100     }
 101
 102     return TLV;
 103 }
 104
 105 char *
 106 storeSwapMetaPack(tlv * tlv_list, int *length)
 107 {
 108     int buflen = 0;
 109     tlv *t;
 110     int j = 0;
 111     char *buf;
 112     assert(length != NULL);
 113     ++buflen;           /* STORE_META_OK */
 114     buflen += sizeof(int);  /* size of header to follow */
 115
 116     for (t = tlv_list; t; t = t->next)
 117         buflen += sizeof(char) + sizeof(int) + t->length;
 118
 119     buf = (char *)xmalloc(buflen);
 120
 121     buf[j] = (char) STORE_META_OK;
 122     ++j;
 123
 124     memcpy(&buf[j], &buflen, sizeof(int));
 125
 126     j += sizeof(int);
 127
 128     for (t = tlv_list; t; t = t->next) {
 129         buf[j] = t->getType();
 130         ++j;
 131         memcpy(&buf[j], &t->length, sizeof(int));
 132         j += sizeof(int);
 133         memcpy(&buf[j], t->value, t->length);
 134         j += t->length;
 135     }
 136
 137     assert((int) j == buflen);
 138     *length = buflen;
 139     return buf;
 140 }
 141