CapturingStoreEntry Class Reference

#include <CapturingStoreEntry.h>

Inheritance diagram for CapturingStoreEntry:

Collaboration diagram for CapturingStoreEntry:

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
HttpReply const *	getReply () 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
char const *	getSerialisedMetaData ()
void	storeErrorResponse (HttpReply *reply)
	Store a prepared error response. MemObject locks the reply object. More...
void	replaceHttpReply (HttpReply *, 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	registerAbort (STABH *cb, void *)
void	reset ()
void	setMemStatus (mem_status_t)
bool	timestampsSet ()
void	unregisterAbort ()
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...
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)

Detailed Description

Definition at line 16 of file CapturingStoreEntry.h.

Member Typedef Documentation

EntryGuard

typedef Store::EntryGuard StoreEntry::EntryGuard

protectedinherited

Definition at line 287 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 265 of file Store.h.

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

Referenced by StoreEntry::unlock().

abort()

void StoreEntry::abort ( )

inherited

Definition at line 1113 of file store.cc.

References MemObject::abort, StatCounters::aborted_requests, assert, MemObject::abort_::callback, cbdataReferenceValid(), MemObject::abort_::data, DBG_IMPORTANT, debugs, EBIT_CLR, EBIT_SET, ENTRY_ABORTED, ENTRY_FWD_HDR_WAIT, eventAdd(), StoreEntry::flags, StoreEntry::getMD5Text(), HERE(), StoreEntry::invokeHandlers(), StoreEntry::lock(), StoreEntry::mem_obj, StoreEntry::negativeCache(), NOT_IN_MEMORY, NULL, StoreEntry::releaseRequest(), StoreEntry::setMemStatus(), statCounter, STORE_OK, STORE_PENDING, StoreEntry::store_status, StoreEntry::swapOutFileClose(), StoreEntry::unlock(), StoreEntry::unregisterAbort(), and StoreIOState::writerGone.

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

append()

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

inlinevirtual

Reimplemented from StoreEntry.

Definition at line 35 of file CapturingStoreEntry.h.

References String::append().

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(), Adaptation::Icap::Xaction::fillDoneStatus(), Adaptation::Icap::ModXact::fillDoneStatus(), Adaptation::Icap::Xaction::fillPendingStatus(), Adaptation::Icap::ModXact::fillPendingStatus(), HttpStateData::getMoreRequestBody(), gopherSendRequest(), Ftp::Server::handleEpsvReply(), Ftp::Server::handlePasvReply(), helperDispatch(), httpHdrContRangePackInto(), httpHdrRangeRespSpecPackInto(), internalRemoteUri(), Adaptation::Icap::ModXact::makeAllowHeader(), Adaptation::Icap::OptXact::makeRequest(), Adaptation::Icap::ModXact::makeRequestHeaders(), Adaptation::Icap::ModXact::makeUsernameHeader(), memBufReport(), munge_menu_line(), munge_other_line(), Adaptation::Icap::ModXact::openChunk(), 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(), ExternalACLLookup::Start(), Ident::Start(), MemObject::stat(), statStoreEntry(), Ipc::Inquirer::status(), Comm::TcpAcceptor::status(), AsyncJob::status(), Adaptation::Ecap::XactionRep::status(), Security::PeerConnector::status(), Adaptation::Icap::Xaction::status(), BodyPipe::status(), Adaptation::Icap::ServiceRep::status(), tunnelRelayConnectRequest(), wordlistCat(), Ftp::Server::writeCustomReply(), Ftp::Server::writeEarlyReply(), and Ftp::Server::writeErrorReply().

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 2014 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(), StoreEntry::lastModified(), 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.

bytesWanted()

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

inherited

Definition at line 229 of file store.cc.

References Range< C, S >::end, and NULL.

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

cacheInMemory()

void StoreEntry::cacheInMemory ( )

inherited

Referenced by StoreEntry::publicKey().

cacheNegatively()

bool StoreEntry::cacheNegatively ( )

inherited

Definition at line 166 of file store.cc.

Referenced by HttpStateData::haveParsedReplyHeaders(), and StoreEntry::publicKey().

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 958 of file store.cc.

References StoreEntry::checkTooBig(), StoreEntry::checkTooSmall(), debugs, _store_check_cachable_hist::Default, EBIT_TEST, ENTRY_BAD_LENGTH, ENTRY_NEGCACHED, fdNFree(), StoreEntry::flags, StoreEntry::getReply(), StoreEntry::hasDisk(), KEY_PRIVATE, StoreEntry::mem_obj, MemObject::method, Http::METHOD_GET, _store_check_cachable_hist::missing_parts, _store_check_cachable_hist::negative_cached, _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(), storeSwapOutFileClosed(), and StoreEntry::swapoutFailed().

checkDeferRead()

bool StoreEntry::checkDeferRead ( int  fd ) const

inherited

Definition at line 247 of file store.cc.

References INT_MAX.

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

checkDisk()

void StoreEntry::checkDisk ( ) const

protectedinherited

Definition at line 2036 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 1366 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(), and StoreEntry::swapoutFailed().

checkTooSmall()

int StoreEntry::checkTooSmall ( )

inherited

Definition at line 929 of file store.cc.

