Public Member Functions | Static Public Member Functions | Public Attributes | Static Public Attributes | Protected Types | Protected Member Functions | Private Member Functions | Private Attributes | Static Private Attributes | List of all members
CapturingStoreEntry Class Reference

#include <CapturingStoreEntry.h>

Inheritance diagram for CapturingStoreEntry:
Inheritance graph
[legend]
Collaboration diagram for CapturingStoreEntry:
Collaboration graph
[legend]

Public Member Functions

 CapturingStoreEntry ()
 
virtual void buffer ()
 
virtual void flush ()
 
virtual void append (char const *buf, int len)
 Appends a c-string to existing packed data. More...
 
bool checkDeferRead (int fd) const
 
const char * getMD5Text () const
 
MemObject & mem ()
 
const MemObject & mem () const
 
const HttpReply * hasFreshestReply () const
 
void write (StoreIOBuffer)
 
bool isEmpty () const
 
bool isAccepting () const
 
size_t bytesWanted (Range< size_t > const aRange, bool ignoreDelayPool=false) const
 
void lengthWentBad (const char *reason)
 flags [truncated or too big] entry with ENTRY_BAD_LENGTH and releases it More...
 
void complete ()
 
store_client_t storeClientType () const
 
const char * getSerialisedMetaData (size_t &length) const
 
void storeErrorResponse (HttpReply *reply)
 Store a prepared error response. MemObject locks the reply object. More...
 
void replaceHttpReply (const HttpReplyPointer &, const bool andStartWriting=true)
 
void startWriting ()
 
bool mayStartSwapOut ()
 whether we may start writing to disk (now or in the future) More...
 
void trimMemory (const bool preserveSwappable)
 
void memOutDecision (const bool willCacheInRam)
 
void swapOutDecision (const MemObject::SwapOut::Decision &decision)
 
void abort ()
 
bool makePublic (const KeyScope keyScope=ksDefault)
 
void makePrivate (const bool shareable)
 
void clearPrivate ()
 
bool setPublicKey (const KeyScope keyScope=ksDefault)
 
void clearPublicKeyScope ()
 
const cache_key * publicKey () const
 
void setPrivateKey (const bool shareable, const bool permanent)
 
void expireNow ()
 
void releaseRequest (const bool shareable=false)
 
void negativeCache ()
 
bool cacheNegatively ()
 
void invokeHandlers ()
 
void cacheInMemory ()
 start or continue storing in memory cache More...
 
void swapOut ()
 
bool swappingOut () const
 whether we are in the process of writing this entry to disk More...
 
bool swappedOut () const
 whether the entire entry is now on disk (possibly marked for deletion) More...
 
bool swapoutFailed () const
 whether we failed to write this entry to disk More...
 
void swapOutFileClose (int how)
 
const char * url () const
 
bool checkCachable ()
 
int checkNegativeHit () const
 
int locked () const
 
int validToSend () const
 
bool memoryCachable ()
 checkCachable() and can be cached in memory More...
 
void createMemObject ()
 
void createMemObject (const char *storeId, const char *logUri, const HttpRequestMethod &aMethod)
 initialize mem_obj with URIs/method; assert if mem_obj already exists More...
 
void ensureMemObject (const char *storeId, const char *logUri, const HttpRequestMethod &aMethod)
 initialize mem_obj (if needed) and set URIs/method (if missing) More...
 
void dump (int debug_lvl) const
 
void hashDelete ()
 
void hashInsert (const cache_key *)
 
void registerAbortCallback (const AsyncCall::Pointer &)
 notify the StoreEntry writer of a 3rd-party initiated StoreEntry abort More...
 
void reset ()
 
void setMemStatus (mem_status_t)
 
bool timestampsSet ()
 
void unregisterAbortCallback (const char *reason)
 
void destroyMemObject ()
 
int checkTooSmall ()
 
void delayAwareRead (const Comm::ConnectionPointer &conn, char *buf, int len, AsyncCall::Pointer callback)
 
void setNoDelay (bool const)
 
void lastModified (const time_t when)
 
time_t lastModified () const
 
const char * describeTimestamps () const
 
bool modifiedSince (const time_t ims, const int imslen=-1) const
 
bool hasIfMatchEtag (const HttpRequest &request) const
 has ETag matching at least one of the If-Match etags More...
 
bool hasIfNoneMatchEtag (const HttpRequest &request) const
 has ETag matching at least one of the If-None-Match etags More...
 
bool hasEtag (ETag &etag) const
 whether this entry has an ETag; if yes, puts ETag value into parameter More...
 
bool updateOnNotModified (const StoreEntry &e304)
 
Store::Disk & disk () const
 the disk this entry is [being] cached on; asserts for entries w/o a disk More...
 
bool hasDisk (const sdirno dirn=-1, const sfileno filen=-1) const
 
void attachToDisk (const sdirno, const sfileno, const swap_status_t)
 
void detachFromDisk ()
 
bool hasTransients () const
 whether there is a corresponding locked transients table entry More...
 
bool hasMemStore () const
 whether there is a corresponding locked shared memory table entry More...
 
bool hittingRequiresCollapsing () const
 whether this entry can feed collapsed requests and only them More...
 
void setCollapsingRequirement (const bool required)
 allow or forbid collapsed requests feeding More...
 
void * operator new (size_t byteCount)
 
void operator delete (void *address)
 
int64_t objectLen () const
 
int64_t contentLen () const
 
void lock (const char *context)
 
int unlock (const char *context)
 
int locks () const
 returns a local concurrent use counter, for debugging More...
 
void touch ()
 update last reference timestamp and related Store metadata More...
 
void release (const bool shareable=false)
 
void abandon (const char *context)
 
bool mayStartHitting () const
 
void deferProducer (const AsyncCall::Pointer &producer)
 call back producer when more buffer space is available More...
 
void kickProducer ()
 calls back producer registered with deferProducer More...
 
virtual void vappendf (const char *, va_list)
 
void appendf (const char *fmt,...) PRINTF_FORMAT_ARG2
 Append operation with printf-style arguments. More...
 

Static Public Member Functions

static size_t inUseCount ()
 
static void getPublicByRequestMethod (StoreClient *aClient, HttpRequest *request, const HttpRequestMethod &method)
 
static void getPublicByRequest (StoreClient *aClient, HttpRequest *request)
 
static void getPublic (StoreClient *aClient, const char *uri, const HttpRequestMethod &method)
 

Public Attributes

String _appended_text
 
int _buffer_calls
 
int _flush_calls
 
MemObject * mem_obj
 
RemovalPolicyNode repl
 
time_t timestamp
 
time_t lastref
 
time_t expires
 
uint64_t swap_file_sz
 
uint16_t refcount
 
uint16_t flags
 
sfileno swap_filen:25
 unique ID inside a cache_dir for swapped out entries; -1 for others More...
 
sdirno swap_dirn:7
 
mem_status_t mem_status:3
 
ping_status_t ping_status:3
 
store_status_t store_status:3
 
swap_status_t swap_status:3
 
ESIElement::Pointer cachedESITree
 
void * key
 
hash_link * next
 

Static Public Attributes

static DeferredRead::DeferrableRead DeferReader
 

Protected Types

typedef Store::EntryGuard EntryGuard
 

Protected Member Functions

void transientsAbandonmentCheck ()
 
void checkDisk () const
 does nothing except throwing if disk-associated data members are inconsistent More...
 

Private Member Functions

 MEMPROXY_CLASS (CapturingStoreEntry)
 
void doAbandon (const char *context)
 
bool checkTooBig () const
 
void forcePublicKey (const cache_key *newkey)
 
StoreEntry * adjustVary ()
 
const cache_key * calcPublicKey (const KeyScope keyScope)
 
bool validLength () const
 
bool hasOneOfEtags (const String &reqETags, const bool allowWeakMatch) const
 whether at least one of the request ETags matches entity ETag More...
 

Private Attributes

time_t lastModified_
 received Last-Modified value or -1; use lastModified() More...
 
unsigned short lock_count
 
bool shareableWhenPrivate
 
AsyncCall::Pointer deferredProducer
 producer callback registered with deferProducer More...
 

Static Private Attributes

static MemAllocator * pool = NULL
 

Detailed Description

Definition at line 16 of file CapturingStoreEntry.h.

Member Typedef Documentation

◆ EntryGuard

typedef Store::EntryGuard StoreEntry::EntryGuard
protectedinherited

Definition at line 301 of file Store.h.

Constructor & Destructor Documentation

◆ CapturingStoreEntry()

CapturingStoreEntry::CapturingStoreEntry ( )
inline

Definition at line 21 of file CapturingStoreEntry.h.

Member Function Documentation

◆ abandon()

void StoreEntry::abandon ( const char *  context)
inlineinherited

One of the three methods to get rid of an unlocked StoreEntry object. May destroy this object if it is unlocked; does nothing otherwise. Unlike release(), may not trigger eviction of underlying store entries, but, unlike destroyStoreEntry(), does honor an earlier release request.

Definition at line 279 of file Store.h.

References StoreEntry::doAbandon(), and StoreEntry::locked().

Referenced by StoreEntry::unlock().

◆ abort()

void StoreEntry::abort ( )
inherited

Definition at line 1124 of file store.cc.

References MemObject::abortCallback, StatCounters::aborted_requests, assert, debugs, EBIT_CLR, EBIT_SET, ENTRY_ABORTED, ENTRY_FWD_HDR_WAIT, StoreEntry::flags, StoreEntry::getMD5Text(), StoreEntry::invokeHandlers(), StoreEntry::lock(), StoreEntry::mem_obj, StoreEntry::negativeCache(), NOT_IN_MEMORY, NULL, StoreEntry::releaseRequest(), ScheduleCallHere, StoreEntry::setMemStatus(), statCounter, STORE_OK, STORE_PENDING, StoreEntry::store_status, StoreEntry::swapOutFileClose(), StoreEntry::unlock(), and StoreIOState::writerGone.

Referenced by peerCountMcastPeersAbort(), storeUnregister(), StoreEntry::swapOut(), and Store::Controller::syncCollapsed().

◆ adjustVary()

StoreEntry * StoreEntry::adjustVary ( )
privateinherited

Updates mem_obj->request->vary_headers to reflect the current Vary. The vary_headers field is used to calculate the Vary marker key. Releases the old Vary marker with an outdated key (if any).

Returns
new (locked) Vary marker StoreEntry or, if none was needed, nil
Exceptions
std::exceptionon failures

Definition at line 709 of file store.cc.

References assert, StoreEntry::complete(), MemObject::freshestReply(), Http::HDR_X_ACCELERATOR_VARY, Http::Message::header, httpMakeVaryMark(), SBuf::isEmpty(), MemObject::logUri(), StoreEntry::makePublic(), StoreEntry::mem_obj, _request::method, MemObject::method, HttpHeader::putStr(), StoreEntry::replaceHttpReply(), MemObject::request, request(), Http::scOkay, HttpReply::setHeaders(), squid_curtime, StoreEntry::startWriting(), storeCreateEntry(), storeGetPublic(), MemObject::storeId(), TexcHere, StoreEntry::timestampsSet(), StoreEntry::unlock(), Http::VARY, and MemObject::vary_headers.

Referenced by StoreEntry::setPublicKey().

◆ append()

virtual void CapturingStoreEntry::append ( char const *  buf,
int  size 
)
inlinevirtual

Reimplemented from StoreEntry.

Definition at line 35 of file CapturingStoreEntry.h.

References _appended_text, String::append(), buf, and len.

◆ appendf()

void Packable::appendf ( const char *  fmt,
  ... 
)
inlineinherited

Definition at line 61 of file Packable.h.

References Packable::vappendf().

