peer_digest.cc
Go to the documentation of this file.
44static int peerDigestFetchedEnough(DigestFetchState * fetch, char *buf, ssize_t size, const char *step_name);
47static void peerDigestReqFinish(DigestFetchState * fetch, char *buf, int, int, int, const char *reason, int err);
216 debugs(72, 3, "peerDigestSetCheck: will check peer " << pd->host << " in " << delay << " secs");
306 url = xstrdup(internalRemoteUri(p->secure.encryptTransport, p->host, p->http_port, "/squid-internal-periodic/", SBuf(StoreDigestFileName)));
693peerDigestFetchedEnough(DigestFetchState * fetch, char *buf, ssize_t size, const char *step_name)
745 debugs(72, level, "" << step_name << ": peer " << host << ", exiting after '" << reason << "'");
829 debugs(72, DBG_IMPORTANT, "" << (pcb_valid ? "temporary " : "" ) << "disabling (" << pd->req_result << ") digest from " << host);
960 if ((size_t)cblock.mask_size != CacheDigest::CalcMaskSize(cblock.capacity, cblock.bits_per_entry)) {
void cacheDigestGuessStatsReport(const CacheDigestGuessStats *stats, StoreEntry *sentry, const SBuf &label)
Definition: CacheDigest.cc:209
void cacheDigestReport(CacheDigest *cd, const SBuf &label, StoreEntry *e)
Definition: CacheDigest.cc:245
Definition: CacheDigest.h:21
static uint32_t CalcMaskSize(uint64_t cap, uint8_t bpe)
Definition: CacheDigest.cc:273
Definition: CachePeer.h:31
Definition: CbcPointer.h:26
Definition: PeerDigest.h:45
struct DigestFetchState::@83 sent
struct DigestFetchState::@83 recv
DigestFetchState(PeerDigest *, HttpRequest *)
Definition: peer_digest.cc:88
static void fwdStart(const Comm::ConnectionPointer &client, StoreEntry *, HttpRequest *)
Same as Start() but no master xaction info (AccessLogEntry) available.
Definition: FwdState.cc:418
Definition: HttpRequest.h:49
static HttpRequest * FromUrlXXX(const char *url, const MasterXaction::Pointer &, const HttpRequestMethod &method=Http::METHOD_GET)
Definition: HttpRequest.cc:528
Http::StatusCode status() const
retrieve the status code for this status line
Definition: StatusLine.h:45
Definition: MemObject.h:33
Definition: PeerDigest.h:75
struct PeerDigest::@86::@87 recv
struct PeerDigest::@86 stats
struct PeerDigest::@85 times
struct PeerDigest::@86::@87 sent
struct PeerDigest::@84 flags
bool encryptTransport
whether transport encryption (TLS/SSL) is to be used on connections to the peer
Definition: PeerOptions.h:145
struct StatCounters::@129 cd
Definition: PeerDigest.h:27
Definition: Store.h:42
void ensureMemObject(const char *storeId, const char *logUri, const HttpRequestMethod &aMethod)
initialize mem_obj (if needed) and set URIs/method (if missing)
Definition: store.cc:1557
Definition: StoreIOBuffer.h:16
void updateOnNotModified(StoreEntry *old, StoreEntry &e304)
using a 304 response, update the old entry (metadata and reply headers)
Definition: Controller.cc:695
Definition: PeerDigest.h:18
void eventAdd(const char *name, EVH *func, void *arg, double when, int weight, bool cbdata)
Definition: event.cc:107
int CacheDigestHashFuncCount
const char * StoreDigestMimeStr
const char * StoreDigestFileName
char * internalRemoteUri(bool encrypt, const char *host, unsigned short port, const char *dir, const SBuf &name)
Definition: internal.cc:86
size_t headersEnd(const char *mime, size_t l, bool &containsObsFold)
Definition: mime_header.cc:17
#define appendTime(tm)
int peerDigestSwapInCBlock(void *, char *, ssize_t)
Definition: peer_digest.cc:621
static time_t peerDigestIncDelay(const PeerDigest *pd)
Definition: peer_digest.cc:189
static void peerDigestSetCheck(PeerDigest *pd, time_t delay)
Definition: peer_digest.cc:212
static void peerDigestPDFinish(DigestFetchState *fetch, int pcb_valid, int err)
Definition: peer_digest.cc:817
#define f2s(flag)
void peerDigestStatsReport(const PeerDigest *pd, StoreEntry *e)
Definition: peer_digest.cc:1025
static void peerDigestFetchSetStats(DigestFetchState *fetch)
Definition: peer_digest.cc:880
static int peerDigestFetchedEnough(DigestFetchState *fetch, char *buf, ssize_t size, const char *step_name)
Definition: peer_digest.cc:693
static void peerDigestFetchStop(DigestFetchState *fetch, char *buf, const char *reason)
Definition: peer_digest.cc:759
static int peerDigestSetCBlock(PeerDigest *pd, const char *buf)
Definition: peer_digest.cc:912
static void peerDigestReqFinish(DigestFetchState *fetch, char *buf, int, int, int, const char *reason, int err)
Definition: peer_digest.cc:777
static int peerDigestFetchReply(void *, char *, ssize_t)
Definition: peer_digest.cc:498
int peerDigestSwapInHeaders(void *, char *, ssize_t)
Definition: peer_digest.cc:582
static void peerDigestFetchAbort(DigestFetchState *fetch, char *buf, const char *reason)
Definition: peer_digest.cc:768
static time_t peerDigestNewDelay(const StoreEntry *e)
Definition: peer_digest.cc:200
static void peerDigestFetchFinish(DigestFetchState *fetch, int err)
Definition: peer_digest.cc:857
StoreEntry * storeGetPublicByRequest(HttpRequest *req, const KeyScope keyScope)
Definition: store.cc:490
StoreEntry * storeCreateEntry(const char *url, const char *logUrl, const RequestFlags &flags, const HttpRequestMethod &method)
Definition: store.cc:733
int storeUnregister(store_client *sc, StoreEntry *e, void *data)
Definition: store_client.cc:658
void storeClientCopy(store_client *sc, StoreEntry *e, StoreIOBuffer copyInto, STCB *callback, void *data)
Definition: store_client.cc:241
store_client * storeClientListAdd(StoreEntry *e, void *data)
Definition: store_client.cc:121