store_client.cc
Go to the documentation of this file.
529 if (!entry->mem_obj->adjustableBaseReply().parseCharBuf(copyInto.data, headersEnd(copyInto.data, len))) {
534 if (len > 0 && rep && entry->mem_obj->inmem_lo == 0 && entry->objectLen() <= (int64_t)Config.Store.maxInMemObjSize && Config.onoff.memory_cache_disk) {
583 _callback.notifier = asyncCall(90, 4, "store_client::FinishCallback", cbdataDialer(store_client::FinishCallback, this));
622 debugs(90, DBG_IMPORTANT, "ERROR: Failed to unpack Store entry metadata: " << CurrentException);
678 debugs(90, 3, "storeUnregister: Consistency failure - store client being unregistered is not in the mem object's list for '" << e->getMD5Text() << "'");
867 debugs(90, 3, "quick-abort? YES bad content length (" << curlen << " of " << expectlen << " bytes received)");
RefCount< AsyncCallT< Dialer > > asyncCall(int aDebugSection, int aDebugLevel, const char *aName, const Dialer &aDialer)
Definition: AsyncCall.h:155
UnaryCbdataDialer< Argument1 > cbdataDialer(typename UnaryCbdataDialer< Argument1 >::Handler *handler, Argument1 *arg1)
Definition: AsyncCbdataCalls.h:40
int storeClientIsThisAClient(store_client *sc, void *someClient)
std::ostream & CurrentException(std::ostream &os)
prints active (i.e., thrown but not yet handled) exception
Definition: TextException.cc:69
void error(char *format,...)
Definition: FilledChecklist.h:33
virtual void fillChecklist(ACLFilledChecklist &) const =0
configure the given checklist (to reflect the current transaction state)
Definition: CodeContext.h:53
static void Reset()
forgets the current context, setting it to nil/unknown
Definition: CodeContext.cc:77
Definition: DelayId.h:22
bool parseCharBuf(const char *buf, ssize_t end)
Definition: Message.cc:140
Definition: MemBuf.h:24
Definition: MemObject.h:33
void appendf(const char *fmt,...) PRINTF_FORMAT_ARG2
Append operation with printf-style arguments.
Definition: Packable.h:61
struct SquidConfig::@107 accessList
struct SquidConfig::@106 onoff
struct SquidConfig::@92 quickAbort
acl_access * collapsedForwardingAccess
Definition: SquidConfig.h:404
struct SquidConfig::@104 Store
struct StatCounters::@132 swap
bool onCollapsingPath() const
whether Squid configuration allows collapsing for this transaction
Definition: store_client.cc:50
virtual LogTags * loggingTags() const =0
bool startCollapsingOn(const StoreEntry &, const bool doingRevalidation) const
Definition: store_client.cc:64
Definition: Store.h:42
bool swappedOut() const
whether the entire entry is now on disk (possibly marked for deletion)
Definition: Store.h:136
bool hasDisk(const sdirno dirn=-1, const sfileno filen=-1) const
Definition: store.cc:1897
bool swappingOut() const
whether we are in the process of writing this entry to disk
Definition: Store.h:134
bool hittingRequiresCollapsing() const
whether this entry can feed collapsed requests and only them
Definition: Store.h:216
Definition: StoreIOBuffer.h:16
struct StoreIOBuffer::@142 flags
void STRCB(void *their_data, const char *buf, ssize_t len, StoreIOState::Pointer self)
Definition: StoreIOState.h:29
Definition: cbdata.cc:38
Definition: dlink.h:15
Definition: StoreClient.h:57
void readHeader(const char *buf, ssize_t len)
Definition: store_client.cc:604
bool startSwapin()
opens the swapin "file" if possible; otherwise, fail()s and returns false
Definition: store_client.cc:411
bool moreToSend() const
Whether there is (or will be) more entry data for us.
Definition: store_client.cc:309
void noteNews()
if necessary and possible, informs the Store reader about copy() result
Definition: store_client.cc:564
void copy(StoreEntry *, StoreIOBuffer, STCB *, void *)
Definition: store_client.cc:252
struct store_client::Callback _callback
void finishCallback()
finishes a copy()-STCB sequence by synchronously calling STCB
Definition: store_client.cc:165
static void FinishCallback(store_client *)
finishCallback() wrapper; TODO: Add NullaryMemFunT for non-jobs.
Definition: store_client.cc:158
struct store_client::@141 flags
void dumpStats(MemBuf *output, int clientNumber) const
Definition: store_client.cc:897
size_t headersEnd(const char *mime, size_t l, bool &containsObsFold)
Definition: mime_header.cc:17
void UnpackHitSwapMeta(char const *, ssize_t, StoreEntry &)
deserializes entry metadata from the given buffer into the cache hit entry
Definition: SwapMetaIn.cc:310
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
static void storeClientCopy2(StoreEntry *e, store_client *sc)
Definition: store_client.cc:337
store_client * storeClientListAdd(StoreEntry *e, void *data)
Definition: store_client.cc:121
static bool CheckQuickAbortIsReasonable(StoreEntry *entry)
Definition: store_client.cc:793
void storeRead(StoreIOState::Pointer sio, char *buf, size_t size, off_t offset, StoreIOState::STRCB *callback, void *callback_data)
Definition: store_io.cc:79
Definition: parse.c:104
Definition: StoreClient.h:157
AsyncCall::Pointer notifier
a scheduled asynchronous finishCallback() call (or nil)
Definition: StoreClient.h:172