Referenced by Ftp::Server::acceptDataConnection(), aclParseAccessLine(), aclParseAclList(), Format::Format::assemble(), HttpStateData::buildRequestPrefix(), clientPackRangeHdr(), clientPackTermBound(), ErrorState::compileLegacyCode(), ErrorState::Dump(), dump_cachemgrpasswd(), Security::ServerOptions::dumpCfg(), Security::PeerOptions::dumpCfg(), store_client::dumpStats(), Adaptation::Icap::ModXact::encapsulateHead(), errorInitialize(), gopherSendRequest(), Ftp::Server::handleEpsvReply(), Ftp::Server::handlePasvReply(), helperDispatch(), httpHdrContRangePackInto(), httpHdrRangeRespSpecPackInto(), internalRemoteUri(), memBufReport(), munge_menu_line(), munge_other_line(), HttpRequest::pack(), Http::Stream::packChunk(), HttpRequest::packFirstLineInto(), HttpHdrRangeSpec::packInto(), Http::StatusLine::packInto(), HttpHdrScTarget::packInto(), HttpHdrCc::packInto(), helper::packStatsInto(), Acl::AllOf::parse(), Ftp::PrintReply(), Ftp::Client::sendEprt(), Ftp::Client::sendPassive(), Ident::Start(), MemObject::stat(), statStoreEntry(), BodyPipe::status(), wordlistCat(), Ftp::Server::writeCustomReply(), Ftp::Server::writeEarlyReply(), Ftp::Server::writeErrorReply(), and Http::Tunneler::writeRequest().

◆ attachToDisk()

void StoreEntry::attachToDisk ( const sdirno  dirn,
const sfileno  fno,
const swap_status_t  status 
)
inherited

Makes hasDisk(dirn, filn) true. The caller should have locked the corresponding disk store entry for reading or writing.

Definition at line 2001 of file store.cc.

References StoreEntry::checkDisk(), debugs, StoreEntry::getMD5Text(), StoreEntry::swap_dirn, StoreEntry::swap_filen, StoreEntry::swap_status, and swapStatusStr.

Referenced by Fs::Ufs::UFSSwapDir::addDiskRestore(), Rock::SwapDir::anchorEntry(), and storeSwapOutStart().

◆ buffer()

virtual void CapturingStoreEntry::buffer ( )
inlinevirtual

disable sending content to the clients.

This just sets DELAY_SENDING.

Reimplemented from StoreEntry.

Definition at line 27 of file CapturingStoreEntry.h.

References _buffer_calls.

◆ bytesWanted()

size_t StoreEntry::bytesWanted ( Range< size_t > const  aRange,
bool  ignoreDelayPool = false 
) const
inherited

Definition at line 249 of file store.cc.

References Range< C, S >::end, StoreEntry::mem_obj, MemObject::mostBytesWanted(), NULL, and MemObject::readAheadPolicyCanRead().

Referenced by StoreEntry::checkDeferRead(), StoreEntry::delayAwareRead(), Client::handleMoreAdaptedBodyAvailable(), ClientHttpRequest::noteMoreBodyDataAvailable(), and HttpStateData::readReply().

◆ cacheInMemory()

void StoreEntry::cacheInMemory ( )
inherited

◆ cacheNegatively()

bool StoreEntry::cacheNegatively ( )
inherited

Definition at line 186 of file store.cc.

References StoreEntry::makePublic(), and StoreEntry::negativeCache().

Referenced by HttpStateData::haveParsedReplyHeaders().

◆ calcPublicKey()

const cache_key * StoreEntry::calcPublicKey ( const KeyScope  keyScope)
privateinherited

Calculates correct public key for feeding forcePublicKey(). Assumes adjustVary() has been called for this entry already.

Definition at line 696 of file store.cc.

References assert, RefCount< C >::getRaw(), StoreEntry::mem_obj, MemObject::method, MemObject::request, MemObject::storeId(), storeKeyPublic(), and storeKeyPublicByRequest().

Referenced by StoreEntry::clearPublicKeyScope(), and StoreEntry::setPublicKey().

◆ checkCachable()

bool StoreEntry::checkCachable ( )
inherited

Satisfies cachability requirements shared among disk and RAM caches. Encapsulates common checks of mayStartSwapOut() and memoryCachable(). TODO: Rename and make private so only those two methods can call this.

Definition at line 976 of file store.cc.

References StoreEntry::checkTooBig(), StoreEntry::checkTooSmall(), debugs, _store_check_cachable_hist::Default, EBIT_TEST, ENTRY_BAD_LENGTH, fdNFree(), StoreEntry::flags, StoreEntry::hasDisk(), KEY_PRIVATE, StoreEntry::mem_obj, MemObject::method, Http::METHOD_GET, _store_check_cachable_hist::missing_parts, _store_check_cachable_hist::no, _store_check_cachable_hist::non_get, _store_check_cachable_hist::not_entry_cachable, _store_check_cachable_hist::private_key, RELEASE_REQUEST, StoreEntry::releaseRequest(), RESERVED_FD, store_check_cachable_hist, STORE_OK, StoreEntry::store_status, storeTooManyDiskFilesOpen(), _store_check_cachable_hist::too_big, _store_check_cachable_hist::too_many_open_fds, _store_check_cachable_hist::too_many_open_files, _store_check_cachable_hist::too_small, _store_check_cachable_hist::wrong_content_length, and _store_check_cachable_hist::yes.

Referenced by StoreEntry::mayStartSwapOut(), StoreEntry::memoryCachable(), and storeSwapOutFileClosed().

◆ checkDeferRead()

bool StoreEntry::checkDeferRead ( int  fd) const
inherited

Definition at line 267 of file store.cc.

References StoreEntry::bytesWanted(), and INT_MAX.

Referenced by statObjects(), and StoreEntry::swapOut().

◆ checkDisk()

void StoreEntry::checkDisk ( ) const
protectedinherited

Definition at line 2023 of file store.cc.

References SquidConfig::cacheSwap, Config, CurrentException(), DBG_IMPORTANT, debugs, EBIT_TEST, StoreEntry::flags, Must, Store::DiskConfig::n_configured, RELEASE_REQUEST, StoreEntry::swap_dirn, StoreEntry::swap_filen, StoreEntry::swap_status, SWAPOUT_NONE, StoreEntry::swapoutFailed(), StoreEntry::swappedOut(), and StoreEntry::swappingOut().

Referenced by StoreEntry::attachToDisk(), and StoreEntry::hasDisk().

◆ checkNegativeHit()

int StoreEntry::checkNegativeHit ( ) const
inherited

Definition at line 1352 of file store.cc.

References EBIT_TEST, ENTRY_NEGCACHED, StoreEntry::expires, StoreEntry::flags, squid_curtime, STORE_OK, and StoreEntry::store_status.

Referenced by clientReplyContext::cacheHit().

◆ checkTooBig()

bool StoreEntry::checkTooBig ( ) const
privateinherited

Definition at line 965 of file store.cc.

References MemObject::baseReply(), Http::Message::content_length, MemObject::endOffset(), StoreEntry::mem_obj, and store_maxobjsize.

Referenced by StoreEntry::checkCachable().

◆ checkTooSmall()

int StoreEntry::checkTooSmall ( )
inherited

Definition at line 948 of file store.cc.

References MemObject::baseReply(), Config, Http::Message::content_length, EBIT_TEST, ENTRY_SPECIAL, StoreEntry::flags, StoreEntry::mem(), StoreEntry::mem_obj, SquidConfig::minObjectSize, MemObject::object_sz, SquidConfig::Store, STORE_OK, and StoreEntry::store_status.

Referenced by StoreEntry::checkCachable().

◆ clearPrivate()

void StoreEntry::clearPrivate ( )
inherited

A low-level method just resetting "private key" flags. To avoid key inconsistency please use forcePublicKey() or similar instead.

Definition at line 178 of file store.cc.

References assert, EBIT_CLR, EBIT_TEST, StoreEntry::flags, KEY_PRIVATE, RELEASE_REQUEST, and StoreEntry::shareableWhenPrivate.

Referenced by StoreEntry::forcePublicKey().

◆ clearPublicKeyScope()

void StoreEntry::clearPublicKeyScope ( )
inherited

Resets existing public key to a public key with default scope, releasing the old default-scope entry (if any). Does nothing if the existing public key already has default scope.

Definition at line 653 of file store.cc.

References StoreEntry::calcPublicKey(), EBIT_TEST, StoreEntry::flags, StoreEntry::forcePublicKey(), hash_link::key, KEY_PRIVATE, ksDefault, and storeKeyHashCmp.

Referenced by clientReplyContext::sendClientUpstreamResponse().

◆ complete()

void StoreEntry::complete ( )
inherited

Definition at line 1078 of file store.cc.

References assert, current_time, debugs, EBIT_CLR, EBIT_TEST, MemObject::endOffset(), ENTRY_ABORTED, ENTRY_BAD_LENGTH, ENTRY_FWD_HDR_WAIT, StoreEntry::flags, StoreEntry::getMD5Text(), HttpRequest::hier, StoreEntry::invokeHandlers(), StoreEntry::lengthWentBad(), StoreEntry::mem_obj, StoreEntry::mem_status, MemObject::nclients, NOT_IN_MEMORY, MemObject::object_sz, MemObject::request, HierarchyLogEntry::store_complete_stop, STORE_OK, STORE_PENDING, StoreEntry::store_status, and StoreEntry::validLength().

Referenced by testRock::addEntry(), StoreEntry::adjustVary(), FwdState::complete(), FwdState::completed(), MimeIcon::created(), ClientHttpRequest::endRequestSatisfaction(), Mgr::Action::fillEntry(), ClientHttpRequest::handleAdaptedHeader(), internalStart(), netdbBinaryExchange(), clientReplyContext::processMiss(), clientReplyContext::purgeDoPurgeHead(), clientReplyContext::sendNotModified(), CacheManager::start(), statObjects(), storeDigestRewriteFinish(), StoreEntry::storeErrorResponse(), testUfs::testUfsSearch(), clientReplyContext::traceReply(), and urnHandleReply().

◆ contentLen()

int64_t StoreEntry::contentLen ( ) const
inlineinherited

Definition at line 253 of file Store.h.

References MemObject::baseReply(), Http::Message::hdr_sz, StoreEntry::mem(), and StoreEntry::objectLen().

Referenced by ClientHttpRequest::logRequest(), and storeLog().

◆ createMemObject() [1/2]

void StoreEntry::createMemObject ( )
inherited

initialize mem_obj; assert if mem_obj already exists avoid this method in favor of createMemObject(trio)!

Definition at line 1631 of file store.cc.

References assert, and StoreEntry::mem_obj.

Referenced by Rock::SwapDir::get(), MemStore::get(), Transients::get(), storeCreatePureEntry(), testStoreController::testMaxSize(), testStoreHashIndex::testMaxSize(), testStoreHashIndex::testStats(), and testStoreController::testStats().

◆ createMemObject() [2/2]

void StoreEntry::createMemObject ( const char *  storeId,
const char *  logUri,
const HttpRequestMethod &  aMethod 
)
inherited

Definition at line 1638 of file store.cc.

References assert, StoreEntry::ensureMemObject(), and StoreEntry::mem_obj.

◆ deferProducer()

void StoreEntry::deferProducer ( const AsyncCall::Pointer &  producer)
inherited

Definition at line 378 of file store.cc.

References debugs, and StoreEntry::deferredProducer.

Referenced by Client::handleMoreAdaptedBodyAvailable(), and ClientHttpRequest::noteMoreBodyDataAvailable().

◆ delayAwareRead()

void StoreEntry::delayAwareRead ( const Comm::ConnectionPointer &  conn,
char *  buf,
int  len,
AsyncCall::Pointer  callback 
)
inherited

Definition at line 223 of file store.cc.

References assert, buf, StoreEntry::bytesWanted(), callback, comm_read(), conn, debugs, StoreEntry::DeferReader, MemObject::delayRead(), fd_table, len, and StoreEntry::mem_obj.

Referenced by gopherSendComplete().

◆ describeTimestamps()

const char * StoreEntry::describeTimestamps ( ) const
inherited
Returns
a formatted string with entry's timestamps

Definition at line 2062 of file store.cc.

References buf, StoreEntry::expires, StoreEntry::lastModified_, StoreEntry::lastref, LOCAL_ARRAY, and StoreEntry::timestamp.

Referenced by statStoreEntry(), and StoreEntry::timestampsSet().

◆ destroyMemObject()

void StoreEntry::destroyMemObject ( )
inherited

