peer_digest.cc
Go to the documentation of this file.
44 static int peerDigestFetchedEnough(DigestFetchState * fetch, char *buf, ssize_t size, const char *step_name);
47 static 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)));
693 peerDigestFetchedEnough(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)) {
static void peerDigestFetchAbort(DigestFetchState *fetch, char *buf, const char *reason)
Definition: peer_digest.cc:768
struct PeerDigest::@89::@90 sent
static int peerDigestFetchReply(void *, char *, ssize_t)
Definition: peer_digest.cc:498
int peerDigestSwapInHeaders(void *, char *, ssize_t)
Definition: peer_digest.cc:582
struct PeerDigest::@89 stats
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:1567
#define appendTime(tm)
struct StatCounters::@133 cd
struct PeerDigest::@89::@90 recv
Definition: CachePeer.h:28
Definition: PeerDigest.h:45
Definition: CbcPointer.h:26
void cacheDigestGuessStatsReport(const CacheDigestGuessStats *stats, StoreEntry *sentry, const SBuf &label)
Definition: CacheDigest.cc:209
static void peerDigestFetchSetStats(DigestFetchState *fetch)
Definition: peer_digest.cc:880
static int peerDigestSetCBlock(PeerDigest *pd, const char *buf)
Definition: peer_digest.cc:912
Definition: CacheDigest.h:21
Definition: PeerDigest.h:27
StoreEntry * storeGetPublicByRequest(HttpRequest *req, const KeyScope keyScope)
Definition: store.cc:491
void peerDigestStatsReport(const PeerDigest *pd, StoreEntry *e)
Definition: peer_digest.cc:1025
Definition: HttpRequest.h:49
const char * StoreDigestFileName
char * internalRemoteUri(bool encrypt, const char *host, unsigned short port, const char *dir, const SBuf &name)
Definition: internal.cc:86
Definition: StoreIOBuffer.h:16
void cacheDigestReport(CacheDigest *cd, const SBuf &label, StoreEntry *e)
Definition: CacheDigest.cc:245
static int peerDigestFetchedEnough(DigestFetchState *fetch, char *buf, ssize_t size, const char *step_name)
Definition: peer_digest.cc:693
Http::StatusCode status() const
retrieve the status code for this status line
Definition: StatusLine.h:45
static void peerDigestFetchStop(DigestFetchState *fetch, char *buf, const char *reason)
Definition: peer_digest.cc:759
static void peerDigestFetchFinish(DigestFetchState *fetch, int err)
Definition: peer_digest.cc:857
struct PeerDigest::@87 flags
static uint32_t CalcMaskSize(uint64_t cap, uint8_t bpe)
Definition: CacheDigest.cc:273
const char * StoreDigestMimeStr
static time_t peerDigestIncDelay(const PeerDigest *pd)
Definition: peer_digest.cc:189
static void peerDigestReqFinish(DigestFetchState *fetch, char *buf, int, int, int, const char *reason, int err)
Definition: peer_digest.cc:777
static void peerDigestPDFinish(DigestFetchState *fetch, int pcb_valid, int err)
Definition: peer_digest.cc:817
int peerDigestSwapInCBlock(void *, char *, ssize_t)
Definition: peer_digest.cc:621
Definition: RefCount.h:27
StoreEntry * storeCreateEntry(const char *url, const char *logUrl, const RequestFlags &flags, const HttpRequestMethod &method)
Definition: store.cc:734
#define f2s(flag)
struct DigestFetchState::@86 sent
Definition: MemObject.h:33
static void peerDigestSetCheck(PeerDigest *pd, time_t delay)
Definition: peer_digest.cc:212
Definition: Store.h:42
void updateOnNotModified(StoreEntry *old, StoreEntry &e304)
using a 304 response, update the old entry (metadata and reply headers)
Definition: Controller.cc:721
static HttpRequest * FromUrlXXX(const char *url, const MasterXaction::Pointer &, const HttpRequestMethod &method=Http::METHOD_GET)
Definition: HttpRequest.cc:529
struct PeerDigest::@88 times
DigestFetchState(PeerDigest *, HttpRequest *)
Definition: peer_digest.cc:88
static time_t peerDigestNewDelay(const StoreEntry *e)
Definition: peer_digest.cc:200
static void fwdStart(const Comm::ConnectionPointer &client, StoreEntry *, HttpRequest *)
Same as Start() but no master xaction info (AccessLogEntry) available.
Definition: FwdState.cc:438
bool encryptTransport
whether transport encryption (TLS/SSL) is to be used on connections to the peer
Definition: PeerOptions.h:145
Definition: PeerDigest.h:18
int storeUnregister(store_client *sc, StoreEntry *e, void *data)
Definition: store_client.cc:671
size_t headersEnd(const char *mime, size_t l, bool &containsObsFold)
Definition: mime_header.cc:17
void storeClientCopy(store_client *sc, StoreEntry *e, StoreIOBuffer copyInto, STCB *callback, void *data)
Definition: store_client.cc:216
int CacheDigestHashFuncCount
Definition: PeerDigest.h:75
void eventAdd(const char *name, EVH *func, void *arg, double when, int weight, bool cbdata)
Definition: event.cc:107
store_client * storeClientListAdd(StoreEntry *e, void *data)
Definition: store_client.cc:128
struct DigestFetchState::@86 recv