References Config, EBIT_TEST, ENTRY_SPECIAL, StoreEntry::flags, StoreEntry::getReply(), StoreEntry::mem_obj, SquidConfig::minObjectSize, MemObject::object_sz, SquidConfig::Store, STORE_OK, and StoreEntry::store_status.

Referenced by StoreEntry::checkCachable(), and StoreEntry::swapoutFailed().

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 158 of file store.cc.

References assert, EBIT_CLR, EBIT_TEST, KEY_PRIVATE, and RELEASE_REQUEST.

Referenced by StoreEntry::forcePublicKey(), and StoreEntry::isEmpty().

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 633 of file store.cc.

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

Referenced by clientReplyContext::handleIMSReply(), and StoreEntry::isEmpty().

complete()

void StoreEntry::complete ( )

inherited

Definition at line 1064 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(), StoreEntry::isEmpty(), netdbBinaryExchange(), clientReplyContext::processMiss(), clientReplyContext::purgeDoPurgeHead(), Mgr::Forwarder::sendError(), clientReplyContext::sendNotModified(), CacheManager::start(), statObjects(), storeDigestRewriteFinish(), StoreEntry::storeErrorResponse(), testUfs::testUfsSearch(), clientReplyContext::traceReply(), and urnHandleReply().

contentLen()

int64_t StoreEntry::contentLen ( ) const

inherited

Definition at line 1668 of file store.cc.

References assert, StoreEntry::getReply(), Http::Message::hdr_sz, StoreEntry::mem_obj, NULL, and StoreEntry::objectLen().

Referenced by StoreEntry::modifiedSince(), 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 1615 of file store.cc.

References assert, and StoreEntry::mem_obj.

Referenced by Rock::SwapDir::get(), MemStore::get(), Transients::get(), storeCreatePureEntry(), StoreEntry::swapoutFailed(), testStoreHashIndex::testMaxSize(), testStoreController::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 1622 of file store.cc.

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

deferProducer()

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

inherited

Definition at line 358 of file store.cc.

References debugs, and StoreEntry::deferredProducer.

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

delayAwareRead()

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

inherited

Definition at line 203 of file store.cc.

References assert, comm_read(), debugs, Comm::Connection::fd, and fd_table.

Referenced by StoreEntry::getMD5Text(), gopherSendComplete(), Ftp::Client::maybeReadVirginBody(), and StoreEntry::swapoutFailed().

describeTimestamps()

const char * StoreEntry::describeTimestamps ( ) const

inherited

Returns

a formatted string with entry's timestamps

Definition at line 2075 of file store.cc.

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

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

destroyMemObject()

void StoreEntry::destroyMemObject ( )

inherited

Definition at line 378 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(), Store::Controller::memoryEvictCached(), and StoreEntry::swapoutFailed().

detachFromDisk()

void StoreEntry::detachFromDisk ( )

inherited

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

Definition at line 2028 of file store.cc.

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

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

disk()

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

inherited

Definition at line 1994 of file store.cc.

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

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

dump()

void StoreEntry::dump ( int  debug_lvl ) const

inherited

Definition at line 1539 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(), dump_acl_list(), Fs::Ufs::UFSSwapDir::dumpEntry(), clientReplyContext::processMiss(), and StoreEntry::swapoutFailed().

ensureMemObject()

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

inherited

Definition at line 1629 of file store.cc.

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

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

expireNow()

void StoreEntry::expireNow ( )

inherited

Definition at line 796 of file store.cc.

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

Referenced by StoreEntry::publicKey().

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.

getMD5Text()

const char * StoreEntry::getMD5Text ( ) const

inherited

Definition at line 185 of file store.cc.

References CommRead::buf, CommRead::callback, CommRead::conn, StoreEntry::DeferReader, StoreEntry::delayAwareRead(), CommRead::len, 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::lock(), neighborsUdpPing(), HttpStateData::processReplyHeader(), 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 515 of file store.cc.

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

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

getPublicByRequest()

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

staticinherited

Definition at line 508 of file store.cc.

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

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

getPublicByRequestMethod()

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

staticinherited

Definition at line 501 of file store.cc.

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

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

getReply()

HttpReply const * StoreEntry::getReply ( ) const

inherited

Definition at line 1676 of file store.cc.

References RefCount< C >::getRaw(), MemObject::getReply(), and StoreEntry::mem_obj.

Referenced by testRock::addEntry(), StoreEntry::append(), asHandleReply(), Client::blockCaching(), clientReplyContext::blockedHit(), StoreEntry::checkCachable(), CheckQuickAbortIsReasonable(), StoreEntry::checkTooBig(), StoreEntry::checkTooSmall(), clientReplyContext::cloneReply(), FwdState::complete(), StoreEntry::contentLen(), MemStore::copyFromShmSlice(), testRock::createEntry(), clientReplyContext::handleIMSReply(), StoreEntry::hasEtag(), StoreEntry::hasOneOfEtags(), StoreEntry::modifiedSince(), netdbExchangeHandleReply(), peerDigestFetchReply(), peerDigestSwapInCBlock(), peerDigestSwapInHeaders(), clientReplyContext::processConditional(), store_client::readBody(), FwdState::reforward(), refreshIsCachable(), clientReplyContext::replyStatus(), clientReplyContext::sendNotModified(), StoreEntry::startWriting(), storeLog(), testUfs::testUfsSearch(), StoreEntry::timestampsSet(), MemStore::updateHeadersOrThrow(), Store::Controller::updateOnNotModified(), urnHandleReply(), StoreEntry::validLength(), and varyEvaluateMatch().