Definition at line 398 of file store.cc.

References debugs, StoreEntry::hasMemStore(), StoreEntry::hasTransients(), StoreEntry::mem_obj, Store::Controller::memoryDisconnect(), NOT_IN_MEMORY, NULL, Store::Root(), StoreEntry::setMemStatus(), shutting_down, and Store::Controller::transientsDisconnect().

Referenced by destroyStoreEntry(), MemStore::evictCached(), and Store::Controller::memoryEvictCached().

◆ detachFromDisk()

void StoreEntry::detachFromDisk ( )
inherited

Makes hasDisk() false. The caller should have unlocked the corresponding disk store entry.

Definition at line 2015 of file store.cc.

References StoreEntry::swap_dirn, StoreEntry::swap_filen, StoreEntry::swap_status, and SWAPOUT_NONE.

Referenced by Rock::SwapDir::disconnect(), and Fs::Ufs::UFSSwapDir::evictCached().

◆ disk()

Store::Disk & StoreEntry::disk ( ) const
inherited

Definition at line 1981 of file store.cc.

References assert, StoreEntry::hasDisk(), INDEXSD, and StoreEntry::swap_dirn.

Referenced by Store::Disks::dereference(), destroyStoreEntry(), Store::Disks::evictCached(), Store::Disks::reference(), storeOpen(), storeSwapOutFileClosed(), and Store::Disks::updateHeaders().

◆ doAbandon()

void StoreEntry::doAbandon ( const char *  context)
privateinherited

keep the unlocked StoreEntry object in the local store_table (if needed) or delete it (otherwise)

Definition at line 500 of file store.cc.

References assert, DBG_IMPORTANT, debugs, EBIT_TEST, StoreEntry::flags, Store::Controller::handleIdleEntry(), KEY_PRIVATE, StoreEntry::locked(), StoreEntry::release(), RELEASE_REQUEST, Store::Root(), STORE_PENDING, StoreEntry::store_status, and storePendingNClients().

Referenced by StoreEntry::abandon().

◆ dump()

void StoreEntry::dump ( int  debug_lvl) const
inherited

Definition at line 1555 of file store.cc.

References debugs, StoreEntry::expires, StoreEntry::getMD5Text(), StoreEntry::lastModified_, StoreEntry::lastref, StoreEntry::lock_count, StoreEntry::mem_obj, StoreEntry::mem_status, hash_link::next, StoreEntry::ping_status, StoreEntry::refcount, StoreEntry::store_status, storeEntryFlags(), StoreEntry::swap_dirn, StoreEntry::swap_file_sz, StoreEntry::swap_filen, StoreEntry::swap_status, and StoreEntry::timestamp.

Referenced by clientReplyContext::buildReplyHeader(), Fs::Ufs::UFSSwapDir::dumpEntry(), and clientReplyContext::processMiss().

◆ ensureMemObject()

void StoreEntry::ensureMemObject ( const char *  storeId,
const char *  logUri,
const HttpRequestMethod &  aMethod 
)
inherited

Definition at line 1645 of file store.cc.

References StoreEntry::mem_obj, and MemObject::setUris().

Referenced by StoreEntry::createMemObject(), clientReplyContext::doGetMoreData(), peerDigestRequest(), clientReplyContext::processExpired(), and clientReplyContext::purgeFoundObject().

◆ expireNow()

void StoreEntry::expireNow ( )
inherited

Definition at line 817 of file store.cc.

References debugs, StoreEntry::expires, StoreEntry::getMD5Text(), and squid_curtime.

◆ flush()

virtual void CapturingStoreEntry::flush ( )
inlinevirtual

flush any buffered content.

This just clears DELAY_SENDING and Invokes the handlers to begin sending anything that may be buffered.

Reimplemented from StoreEntry.

Definition at line 31 of file CapturingStoreEntry.h.

References _flush_calls.

◆ forcePublicKey()

void StoreEntry::forcePublicKey ( const cache_key *  newkey)
privateinherited

Unconditionally sets public key for this store entry. Releases the old entry with the same public key (if any).

Definition at line 670 of file store.cc.

References assert, StoreEntry::clearPrivate(), debugs, StoreEntry::hasDisk(), hash_lookup(), StoreEntry::hashDelete(), StoreEntry::hashInsert(), MemObject::hasUris(), hash_link::key, StoreEntry::mem_obj, store_table, storeDirSwapLog(), storeKeyText(), and SWAP_LOG_ADD.

Referenced by StoreEntry::clearPublicKeyScope(), and StoreEntry::setPublicKey().

◆ getMD5Text()

const char * StoreEntry::getMD5Text ( ) const
inherited

Definition at line 205 of file store.cc.

References hash_link::key, and storeKeyText().

Referenced by StoreEntry::abort(), StoreEntry::attachToDisk(), StoreMetaMD5::checkConsistency(), StoreEntry::complete(), store_client::copy(), StoreEntry::dump(), StoreEntry::expireNow(), HeapKeyGen_StoreEntry_GDSF(), HeapKeyGen_StoreEntry_LFUDA(), HeapKeyGen_StoreEntry_LRU(), StoreEntry::invokeHandlers(), StoreEntry::lock(), neighborsUdpPing(), HttpStateData::processReplyHeader(), ClientHttpRequest::rangeBoundaryStr(), StoreEntry::release(), StoreEntry::setMemStatus(), statClientRequests(), statStoreEntry(), storeClientCopy2(), storeDigestAdd(), storeDigestAddable(), storeDigestDel(), storeDigestRewriteStart(), storeDirSwapLog(), storeLog(), storeSwapInStart(), storeUnregister(), StoreEntry::swapOutFileClose(), StoreEntry::unlock(), StoreEntry::validLength(), and StoreEntry::write().

◆ getPublic()

void StoreEntry::getPublic ( StoreClient *  aClient,
const char *  uri,
const HttpRequestMethod &  method 
)
staticinherited

Definition at line 535 of file store.cc.

References assert, StoreClient::created(), method, and storeGetPublic().

Referenced by doV2Query(), doV3Query(), MimeIcon::load(), and UrnState::start().

◆ getPublicByRequest()

void StoreEntry::getPublicByRequest ( StoreClient *  aClient,
HttpRequest *  request 
)
staticinherited

Definition at line 528 of file store.cc.

References assert, StoreClient::created(), request(), and storeGetPublicByRequest().

Referenced by htcpSpecifier::checkHit(), and clientReplyContext::identifyStoreObject().

◆ getPublicByRequestMethod()

void StoreEntry::getPublicByRequestMethod ( StoreClient *  aClient,
HttpRequest *  request,
const HttpRequestMethod &  method 
)
staticinherited

Definition at line 521 of file store.cc.

References assert, StoreClient::created(), method, request(), and storeGetPublicByRequestMethod().

Referenced by clientReplyContext::purgeDoMissPurge(), clientReplyContext::purgeDoPurgeGet(), clientReplyContext::purgeFoundGet(), and clientReplyContext::purgeRequestFindObjectToPurge().

◆ getSerialisedMetaData()

const char * StoreEntry::getSerialisedMetaData ( size_t &  length) const
inherited
Returns
a malloc()ed buffer containing a length-long packed swap header

Definition at line 1829 of file store.cc.

References assert, storeSwapMetaBuild(), storeSwapMetaPack(), and storeSwapTLVFree().

Referenced by storeSwapOutStart().

◆ hasDisk()

bool StoreEntry::hasDisk ( const sdirno  dirn = -1,
const sfileno  filen = -1 
) const
inherited

whether one of this StoreEntry owners has locked the corresponding disk entry (at the specified disk entry coordinates, if any)

Definition at line 1990 of file store.cc.

References StoreEntry::checkDisk(), Must, StoreEntry::swap_dirn, and StoreEntry::swap_filen.

Referenced by MemStore::anchorEntry(), Store::Disk::canLog(), StoreEntry::checkCachable(), Store::Controller::dereferenceIdle(), destroyStoreEntry(), Rock::SwapDir::disconnect(), StoreEntry::disk(), Store::Disks::evictCached(), Rock::SwapDir::evictCached(), Fs::Ufs::UFSSwapDir::evictCached(), StoreEntry::forcePublicKey(), StoreEntry::mayStartSwapOut(), store_client::moreToSend(), neighborsUdpPing(), Rock::SwapDir::openStoreIO(), Store::Controller::referenceBusy(), StoreEntry::release(), Fs::Ufs::UFSSwapDir::replacementRemove(), store_client::store_client(), storeCleanup(), storeDirSwapLog(), storeSwapInStart(), storeSwapOutStart(), StoreEntry::swapOut(), Store::Controller::syncCollapsed(), Store::Disks::updateAnchored(), Rock::SwapDir::updateAnchored(), and StoreEntry::validToSend().

◆ hasEtag()

bool StoreEntry::hasEtag ( ETag &  etag) const
inherited

Definition at line 1923 of file store.cc.

References Http::ETAG, StoreEntry::hasFreshestReply(), and ETag::str.

Referenced by clientReplyContext::processExpired().

◆ hasFreshestReply()

const HttpReply* StoreEntry::hasFreshestReply ( ) const
inlineinherited
Return values
*the address of freshest reply (if mem_obj exists)
nullptrwhen mem_obj does not exist
See also
MemObject::freshestReply()

Definition at line 58 of file Store.h.

References MemObject::freshestReply(), and StoreEntry::mem_obj.

Referenced by StoreEntry::hasEtag(), and refreshCheck().

◆ hashDelete()

void StoreEntry::hashDelete ( )
inherited

Definition at line 447 of file store.cc.

References hash_remove_link(), hash_link::key, NULL, store_table, and storeKeyFree().

Referenced by destroyStoreEntry(), StoreEntry::forcePublicKey(), and StoreEntry::setPrivateKey().

◆ hashInsert()

void StoreEntry::hashInsert ( const cache_key *  someKey)
inherited

Definition at line 438 of file store.cc.

References assert, debugs, hash_join(), hash_link::key, store_table, storeKeyDup(), and storeKeyText().

Referenced by Fs::Ufs::UFSSwapDir::addDiskRestore(), addedEntry(), Store::Controller::addReading(), StoreEntry::forcePublicKey(), and StoreEntry::setPrivateKey().

◆ hasIfMatchEtag()

bool StoreEntry::hasIfMatchEtag ( const HttpRequest &  request) const
inherited

Definition at line 1934 of file store.cc.

References StoreEntry::hasOneOfEtags(), Http::IF_MATCH, and request().

Referenced by clientReplyContext::processConditional().

◆ hasIfNoneMatchEtag()

bool StoreEntry::hasIfNoneMatchEtag ( const HttpRequest &  request) const
inherited

Definition at line 1941 of file store.cc.

References StoreEntry::hasOneOfEtags(), Http::IF_NONE_MATCH, _request::method, Http::METHOD_GET, Http::METHOD_HEAD, and request().

Referenced by clientReplyContext::processConditional().

◆ hasMemStore()

bool StoreEntry::hasMemStore ( ) const
inlineinherited

Definition at line 205 of file Store.h.

References MemObject::MemCache::index, StoreEntry::mem_obj, and MemObject::memCache.

Referenced by StoreEntry::destroyMemObject(), MemStore::disconnect(), MemStore::evictCached(), operator<<(), Store::Controller::syncCollapsed(), StoreEntry::transientsAbandonmentCheck(), and MemStore::updateAnchored().

◆ hasOneOfEtags()

bool StoreEntry::hasOneOfEtags ( const String &  reqETags,
const bool  allowWeakMatch 
) const
privateinherited

Definition at line 1952 of file store.cc.

References String::append(), Http::ETAG, etagIsStrongEqual(), etagIsWeakEqual(), etagParseInit(), MemObject::freshestReply(), HttpHeader::getETag(), Http::Message::header, StoreEntry::mem(), NULL, strListGetItem(), strListIsMember(), and String::termedBuf().

Referenced by StoreEntry::hasIfMatchEtag(), and StoreEntry::hasIfNoneMatchEtag().

◆ hasTransients()

bool StoreEntry::hasTransients ( ) const
inlineinherited

Definition at line 203 of file Store.h.

