src/store_swapin.cc

   1 /*
   2  * Copyright (C) 1996-2021 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 Swapin Functions */
  10
  11 #include "squid.h"
  12 #include "globals.h"
  13 #include "StatCounters.h"
  14 #include "Store.h"
  15 #include "store_swapin.h"
  16 #include "StoreClient.h"
  17
  18 static StoreIOState::STIOCB storeSwapInFileClosed;
  19 static StoreIOState::STFNCB storeSwapInFileNotify;
  20
  21 void
  22 storeSwapInStart(store_client * sc)
  23 {
  24     StoreEntry *e = sc->entry;
  25
  26     if (!EBIT_TEST(e->flags, ENTRY_VALIDATED)) {
  27         /* We're still reloading and haven't validated this entry yet */
  28         return;
  29     }
  30
  31     if (e->mem_status != NOT_IN_MEMORY)
  32         debugs(20, 3, HERE << "already IN_MEMORY");
  33
  34     debugs(20, 3, *e << " " <<  e->getMD5Text());
  35
  36     if (!e->hasDisk()) {
  37         debugs(20, DBG_IMPORTANT, "BUG: Attempt to swap in a not-stored entry " << *e << ". Salvaged.");
  38         return;
  39     }
  40
  41     if (e->swapoutFailed()) {
  42         debugs(20, DBG_IMPORTANT, "BUG: Attempt to swap in a failed-to-store entry " << *e << ". Salvaged.");
  43         return;
  44     }
  45
  46     assert(e->mem_obj != NULL);
  47     sc->swapin_sio = storeOpen(e, storeSwapInFileNotify, storeSwapInFileClosed, sc);
  48 }
  49
  50 static void
  51 storeSwapInFileClosed(void *data, int errflag, StoreIOState::Pointer)
  52 {
  53     store_client *sc = (store_client *)data;
  54     debugs(20, 3, "storeSwapInFileClosed: sio=" << sc->swapin_sio.getRaw() << ", errflag=" << errflag);
  55     sc->swapin_sio = NULL;
  56
  57     if (sc->_callback.pending()) {
  58         assert (errflag <= 0);
  59         sc->callback(0, errflag ? true : false);
  60     }
  61
  62     ++statCounter.swap.ins;
  63 }
  64
  65 static void
  66 storeSwapInFileNotify(void *data, int, StoreIOState::Pointer)
  67 {
  68     store_client *sc = (store_client *)data;
  69     StoreEntry *e = sc->entry;
  70
  71     debugs(1, 3, "storeSwapInFileNotify: changing " << e->swap_filen << "/" <<
  72            e->swap_dirn << " to " << sc->swapin_sio->swap_filen << "/" <<
  73            sc->swapin_sio->swap_dirn);
  74
  75     assert(e->swap_filen < 0); // if this fails, call SwapDir::disconnect(e)
  76     e->swap_filen = sc->swapin_sio->swap_filen;
  77     e->swap_dirn = sc->swapin_sio->swap_dirn;
  78 }
  79