]> git.ipfire.org Git - thirdparty/squid.git/blame - src/peer_digest.cc
Maintenance: replace most NULL with nullptr (#1402)
[thirdparty/squid.git] / src / peer_digest.cc
CommitLineData
9b7de833 1/*
b8ae064d 2 * Copyright (C) 1996-2023 The Squid Software Foundation and contributors
e25c139f 3 *
bbc27441
AJ
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.
9b7de833 7 */
8
bbc27441
AJ
9/* DEBUG: section 72 Peer Digest Routines */
10
582c2af2 11#include "squid.h"
6cfa8966 12#if USE_CACHE_DIGESTS
0f783794 13#include "base/IoManip.h"
b814e8d4 14#include "CacheDigest.h"
a011edee 15#include "CachePeer.h"
a553a5a3 16#include "event.h"
eb13c21e 17#include "FwdState.h"
af69c635 18#include "globals.h"
528b2c61 19#include "HttpReply.h"
582c2af2 20#include "HttpRequest.h"
308e60be 21#include "internal.h"
528b2c61 22#include "MemObject.h"
b6149797 23#include "mime_header.h"
602d9612 24#include "neighbors.h"
aa839030 25#include "PeerDigest.h"
582c2af2 26#include "Store.h"
fb548aaf 27#include "store_key_md5.h"
598465f1 28#include "StoreClient.h"
4e540555 29#include "tools.h"
ed6e9fb9 30#include "util.h"
598465f1 31
9b7de833 32/* local types */
33
34/* local prototypes */
e13ee7ad 35static time_t peerDigestIncDelay(const PeerDigest * pd);
36static time_t peerDigestNewDelay(const StoreEntry * e);
37static void peerDigestSetCheck(PeerDigest * pd, time_t delay);
38static EVH peerDigestCheck;
39static void peerDigestRequest(PeerDigest * pd);
add2192d 40static STCB peerDigestHandleReply;
3dfaa3d2 41static int peerDigestFetchReply(void *, char *, ssize_t);
1f140227 42int peerDigestSwapInCBlock(void *, char *, ssize_t);
43int peerDigestSwapInMask(void *, char *, ssize_t);
4b4cd312 44static int peerDigestFetchedEnough(DigestFetchState * fetch, char *buf, ssize_t size, const char *step_name);
551e60a9 45static void peerDigestFetchStop(DigestFetchState * fetch, char *buf, const char *reason);
e13ee7ad 46static void peerDigestFetchAbort(DigestFetchState * fetch, char *buf, const char *reason);
47static void peerDigestReqFinish(DigestFetchState * fetch, char *buf, int, int, int, const char *reason, int err);
48static void peerDigestPDFinish(DigestFetchState * fetch, int pcb_valid, int err);
49static void peerDigestFetchFinish(DigestFetchState * fetch, int err);
50static void peerDigestFetchSetStats(DigestFetchState * fetch);
51static int peerDigestSetCBlock(PeerDigest * pd, const char *buf);
52static int peerDigestUseful(const PeerDigest * pd);
395b813e 53
9b7de833 54/* local constants */
aa839030 55Version const CacheDigestVer = { 5, 3 };
9d486b43 56
9b7de833 57#define StoreDigestCBlockSize sizeof(StoreDigestCBlock)
58
e13ee7ad 59/* min interval for requesting digests from a given peer */
f53969cc 60static const time_t PeerDigestReqMinGap = 5 * 60; /* seconds */
e13ee7ad 61/* min interval for requesting digests (cumulative request stream) */
f53969cc 62static const time_t GlobDigestReqMinGap = 1 * 60; /* seconds */
bd890734 63
64/* local vars */
9d486b43 65
f53969cc 66static time_t pd_last_req_time = 0; /* last call to Check */
9b7de833 67
0f783794
EB
68PeerDigest::PeerDigest(CachePeer * const p):
69 peer(p),
70 host(peer->host) // if peer disappears, we will know its name
9b7de833 71{
b56b37cf 72 times.initialized = squid_curtime;
9b7de833 73}
74
0353e724 75CBDATA_CLASS_INIT(PeerDigest);
76
a44986dc
AJ
77CBDATA_CLASS_INIT(DigestFetchState);
78
022099cb 79DigestFetchState::DigestFetchState(PeerDigest *aPd, HttpRequest *req) :
a44986dc 80 pd(cbdataReference(aPd)),
aee3523a
AR
81 entry(nullptr),
82 old_entry(nullptr),
83 sc(nullptr),
84 old_sc(nullptr),
a44986dc
AJ
85 request(req),
86 offset(0),
87 mask_offset(0),
88 start_time(squid_curtime),
89 resp_time(0),
90 expires(0),
91 bufofs(0),
92 state(DIGEST_READ_REPLY)
93{
94 HTTPMSGLOCK(request);
95
96 sent.msg = 0;
97 sent.bytes = 0;
98
99 recv.msg = 0;
100 recv.bytes = 0;
101
102 *buf = 0;
103}
104
105DigestFetchState::~DigestFetchState()
106{
107 /* unlock everything */
108 storeUnregister(sc, entry, this);
109
110 entry->unlock("DigestFetchState destructed");
aee3523a 111 entry = nullptr;
a44986dc
AJ
112
113 HTTPMSGUNLOCK(request);
114
aee3523a 115 assert(pd == nullptr);
a44986dc
AJ
116}
117
b56b37cf
AJ
118PeerDigest::~PeerDigest()
119{
97269a72
EB
120 if (times.next_check && eventFind(peerDigestCheck, this))
121 eventDelete(peerDigestCheck, this);
b56b37cf
AJ
122 delete cd;
123 // req_result pointer is not owned by us
124}
125
e13ee7ad 126/* called by peer to indicate that somebody actually needs this digest */
127void
8a6218c6 128peerDigestNeeded(PeerDigest * pd)
e13ee7ad 129{
130 assert(pd);
131 assert(!pd->flags.needed);
132 assert(!pd->cd);
133
be4d35dc 134 pd->flags.needed = true;
e13ee7ad 135 pd->times.needed = squid_curtime;
f53969cc 136 peerDigestSetCheck(pd, 0); /* check asap */
e13ee7ad 137}
138
e13ee7ad 139/* increment retry delay [after an unsuccessful attempt] */
395b813e 140static time_t
8a6218c6 141peerDigestIncDelay(const PeerDigest * pd)
395b813e 142{
e13ee7ad 143 assert(pd);
144 return pd->times.retry_delay > 0 ?
f53969cc
SM
145 2 * pd->times.retry_delay : /* exponential backoff */
146 PeerDigestReqMinGap; /* minimal delay */
395b813e 147}
148
62e76326 149/* artificially increases Expires: setting to avoid race conditions
e13ee7ad 150 * returns the delay till that [increased] expiration time */
00485c29 151static time_t
e13ee7ad 152peerDigestNewDelay(const StoreEntry * e)
00485c29 153{
e13ee7ad 154 assert(e);
62e76326 155
00485c29 156 if (e->expires > 0)
62e76326 157 return e->expires + PeerDigestReqMinGap - squid_curtime;
158
e13ee7ad 159 return PeerDigestReqMinGap;
00485c29 160}
161
e13ee7ad 162/* registers next digest verification */
395b813e 163static void
e13ee7ad 164peerDigestSetCheck(PeerDigest * pd, time_t delay)
395b813e 165{
e13ee7ad 166 eventAdd("peerDigestCheck", peerDigestCheck, pd, (double) delay, 1);
167 pd->times.next_check = squid_curtime + delay;
bb790702 168 debugs(72, 3, "peerDigestSetCheck: will check peer " << pd->host << " in " << delay << " secs");
e13ee7ad 169}
170
5385c86a 171/*
172 * called when peer is about to disappear or have already disappeared
173 */
e13ee7ad 174void
8a6218c6 175peerDigestNotePeerGone(PeerDigest * pd)
176{
e13ee7ad 177 if (pd->flags.requested) {
bb790702 178 debugs(72, 2, "peerDigest: peer " << pd->host << " gone, will destroy after fetch.");
62e76326 179 /* do nothing now, the fetching chain will notice and take action */
395b813e 180 } else {
bb790702 181 debugs(72, 2, "peerDigest: peer " << pd->host << " is gone, destroying now.");
0f783794 182 delete pd;
395b813e 183 }
184}
185
e13ee7ad 186/* callback for eventAdd() (with peer digest locked)
26ac0430 187 * request new digest if our copy is too old or if we lack one;
e13ee7ad 188 * schedule next check otherwise */
9b7de833 189static void
e13ee7ad 190peerDigestCheck(void *data)
9b7de833 191{
e6ccf245 192 PeerDigest *pd = (PeerDigest *)data;
e13ee7ad 193 time_t req_time;
194
e13ee7ad 195 assert(!pd->flags.requested);
5d9bb360 196
f53969cc 197 pd->times.next_check = 0; /* unknown */
e13ee7ad 198
0f783794 199 if (pd->peer.set() && !pd->peer.valid()) {
62e76326 200 peerDigestNotePeerGone(pd);
201 return;
9b7de833 202 }
62e76326 203
0f783794 204 debugs(72, 3, "cache_peer " << RawPointer(pd->peer).orNil());
26ac0430
AJ
205 debugs(72, 3, "peerDigestCheck: time: " << squid_curtime <<
206 ", last received: " << (long int) pd->times.received << " (" <<
bf8fe701 207 std::showpos << (int) (squid_curtime - pd->times.received) << ")");
e13ee7ad 208
209 /* decide when we should send the request:
210 * request now unless too close to other requests */
211 req_time = squid_curtime;
212
213 /* per-peer limit */
62e76326 214
e13ee7ad 215 if (req_time - pd->times.received < PeerDigestReqMinGap) {
b4197865 216 debugs(72, 2, "peerDigestCheck: " << pd->host <<
bf8fe701 217 ", avoiding close peer requests (" <<
218 (int) (req_time - pd->times.received) << " < " <<
219 (int) PeerDigestReqMinGap << " secs).");
220
62e76326 221 req_time = pd->times.received + PeerDigestReqMinGap;
bd890734 222 }
62e76326 223
e13ee7ad 224 /* global limit */
225 if (req_time - pd_last_req_time < GlobDigestReqMinGap) {
b4197865 226 debugs(72, 2, "peerDigestCheck: " << pd->host <<
bf8fe701 227 ", avoiding close requests (" <<
228 (int) (req_time - pd_last_req_time) << " < " <<
229 (int) GlobDigestReqMinGap << " secs).");
230
62e76326 231 req_time = pd_last_req_time + GlobDigestReqMinGap;
9b7de833 232 }
62e76326 233
e13ee7ad 234 if (req_time <= squid_curtime)
f53969cc 235 peerDigestRequest(pd); /* will set pd->flags.requested */
e13ee7ad 236 else
62e76326 237 peerDigestSetCheck(pd, req_time - squid_curtime);
9b7de833 238}
239
e13ee7ad 240/* ask store for a digest */
9b7de833 241static void
e13ee7ad 242peerDigestRequest(PeerDigest * pd)
9b7de833 243{
0f783794 244 const auto p = pd->peer.get(); // TODO: Replace with a reference.
9b7de833 245 StoreEntry *e, *old_e;
aee3523a 246 char *url = nullptr;
190154cf 247 HttpRequest *req;
528b2c61 248 StoreIOBuffer tempBuffer;
e13ee7ad 249
aee3523a 250 pd->req_result = nullptr;
be4d35dc 251 pd->flags.requested = true;
e13ee7ad 252
9b7de833 253 /* compute future request components */
62e76326 254
7e3ce7b9 255 if (p->digest_url)
62e76326 256 url = xstrdup(p->digest_url);
7e3ce7b9 257 else
c002f0e7 258 url = xstrdup(internalRemoteUri(p->secure.encryptTransport, p->host, p->http_port, "/squid-internal-periodic/", SBuf(StoreDigestFileName)));
4310f8b0 259 debugs(72, 2, url);
7e3ce7b9 260
ad05b958 261 const auto mx = MasterXaction::MakePortless<XactionInitiator::initCacheDigest>();
6c880a16 262 req = HttpRequest::FromUrlXXX(url, mx);
62e76326 263
e13ee7ad 264 assert(req);
62e76326 265
9b7de833 266 /* add custom headers */
2246b732 267 assert(!req->header.len);
62e76326 268
789217a2 269 req->header.putStr(Http::HdrType::ACCEPT, StoreDigestMimeStr);
62e76326 270
789217a2 271 req->header.putStr(Http::HdrType::ACCEPT, "text/html");
62e76326 272
89000349
AJ
273 if (p->login &&
274 p->login[0] != '*' &&
b552ea1f
A
275 strcmp(p->login, "PASS") != 0 &&
276 strcmp(p->login, "PASSTHRU") != 0 &&
98ace3e4 277 strncmp(p->login, "NEGOTIATE",9) != 0 &&
89000349 278 strcmp(p->login, "PROXYPASS") != 0) {
c486d50a 279 req->url.userInfo(SBuf(p->login)); // XXX: performance regression make peer login SBuf as well.
89000349 280 }
9b7de833 281 /* create fetch state structure */
022099cb 282 DigestFetchState *fetch = new DigestFetchState(pd, req);
e13ee7ad 283
284 /* update timestamps */
e13ee7ad 285 pd->times.requested = squid_curtime;
286 pd_last_req_time = squid_curtime;
aeeff7fd 287 req->flags.cachable.support(); // prevent RELEASE_REQUEST in storeCreateEntry()
62e76326 288
4310f8b0 289 /* the rest is based on clientReplyContext::processExpired() */
e857372a 290 req->flags.refresh = true;
62e76326 291
4310f8b0 292 old_e = fetch->old_entry = storeGetPublicByRequest(req);
62e76326 293
d2a6dcba 294 // XXX: Missing a hittingRequiresCollapsing() && startCollapsingOn() check.
9b7de833 295 if (old_e) {
4310f8b0 296 debugs(72, 5, "found old " << *old_e);
34266cde 297
acc5dc4c 298 old_e->lock("peerDigestRequest");
dba7b575 299 old_e->ensureMemObject(url, url, req->method);
34266cde 300
62e76326 301 fetch->old_sc = storeClientListAdd(old_e, fetch);
9b7de833 302 }
62e76326 303
9b7de833 304 e = fetch->entry = storeCreateEntry(url, url, req->flags, req->method);
4310f8b0 305 debugs(72, 5, "created " << *e);
e13ee7ad 306 assert(EBIT_TEST(e->flags, KEY_PRIVATE));
06d2839d 307 fetch->sc = storeClientListAdd(e, fetch);
9b7de833 308 /* set lastmod to trigger IMS request if possible */
62e76326 309
122a6e3c
AR
310 // TODO: Also check for fetch->pd->cd presence as a precondition for sending
311 // IMS requests because peerDigestFetchReply() does not accept 304 responses
312 // without an in-memory cache digest.
9b7de833 313 if (old_e)
438b41ba 314 e->lastModified(old_e->lastModified());
e13ee7ad 315
9b7de833 316 /* push towards peer cache */
e83cc785 317 FwdState::fwdStart(Comm::ConnectionPointer(), e, req);
62e76326 318
598465f1 319 tempBuffer.offset = 0;
62e76326 320
f95db407 321 tempBuffer.length = SM_PAGE_SIZE;
62e76326 322
598465f1 323 tempBuffer.data = fetch->buf;
62e76326 324
598465f1 325 storeClientCopy(fetch->sc, e, tempBuffer,
62e76326 326 peerDigestHandleReply, fetch);
7e928efc
AJ
327
328 safe_free(url);
9b7de833 329}
330
add2192d 331/* Handle the data copying .. */
332
333/*
334 * This routine handles the copy data and then redirects the
335 * copy to a bunch of subfunctions depending upon the copy state.
336 * It also tracks the buffer offset and "seen", since I'm actually
337 * not interested in rewriting everything to suit my little idea.
338 */
9b7de833 339static void
2324cda2 340peerDigestHandleReply(void *data, StoreIOBuffer receivedData)
add2192d 341{
e6ccf245 342 DigestFetchState *fetch = (DigestFetchState *)data;
add2192d 343 int retsize = -1;
344 digest_read_state_t prevstate;
345 int newsize;
346
122a6e3c
AR
347 if (receivedData.flags.error) {
348 peerDigestFetchAbort(fetch, fetch->buf, "failure loading digest reply from Store");
349 return;
350 }
351
2324cda2 352 assert(fetch->pd && receivedData.data);
353 /* The existing code assumes that the received pointer is
598465f1 354 * where we asked the data to be put
355 */
2324cda2 356 assert(fetch->buf + fetch->bufofs == receivedData.data);
add2192d 357
358 /* Update the buffer size */
2324cda2 359 fetch->bufofs += receivedData.length;
add2192d 360
361 assert(fetch->bufofs <= SM_PAGE_SIZE);
362
363 /* If we've fetched enough, return */
62e76326 364
add2192d 365 if (peerDigestFetchedEnough(fetch, fetch->buf, fetch->bufofs, "peerDigestHandleReply"))
62e76326 366 return;
add2192d 367
368 /* Call the right function based on the state */
369 /* (Those functions will update the state if needed) */
fa80a8ef 370
e2848e94 371 /* Give us a temporary reference. Some of the calls we make may
372 * try to destroy the fetch structure, and we like to know if they
373 * do
bac6d4bd 374 */
a44986dc 375 CbcPointer<DigestFetchState> tmpLock = fetch;
add2192d 376
377 /* Repeat this loop until we're out of data OR the state changes */
378 /* (So keep going if the state has changed and we still have data */
379 do {
62e76326 380 prevstate = fetch->state;
381
382 switch (fetch->state) {
383
384 case DIGEST_READ_REPLY:
385 retsize = peerDigestFetchReply(fetch, fetch->buf, fetch->bufofs);
386 break;
387
62e76326 388 case DIGEST_READ_CBLOCK:
389 retsize = peerDigestSwapInCBlock(fetch, fetch->buf, fetch->bufofs);
390 break;
391
392 case DIGEST_READ_MASK:
393 retsize = peerDigestSwapInMask(fetch, fetch->buf, fetch->bufofs);
394 break;
395
396 case DIGEST_READ_NONE:
397 break;
398
399 case DIGEST_READ_DONE:
a44986dc 400 return;
62e76326 401 break;
402
403 default:
404 fatal("Bad digest transfer mode!\n");
405 }
406
407 if (retsize < 0)
a44986dc 408 return;
62e76326 409
410 /*
411 * The returned size indicates how much of the buffer was read -
412 * so move the remainder of the buffer to the beginning
413 * and update the bufofs / bufsize
414 */
415 newsize = fetch->bufofs - retsize;
416
41d00cd3 417 memmove(fetch->buf, fetch->buf + retsize, fetch->bufofs - newsize);
62e76326 418
419 fetch->bufofs = newsize;
add2192d 420
e2848e94 421 } while (cbdataReferenceValid(fetch) && prevstate != fetch->state && fetch->bufofs > 0);
add2192d 422
05cb3e57
EB
423 // Check for EOF here, thus giving the parser one extra run. We could avoid this overhead by
424 // checking at the beginning of this function. However, in this case, we would have to require
425 // that the parser does not regard EOF as a special condition (it is true now but may change
426 // in the future).
122a6e3c 427 if (fetch->sc->atEof()) {
05cb3e57
EB
428 peerDigestFetchAbort(fetch, fetch->buf, "premature end of digest reply");
429 return;
430 }
431
add2192d 432 /* Update the copy offset */
2324cda2 433 fetch->offset += receivedData.length;
add2192d 434
435 /* Schedule another copy */
fa80a8ef 436 if (cbdataReferenceValid(fetch)) {
62e76326 437 StoreIOBuffer tempBuffer;
438 tempBuffer.offset = fetch->offset;
439 tempBuffer.length = SM_PAGE_SIZE - fetch->bufofs;
440 tempBuffer.data = fetch->buf + fetch->bufofs;
441 storeClientCopy(fetch->sc, fetch->entry, tempBuffer,
442 peerDigestHandleReply, fetch);
add2192d 443 }
add2192d 444}
445
122a6e3c 446/// handle HTTP response headers in the initial storeClientCopy() response
add2192d 447static int
9b7de833 448peerDigestFetchReply(void *data, char *buf, ssize_t size)
449{
e6ccf245 450 DigestFetchState *fetch = (DigestFetchState *)data;
e13ee7ad 451 PeerDigest *pd = fetch->pd;
452 assert(pd && buf);
9b7de833 453 assert(!fetch->offset);
e13ee7ad 454
add2192d 455 assert(fetch->state == DIGEST_READ_REPLY);
62e76326 456
9b7de833 457 if (peerDigestFetchedEnough(fetch, buf, size, "peerDigestFetchReply"))
62e76326 458 return -1;
e13ee7ad 459
122a6e3c 460 {
66d51f4f
AR
461 const auto &reply = fetch->entry->mem().freshestReply();
462 const auto status = reply.sline.status();
463 assert(status != Http::scNone);
b4197865 464 debugs(72, 3, "peerDigestFetchReply: " << pd->host << " status: " << status <<
66d51f4f
AR
465 ", expires: " << (long int) reply.expires << " (" << std::showpos <<
466 (int) (reply.expires - squid_curtime) << ")");
62e76326 467
468 /* this "if" is based on clientHandleIMSReply() */
469
955394ce 470 if (status == Http::scNotModified) {
62e76326 471 /* our old entry is fine */
472 assert(fetch->old_entry);
473
e2cc8c07 474 if (!fetch->old_entry->mem_obj->request)
b248c2a3 475 fetch->old_entry->mem_obj->request = fetch->entry->mem_obj->request;
62e76326 476
477 assert(fetch->old_entry->mem_obj->request);
478
abf396ec 479 Store::Root().updateOnNotModified(fetch->old_entry, *fetch->entry);
62e76326 480
481 /* get rid of 304 reply */
482 storeUnregister(fetch->sc, fetch->entry, fetch);
483
acc5dc4c 484 fetch->entry->unlock("peerDigestFetchReply 304");
62e76326 485
486 fetch->entry = fetch->old_entry;
487
aee3523a 488 fetch->old_entry = nullptr;
62e76326 489
490 /* preserve request -- we need its size to update counters */
491 /* requestUnlink(r); */
a1b1756c 492 /* fetch->entry->mem_obj->request = nullptr; */
122a6e3c
AR
493
494 if (!fetch->pd->cd) {
495 peerDigestFetchAbort(fetch, buf, "304 without the old in-memory digest");
496 return -1;
497 }
498
499 // stay with the old in-memory digest
500 peerDigestFetchStop(fetch, buf, "Not modified");
501 fetch->state = DIGEST_READ_DONE;
955394ce 502 } else if (status == Http::scOkay) {
62e76326 503 /* get rid of old entry if any */
504
505 if (fetch->old_entry) {
bf8fe701 506 debugs(72, 3, "peerDigestFetchReply: got new digest, releasing old one");
62e76326 507 storeUnregister(fetch->old_sc, fetch->old_entry, fetch);
d88e3c49 508 fetch->old_entry->releaseRequest();
acc5dc4c 509 fetch->old_entry->unlock("peerDigestFetchReply 200");
aee3523a 510 fetch->old_entry = nullptr;
62e76326 511 }
122a6e3c
AR
512
513 fetch->state = DIGEST_READ_CBLOCK;
62e76326 514 } else {
515 /* some kind of a bug */
66d51f4f 516 peerDigestFetchAbort(fetch, buf, reply.sline.reason());
f53969cc 517 return -1; /* XXX -1 will abort stuff in ReadReply! */
62e76326 518 }
9b7de833 519 }
62e76326 520
122a6e3c 521 return 0; // we consumed/used no buffered bytes
9b7de833 522}
523
1f140227 524int
9b7de833 525peerDigestSwapInCBlock(void *data, char *buf, ssize_t size)
526{
e6ccf245 527 DigestFetchState *fetch = (DigestFetchState *)data;
e13ee7ad 528
add2192d 529 assert(fetch->state == DIGEST_READ_CBLOCK);
62e76326 530
9b7de833 531 if (peerDigestFetchedEnough(fetch, buf, size, "peerDigestSwapInCBlock"))
62e76326 532 return -1;
e13ee7ad 533
e6ccf245 534 if (size >= (ssize_t)StoreDigestCBlockSize) {
62e76326 535 PeerDigest *pd = fetch->pd;
62e76326 536
66d51f4f
AR
537 assert(pd);
538 assert(fetch->entry->mem_obj);
62e76326 539
540 if (peerDigestSetCBlock(pd, buf)) {
541 /* XXX: soon we will have variable header size */
542 /* switch to CD buffer and fetch digest guts */
aee3523a 543 buf = nullptr;
62e76326 544 assert(pd->cd->mask);
545 fetch->state = DIGEST_READ_MASK;
546 return StoreDigestCBlockSize;
547 } else {
548 peerDigestFetchAbort(fetch, buf, "invalid digest cblock");
549 return -1;
550 }
cfd861ab 551 }
62e76326 552
cfd861ab
AJ
553 /* need more data, do we have space? */
554 if (size >= SM_PAGE_SIZE) {
555 peerDigestFetchAbort(fetch, buf, "digest cblock too big");
556 return -1;
9b7de833 557 }
62e76326 558
cfd861ab 559 return 0; /* We need more data */
9b7de833 560}
561
1f140227 562int
9b7de833 563peerDigestSwapInMask(void *data, char *buf, ssize_t size)
564{
e6ccf245 565 DigestFetchState *fetch = (DigestFetchState *)data;
e13ee7ad 566 PeerDigest *pd;
567
e13ee7ad 568 pd = fetch->pd;
569 assert(pd->cd && pd->cd->mask);
9d486b43 570
add2192d 571 /*
572 * NOTENOTENOTENOTENOTE: buf doesn't point to pd->cd->mask anymore!
573 * we need to do the copy ourselves!
574 */
41d00cd3 575 memcpy(pd->cd->mask + fetch->mask_offset, buf, size);
add2192d 576
577 /* NOTE! buf points to the middle of pd->cd->mask! */
62e76326 578
aee3523a 579 if (peerDigestFetchedEnough(fetch, nullptr, size, "peerDigestSwapInMask"))
62e76326 580 return -1;
add2192d 581
da407def 582 fetch->mask_offset += size;
62e76326 583
57d55dfa 584 if (fetch->mask_offset >= pd->cd->mask_size) {
e4049756 585 debugs(72, 2, "peerDigestSwapInMask: Done! Got " <<
586 fetch->mask_offset << ", expected " << pd->cd->mask_size);
57d55dfa 587 assert(fetch->mask_offset == pd->cd->mask_size);
aee3523a 588 assert(peerDigestFetchedEnough(fetch, nullptr, 0, "peerDigestSwapInMask"));
f53969cc 589 return -1; /* XXX! */
9b7de833 590 }
62e76326 591
cfd861ab
AJ
592 /* We always read everything, so return size */
593 return size;
9b7de833 594}
595
596static int
4b4cd312 597peerDigestFetchedEnough(DigestFetchState * fetch, char *buf, ssize_t size, const char *step_name)
9b7de833 598{
0e3b8c9f
AJ
599 static const SBuf hostUnknown("<unknown>"); // peer host (if any)
600 SBuf host = hostUnknown;
601
aee3523a
AR
602 PeerDigest *pd = nullptr;
603 const char *reason = nullptr; /* reason for completion */
604 const char *no_bug = nullptr; /* successful completion if set */
e2848e94 605 const int pdcb_valid = cbdataReferenceValid(fetch->pd);
0f783794 606 const int pcb_valid = pdcb_valid && fetch->pd->peer.valid();
e13ee7ad 607
608 /* test possible exiting conditions (the same for most steps!)
609 * cases marked with '?!' should not happen */
610
611 if (!reason) {
0f783794 612 if (!pdcb_valid || !(pd = fetch->pd))
62e76326 613 reason = "peer digest disappeared?!";
62e76326 614 else
0e3b8c9f 615 host = pd->host;
e13ee7ad 616 }
62e76326 617
e4049756 618 debugs(72, 6, step_name << ": peer " << host << ", offset: " <<
619 fetch->offset << " size: " << size << ".");
e13ee7ad 620
621 /* continue checking (with pd and host known and valid) */
62e76326 622
e13ee7ad 623 if (!reason) {
0f783794 624 if (!pd->peer)
62e76326 625 reason = "peer disappeared";
626 else if (size < 0)
627 reason = "swap failure";
628 else if (!fetch->entry)
629 reason = "swap aborted?!";
630 else if (EBIT_TEST(fetch->entry->flags, ENTRY_ABORTED))
631 reason = "swap aborted";
e13ee7ad 632 }
62e76326 633
e13ee7ad 634 /* continue checking (maybe-successful eof case) */
635 if (!reason && !size) {
62e76326 636 if (!pd->cd)
637 reason = "null digest?!";
831e953c 638 else if (fetch->mask_offset != pd->cd->mask_size)
62e76326 639 reason = "premature end of digest?!";
640 else if (!peerDigestUseful(pd))
641 reason = "useless digest";
642 else
643 reason = no_bug = "success";
e13ee7ad 644 }
62e76326 645
e13ee7ad 646 /* finish if we have a reason */
9b7de833 647 if (reason) {
62e76326 648 const int level = strstr(reason, "?!") ? 1 : 3;
bf8fe701 649 debugs(72, level, "" << step_name << ": peer " << host << ", exiting after '" << reason << "'");
62e76326 650 peerDigestReqFinish(fetch, buf,
651 1, pdcb_valid, pcb_valid, reason, !no_bug);
e13ee7ad 652 } else {
62e76326 653 /* paranoid check */
654 assert(pdcb_valid && pcb_valid);
e13ee7ad 655 }
62e76326 656
aee3523a 657 return reason != nullptr;
e13ee7ad 658}
659
551e60a9 660/* call this when all callback data is valid and fetch must be stopped but
661 * no error has occurred (e.g. we received 304 reply and reuse old digest) */
662static void
663peerDigestFetchStop(DigestFetchState * fetch, char *buf, const char *reason)
664{
665 assert(reason);
b4197865 666 debugs(72, 2, "peerDigestFetchStop: peer " << fetch->pd->host << ", reason: " << reason);
551e60a9 667 peerDigestReqFinish(fetch, buf, 1, 1, 1, reason, 0);
668}
669
e13ee7ad 670/* call this when all callback data is valid but something bad happened */
671static void
672peerDigestFetchAbort(DigestFetchState * fetch, char *buf, const char *reason)
673{
551e60a9 674 assert(reason);
b4197865 675 debugs(72, 2, "peerDigestFetchAbort: peer " << fetch->pd->host << ", reason: " << reason);
e13ee7ad 676 peerDigestReqFinish(fetch, buf, 1, 1, 1, reason, 1);
677}
678
679/* complete the digest transfer, update stats, unlock/release everything */
680static void
8b082ed9 681peerDigestReqFinish(DigestFetchState * fetch, char * /* buf */,
62e76326 682 int fcb_valid, int pdcb_valid, int pcb_valid,
683 const char *reason, int err)
e13ee7ad 684{
685 assert(reason);
686
687 /* must go before peerDigestPDFinish */
62e76326 688
e13ee7ad 689 if (pdcb_valid) {
be4d35dc 690 fetch->pd->flags.requested = false;
62e76326 691 fetch->pd->req_result = reason;
e13ee7ad 692 }
62e76326 693
e13ee7ad 694 /* schedule next check if peer is still out there */
695 if (pcb_valid) {
62e76326 696 PeerDigest *pd = fetch->pd;
697
698 if (err) {
699 pd->times.retry_delay = peerDigestIncDelay(pd);
700 peerDigestSetCheck(pd, pd->times.retry_delay);
701 } else {
702 pd->times.retry_delay = 0;
703 peerDigestSetCheck(pd, peerDigestNewDelay(fetch->entry));
704 }
9b7de833 705 }
62e76326 706
e13ee7ad 707 /* note: order is significant */
708 if (fcb_valid)
62e76326 709 peerDigestFetchSetStats(fetch);
710
e13ee7ad 711 if (pdcb_valid)
62e76326 712 peerDigestPDFinish(fetch, pcb_valid, err);
713
e13ee7ad 714 if (fcb_valid)
62e76326 715 peerDigestFetchFinish(fetch, err);
9b7de833 716}
717
e13ee7ad 718/* destroys digest if peer disappeared
719 * must be called only when fetch and pd cbdata are valid */
9b7de833 720static void
e13ee7ad 721peerDigestPDFinish(DigestFetchState * fetch, int pcb_valid, int err)
9b7de833 722{
e13ee7ad 723 PeerDigest *pd = fetch->pd;
0e3b8c9f 724 const auto host = pd->host;
e13ee7ad 725 pd->times.received = squid_curtime;
726 pd->times.req_delay = fetch->resp_time;
a0864754
AJ
727 pd->stats.sent.kbytes += fetch->sent.bytes;
728 pd->stats.recv.kbytes += fetch->recv.bytes;
e13ee7ad 729 pd->stats.sent.msgs += fetch->sent.msg;
730 pd->stats.recv.msgs += fetch->recv.msg;
731
732 if (err) {
e0236918 733 debugs(72, DBG_IMPORTANT, "" << (pcb_valid ? "temporary " : "" ) << "disabling (" << pd->req_result << ") digest from " << host);
62e76326 734
a901d0b4
AJ
735 delete pd->cd;
736 pd->cd = nullptr;
62e76326 737
be4d35dc 738 pd->flags.usable = false;
62e76326 739
740 if (!pcb_valid)
741 peerDigestNotePeerGone(pd);
e13ee7ad 742 } else {
62e76326 743 assert(pcb_valid);
744
be4d35dc 745 pd->flags.usable = true;
e13ee7ad 746
62e76326 747 /* XXX: ugly condition, but how? */
e13ee7ad 748
62e76326 749 if (fetch->entry->store_status == STORE_OK)
bf8fe701 750 debugs(72, 2, "re-used old digest from " << host);
62e76326 751 else
bf8fe701 752 debugs(72, 2, "received valid digest from " << host);
d1cdaa16 753 }
62e76326 754
fa80a8ef 755 cbdataReferenceDone(fetch->pd);
e13ee7ad 756}
757
758/* free fetch state structures
759 * must be called only when fetch cbdata is valid */
760static void
8b082ed9 761peerDigestFetchFinish(DigestFetchState * fetch, int /* err */)
e13ee7ad 762{
763 assert(fetch->entry && fetch->request);
764
9b7de833 765 if (fetch->old_entry) {
48e7baac 766 debugs(72, 3, "peerDigestFetchFinish: deleting old entry");
8121ba82 767 storeUnregister(fetch->old_sc, fetch->old_entry, fetch);
d88e3c49 768 fetch->old_entry->releaseRequest();
acc5dc4c 769 fetch->old_entry->unlock("peerDigestFetchFinish old");
aee3523a 770 fetch->old_entry = nullptr;
9b7de833 771 }
62e76326 772
1543ab6c 773 /* update global stats */
a0864754
AJ
774 statCounter.cd.kbytes_sent += fetch->sent.bytes;
775 statCounter.cd.kbytes_recv += fetch->recv.bytes;
83704487 776 statCounter.cd.msgs_sent += fetch->sent.msg;
777 statCounter.cd.msgs_recv += fetch->recv.msg;
e13ee7ad 778
a44986dc 779 delete fetch;
9b7de833 780}
781
e13ee7ad 782/* calculate fetch stats after completion */
783static void
784peerDigestFetchSetStats(DigestFetchState * fetch)
785{
786 MemObject *mem;
787 assert(fetch->entry && fetch->request);
788
789 mem = fetch->entry->mem_obj;
790 assert(mem);
791
792 /* XXX: outgoing numbers are not precise */
793 /* XXX: we must distinguish between 304 hits and misses here */
e11fe29a 794 fetch->sent.bytes = fetch->request->prefixLen();
528b2c61 795 /* XXX: this is slightly wrong: we don't KNOW that the entire memobject
796 * was fetched. We only know how big it is
797 */
798 fetch->recv.bytes = mem->size();
e13ee7ad 799 fetch->sent.msg = fetch->recv.msg = 1;
800 fetch->expires = fetch->entry->expires;
801 fetch->resp_time = squid_curtime - fetch->start_time;
802
bf8fe701 803 debugs(72, 3, "peerDigestFetchFinish: recv " << fetch->recv.bytes <<
804 " bytes in " << (int) fetch->resp_time << " secs");
805
806 debugs(72, 3, "peerDigestFetchFinish: expires: " <<
807 (long int) fetch->expires << " (" << std::showpos <<
808 (int) (fetch->expires - squid_curtime) << "), lmt: " <<
438b41ba
EB
809 std::noshowpos << (long int) fetch->entry->lastModified() << " (" <<
810 std::showpos << (int) (fetch->entry->lastModified() - squid_curtime) <<
bf8fe701 811 ")");
812
e13ee7ad 813}
814
9b7de833 815static int
8a6218c6 816peerDigestSetCBlock(PeerDigest * pd, const char *buf)
9b7de833 817{
818 StoreDigestCBlock cblock;
819 int freed_size = 0;
0e3b8c9f 820 const auto host = pd->host;
e13ee7ad 821
41d00cd3 822 memcpy(&cblock, buf, sizeof(cblock));
9b7de833 823 /* network -> host conversions */
824 cblock.ver.current = ntohs(cblock.ver.current);
825 cblock.ver.required = ntohs(cblock.ver.required);
826 cblock.capacity = ntohl(cblock.capacity);
827 cblock.count = ntohl(cblock.count);
828 cblock.del_count = ntohl(cblock.del_count);
829 cblock.mask_size = ntohl(cblock.mask_size);
bf8fe701 830 debugs(72, 2, "got digest cblock from " << host << "; ver: " <<
831 (int) cblock.ver.current << " (req: " << (int) cblock.ver.required <<
832 ")");
833
26ac0430
AJ
834 debugs(72, 2, "\t size: " <<
835 cblock.mask_size << " bytes, e-cnt: " <<
836 cblock.count << ", e-util: " <<
bf8fe701 837 xpercentInt(cblock.count, cblock.capacity) << "%" );
6106c6fc 838 /* check version requirements (both ways) */
62e76326 839
9b7de833 840 if (cblock.ver.required > CacheDigestVer.current) {
e0236918 841 debugs(72, DBG_IMPORTANT, "" << host << " digest requires version " <<
bf8fe701 842 cblock.ver.required << "; have: " << CacheDigestVer.current);
843
62e76326 844 return 0;
9b7de833 845 }
62e76326 846
6106c6fc 847 if (cblock.ver.current < CacheDigestVer.required) {
e0236918 848 debugs(72, DBG_IMPORTANT, "" << host << " digest is version " <<
bf8fe701 849 cblock.ver.current << "; we require: " <<
850 CacheDigestVer.required);
851
62e76326 852 return 0;
6106c6fc 853 }
62e76326 854
9b7de833 855 /* check consistency */
4b4cd312 856 if (cblock.ver.required > cblock.ver.current ||
62e76326 857 cblock.mask_size <= 0 || cblock.capacity <= 0 ||
858 cblock.bits_per_entry <= 0 || cblock.hash_func_count <= 0) {
fa84c01d 859 debugs(72, DBG_CRITICAL, "" << host << " digest cblock is corrupted.");
62e76326 860 return 0;
9b7de833 861 }
62e76326 862
d1cdaa16 863 /* check consistency further */
5bc5e81f 864 if ((size_t)cblock.mask_size != CacheDigest::CalcMaskSize(cblock.capacity, cblock.bits_per_entry)) {
fa84c01d 865 debugs(72, DBG_CRITICAL, host << " digest cblock is corrupted " <<
e4049756 866 "(mask size mismatch: " << cblock.mask_size << " ? " <<
5bc5e81f 867 CacheDigest::CalcMaskSize(cblock.capacity, cblock.bits_per_entry)
e4049756 868 << ").");
62e76326 869 return 0;
d1cdaa16 870 }
62e76326 871
d1cdaa16 872 /* there are some things we cannot do yet */
873 if (cblock.hash_func_count != CacheDigestHashFuncCount) {
d816f28d 874 debugs(72, DBG_CRITICAL, "ERROR: " << host << " digest: unsupported #hash functions: " <<
bf8fe701 875 cblock.hash_func_count << " ? " << CacheDigestHashFuncCount << ".");
62e76326 876 return 0;
d1cdaa16 877 }
62e76326 878
9b7de833 879 /*
880 * no cblock bugs below this point
881 */
882 /* check size changes */
e6ccf245 883 if (pd->cd && cblock.mask_size != (ssize_t)pd->cd->mask_size) {
e4049756 884 debugs(72, 2, host << " digest changed size: " << cblock.mask_size <<
885 " -> " << pd->cd->mask_size);
62e76326 886 freed_size = pd->cd->mask_size;
a901d0b4
AJ
887 delete pd->cd;
888 pd->cd = nullptr;
9b7de833 889 }
62e76326 890
e13ee7ad 891 if (!pd->cd) {
26ac0430
AJ
892 debugs(72, 2, "creating " << host << " digest; size: " << cblock.mask_size << " (" <<
893 std::showpos << (int) (cblock.mask_size - freed_size) << ") bytes");
e04fc9d3 894 pd->cd = new CacheDigest(cblock.capacity, cblock.bits_per_entry);
62e76326 895
896 if (cblock.mask_size >= freed_size)
a0864754 897 statCounter.cd.memory += (cblock.mask_size - freed_size);
9b7de833 898 }
62e76326 899
e13ee7ad 900 assert(pd->cd);
9b7de833 901 /* these assignments leave us in an inconsistent state until we finish reading the digest */
e13ee7ad 902 pd->cd->count = cblock.count;
903 pd->cd->del_count = cblock.del_count;
9b7de833 904 return 1;
905}
906
9b7de833 907static int
8a6218c6 908peerDigestUseful(const PeerDigest * pd)
9b7de833 909{
d1cdaa16 910 /* TODO: we should calculate the prob of a false hit instead of bit util */
6fbd1d41 911 const auto bit_util = pd->cd->usedMaskPercent();
62e76326 912
6fbd1d41 913 if (bit_util > 65.0) {
d816f28d 914 debugs(72, DBG_CRITICAL, "WARNING: " << pd->host <<
6fbd1d41 915 " peer digest has too many bits on (" << bit_util << "%).");
62e76326 916 return 0;
9b7de833 917 }
62e76326 918
9b7de833 919 return 1;
920}
7f6eb0fe 921
e13ee7ad 922static int
923saneDiff(time_t diff)
924{
3db6fb54 925 return abs((int) diff) > squid_curtime / 2 ? 0 : diff;
e13ee7ad 926}
927
928void
8a6218c6 929peerDigestStatsReport(const PeerDigest * pd, StoreEntry * e)
e13ee7ad 930{
931#define f2s(flag) (pd->flags.flag ? "yes" : "no")
38650cc8 932#define appendTime(tm) storeAppendPrintf(e, "%s\t %10ld\t %+d\t %+d\n", \
933 ""#tm, (long int)pd->times.tm, \
e13ee7ad 934 saneDiff(pd->times.tm - squid_curtime), \
935 saneDiff(pd->times.tm - pd->times.initialized))
936
e13ee7ad 937 assert(pd);
938
0e3b8c9f
AJ
939 auto host = pd->host;
940 storeAppendPrintf(e, "\npeer digest from " SQUIDSBUFPH "\n", SQUIDSBUFPRINT(host));
e13ee7ad 941
942 cacheDigestGuessStatsReport(&pd->stats.guess, e, host);
943
944 storeAppendPrintf(e, "\nevent\t timestamp\t secs from now\t secs from init\n");
945 appendTime(initialized);
946 appendTime(needed);
947 appendTime(requested);
948 appendTime(received);
949 appendTime(next_check);
950
951 storeAppendPrintf(e, "peer digest state:\n");
952 storeAppendPrintf(e, "\tneeded: %3s, usable: %3s, requested: %3s\n",
62e76326 953 f2s(needed), f2s(usable), f2s(requested));
e13ee7ad 954 storeAppendPrintf(e, "\n\tlast retry delay: %d secs\n",
62e76326 955 (int) pd->times.retry_delay);
e13ee7ad 956 storeAppendPrintf(e, "\tlast request response time: %d secs\n",
62e76326 957 (int) pd->times.req_delay);
e13ee7ad 958 storeAppendPrintf(e, "\tlast request result: %s\n",
62e76326 959 pd->req_result ? pd->req_result : "(none)");
e13ee7ad 960
961 storeAppendPrintf(e, "\npeer digest traffic:\n");
962 storeAppendPrintf(e, "\trequests sent: %d, volume: %d KB\n",
62e76326 963 pd->stats.sent.msgs, (int) pd->stats.sent.kbytes.kb);
e13ee7ad 964 storeAppendPrintf(e, "\treplies recv: %d, volume: %d KB\n",
62e76326 965 pd->stats.recv.msgs, (int) pd->stats.recv.kbytes.kb);
e13ee7ad 966
967 storeAppendPrintf(e, "\npeer digest structure:\n");
62e76326 968
e13ee7ad 969 if (pd->cd)
62e76326 970 cacheDigestReport(pd->cd, host, e);
e13ee7ad 971 else
62e76326 972 storeAppendPrintf(e, "\tno in-memory copy\n");
e13ee7ad 973}
974
7f6eb0fe 975#endif
f53969cc 976