References MemObject::XitTable::index, StoreEntry::mem_obj, and MemObject::xitTable.

Referenced by Transients::addEntry(), Store::Controller::allowCollapsing(), Store::Controller::allowSharing(), Store::Controller::anchorToCache(), CollapsedForwarding::Broadcast(), Store::Controller::checkFoundCandidate(), Store::Controller::checkTransients(), Transients::clearCollapsingRequirement(), Transients::completeWriting(), StoreEntry::destroyMemObject(), Transients::disconnect(), Transients::evictCached(), Transients::hasWriter(), Transients::monitorIo(), operator<<(), Transients::readers(), Transients::status(), Store::Controller::stopSharing(), Store::Controller::transientReaders(), StoreEntry::transientsAbandonmentCheck(), Store::Controller::transientsCompleteWriting(), Store::Controller::transientsReader(), and Store::Controller::transientsWriter().

◆ hittingRequiresCollapsing()

bool StoreEntry::hittingRequiresCollapsing ( ) const
inlineinherited

Definition at line 208 of file Store.h.

References EBIT_TEST, ENTRY_REQUIRES_COLLAPSING, and StoreEntry::flags.

Referenced by Store::Controller::allowSharing(), Store::Controller::checkFoundCandidate(), ICPState::confirmAndPrepHit(), UrnState::created(), htcpSpecifier::created(), Store::Controller::dereferenceIdle(), Ipc::StoreMapAnchor::exportInto(), StoreClient::startCollapsingOn(), StoreEntry::startWriting(), and Store::Controller::syncCollapsed().

◆ inUseCount()

size_t StoreEntry::inUseCount ( )
staticinherited

Definition at line 197 of file store.cc.

References MemAllocator::getInUseCount(), and StoreEntry::pool.

Referenced by Store::Controller::getStats(), snmp_prfSysFn(), Store::Controller::stat(), and storeDigestCalcCap().

◆ invokeHandlers()

void StoreEntry::invokeHandlers ( )
inherited

Definition at line 756 of file store_client.cc.

References MemObject::clients, CodeContext::Current(), debugs, DELAY_SENDING, EBIT_TEST, ENTRY_FWD_HDR_WAIT, StoreEntry::flags, StoreEntry::getMD5Text(), dlink_list::head, StoreEntry::mem_obj, MemObject::nclients, node::next, NULL, PROF_start, PROF_stop, CodeContext::Reset(), sc, storeClientCopy2(), and StoreEntry::swapOut().

Referenced by StoreEntry::abort(), StoreEntry::complete(), StoreEntry::flush(), Store::Controller::syncCollapsed(), and StoreEntry::write().

◆ isAccepting()

bool StoreEntry::isAccepting ( ) const
inherited

Definition at line 2050 of file store.cc.

References EBIT_TEST, ENTRY_ABORTED, StoreEntry::flags, STORE_PENDING, and StoreEntry::store_status.

Referenced by Client::abortOnBadEntry(), Store::Controller::checkFoundCandidate(), and HttpStateData::processReplyBody().

◆ isEmpty()

bool StoreEntry::isEmpty ( ) const
inlineinherited

Check if the Store entry is empty

Return values
trueStore contains 0 bytes of data.
falseStore contains 1 or more bytes of data.
falseStore contains negative content !!!!!!

Definition at line 67 of file Store.h.

References MemObject::endOffset(), and StoreEntry::mem().

Referenced by FwdState::checkRetry(), FwdState::completed(), Ssl::ServerBump::connectedOk(), errorAppendEntry(), gopherMimeCreate(), gopherReadReply(), Client::handleAdaptationAborted(), Client::handleAdaptationBlocked(), ClientHttpRequest::handleAdaptationFailure(), Client::handledEarlyAdaptationAbort(), HttpStateData::handleRequestBodyProducerAborted(), FwdState::retryOrBail(), ConnStateData::serveDelayedError(), StoreEntry::startWriting(), and StoreEntry::storeClientType().

◆ kickProducer()

void StoreEntry::kickProducer ( )
inherited

Definition at line 388 of file store.cc.

References StoreEntry::deferredProducer, NULL, and ScheduleCallHere.

Referenced by store_client::copy(), and storeUnregister().

◆ lastModified() [1/2]

time_t StoreEntry::lastModified ( ) const
inlineinherited
Returns
entry's 'effective' modification time

Definition at line 170 of file Store.h.

References StoreEntry::lastModified_, and StoreEntry::timestamp.

Referenced by StoreEntry::modifiedSince(), and StoreEntry::timestampsSet().

◆ lastModified() [2/2]

void StoreEntry::lastModified ( const time_t  when)
inlineinherited

Definition at line 168 of file Store.h.

References StoreEntry::lastModified_.

Referenced by Fs::Ufs::UFSSwapDir::addDiskRestore(), addedEntry(), clientReplyContext::cacheHit(), Ipc::StoreMapAnchor::exportInto(), htcpTstReply(), Fs::Ufs::UFSSwapDir::logEntry(), InitStoreEntry::operator()(), peerDigestFetchSetStats(), peerDigestRequest(), clientReplyContext::processExpired(), Fs::Ufs::RebuildState::rebuildFromDirectory(), refreshIsCachable(), refreshStaleness(), Ipc::StoreMapAnchor::set(), and UFSCleanLog::write().

◆ lengthWentBad()

void StoreEntry::lengthWentBad ( const char *  reason)
inherited

Definition at line 1070 of file store.cc.

References debugs, EBIT_SET, ENTRY_BAD_LENGTH, StoreEntry::flags, and StoreEntry::releaseRequest().

Referenced by StoreEntry::complete(), Client::handleAdaptedBodyProducerAborted(), and HttpStateData::processReplyBody().

◆ lock()

void StoreEntry::lock ( const char *  context)
inherited

claim shared ownership of this entry (for use in a given context) matching lock() and unlock() contexts eases leak triage but is optional

Definition at line 459 of file store.cc.

References debugs, StoreEntry::getMD5Text(), and StoreEntry::lock_count.

Referenced by StoreEntry::abort(), Client::Client(), store_client::copy(), UrnState::created(), MimeIcon::created(), clientReplyContext::doGetMoreData(), clientReplyContext::forgetHit(), Mgr::Forwarder::Forwarder(), FwdState::FwdState(), GopherStateData::GopherStateData(), heap_purgeNext(), Rock::IoState::IoState(), ClientHttpRequest::loggingEntry(), peerDigestRequest(), clientReplyContext::processExpired(), clientReplyContext::purgeFoundObject(), StoreEntry::release(), Ssl::ServerBump::ServerBump(), clientReplyContext::setReplyToStoreEntry(), UrnState::start(), statObjectsStart(), storeCreateEntry(), StoreEntry::storeErrorResponse(), Ipc::StoreMapUpdate::StoreMapUpdate(), storeSwapOutStart(), storeUnregister(), testPackableStream::testGetStream(), and whoisStart().

◆ locked()

int StoreEntry::locked ( ) const
inlineinherited

Definition at line 136 of file Store.h.

References StoreEntry::lock_count.

Referenced by StoreEntry::abandon(), Store::Controller::checkFoundCandidate(), FwdState::dispatch(), StoreEntry::doAbandon(), Store::EntryGuard::EntryGuard(), Rock::SwapDir::evictCached(), Fs::Ufs::UFSSwapDir::evictCached(), MemStore::evictCached(), heap_purgeNext(), lru_purgeNext(), lru_stats(), Store::Controller::memoryEvictCached(), neighborsHtcpReply(), neighborsUdpAck(), StoreEntry::release(), storeDigestRewriteResume(), storeUnregister(), and Store::Controller::syncCollapsed().

◆ locks()

int StoreEntry::locks ( ) const
inlineinherited

Definition at line 264 of file Store.h.

References StoreEntry::lock_count.

Referenced by operator<<(), and statStoreEntry().

◆ makePrivate()

void StoreEntry::makePrivate ( const bool  shareable)
inherited

Definition at line 172 of file store.cc.

References StoreEntry::releaseRequest().

Referenced by gopherSendRequest(), HttpStateData::haveParsedReplyHeaders(), HttpStateData::processSurrogateControl(), and WhoisState::readReply().

◆ makePublic()

bool StoreEntry::makePublic ( const KeyScope  keyScope = ksDefault)
inherited

Definition at line 165 of file store.cc.

References EBIT_TEST, StoreEntry::flags, RELEASE_REQUEST, and StoreEntry::setPublicKey().

Referenced by StoreEntry::adjustVary(), Store::Controller::allowCollapsing(), StoreEntry::cacheNegatively(), gopherSendRequest(), HttpStateData::haveParsedReplyHeaders(), Ftp::Gateway::haveParsedReplyHeaders(), and WhoisState::readReply().

◆ mayStartHitting()

bool StoreEntry::mayStartHitting ( ) const
inlineinherited

May the caller commit to treating this [previously locked] entry as a cache hit?

Definition at line 283 of file Store.h.

References EBIT_TEST, StoreEntry::flags, KEY_PRIVATE, and StoreEntry::shareableWhenPrivate.

Referenced by clientReplyContext::cacheHit(), and clientReplyContext::handleIMSReply().

◆ mayStartSwapOut()

bool StoreEntry::mayStartSwapOut ( )
inherited

Definition at line 333 of file store_swapout.cc.

References Store::Controller::accumulateMore(), assert, SquidConfig::cacheSwap, StoreEntry::checkCachable(), Config, debugs, MemObject::SwapOut::decision, EBIT_TEST, MemObject::endOffset(), ENTRY_ABORTED, ENTRY_SPECIAL, MemObject::expectedReplySize(), StoreEntry::flags, StoreEntry::hasDisk(), HERE(), MemObject::inmem_lo, MemObject::isContiguous(), StoreEntry::mem_obj, Store::DiskConfig::n_configured, Store::Root(), store_maxobjsize, STORE_OK, StoreEntry::store_status, MemObject::swapout, StoreEntry::swapOutDecision(), StoreEntry::swappingOut(), MemObject::SwapOut::swImpossible, MemObject::SwapOut::swPossible, MemObject::SwapOut::swStarted, and StoreEntry::url().

Referenced by StoreEntry::swapOut().

◆ mem() [1/2]

MemObject& StoreEntry::mem ( )
inlineinherited

Definition at line 52 of file Store.h.

References assert, and StoreEntry::mem_obj.

Referenced by testRock::addEntry(), asHandleReply(), Client::blockCaching(), clientReplyContext::blockedHit(), StoreEntry::checkTooSmall(), clientReplyContext::cloneReply(), FwdState::complete(), StoreEntry::contentLen(), MemStore::copyFromShmSlice(), testRock::createEntry(), clientReplyContext::handleIMSReply(), StoreEntry::hasOneOfEtags(), StoreEntry::isEmpty(), netdbExchangeHandleReply(), StoreEntry::objectLen(), peerDigestFetchReply(), peerDigestSwapInHeaders(), HttpStateData::peerSupportsConnectionPinning(), clientReplyContext::processConditional(), store_client::readBody(), FwdState::reforward(), clientReplyContext::replyStatus(), StoreEntry::reset(), clientReplyContext::sendNotModified(), testUfs::testUfsSearch(), StoreEntry::timestampsSet(), MemStore::updateHeadersOrThrow(), and varyEvaluateMatch().

◆ mem() [2/2]

const MemObject& StoreEntry::mem ( ) const
inlineinherited

Definition at line 53 of file Store.h.

References assert, and StoreEntry::mem_obj.

◆ memoryCachable()

bool StoreEntry::memoryCachable ( )
inherited

Definition at line 1331 of file store.cc.

References StoreEntry::checkCachable(), Config, MemObject::data_hdr, MemObject::inmem_lo, StoreEntry::mem_obj, SquidConfig::memory_cache_first, NULL, SquidConfig::onoff, StoreEntry::refcount, mem_hdr::size(), and StoreEntry::swappedOut().

Referenced by Store::Controller::keepForLocalMemoryCache(), and MemStore::shouldCache().

◆ memOutDecision()

void StoreEntry::memOutDecision ( const bool  willCacheInRam)
inherited