getSerialisedMetaData()

char const * StoreEntry::getSerialisedMetaData ( )

inherited

Definition at line 1831 of file store.cc.

References assert, StoreEntry::mem_obj, size_t, storeSwapMetaBuild(), storeSwapMetaPack(), storeSwapTLVFree(), and MemObject::swap_hdr_sz.

Referenced by StoreEntry::isEmpty(), Rock::HeaderUpdater::startWriting(), and 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 2003 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::lastModified(), 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 1936 of file store.cc.

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

Referenced by StoreEntry::lastModified(), and clientReplyContext::processExpired().

hashDelete()

void StoreEntry::hashDelete ( )

inherited

Definition at line 427 of file store.cc.

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

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

hashInsert()

void StoreEntry::hashInsert ( const cache_key *  someKey )

inherited

Definition at line 418 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(), StoreEntry::setPrivateKey(), and StoreEntry::swapoutFailed().

hasIfMatchEtag()

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

inherited

Definition at line 1947 of file store.cc.

References HttpHeader::getList(), StoreEntry::hasOneOfEtags(), Http::Message::header, and Http::IF_MATCH.

Referenced by StoreEntry::lastModified(), and clientReplyContext::processConditional().

hasIfNoneMatchEtag()

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

inherited

Definition at line 1954 of file store.cc.

References HttpRequest::flags, HttpHeader::getList(), StoreEntry::hasOneOfEtags(), Http::Message::header, Http::IF_NONE_MATCH, RequestFlags::isRanged, HttpRequest::method, Http::METHOD_GET, and Http::METHOD_HEAD.

Referenced by StoreEntry::lastModified(), and clientReplyContext::processConditional().

hasMemStore()

bool StoreEntry::hasMemStore ( ) const

inlineinherited

Definition at line 191 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().

hasTransients()

bool StoreEntry::hasTransients ( ) const

inlineinherited

Definition at line 189 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::checkTransients(), Transients::clearCollapsingRequirement(), Transients::completeWriting(), StoreEntry::destroyMemObject(), Transients::disconnect(), Transients::evictCached(), 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 194 of file Store.h.

References EBIT_TEST, ENTRY_REQUIRES_COLLAPSING, StoreEntry::flags, and StoreEntry::setCollapsingRequirement().

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

inUseCount()

size_t StoreEntry::inUseCount ( )

staticinherited

Definition at line 177 of file store.cc.

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

invokeHandlers()

void StoreEntry::invokeHandlers ( )

inherited

Todo:

argh, why both?

Definition at line 756 of file store_client.cc.

References store_client::_callback, dlink_node::data, debugs, DELAY_SENDING, store_client::disk_io_pending, EBIT_TEST, ENTRY_FWD_HDR_WAIT, store_client::flags, i, dlink_node::next, store_client::node, NULL, store_client::Callback::pending(), PROF_start, PROF_stop, sc, and storeClientCopy2().

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

isAccepting()

bool StoreEntry::isAccepting ( ) const

inherited

Definition at line 2063 of file store.cc.

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

Referenced by Client::abortOnBadEntry(), StoreEntry::isEmpty(), and HttpStateData::processReplyBody().

isEmpty()

bool StoreEntry::isEmpty ( ) const

inlineinherited

Check if the Store entry is empty

Return values

true	Store contains 0 bytes of data.
false	Store contains 1 or more bytes of data.
false	Store contains negative content !!!!!!

Definition at line 60 of file Store.h.

References StoreEntry::abort(), assert, StoreEntry::bytesWanted(), StoreEntry::clearPrivate(), StoreEntry::clearPublicKeyScope(), StoreEntry::complete(), MemObject::endOffset(), StoreEntry::getSerialisedMetaData(), StoreEntry::isAccepting(), ksDefault, StoreEntry::lengthWentBad(), StoreEntry::makePrivate(), StoreEntry::makePublic(), StoreEntry::mayStartSwapOut(), StoreEntry::mem_obj, StoreEntry::memOutDecision(), StoreEntry::replaceHttpReply(), StoreEntry::setPublicKey(), StoreEntry::startWriting(), StoreEntry::storeClientType(), StoreEntry::storeErrorResponse(), StoreEntry::swapOutDecision(), and StoreEntry::trimMemory().

Referenced by Ftp::Gateway::appendSuccessHeader(), FwdState::checkRetry(), FwdState::completed(), Ssl::ServerBump::connectedOk(), FwdState::connectTimeout(), errorAppendEntry(), Ftp::Relay::failed(), Ftp::Client::failed(), Ftp::Relay::forwardReply(), gopherMimeCreate(), gopherReadReply(), Client::handleAdaptationAborted(), Client::handleAdaptationBlocked(), ClientHttpRequest::handleAdaptationFailure(), Client::handledEarlyAdaptationAbort(), HttpStateData::handleRequestBodyProducerAborted(), FwdState::retryOrBail(), and StoreEntry::startWriting().

kickProducer()

void StoreEntry::kickProducer ( )

