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
storeSwapInStart(store_client * sc)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
storeSwapInFileClosed(void * data,int errflag,StoreIOState::Pointer)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
storeSwapInFileNotify(void * data,int,StoreIOState::Pointer)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
80