Definition at line 1860 of file store.cc.

References StoreEntry::transientsAbandonmentCheck().

Referenced by MemStore::startCaching(), and MemStore::write().

◆ MEMPROXY_CLASS()

CapturingStoreEntry::MEMPROXY_CLASS ( CapturingStoreEntry  )
private

◆ modifiedSince()

bool StoreEntry::modifiedSince ( const time_t  ims,
const int  imslen = -1 
) const
inherited

Definition at line 1897 of file store.cc.

References assert, debugs, StoreEntry::lastModified(), and StoreEntry::url().

Referenced by clientIfRangeMatch(), clientReplyContext::handleIMSReply(), and clientReplyContext::processConditional().

◆ negativeCache()

void StoreEntry::negativeCache ( )
inherited

Set object for negative caching. Preserves any expiry information given by the server. In absence of proper expiry info it will set to expire immediately, or with HTTP-violations enabled the configured negative-TTL is observed

Definition at line 1373 of file store.cc.

References Config, debugs, EBIT_SET, ENTRY_NEGCACHED, StoreEntry::expires, StoreEntry::flags, SquidConfig::negativeTtl, and squid_curtime.

Referenced by StoreEntry::abort(), StoreEntry::cacheNegatively(), and StoreEntry::storeErrorResponse().

◆ objectLen()

int64_t StoreEntry::objectLen ( ) const
inlineinherited

Definition at line 252 of file Store.h.

References StoreEntry::mem(), and MemObject::object_sz.

Referenced by StoreEntry::contentLen(), store_client::moreToSend(), store_client::readBody(), clientReplyContext::storeOKTransferDone(), storeSwapOutFileClosed(), StoreEntry::validLength(), and Http::Stream::writeComplete().

◆ operator delete()

void StoreEntry::operator delete ( void *  address)
inherited

Definition at line 159 of file store.cc.

◆ operator new()

void * StoreEntry::operator new ( size_t  byteCount)
inherited

Definition at line 147 of file store.cc.

References assert, and memPoolCreate.

◆ publicKey()

const cache_key* StoreEntry::publicKey ( ) const
inlineinherited
Returns
public key (if the entry has it) or nil (otherwise)

Definition at line 103 of file Store.h.

References EBIT_TEST, StoreEntry::flags, hash_link::key, and KEY_PRIVATE.

Referenced by Store::Disks::evictCached(), Rock::SwapDir::evictCached(), and MemStore::evictCached().

◆ registerAbortCallback()

void StoreEntry::registerAbortCallback ( const AsyncCall::Pointer &  handler)
inherited

Definition at line 1537 of file store.cc.

References MemObject::abortCallback, assert, handler, and StoreEntry::mem_obj.

Referenced by Ftp::Relay::Relay(), and FwdState::start().

◆ release()

void StoreEntry::release ( const bool  shareable = false)
inherited

One of the three methods to get rid of an unlocked StoreEntry object. Removes all unlocked (and marks for eventual removal all locked) Store entries, including attached and unattached entries that have our key. Also destroys us if we are unlocked or makes us private otherwise.

Definition at line 1196 of file store.cc.

References debugs, destroyStoreEntry(), Store::Controller::evictCached(), StoreEntry::getMD5Text(), StoreEntry::hasDisk(), LateReleaseStack, StoreEntry::lock(), StoreEntry::locked(), PROF_start, PROF_stop, StoreEntry::releaseRequest(), Store::Root(), Store::Controller::store_dirs_rebuilding, STORE_LOG_RELEASE, and storeLog().

Referenced by StoreEntry::doAbandon(), Store::Controller::handleIdleEntry(), Ftp::Gateway::haveParsedReplyHeaders(), httpMaybeRemovePublic(), Fs::Ufs::UFSSwapDir::maintain(), clientReplyContext::purgeDoPurgeGet(), clientReplyContext::purgeDoPurgeHead(), Client::setFinalReply(), Store::Controller::syncCollapsed(), and testRock::testRockSwapOut().

◆ releaseRequest()

void StoreEntry::releaseRequest ( const bool  shareable = false)
inherited

Makes the StoreEntry private and marks the corresponding entry for eventual removal from the Store.

Definition at line 472 of file store.cc.

References debugs, EBIT_TEST, StoreEntry::flags, RELEASE_REQUEST, StoreEntry::setPrivateKey(), and StoreEntry::shareableWhenPrivate.

Referenced by StoreEntry::abort(), StoreEntry::checkCachable(), FwdState::completed(), htcpClrStoreEntry(), HttpStateData::HttpStateData(), StoreEntry::lengthWentBad(), StoreEntry::makePrivate(), Store::EntryGuard::onException(), peerDigestFetchFinish(), peerDigestFetchReply(), clientReplyContext::processMiss(), Ftp::Relay::Relay(), StoreEntry::release(), StoreEntry::storeErrorResponse(), storeSwapOutFileClosed(), and clientReplyContext::traceReply().

◆ replaceHttpReply()

void StoreEntry::replaceHttpReply ( const HttpReplyPointer &  rep,
const bool  andStartWriting = true 
)
inherited

Definition at line 1782 of file store.cc.

References DBG_CRITICAL, debugs, StoreEntry::mem_obj, MemObject::replaceBaseReply(), StoreEntry::startWriting(), and StoreEntry::url().

Referenced by StoreEntry::adjustVary(), MimeIcon::created(), Mgr::Action::fillEntry(), ftpFail(), ftpSendReply(), gopherMimeCreate(), ClientHttpRequest::handleAdaptedHeader(), internalStart(), netdbBinaryExchange(), clientReplyContext::processMiss(), clientReplyContext::purgeDoPurgeHead(), clientReplyContext::sendNotModified(), Client::setFinalReply(), Ftp::Server::setReply(), WhoisState::setReplyToOK(), CacheManager::start(), storeDigestRewriteResume(), StoreEntry::storeErrorResponse(), clientReplyContext::traceReply(), and urnHandleReply().

◆ reset()

void StoreEntry::reset ( )
inherited

Definition at line 1677 of file store.cc.

References debugs, StoreEntry::expires, StoreEntry::lastModified_, StoreEntry::mem(), MemObject::reset(), StoreEntry::timestamp, and StoreEntry::url().

Referenced by FwdState::complete(), and HttpStateData::continueAfterParsingHeader().

◆ setCollapsingRequirement()

void StoreEntry::setCollapsingRequirement ( const bool  required)
inherited

Definition at line 2074 of file store.cc.

References EBIT_CLR, EBIT_SET, ENTRY_REQUIRES_COLLAPSING, and StoreEntry::flags.

Referenced by Store::Controller::allowCollapsing(), Transients::anchorEntry(), Ipc::StoreMapAnchor::exportInto(), StoreEntry::startWriting(), and Store::Controller::syncCollapsed().

◆ setMemStatus()

void StoreEntry::setMemStatus ( mem_status_t  new_status)
inherited

Definition at line 1580 of file store.cc.

References RemovalPolicy::Add, assert, debugs, EBIT_TEST, MemStore::Enabled(), ENTRY_SPECIAL, StoreEntry::flags, StoreEntry::getMD5Text(), hot_obj_count, IN_MEMORY, MemObject::inmem_lo, StoreEntry::mem_obj, mem_policy, StoreEntry::mem_status, NULL, RemovalPolicy::Remove, and MemObject::repl.

Referenced by StoreEntry::abort(), Fs::Ufs::UFSSwapDir::addDiskRestore(), addedEntry(), MemStore::anchorEntry(), MemStore::copyFromShm(), StoreEntry::destroyMemObject(), and Store::Controller::handleIdleEntry().

◆ setNoDelay()

void StoreEntry::setNoDelay ( bool const  newValue)
inherited

Definition at line 273 of file store.cc.

References StoreEntry::mem_obj, and MemObject::setNoDelay().

Referenced by HttpStateData::HttpStateData().

◆ setPrivateKey()

void StoreEntry::setPrivateKey ( const bool  shareable,
const bool  permanent 
)
inherited

Either fills this entry with private key or changes the existing key from public to private.

Parameters
permanentwhether this entry should be private forever.

Definition at line 586 of file store.cc.

References assert, debugs, EBIT_SET, EBIT_TEST, Store::Controller::evictCached(), StoreEntry::flags, getKeyCounter(), hash_lookup(), StoreEntry::hashDelete(), StoreEntry::hashInsert(), MemObject::hasUris(), MemObject::id, hash_link::key, KEY_PRIVATE, StoreEntry::mem_obj, NULL, RELEASE_REQUEST, Store::Root(), StoreEntry::shareableWhenPrivate, store_table, and storeKeyPrivate().

Referenced by StoreEntry::releaseRequest(), and storeCreateEntry().

◆ setPublicKey()

bool StoreEntry::setPublicKey ( const KeyScope  keyScope = ksDefault)
inherited

Definition at line 613 of file store.cc.

References Store::Controller::addWriting(), StoreEntry::adjustVary(), assert, StoreEntry::calcPublicKey(), DBG_IMPORTANT, debugs, EBIT_TEST, StoreEntry::flags, StoreEntry::forcePublicKey(), hash_link::key, KEY_PRIVATE, StoreEntry::mem_obj, RELEASE_REQUEST, Store::Root(), and Store::EntryGuard::unlockAndReset().

Referenced by MimeIcon::created(), testRock::createEntry(), StoreEntry::makePublic(), storeCreateEntry(), storeDigestRewriteResume(), and testUfs::testUfsSearch().

◆ startWriting()

void StoreEntry::startWriting ( )
inherited

pack and write reply headers and, maybe, body

Definition at line 1798 of file store.cc.

References assert, MemObject::baseReply(), StoreEntry::buffer(), StoreEntry::flush(), StoreEntry::hittingRequiresCollapsing(), StoreEntry::isEmpty(), MemObject::markEndOfReplyHeaders(), StoreEntry::mem_obj, Store::Root(), StoreEntry::setCollapsingRequirement(), Store::Controller::transientsClearCollapsingRequirement(), and MemObject::updatedReply().

Referenced by StoreEntry::adjustVary(), StoreEntry::replaceHttpReply(), and Client::setFinalReply().

◆ storeClientType()

store_client_t StoreEntry::storeClientType ( ) const
inherited

Definition at line 287 of file store.cc.

References assert, DBG_IMPORTANT, debugs, EBIT_TEST, MemObject::endOffset(), ENTRY_ABORTED, StoreEntry::flags, HERE(), MemObject::inmem_lo, StoreEntry::isEmpty(), StoreEntry::mem_obj, MemObject::nclients, MemObject::object_sz, STORE_DISK_CLIENT, STORE_MEM_CLIENT, STORE_OK, StoreEntry::store_status, StoreEntry::swap_status, SWAPOUT_NONE, StoreEntry::swapoutFailed(), and StoreEntry::swappedOut().

◆ storeErrorResponse()

void StoreEntry::storeErrorResponse ( HttpReply *  reply)
inherited

Definition at line 1765 of file store.cc.

References StoreEntry::buffer(), StoreEntry::complete(), StoreEntry::flush(), StoreEntry::lock(), StoreEntry::negativeCache(), StoreEntry::releaseRequest(), StoreEntry::replaceHttpReply(), and StoreEntry::unlock().

Referenced by errorAppendEntry(), and clientReplyContext::setReplyToReply().

◆ swapOut()

void StoreEntry::swapOut ( )
inherited

Definition at line 160 of file store_swapout.cc.

References StoreEntry::abort(), assert, MemObject::availableForSwapOut(), StoreEntry::checkDeferRead(), DBG_CRITICAL, debugs, MemObject::SwapOut::decision, doPages(), EBIT_TEST, MemObject::endOffset(), ENTRY_ABORTED, StoreEntry::flags, StoreEntry::hasDisk(), HERE(), MemObject::inmem_lo, MemObject::lowestMemReaderOffset(), StoreEntry::mayStartSwapOut(), StoreEntry::mem_obj, Store::Controller::memoryOut(), NULL, MemObject::object_sz, MemObject::objectBytesOnDisk(), StoreIOState::offset(), MemObject::SwapOut::queue_offset, RELEASE_REQUEST, Store::Root(), MemObject::SwapOut::sio, SM_PAGE_SIZE, STORE_OK, STORE_PENDING, StoreEntry::store_status, storeSwapOutStart(), storeTooManyDiskFilesOpen(), MemObject::swapout, StoreEntry::swapOutFileClose(), StoreEntry::swappingOut(), MemObject::SwapOut::swPossible, StoreEntry::url(), and StoreIOState::wroteAll.