inherited

Definition at line 368 of file store.cc.

References StoreEntry::deferredProducer, NULL, and ScheduleCallHere.

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

lastModified() [1/2]

void StoreEntry::lastModified ( const time_t  when )

inlineinherited

Definition at line 159 of file Store.h.

References StoreEntry::lastModified_.

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

lastModified() [2/2]

time_t StoreEntry::lastModified ( ) const

inlineinherited

Returns

entry's 'effective' modification time

Definition at line 161 of file Store.h.

References StoreEntry::attachToDisk(), StoreEntry::describeTimestamps(), StoreEntry::detachFromDisk(), StoreEntry::disk(), StoreEntry::hasDisk(), StoreEntry::hasEtag(), StoreEntry::hasIfMatchEtag(), StoreEntry::hasIfNoneMatchEtag(), StoreEntry::lastModified_, StoreEntry::modifiedSince(), request(), and StoreEntry::timestamp.

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

lengthWentBad()

void StoreEntry::lengthWentBad ( const char *  reason )

inherited

Definition at line 1056 of file store.cc.

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

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

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 439 of file store.cc.

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

Referenced by StoreEntry::abort(), Client::Client(), Ftp::Gateway::completedListing(), 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(), statObjectsStart(), storeCreateEntry(), StoreEntry::storeErrorResponse(), Ipc::StoreMapUpdate::StoreMapUpdate(), storeSwapOutStart(), storeUnregister(), testPackableStream::testGetStream(), and whoisStart().

locked()

int StoreEntry::locked ( ) const

inherited

Definition at line 1255 of file store.cc.

References EBIT_TEST, ENTRY_SPECIAL, StoreEntry::flags, KEY_PRIVATE, and StoreEntry::lock_count.

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

locks()

int StoreEntry::locks ( ) const

inlineinherited

Definition at line 250 of file Store.h.

References StoreEntry::lock_count, StoreEntry::release(), and StoreEntry::touch().

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

makePrivate()

void StoreEntry::makePrivate ( const bool  shareable )

inherited

Definition at line 152 of file store.cc.

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

makePublic()

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

inherited

Definition at line 145 of file store.cc.

References EBIT_TEST, and RELEASE_REQUEST.

Referenced by StoreEntry::adjustVary(), Store::Controller::allowCollapsing(), gopherSendRequest(), HttpStateData::haveParsedReplyHeaders(), Ftp::Gateway::haveParsedReplyHeaders(), StoreEntry::isEmpty(), 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 269 of file Store.h.

References StoreEntry::append(), StoreEntry::buffer(), StoreEntry::deferProducer(), EBIT_TEST, StoreEntry::flush(), KEY_PRIVATE, StoreEntry::kickProducer(), StoreEntry::shareableWhenPrivate, and StoreEntry::vappendf().

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::isEmpty(), and StoreEntry::swapOut().

memoryCachable()

bool StoreEntry::memoryCachable ( )

inherited

Definition at line 1345 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(), MemStore::shouldCache(), and StoreEntry::swapoutFailed().

memOutDecision()

void StoreEntry::memOutDecision ( const bool  willCacheInRam )

inherited

Definition at line 1862 of file store.cc.

References StoreEntry::transientsAbandonmentCheck().

Referenced by StoreEntry::isEmpty(), 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 1899 of file store.cc.

References Http::Message::content_length, StoreEntry::contentLen(), debugs, StoreEntry::getReply(), StoreEntry::lastModified(), and StoreEntry::url().

Referenced by clientIfRangeMatch(), clientReplyContext::handleIMSReply(), StoreEntry::lastModified(), 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 1387 of file store.cc.

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

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

objectLen()

int64_t StoreEntry::objectLen ( ) const

inherited

Definition at line 1661 of file store.cc.

References assert, StoreEntry::mem_obj, NULL, and MemObject::object_sz.

Referenced by StoreEntry::contentLen(), Mgr::StoreToCommWriter::doneAll(), 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 139 of file store.cc.

operator new()

void * StoreEntry::operator new ( size_t  byteCount )

inherited

Definition at line 127 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 98 of file Store.h.

References StoreEntry::cacheInMemory(), StoreEntry::cacheNegatively(), EBIT_TEST, StoreEntry::expireNow(), StoreEntry::flags, StoreEntry::invokeHandlers(), hash_link::key, KEY_PRIVATE, StoreEntry::negativeCache(), StoreEntry::releaseRequest(), StoreEntry::setPrivateKey(), and StoreEntry::swapOut().

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

registerAbort()

void StoreEntry::registerAbort ( STABH *  cb, void *  data  )

inherited

Definition at line 1520 of file store.cc.

References MemObject::abort, assert, MemObject::abort_::callback, cbdataReference, MemObject::abort_::data, StoreEntry::mem_obj, and NULL.

Referenced by Ftp::Relay::Relay(), Mgr::StoreToCommWriter::start(), FwdState::start(), and StoreEntry::swapoutFailed().

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 1195 of file store.cc.

References debugs, destroyStoreEntry(), Store::Controller::evictCached(), StoreEntry::getMD5Text(), StoreEntry::hasDisk(), 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(), StoreEntry::locks(), 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 452 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(), peerDigestFetchFinish(), peerDigestFetchReply(), clientReplyContext::processMiss(), StoreEntry::publicKey(), Ftp::Relay::Relay(), StoreEntry::release(), StoreEntry::storeErrorResponse(), storeSwapOutFileClosed(), and clientReplyContext::traceReply().