Referenced by testRock::addEntry(), StoreEntry::invokeHandlers(), storeUnregister(), and testUfs::testUfsSearch().

◆ swapOutDecision()

void StoreEntry::swapOutDecision ( const MemObject::SwapOut::Decision &  decision)
inherited

Definition at line 1866 of file store.cc.

References assert, MemObject::SwapOut::decision, StoreEntry::mem_obj, MemObject::swapout, and StoreEntry::transientsAbandonmentCheck().

Referenced by StoreEntry::mayStartSwapOut(), and storeSwapOutStart().

◆ swapoutFailed()

bool StoreEntry::swapoutFailed ( ) const
inlineinherited

Definition at line 128 of file Store.h.

References StoreEntry::swap_status, and SWAPOUT_FAILED.

Referenced by StoreEntry::checkDisk(), store_client::store_client(), StoreEntry::storeClientType(), storeSwapInStart(), and storeUnregister().

◆ swapOutFileClose()

void StoreEntry::swapOutFileClose ( int  how)
inherited

Definition at line 261 of file store_swapout.cc.

References assert, debugs, StoreEntry::getMD5Text(), RefCount< C >::getRaw(), StoreEntry::mem_obj, NULL, MemObject::SwapOut::sio, storeClose(), and MemObject::swapout.

Referenced by StoreEntry::abort(), and StoreEntry::swapOut().

◆ swappedOut()

bool StoreEntry::swappedOut ( ) const
inlineinherited

Definition at line 126 of file Store.h.

References StoreEntry::swap_status, and SWAPOUT_DONE.

Referenced by Store::Disk::canLog(), StoreEntry::checkDisk(), Fs::Ufs::UFSSwapDir::evictCached(), Store::Controller::handleIdleEntry(), StoreEntry::memoryCachable(), StoreEntry::storeClientType(), and storeUnregister().

◆ swappingOut()

bool StoreEntry::swappingOut ( ) const
inlineinherited

Definition at line 124 of file Store.h.

References StoreEntry::swap_status, and SWAPOUT_WRITING.

Referenced by StoreEntry::checkDisk(), doPages(), store_client::fileRead(), StoreEntry::mayStartSwapOut(), storeSwapOutFileClosed(), StoreEntry::swapOut(), and StoreEntry::validToSend().

◆ timestampsSet()

bool StoreEntry::timestampsSet ( )
inherited

Definition at line 1449 of file store.cc.

References Http::AGE, HttpReply::date, debugs, StoreEntry::describeTimestamps(), StoreEntry::expires, MemObject::freshestReply(), HttpRequest::hier, StoreEntry::lastModified(), StoreEntry::lastModified_, StoreEntry::mem(), StoreEntry::mem_obj, HierarchyLogEntry::peerResponseTime(), MemObject::request, squid_curtime, and StoreEntry::timestamp.

Referenced by testRock::addEntry(), StoreEntry::adjustVary(), MimeIcon::created(), ftpWriteTransferDone(), gopherReadReply(), ClientHttpRequest::handleAdaptedHeader(), HttpStateData::haveParsedReplyHeaders(), Ftp::Gateway::haveParsedReplyHeaders(), HttpStateData::processSurrogateControl(), WhoisState::readReply(), clientReplyContext::sendNotModified(), storeDigestRewriteFinish(), testUfs::testUfsSearch(), and StoreEntry::updateOnNotModified().

◆ touch()

void StoreEntry::touch ( )
inherited

Definition at line 466 of file store.cc.

References StoreEntry::lastref, and squid_curtime.

◆ transientsAbandonmentCheck()

void StoreEntry::transientsAbandonmentCheck ( )
protectedinherited

Abandon the transient entry our worker has created if neither the shared memory cache nor the disk cache wants to store it. Collapsed requests, if any, should notice and use Plan B instead of getting stuck waiting for us to start swapping the entry out.

Definition at line 1847 of file store.cc.

References debugs, MemObject::SwapOut::decision, StoreEntry::hasMemStore(), StoreEntry::hasTransients(), StoreEntry::mem_obj, Store::Root(), shutting_down, Store::Controller::stopSharing(), MemObject::swapout, and MemObject::SwapOut::swImpossible.

Referenced by StoreEntry::memOutDecision(), and StoreEntry::swapOutDecision().

◆ trimMemory()

void StoreEntry::trimMemory ( const bool  preserveSwappable)
inherited

Definition at line 1875 of file store.cc.

References debugs, EBIT_TEST, ENTRY_SPECIAL, StoreEntry::flags, IN_MEMORY, MemObject::inmem_lo, StoreEntry::mem_obj, StoreEntry::mem_status, MemObject::trimSwappable(), and MemObject::trimUnSwappable().

Referenced by Store::Controller::memoryOut().

◆ unlock()

int StoreEntry::unlock ( const char *  context)
inherited

disclaim shared ownership; may remove entry from store and delete it returns remaining lock level (zero for unlocked and possibly gone entry)

Definition at line 483 of file store.cc.

References StoreEntry::abandon(), assert, debugs, StoreEntry::getMD5Text(), and StoreEntry::lock_count.

Referenced by StoreEntry::abort(), StoreEntry::adjustVary(), store_client::copy(), ClientHttpRequest::doCallouts(), clientReplyContext::forgetHit(), heap_purgeDone(), ClientHttpRequest::loggingEntry(), Store::EntryGuard::onException(), peerCountMcastPeersAbort(), peerDigestFetchFinish(), peerDigestFetchReply(), clientReplyContext::removeStoreReference(), statObjects(), storeDigestRewriteResume(), StoreEntry::storeErrorResponse(), storeLateRelease(), storeSwapOutFileClosed(), storeUnregister(), GopherStateData::swanSong(), testRock::testRockSwapOut(), testUfs::testUfsSearch(), Store::EntryGuard::unlockAndReset(), whoisClose(), Client::~Client(), DigestFetchState::~DigestFetchState(), FwdState::~FwdState(), netdbExchangeState::~netdbExchangeState(), PeerSelector::~PeerSelector(), and UrnState::~UrnState().

◆ unregisterAbortCallback()

void StoreEntry::unregisterAbortCallback ( const char *  reason)
inherited

Avoid notifying anybody about a 3rd-party initiated StoreEntry abort. Calling this method does not cancel the already queued notification. TODO: Refactor to represent the end of (shared) ownership by our writer.

Definition at line 1545 of file store.cc.

References MemObject::abortCallback, assert, AsyncCall::cancel(), and StoreEntry::mem_obj.

Referenced by FwdState::~FwdState().

◆ updateOnNotModified()

bool StoreEntry::updateOnNotModified ( const StoreEntry &  e304)
inherited

Updates easily-accessible non-Store-specific parts of the entry. Use Controller::updateOnNotModified() instead of this helper.

Returns
whether anything was actually updated

Definition at line 1514 of file store.cc.

References MemObject::appliedUpdates, assert, MemObject::baseReply(), debugs, MemObject::freshestReply(), StoreEntry::mem_obj, HttpReply::recreateOnNotModified(), StoreEntry::timestampsSet(), and MemObject::updateReply().

Referenced by Store::Controller::updateOnNotModified().

◆ url()

const char * StoreEntry::url ( ) const
inherited

Definition at line 1622 of file store.cc.

References StoreEntry::mem_obj, NULL, and MemObject::storeId().

Referenced by asHandleReply(), FwdState::complete(), FwdState::connectStart(), HttpStateData::continueAfterParsingHeader(), FwdState::dispatch(), FwdState::fail(), ftpSendReply(), FwdState::FwdState(), Ftp::Gateway::Gateway(), gopherSendComplete(), gopherStart(), gopherTimeout(), gopherToHTML(), clientReplyContext::handleIMSReply(), HttpStateData::handleMoreRequestBodyAvailable(), FwdState::handleUnregisteredServerEnd(), htcpClrStoreEntry(), htcpQuery(), HttpStateData::httpBuildRequestHeader(), httpStart(), HttpStateData::httpTimeout(), HttpStateData::keepaliveAccounting(), StoreEntry::mayStartSwapOut(), StoreEntry::modifiedSince(), neighborsUdpPing(), peerSelect(), peerSelectIcpPing(), clientReplyContext::purgeDoPurgeGet(), clientReplyContext::purgeDoPurgeHead(), WhoisState::readReply(), FwdState::reforward(), StoreEntry::replaceHttpReply(), StoreEntry::reset(), clientReplyContext::sendMoreData(), FwdState::serverClosed(), UrnState::start(), CacheManager::start(), FwdState::Start(), HttpStateData::statusIfComplete(), storeDigestDel(), storeSwapMetaBuild(), storeSwapOutFileClosed(), storeSwapOutStart(), StoreEntry::swapOut(), FwdState::unregister(), PeerSelector::url(), urnHandleReply(), FwdState::useDestinations(), whoisTimeout(), netdbExchangeState::~netdbExchangeState(), and PeerSelector::~PeerSelector().

◆ validLength()

bool StoreEntry::validLength ( ) const
privateinherited

whether the base response has all the body bytes we expect

Returns
true for responses with unknown/unspecified body length
true for responses with the right number of accumulated body bytes

Definition at line 1258 of file store.cc.

References assert, MemObject::baseReply(), debugs, StoreEntry::getMD5Text(), StoreEntry::mem_obj, MemObject::method, Http::METHOD_HEAD, NULL, StoreEntry::objectLen(), Http::scNoContent, and Http::scNotModified.

Referenced by StoreEntry::complete().

◆ validToSend()

int StoreEntry::validToSend ( ) const
inherited

Definition at line 1409 of file store.cc.

References EBIT_TEST, ENTRY_ABORTED, ENTRY_NEGCACHED, StoreEntry::expires, StoreEntry::flags, StoreEntry::hasDisk(), MemObject::inmem_lo, StoreEntry::mem_obj, RELEASE_REQUEST, squid_curtime, and StoreEntry::swappingOut().

Referenced by ICPState::confirmAndPrepHit(), and htcpSpecifier::created().

◆ vappendf()

void StoreEntry::vappendf ( const char *  fmt,
va_list  ap 
)
virtualinherited

Append operation, with vsprintf(3)-style arguments.

Note
arguments may be evaluated more than once, be careful of side-effects

XXX: This method either should not exist or should not be virtual. Kids should not be forced to re-implement vappendf() logic. That logic should be implemented once, using other [Packable] APIs. Packable is not about providing a printf(3) service. Packable is about writing opaque data to various custom destinations.

Implements Packable.

Definition at line 867 of file store.cc.

References StoreEntry::append(), assert, buf, fatal(), LOCAL_ARRAY, and xstrerr().

Referenced by storeAppendPrintf(), and storeAppendVPrintf().

◆ write()

void StoreEntry::write ( StoreIOBuffer  writeBuffer)
inherited

Definition at line 824 of file store.cc.

References assert, MemObject::baseReply(), debugs, EBIT_CLR, EBIT_TEST, ENTRY_FWD_HDR_WAIT, StoreEntry::flags, StoreEntry::getMD5Text(), Http::Message::hdr_sz, StoreEntry::invokeHandlers(), StoreIOBuffer::length, StoreEntry::mem_obj, NULL, StoreIOBuffer::offset, PROF_start, PROF_stop, MemObject::readAheadPolicyCanRead(), STORE_PENDING, StoreEntry::store_status, storeGetMemSpace(), and MemObject::write().

Referenced by StoreEntry::append(), Client::handleMoreAdaptedBodyAvailable(), ClientHttpRequest::noteMoreBodyDataAvailable(), and Client::storeReplyBody().

Member Data Documentation

◆ _appended_text

String CapturingStoreEntry::_appended_text

Definition at line 23 of file CapturingStoreEntry.h.