replaceHttpReply()

void StoreEntry::replaceHttpReply ( HttpReply *  rep, bool  andStartWriting = true  )

inherited

Definition at line 1788 of file store.cc.

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

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

reset()

void StoreEntry::reset ( )

inherited

Definition at line 1682 of file store.cc.

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

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

setCollapsingRequirement()

void StoreEntry::setCollapsingRequirement ( const bool  required )

inherited

Definition at line 2087 of file store.cc.

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

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

setMemStatus()

void StoreEntry::setMemStatus ( mem_status_t  new_status )

inherited

Definition at line 1564 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(), Store::Controller::handleIdleEntry(), and StoreEntry::swapoutFailed().

setNoDelay()

void StoreEntry::setNoDelay ( bool const  newValue )

inherited

Definition at line 253 of file store.cc.

Referenced by HttpStateData::HttpStateData(), and StoreEntry::swapoutFailed().

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

permanent

whether this entry should be private forever.

Definition at line 566 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::publicKey(), StoreEntry::releaseRequest(), and storeCreateEntry().

setPublicKey()

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

inherited

Definition at line 593 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::isEmpty(), storeCreateEntry(), storeDigestRewriteResume(), and testUfs::testUfsSearch().

startWriting()

void StoreEntry::startWriting ( )

inherited

pack and write reply headers and, maybe, body

Definition at line 1804 of file store.cc.

References assert, HttpReply::body, StoreEntry::buffer(), StoreEntry::flush(), StoreEntry::getReply(), StoreEntry::hittingRequiresCollapsing(), StoreEntry::isEmpty(), MemObject::markEndOfReplyHeaders(), StoreEntry::mem_obj, HttpReply::packHeadersUsingSlowPacker(), HttpBody::packInto(), Store::Root(), StoreEntry::setCollapsingRequirement(), and Store::Controller::transientsClearCollapsingRequirement().

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

storeClientType()

store_client_t StoreEntry::storeClientType ( ) const

inherited

Definition at line 267 of file store.cc.

References assert, DBG_IMPORTANT, debugs, EBIT_TEST, ENTRY_ABORTED, HERE(), STORE_DISK_CLIENT, STORE_MEM_CLIENT, STORE_OK, and SWAPOUT_NONE.

Referenced by StoreEntry::isEmpty().

storeErrorResponse()

void StoreEntry::storeErrorResponse ( HttpReply *  reply )

inherited

Definition at line 1771 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(), StoreEntry::isEmpty(), 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::publicKey(), storeUnregister(), and testUfs::testUfsSearch().

swapOutDecision()

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

inherited

Definition at line 1868 of file store.cc.

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

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

swapoutFailed()

bool StoreEntry::swapoutFailed ( ) const

inlineinherited

Definition at line 123 of file Store.h.

References buf, callback, StoreEntry::checkCachable(), StoreEntry::checkNegativeHit(), StoreEntry::checkTooSmall(), conn, StoreEntry::createMemObject(), StoreEntry::delayAwareRead(), StoreEntry::destroyMemObject(), StoreEntry::dump(), StoreEntry::ensureMemObject(), StoreEntry::hashDelete(), StoreEntry::hashInsert(), len, StoreEntry::locked(), StoreEntry::memoryCachable(), StoreEntry::registerAbort(), StoreEntry::reset(), StoreEntry::setMemStatus(), StoreEntry::setNoDelay(), storeId(), StoreEntry::swap_status, SWAPOUT_FAILED, StoreEntry::swapOutFileClose(), StoreEntry::timestampsSet(), StoreEntry::unregisterAbort(), StoreEntry::url(), and StoreEntry::validToSend().

Referenced by StoreEntry::checkDisk(), store_client::store_client(), 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(), StoreEntry::swapOut(), and StoreEntry::swapoutFailed().

swappedOut()

bool StoreEntry::swappedOut ( ) const

inlineinherited

Definition at line 121 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(), and storeUnregister().

swappingOut()

bool StoreEntry::swappingOut ( ) const

inlineinherited

Definition at line 119 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 1460 of file store.cc.

References Http::AGE, HttpReply::date, HttpReply::expires, StoreEntry::expires, HttpHeader::getInt(), StoreEntry::getReply(), Http::Message::header, HttpRequest::hier, HttpReply::last_modified, StoreEntry::lastModified(), StoreEntry::lastModified_, 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(), StoreEntry::swapoutFailed(), testUfs::testUfsSearch(), and Store::Controller::updateOnNotModified().

touch()

void StoreEntry::touch ( )

inherited

Definition at line 446 of file store.cc.

References StoreEntry::lastref, and squid_curtime.

Referenced by StoreEntry::locks().

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 1849 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 1877 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 StoreEntry::isEmpty(), and Store::Controller::memoryOut().

unlock()

int StoreEntry::unlock ( const char *  context )

inherited

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

Definition at line 463 of file store.cc.

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