Referenced by append(), testEvent::testDump(), and testPackableStream::testGetStream().

◆ _buffer_calls

int CapturingStoreEntry::_buffer_calls

Definition at line 24 of file CapturingStoreEntry.h.

Referenced by buffer(), and testPackableStream::testGetStream().

◆ _flush_calls

int CapturingStoreEntry::_flush_calls

Definition at line 25 of file CapturingStoreEntry.h.

Referenced by flush(), and testPackableStream::testGetStream().

◆ cachedESITree

ESIElement::Pointer StoreEntry::cachedESITree
inherited

Definition at line 250 of file Store.h.

Referenced by ESIContext::getCachedAST(), ESIContext::hasCachedAST(), and ESIContext::updateCachedAST().

◆ DeferReader

void StoreEntry::DeferReader
staticinherited

Definition at line 45 of file Store.h.

Referenced by StoreEntry::delayAwareRead().

◆ deferredProducer

AsyncCall::Pointer StoreEntry::deferredProducer
privateinherited

Definition at line 327 of file Store.h.

Referenced by StoreEntry::deferProducer(), and StoreEntry::kickProducer().

◆ expires

time_t StoreEntry::expires
inherited

Definition at line 218 of file Store.h.

Referenced by Fs::Ufs::UFSSwapDir::addDiskRestore(), addedEntry(), clientReplyContext::buildReplyHeader(), StoreEntry::checkNegativeHit(), StoreEntry::describeTimestamps(), StoreEntry::dump(), StoreEntry::expireNow(), Ipc::StoreMapAnchor::exportInto(), htcpTstReply(), Fs::Ufs::UFSSwapDir::logEntry(), StoreEntry::negativeCache(), InitStoreEntry::operator()(), peerDigestFetchSetStats(), peerDigestNewDelay(), Fs::Ufs::RebuildState::rebuildFromDirectory(), refreshStaleness(), StoreEntry::reset(), Ipc::StoreMapAnchor::set(), CacheManager::start(), storeDigestRewriteFinish(), StoreEntry::timestampsSet(), StoreEntry::validToSend(), and UFSCleanLog::write().

◆ flags

uint16_t StoreEntry::flags
inherited

Definition at line 224 of file Store.h.

Referenced by StoreEntry::abort(), Fs::Ufs::UFSSwapDir::addDiskRestore(), addedEntry(), Store::Controller::addWriting(), MemStore::anchorEntry(), Rock::SwapDir::anchorEntry(), asHandleReply(), StoreEntry::buffer(), clientReplyContext::buildReplyHeader(), clientReplyContext::cacheHit(), Store::Disk::canLog(), Store::Disk::canStore(), StoreEntry::checkCachable(), StoreMetaMD5::checkConsistency(), StoreEntry::checkDisk(), StoreEntry::checkNegativeHit(), CheckQuickAbortIsReasonable(), StoreEntry::checkTooSmall(), Store::Controller::checkTransients(), StoreEntry::clearPrivate(), StoreEntry::clearPublicKeyScope(), StoreEntry::complete(), FwdState::completed(), store_client::copy(), MemStore::copyToShm(), MimeIcon::created(), Store::Controller::dereferenceIdle(), FwdState::dispatch(), StoreEntry::doAbandon(), dummy_action(), errorAppendEntry(), clientReplyContext::errorInStream(), Store::Disks::evictCached(), Ipc::StoreMapAnchor::exportInto(), StoreEntry::flush(), gopherReadReply(), Store::Controller::handleIdleEntry(), clientReplyContext::handleIMSReply(), Http::One::Server::handleReply(), HttpStateData::haveParsedReplyHeaders(), heap_add(), StoreEntry::hittingRequiresCollapsing(), httpMaybeRemovePublic(), StoreEntry::invokeHandlers(), StoreEntry::isAccepting(), StoreEntry::lengthWentBad(), Fs::Ufs::UFSSwapDir::logEntry(), StoreEntry::makePublic(), StoreEntry::mayStartHitting(), StoreEntry::mayStartSwapOut(), StoreEntry::negativeCache(), neighborsHtcpReply(), neighborsUdpAck(), netdbExchangeHandleReply(), InitStoreEntry::operator()(), operator<<(), peerDigestFetchedEnough(), peerDigestRequest(), peerSelectIcpPing(), clientReplyContext::processExpired(), clientReplyContext::processMiss(), HttpStateData::processReplyBody(), StoreEntry::publicKey(), clientReplyContext::purgeFoundObject(), HttpStateData::readReply(), Fs::Ufs::RebuildState::rebuildFromDirectory(), Store::Controller::referenceBusy(), FwdState::reforward(), refreshCheck(), StoreEntry::releaseRequest(), clientReplyContext::replyStatus(), HttpStateData::reusableReply(), clientReplyContext::sendClientOldEntry(), clientReplyContext::sendClientUpstreamResponse(), Client::sentRequestBody(), Ipc::StoreMapAnchor::set(), StoreEntry::setCollapsingRequirement(), Client::setFinalReply(), StoreEntry::setMemStatus(), StoreEntry::setPrivateKey(), StoreEntry::setPublicKey(), MemStore::shouldCache(), statObjects(), storeCleanup(), StoreEntry::storeClientType(), storeCreatePureEntry(), storeDigestAddable(), storeDigestDel(), storeDigestRewriteResume(), storeDirSwapLog(), storeEntryFlags(), storeRebuildParseEntry(), storeSwapInStart(), StoreEntry::swapOut(), Store::Controller::syncCollapsed(), testCacheManager::testRegister(), StoreEntry::trimMemory(), Store::Controller::updateOnNotModified(), urnHandleReply(), StoreEntry::validToSend(), UFSCleanLog::write(), and StoreEntry::write().

◆ key

void* hash_link::key
inherited

Definition at line 19 of file hash.h.

Referenced by aclMatchExternal(), MemStore::anchorToCache(), Rock::SwapDir::anchorToCache(), StoreMetaMD5::checkConsistency(), StoreEntry::clearPublicKeyScope(), ClientInfo::ClientInfo(), Rock::SwapDir::createStoreIO(), CommQuotaQueue::dequeue(), destroyStoreEntry(), CommQuotaQueue::enqueue(), external_acl_cache_add(), StoreEntry::forcePublicKey(), fqdncache_entry::fqdncache_entry(), fqdncacheAddEntry(), fqdncacheParse(), StoreEntry::getMD5Text(), hash_join(), hash_remove_link(), StoreEntry::hashDelete(), StoreEntry::hashInsert(), hashKeyStr(), Rock::SwapDir::hasReadableEntry(), htcpQuery(), IdleConnList::IdleConnList(), idnsStartQuery(), ipcache_entry::ipcache_entry(), ipcacheAddEntry(), ipcacheRelease(), Fs::Ufs::UFSSwapDir::logEntry(), Store::Controller::markedForDeletionAndAbandoned(), my_free(), ipcache_entry::name(), neighborsUdpPing(), net_db_name::net_db_name(), netdbHashInsert(), Ipc::StoreMap::openForUpdating(), Rock::SwapDir::openStoreIO(), peerCountMcastPeersCreateAndSend(), StoreEntry::publicKey(), read_passwd_file(), Ipc::StoreMapAnchor::set(), StoreEntry::setPrivateKey(), StoreEntry::setPublicKey(), ClientInfo::setWriteLimiter(), Ident::Start(), MemStore::startCaching(), storeDigestAdd(), storeDigestDel(), storeKeyHashHash(), storeKeyText(), storeRebuildParseEntry(), storeSwapMetaBuild(), UFSCleanLog::write(), ClientInfo::~ClientInfo(), ExternalACLEntry::~ExternalACLEntry(), fqdncache_entry::~fqdncache_entry(), IdleConnList::~IdleConnList(), and net_db_name::~net_db_name().

◆ lastModified_

time_t StoreEntry::lastModified_
privateinherited

Definition at line 220 of file Store.h.

Referenced by StoreEntry::describeTimestamps(), StoreEntry::dump(), StoreEntry::lastModified(), StoreEntry::reset(), and StoreEntry::timestampsSet().

◆ lastref

time_t StoreEntry::lastref
inherited

Definition at line 217 of file Store.h.

Referenced by Fs::Ufs::UFSSwapDir::addDiskRestore(), addedEntry(), StoreEntry::describeTimestamps(), StoreEntry::dump(), Ipc::StoreMapAnchor::exportInto(), HeapKeyGen_StoreEntry_GDSF(), HeapKeyGen_StoreEntry_LFUDA(), HeapKeyGen_StoreEntry_LRU(), Fs::Ufs::UFSSwapDir::logEntry(), lru_stats(), InitStoreEntry::operator()(), Fs::Ufs::RebuildState::rebuildFromDirectory(), Ipc::StoreMapAnchor::set(), storeCreatePureEntry(), StoreEntry::touch(), and UFSCleanLog::write().

◆ lock_count

unsigned short StoreEntry::lock_count
privateinherited

Definition at line 316 of file Store.h.

Referenced by StoreEntry::dump(), StoreEntry::lock(), StoreEntry::locked(), StoreEntry::locks(), and StoreEntry::unlock().

◆ mem_obj

MemObject* StoreEntry::mem_obj
inherited

Definition at line 213 of file Store.h.

Referenced by StoreEntry::abort(), Store::Disks::accumulateMore(), Transients::addEntry(), Transients::addWriterEntry(), StoreEntry::adjustVary(), MemStore::anchorEntry(), Transients::anchorEntry(), StoreEntry::append(), CollapsedForwarding::Broadcast(), StoreEntry::bytesWanted(), clientReplyContext::cacheHit(), StoreEntry::calcPublicKey(), StoreEntry::checkCachable(), StoreMetaVary::checkConsistency(), StoreMetaURL::checkConsistency(), CheckQuickAbortIsReasonable(), StoreEntry::checkTooBig(), StoreEntry::checkTooSmall(), Transients::clearCollapsingRequirement(), StoreEntry::complete(), FwdState::complete(), FwdState::completed(), MemStore::completeWriting(), Transients::completeWriting(), store_client::copy(), MemStore::copyFromShm(), MemStore::copyFromShmSlice(), MemStore::copyToShm(), MemStore::copyToShmSlice(), MimeIcon::created(), StoreEntry::createMemObject(), StoreEntry::delayAwareRead(), Store::Controller::dereferenceIdle(), StoreEntry::destroyMemObject(), MemStore::disconnect(), Rock::SwapDir::disconnect(), Transients::disconnect(), store_client::doCopy(), doPages(), StoreEntry::dump(), StoreEntry::ensureMemObject(), errorAppendEntry(), FwdState::establishTunnelThruProxy(), MemStore::evictCached(), Transients::evictCached(), store_client::fileRead(), findPreviouslyCachedEntry(), StoreEntry::forcePublicKey(), gopherReadReply(), Store::Controller::handleIdleEntry(), StoreEntry::hasFreshestReply(), StoreEntry::hasMemStore(), StoreEntry::hasTransients(), Transients::hasWriter(), HttpStateData::haveParsedReplyHeaders(), heap_guessType(), HeapKeyGen_StoreEntry_GDSF(), HeapKeyGen_StoreEntry_LFUDA(), HeapKeyGen_StoreEntry_LRU(), httpMaybeRemovePublic(), StoreEntry::invokeHandlers(), Transients::isReader(), Transients::isWriter(), Store::Controller::keepForLocalMemoryCache(), StoreEntry::mayStartSwapOut(), StoreEntry::mem(), StoreEntry::memoryCachable(), Transients::monitorIo(), store_client::moreToSend(), neighborsHtcpReply(), neighborsUdpAck(), neighborsUdpPing(), objectSizeForDirSelection(), operator<<(), peerCountHandleIcpReply(), peerCountMcastPeersAbort(), peerCountMcastPeersCreateAndSend(), peerDigestFetchReply(), peerDigestFetchSetStats(), peerDigestSwapInCBlock(), HttpStateData::processReplyHeader(), store_client::readBody(), Transients::readers(), store_client::readHeader(), HttpStateData::readReply(), Store::Controller::referenceBusy(), FwdState::reforward(), refreshCheck(), refreshCheckDigest(), refreshIsCachable(), StoreEntry::registerAbortCallback(), repl_guessType(), StoreEntry::replaceHttpReply(), store_client::scheduleMemRead(), store_client::scheduleRead(), StoreEntry::setMemStatus(), StoreEntry::setNoDelay(), LruPolicyData::setPolicyNode(), HeapPolicyData::setPolicyNode(), StoreEntry::setPrivateKey(), StoreEntry::setPublicKey(), MemStore::shouldCache(), FwdState::Start(), MemStore::startCaching(), StoreEntry::startWriting(), statObjectsOpenfdFilter(), statObjectsVmFilter(), statStoreEntry(), Transients::status(), storeClientCopyPending(), storeClientListAdd(), StoreEntry::storeClientType(), storeDigestRewriteFinish(), storeDigestRewriteStart(), storeLog(), clientReplyContext::storeNotOKTransferDone(), storePendingNClients(), storeSwapInStart(), storeSwapMetaBuild(), storeSwapOutFileClosed(), storeSwapOutStart(), storeUnregister(), StoreEntry::swapOut(), StoreEntry::swapOutDecision(), StoreEntry::swapOutFileClose(), Store::Controller::syncCollapsed(), testRock::testRockSwapOut(), StoreEntry::timestampsSet(), StoreEntry::transientsAbandonmentCheck(), StoreEntry::trimMemory(), store_client::unpackHeader(), StoreEntry::unregisterAbortCallback(), MemStore::updateAnchored(), MemStore::updateHeaders(), Store::Controller::updateOnNotModified(), StoreEntry::updateOnNotModified(), StoreEntry::url(), StoreEntry::validLength(), StoreEntry::validToSend(), varyEvaluateMatch(), MemStore::write(), StoreEntry::write(), and HttpStateData::wroteLast().