Referenced by StoreEntry::abort(), StoreEntry::adjustVary(), Ftp::Gateway::completedListing(), store_client::copy(), MimeIcon::created(), ClientHttpRequest::doCallouts(), clientReplyContext::forgetHit(), heap_purgeDone(), ClientHttpRequest::loggingEntry(), peerCountMcastPeersDone(), peerDigestFetchFinish(), peerDigestFetchReply(), clientReplyContext::removeStoreReference(), statObjects(), storeDigestRewriteFinish(), StoreEntry::storeErrorResponse(), storeLateRelease(), storeSwapOutFileClosed(), storeUnregister(), Mgr::StoreToCommWriter::swanSong(), GopherStateData::swanSong(), testRock::testRockSwapOut(), testUfs::testUfsSearch(), urnHandleReplyError(), whoisClose(), Client::~Client(), DigestFetchState::~DigestFetchState(), Mgr::Forwarder::~Forwarder(), FwdState::~FwdState(), Rock::IoState::~IoState(), netdbExchangeState::~netdbExchangeState(), Ssl::ServerBump::~ServerBump(), and Ipc::StoreMapUpdate::~StoreMapUpdate().

unregisterAbort()

void StoreEntry::unregisterAbort ( )

inherited

Definition at line 1529 of file store.cc.

References MemObject::abort, assert, MemObject::abort_::callback, cbdataReferenceDone, MemObject::abort_::data, StoreEntry::mem_obj, and NULL.

Referenced by StoreEntry::abort(), Mgr::StoreToCommWriter::swanSong(), StoreEntry::swapoutFailed(), and FwdState::~FwdState().

url()

const char * StoreEntry::url ( ) const

inherited

Definition at line 1606 of file store.cc.

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

Referenced by asHandleReply(), FwdState::complete(), FwdState::connectDone(), FwdState::connectStart(), FwdState::connectTimeout(), HttpStateData::continueAfterParsingHeader(), FwdState::dispatch(), FwdState::fail(), ftpSendReply(), FwdState::FwdState(), Ftp::Gateway::Gateway(), gopherSendComplete(), gopherStart(), gopherTimeout(), gopherToHTML(), Mgr::Forwarder::handleError(), clientReplyContext::handleIMSReply(), HttpStateData::handleMoreRequestBodyAvailable(), FwdState::handleUnregisteredServerEnd(), htcpClear(), htcpClrStoreEntry(), htcpQuery(), HttpStateData::httpBuildRequestHeader(), httpStart(), HttpStateData::httpTimeout(), HttpStateData::keepaliveAccounting(), Ftp::Gateway::listenForDataChannel(), StoreEntry::mayStartSwapOut(), StoreEntry::modifiedSince(), neighborsUdpPing(), Ftp::Gateway::parseListing(), 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(), storeKeyPublicByRequestMethod(), storeSwapMetaBuild(), storeSwapOutFileClosed(), storeSwapOutStart(), StoreEntry::swapOut(), StoreEntry::swapoutFailed(), Ftp::Client::timeout(), FwdState::unregister(), PeerSelector::url(), urnHandleReply(), FwdState::useDestinations(), whoisTimeout(), Ftp::Gateway::~Gateway(), and netdbExchangeState::~netdbExchangeState().

validToSend()

int StoreEntry::validToSend ( ) const

inherited

Definition at line 1420 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(), htcpSpecifier::created(), and StoreEntry::swapoutFailed().

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 847 of file store.cc.

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

Referenced by StoreEntry::mayStartHitting(), storeAppendPrintf(), and storeAppendVPrintf().

write()

void StoreEntry::write ( StoreIOBuffer  writeBuffer )

inherited

Definition at line 803 of file store.cc.

References assert, debugs, EBIT_CLR, EBIT_TEST, ENTRY_FWD_HDR_WAIT, StoreEntry::flags, StoreEntry::getMD5Text(), MemObject::getReply(), 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 testEvent::testDump(), and testPackableStream::testGetStream().

_buffer_calls

int CapturingStoreEntry::_buffer_calls

Definition at line 24 of file CapturingStoreEntry.h.

Referenced by testPackableStream::testGetStream().

_flush_calls

int CapturingStoreEntry::_flush_calls

Definition at line 25 of file CapturingStoreEntry.h.

Referenced by testPackableStream::testGetStream().

cachedESITree

ESIElement::Pointer StoreEntry::cachedESITree

inherited

Definition at line 236 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::getMD5Text().

expires

time_t StoreEntry::expires

inherited

Definition at line 204 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(), peerDigestFetchSetStats(), peerDigestNewDelay(), Fs::Ufs::RebuildState::rebuildFromDirectory(), refreshStaleness(), StoreEntry::reset(), Mgr::Forwarder::sendError(), Ipc::StoreMapAnchor::set(), CacheManager::start(), storeDigestRewriteFinish(), StoreEntry::timestampsSet(), StoreEntry::validToSend(), and UFSCleanLog::write().

flags

uint16_t StoreEntry::flags

inherited