◆ mem_status

mem_status_t StoreEntry::mem_status
inherited

Definition at line 232 of file Store.h.

Referenced by clientReplyContext::cacheHit(), StoreEntry::complete(), Store::Controller::dereferenceIdle(), describeStatuses(), StoreEntry::dump(), operator<<(), Store::Controller::referenceBusy(), StoreEntry::setMemStatus(), MemStore::shouldCache(), storeSwapInStart(), StoreEntry::trimMemory(), and Store::Controller::updateOnNotModified().

◆ next

hash_link* hash_link::next
inherited

Definition at line 20 of file hash.h.

Referenced by clientdbGC(), Store::LocalSearch::copyBucket(), StoreEntry::dump(), hash_join(), hash_next(), hash_remove_link(), IdleConnList::IdleConnList(), and lru_stats().

◆ ping_status

ping_status_t StoreEntry::ping_status
inherited

Definition at line 234 of file Store.h.

Referenced by Fs::Ufs::UFSSwapDir::addDiskRestore(), addedEntry(), Rock::SwapDir::anchorEntry(), describeStatuses(), FwdState::dispatch(), StoreEntry::dump(), PeerSelector::handlePingTimeout(), neighborsHtcpReply(), neighborsUdpAck(), operator<<(), peerCountMcastPeersCreateAndSend(), peerSelectIcpPing(), PeerSelector::selectMore(), PeerSelector::selectPinned(), PeerSelector::selectSomeNeighbor(), PeerSelector::selectSomeNeighborReplies(), PeerSelector::startPingWaiting(), storeCreatePureEntry(), and PeerSelector::~PeerSelector().

◆ pool

MemAllocator * StoreEntry::pool = NULL
staticprivateinherited

Definition at line 314 of file Store.h.

Referenced by StoreEntry::inUseCount().

◆ refcount

uint16_t StoreEntry::refcount
inherited

Definition at line 223 of file Store.h.

Referenced by Fs::Ufs::UFSSwapDir::addDiskRestore(), addedEntry(), StoreEntry::dump(), Ipc::StoreMapAnchor::exportInto(), HeapKeyGen_StoreEntry_GDSF(), HeapKeyGen_StoreEntry_LFUDA(), Fs::Ufs::UFSSwapDir::logEntry(), StoreEntry::memoryCachable(), InitStoreEntry::operator()(), Fs::Ufs::RebuildState::rebuildFromDirectory(), Ipc::StoreMapAnchor::set(), statStoreEntry(), store_client::store_client(), storeCreatePureEntry(), and UFSCleanLog::write().

◆ repl

RemovalPolicyNode StoreEntry::repl
inherited

Definition at line 214 of file Store.h.

Referenced by Fs::Ufs::UFSSwapDir::dereference(), Rock::SwapDir::dereference(), heap_guessType(), Rock::SwapDir::ignoreReferences(), Fs::Ufs::UFSSwapDir::reference(), Rock::SwapDir::reference(), repl_guessType(), Fs::Ufs::UFSSwapDir::replacementAdd(), Fs::Ufs::UFSSwapDir::replacementRemove(), LruPolicyData::setPolicyNode(), HeapPolicyData::setPolicyNode(), and Rock::SwapDir::trackReferences().

◆ shareableWhenPrivate

bool StoreEntry::shareableWhenPrivate
privateinherited

Nobody can find/lock KEY_PRIVATE entries, but some transactions (e.g., collapsed requests) find/lock a public entry before it becomes private. May such transactions start using the now-private entry they previously locked? This member should not affect transactions that already started reading from the entry.

Definition at line 323 of file Store.h.

Referenced by StoreEntry::clearPrivate(), StoreEntry::mayStartHitting(), operator<<(), StoreEntry::releaseRequest(), and StoreEntry::setPrivateKey().

◆ store_status

store_status_t StoreEntry::store_status
inherited

Definition at line 236 of file Store.h.

Referenced by StoreEntry::abort(), Fs::Ufs::UFSSwapDir::addDiskRestore(), addedEntry(), MemStore::anchorEntry(), Rock::SwapDir::anchorEntry(), StoreEntry::append(), asHandleReply(), clientReplyContext::cacheHit(), StoreEntry::checkCachable(), StoreEntry::checkNegativeHit(), CheckQuickAbortIsReasonable(), FwdState::checkRetry(), StoreEntry::checkTooSmall(), clientReplyContext::checkTransferDone(), StoreEntry::complete(), FwdState::completed(), MemStore::copyFromShm(), describeStatuses(), StoreEntry::doAbandon(), store_client::doCopy(), doPages(), StoreEntry::dump(), errorAppendEntry(), HttpStateData::httpTimeout(), StoreEntry::isAccepting(), StoreEntry::mayStartSwapOut(), store_client::moreToSend(), netdbExchangeHandleReply(), operator<<(), peerDigestPDFinish(), FwdState::reforward(), StoreEntry::storeClientType(), storeCreatePureEntry(), storeDigestAddable(), storeUnregister(), StoreEntry::swapOut(), testStoreController::testMaxSize(), testStoreHashIndex::testMaxSize(), testStoreController::testStats(), testStoreHashIndex::testStats(), urnHandleReply(), MemStore::write(), and StoreEntry::write().

◆ swap_dirn

sdirno StoreEntry::swap_dirn
inherited

Definition at line 230 of file Store.h.

Referenced by addedEntry(), StoreEntry::attachToDisk(), StoreEntry::checkDisk(), Fs::Ufs::UFSSwapDir::dereference(), Rock::SwapDir::dereference(), StoreEntry::detachFromDisk(), StoreEntry::disk(), StoreEntry::dump(), StoreEntry::hasDisk(), operator<<(), Fs::Ufs::UFSSwapDir::reference(), Rock::SwapDir::reference(), Fs::Ufs::UFSSwapDir::replacementRemove(), statStoreEntry(), storeCleanupDoubleCheck(), storeDirSwapLog(), storeLog(), storeSwapInFileNotify(), storeSwapOutFileClosed(), storeSwapOutStart(), testRock::testRockSwapOut(), testUfs::testUfsSearch(), Store::Disks::updateAnchored(), and Store::Controller::updateOnNotModified().

◆ swap_file_sz

uint64_t StoreEntry::swap_file_sz
inherited

Definition at line 222 of file Store.h.

Referenced by Fs::Ufs::UFSSwapDir::addDiskRestore(), addedEntry(), MemStore::anchorEntry(), Store::Disk::canLog(), Fs::Ufs::UFSSwapDir::doubleCheck(), StoreEntry::dump(), Fs::Ufs::UFSSwapDir::evictCached(), Ipc::StoreMapAnchor::exportInto(), Fs::Ufs::UFSSwapDir::finalizeSwapoutSuccess(), HeapKeyGen_StoreEntry_GDSF(), Rock::Rebuild::importEntry(), Fs::Ufs::UFSSwapDir::logEntry(), Rock::SwapDir::openStoreIO(), InitStoreEntry::operator()(), Fs::Ufs::RebuildState::rebuildFromDirectory(), Ipc::StoreMapAnchor::set(), storeDigestAddable(), storeRebuildParseEntry(), storeSwapOutFileClosed(), store_client::unpackHeader(), MemStore::updateAnchoredWith(), Rock::SwapDir::updateAnchoredWith(), and UFSCleanLog::write().

◆ swap_filen

sfileno StoreEntry::swap_filen
inherited

Definition at line 228 of file Store.h.

Referenced by Fs::Ufs::UFSSwapDir::addDiskRestore(), addedEntry(), StoreEntry::attachToDisk(), StoreEntry::checkDisk(), Fs::Ufs::UFSSwapDir::dereference(), Rock::SwapDir::dereference(), StoreEntry::detachFromDisk(), Rock::SwapDir::disconnect(), Fs::Ufs::UFSSwapDir::doubleCheck(), StoreEntry::dump(), Fs::Ufs::UFSSwapDir::dumpEntry(), Rock::SwapDir::evictCached(), Fs::Ufs::UFSSwapDir::evictCached(), StoreEntry::hasDisk(), Fs::Ufs::UFSSwapDir::logEntry(), Fs::Ufs::UFSStrategy::open(), Rock::SwapDir::openStoreIO(), operator<<(), Fs::Ufs::UFSSwapDir::reference(), Rock::SwapDir::reference(), statStoreEntry(), storeDirSwapLog(), storeLog(), storeSwapInFileNotify(), storeSwapOutFileClosed(), storeSwapOutStart(), testRock::testRockSwapOut(), testUfs::testUfsSearch(), StoreIOState::touchingStoreEntry(), Fs::Ufs::UFSStoreState::UFSStoreState(), Rock::SwapDir::updateAnchored(), Rock::SwapDir::updateHeaders(), and UFSCleanLog::write().

◆ swap_status

swap_status_t StoreEntry::swap_status
inherited

Definition at line 238 of file Store.h.

Referenced by addedEntry(), StoreEntry::attachToDisk(), StoreEntry::checkDisk(), describeStatuses(), StoreEntry::detachFromDisk(), StoreEntry::dump(), operator<<(), StoreEntry::storeClientType(), storeSwapOutFileClosed(), storeSwapOutStart(), StoreEntry::swapoutFailed(), StoreEntry::swappedOut(), StoreEntry::swappingOut(), and testRock::testRockSwapOut().

◆ timestamp

time_t StoreEntry::timestamp
inherited

Definition at line 216 of file Store.h.

Referenced by Fs::Ufs::UFSSwapDir::addDiskRestore(), addedEntry(), clientReplyContext::buildReplyHeader(), StoreEntry::describeTimestamps(), StoreEntry::dump(), Ipc::StoreMapAnchor::exportInto(), htcpTstReply(), StoreEntry::lastModified(), Fs::Ufs::UFSSwapDir::logEntry(), InitStoreEntry::operator()(), Fs::Ufs::RebuildState::rebuildFromDirectory(), refreshCheck(), refreshStaleness(), StoreEntry::reset(), clientReplyContext::sendNotModified(), Ipc::StoreMapAnchor::set(), storeCreatePureEntry(), storeSwapMetaBuild(), StoreEntry::timestampsSet(), and UFSCleanLog::write().

The documentation for this class was generated from the following file:

 

Introduction

Documentation

Support

Miscellaneous

Web Site Translations

Mirrors