Definition at line 210 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::clearPublicKeyScope(), StoreEntry::complete(), FwdState::completed(), store_client::copy(), MemStore::copyToShm(), MimeIcon::created(), Ftp::Client::dataRead(), Store::Controller::dereferenceIdle(), FwdState::dispatch(), StoreEntry::doAbandon(), dummy_action(), errorAppendEntry(), clientReplyContext::errorInStream(), Store::Disks::evictCached(), Ipc::StoreMapAnchor::exportInto(), StoreEntry::flush(), Ftp::Gateway::ftpAcceptDataConnection(), gopherReadReply(), Store::Controller::handleIdleEntry(), clientReplyContext::handleIMSReply(), Http::One::Server::handleReply(), HttpStateData::haveParsedReplyHeaders(), heap_add(), StoreEntry::hittingRequiresCollapsing(), httpMaybeRemovePublic(), StoreEntry::isAccepting(), StoreEntry::lengthWentBad(), StoreEntry::locked(), Fs::Ufs::UFSSwapDir::logEntry(), StoreEntry::mayStartSwapOut(), StoreEntry::negativeCache(), neighborsHtcpReply(), neighborsUdpAck(), netdbExchangeHandleReply(), operator<<(), peerDigestFetchedEnough(), peerDigestRequest(), peerSelectIcpPing(), clientReplyContext::processExpired(), Ftp::Gateway::processHeadResponse(), clientReplyContext::processMiss(), Ftp::Relay::processReplyBody(), HttpStateData::processReplyBody(), Ftp::Gateway::processReplyBody(), StoreEntry::publicKey(), clientReplyContext::purgeFoundObject(), Ftp::Client::readControlReply(), 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(), storeCreatePureEntry(), storeDigestAddable(), storeDigestDel(), storeDigestRewriteResume(), storeDirSwapLog(), storeEntryFlags(), storeRebuildParseEntry(), storeSwapInStart(), StoreEntry::swapOut(), Store::Controller::syncCollapsed(), testCacheManager::testRegister(), StoreEntry::trimMemory(), urnHandleReply(), StoreEntry::validToSend(), StoreEntry::write(), and UFSCleanLog::write().

key

void* hash_link::key

inherited

Definition at line 19 of file hash.h.

Referenced by accessLogInit(), aclMatchExternal(), MemStore::anchorToCache(), Rock::SwapDir::anchorToCache(), cacheIndexCmp(), StoreMetaMD5::checkConsistency(), StoreEntry::clearPublicKeyScope(), client_entry(), clientdbCutoffDenied(), clientdbEstablished(), clientdbGetInfo(), clientdbUpdate(), ClientInfo::ClientInfo(), Rock::SwapDir::createStoreIO(), CommQuotaQueue::dequeue(), destroyStoreEntry(), LeakFinder::dump(), CommQuotaQueue::enqueue(), external_acl_cache_add(), StoreEntry::forcePublicKey(), fqdncache_entry::fqdncache_entry(), fqdncacheAddEntry(), fqdncacheParse(), hash_join(), hash_lookup(), hash_remove_link(), hash_unlink(), StoreEntry::hashDelete(), hashFreeMemory(), StoreEntry::hashInsert(), hashKeyStr(), Rock::SwapDir::hasReadableEntry(), htcpQuery(), IdleConnList::IdleConnList(), idnsCallback(), idnsStartQuery(), ipcache_entry::ipcache_entry(), ipcacheAddEntry(), ipcacheRelease(), LeakFinderPtr::LeakFinderPtr(), Fs::Ufs::UFSSwapDir::logEntry(), Store::Controller::markedForDeletionAndAbandoned(), my_free(), ipcache_entry::name(), neighborsUdpPing(), net_db_name::net_db_name(), netdbHashInsert(), netdbLookupAddr(), PconnPool::noteConnectionRemoved(), Ipc::StoreMap::openForUpdating(), Rock::SwapDir::openStoreIO(), peerCountMcastPeersStart(), StoreEntry::publicKey(), read_passwd_file(), Ipc::StoreMapAnchor::set(), StoreEntry::setPrivateKey(), StoreEntry::setPublicKey(), ClientInfo::setWriteLimiter(), snmp_meshCtblFn(), Ident::Start(), MemStore::startCaching(), storeDigestAdd(), storeDigestDel(), storeKeyPrivate(), storeRebuildParseEntry(), storeSwapMetaBuild(), UFSCleanLog::write(), Rock::IoState::writeBufToDisk(), ClientInfo::~ClientInfo(), ExternalACLEntry::~ExternalACLEntry(), fqdncache_entry::~fqdncache_entry(), IdleConnList::~IdleConnList(), ipcache_entry::~ipcache_entry(), and net_db_name::~net_db_name().

lastref

time_t StoreEntry::lastref

inherited

Definition at line 203 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(), Fs::Ufs::RebuildState::rebuildFromDirectory(), Ipc::StoreMapAnchor::set(), storeCreatePureEntry(), StoreEntry::touch(), and UFSCleanLog::write().

mem_obj

MemObject* StoreEntry::mem_obj

inherited

Definition at line 199 of file Store.h.

Referenced by StoreEntry::abort(), Store::Disks::accumulateMore(), Transients::addEntry(), StoreEntry::adjustVary(), MemStore::anchorEntry(), StoreEntry::append(), CollapsedForwarding::Broadcast(), 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(), FwdState::connectStart(), StoreEntry::contentLen(), store_client::copy(), MemStore::copyFromShm(), MemStore::copyFromShmSlice(), MemStore::copyToShm(), MemStore::copyToShmSlice(), MimeIcon::created(), StoreEntry::createMemObject(), Ftp::Client::dataRead(), Store::Controller::dereferenceIdle(), StoreEntry::destroyMemObject(), Rock::SwapDir::disconnect(), MemStore::disconnect(), Transients::disconnect(), store_client::doCopy(), doPages(), StoreEntry::dump(), StoreEntry::ensureMemObject(), errorAppendEntry(), MemStore::evictCached(), Transients::evictCached(), store_client::fileRead(), findPreviouslyCachedEntry(), StoreEntry::forcePublicKey(), Transients::get(), StoreEntry::getReply(), StoreEntry::getSerialisedMetaData(), gopherReadReply(), Store::Controller::handleIdleEntry(), StoreEntry::hasMemStore(), StoreEntry::hasTransients(), HttpStateData::haveParsedReplyHeaders(), heap_guessType(), HeapKeyGen_StoreEntry_GDSF(), HeapKeyGen_StoreEntry_LFUDA(), HeapKeyGen_StoreEntry_LRU(), htcpClear(), httpMaybeRemovePublic(), StoreEntry::isEmpty(), Transients::isReader(), Transients::isWriter(), Store::Controller::keepForLocalMemoryCache(), StoreEntry::mayStartSwapOut(), StoreEntry::memoryCachable(), Transients::monitorIo(), store_client::moreToSend(), neighborsHtcpReply(), neighborsUdpAck(), neighborsUdpPing(), StoreEntry::objectLen(), objectSizeForDirSelection(), operator<<(), peerCountHandleIcpReply(), peerCountMcastPeersDone(), peerCountMcastPeersStart(), peerDigestFetchReply(), peerDigestFetchSetStats(), HttpStateData::peerSupportsConnectionPinning(), HttpStateData::processReplyHeader(), store_client::readBody(), Transients::readers(), store_client::readHeader(), HttpStateData::readReply(), Store::Controller::referenceBusy(), FwdState::reforward(), refreshCheck(), refreshCheckDigest(), refreshIsCachable(), StoreEntry::registerAbort(), repl_guessType(), StoreEntry::replaceHttpReply(), StoreEntry::reset(), store_client::scheduleMemRead(), store_client::scheduleRead(), StoreEntry::setMemStatus(), LruPolicyData::setPolicyNode(), HeapPolicyData::setPolicyNode(), StoreEntry::setPrivateKey(), StoreEntry::setPublicKey(), MemStore::shouldCache(), FwdState::Start(), MemStore::startCaching(), Rock::HeaderUpdater::startWriting(), StoreEntry::startWriting(), statObjectsOpenfdFilter(), statObjectsVmFilter(), statStoreEntry(), Transients::status(), storeClientCopyPending(), storeClientListAdd(), 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::unregisterAbort(), MemStore::updateAnchored(), MemStore::updateHeaders(), 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 218 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(), and StoreEntry::trimMemory().

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_lookup(), hash_next(), hash_remove_link(), hash_unlink(), IdleConnList::IdleConnList(), LeakFinderPtr::LeakFinderPtr(), and lru_stats().

ping_status

ping_status_t StoreEntry::ping_status

inherited

Definition at line 220 of file Store.h.

Referenced by Fs::Ufs::UFSSwapDir::addDiskRestore(), addedEntry(), Rock::SwapDir::anchorEntry(), describeStatuses(), FwdState::dispatch(), StoreEntry::dump(), neighborsHtcpReply(), neighborsUdpAck(), operator<<(), peerCountMcastPeersStart(), peerSelectIcpPing(), FwdState::stopAndDestroy(), and storeCreatePureEntry().

refcount

uint16_t StoreEntry::refcount

inherited

Definition at line 209 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(), Fs::Ufs::RebuildState::rebuildFromDirectory(), Ipc::StoreMapAnchor::set(), statStoreEntry(), store_client::store_client(), storeCreatePureEntry(), and UFSCleanLog::write().

repl

RemovalPolicyNode StoreEntry::repl

inherited

Definition at line 200 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().

store_status

store_status_t StoreEntry::store_status

inherited

Definition at line 222 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(), Mgr::StoreToCommWriter::doneAll(), doPages(), StoreEntry::dump(), errorAppendEntry(), HttpStateData::httpTimeout(), StoreEntry::isAccepting(), StoreEntry::mayStartSwapOut(), store_client::moreToSend(), netdbExchangeHandleReply(), operator<<(), peerDigestPDFinish(), Ftp::Client::readControlReply(), FwdState::reforward(), storeCreatePureEntry(), storeDigestAddable(), storeUnregister(), StoreEntry::swapOut(), testStoreHashIndex::testMaxSize(), testStoreController::testMaxSize(), testStoreController::testStats(), testStoreHashIndex::testStats(), urnHandleReply(), MemStore::write(), and StoreEntry::write().

swap_dirn

sdirno StoreEntry::swap_dirn

inherited

Definition at line 216 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(), and Store::Disks::updateAnchored().

swap_file_sz

uint64_t StoreEntry::swap_file_sz

inherited

Definition at line 208 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(), 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 214 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 224 of file Store.h.

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

timestamp

time_t StoreEntry::timestamp

inherited

Definition at line 202 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(), 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:

• src/tests/CapturingStoreEntry.h