#include <Store.h>

Inheritance diagram for StoreEntry:

Collaboration diagram for StoreEntry:

Public Member Functions
bool	checkDeferRead (int fd) const

const char *	getMD5Text () const

	StoreEntry ()

virtual	~StoreEntry ()

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...

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	append (char const *, int)
	Appends a c-string to existing packed data. More...

virtual void	vappendf (const char *, va_list)

virtual void	buffer ()

virtual void	flush ()

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
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
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

Friends
std::ostream &	operator<< (std::ostream &os, const StoreEntry &e)

Detailed Description

Definition at line 41 of file Store.h.

Member Typedef Documentation

typedef Store::EntryGuard StoreEntry::EntryGuard

protected

Definition at line 285 of file Store.h.

Constructor & Destructor Documentation

StoreEntry::StoreEntry ( )

Definition at line 324 of file store.cc.

References debugs.

StoreEntry::~StoreEntry ( )

virtual

Definition at line 345 of file store.cc.

References debugs.

Member Function Documentation

void StoreEntry::abandon ( const char * context )

inline

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 263 of file Store.h.

References doAbandon(), and locked().

Referenced by unlock().

void StoreEntry::abort ( )

Definition at line 1107 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(), flags, getMD5Text(), HERE(), invokeHandlers(), lock(), mem_obj, negativeCache(), NOT_IN_MEMORY, NULL, releaseRequest(), setMemStatus(), statCounter, STORE_OK, STORE_PENDING, store_status, swapOutFileClose(), unlock(), unregisterAbort(), and StoreIOState::writerGone.

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

StoreEntry * StoreEntry::adjustVary ( )

private

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::exception on failures

Definition at line 683 of file store.cc.

References assert, String::clean(), SBuf::clear(), SBuf::cmp(), complete(), HttpRequest::flags, HttpHeader::getList(), RefCount< C >::getRaw(), MemObject::getReply(), Http::HDR_X_ACCELERATOR_VARY, Http::Message::header, httpMakeVaryMark(), SBuf::isEmpty(), MemObject::logUri(), makePublic(), mem_obj, MemObject::method, HttpRequest::method, HttpHeader::putStr(), replaceHttpReply(), MemObject::request, request(), Http::scOkay, HttpReply::setHeaders(), String::size(), squid_curtime, startWriting(), storeCreateEntry(), storeGetPublic(), MemObject::storeId(), String::termedBuf(), TexcHere, timestampsSet(), unlock(), Http::VARY, HttpRequest::vary_headers, and MemObject::vary_headers.

Referenced by setPublicKey().

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

virtual

Implements Packable.

Reimplemented in CapturingStoreEntry.

Definition at line 823 of file store.cc.

References assert, StoreIOBuffer::data, MemObject::endOffset(), getReply(), Http::Message::hdr_sz, len, StoreIOBuffer::length, mem_obj, NULL, StoreIOBuffer::offset, STORE_PENDING, store_status, and write().

Referenced by MimeIcon::created(), Format::Format::dump(), dump_SBufList(), DumpInfo(), gopherReadReply(), gopherToHTML(), internalStart(), netdbBinaryExchange(), WhoisState::readReply(), statObjects(), storeDigestCBlockSwapOut(), storeDigestSwapOutStep(), and vappendf().

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

inlineinherited

Definition at line 61 of file Packable.h.

References Packable::vappendf().

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

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

Definition at line 2008 of file store.cc.

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

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

void StoreEntry::buffer ( )

virtual

disable sending content to the clients.

This just sets DELAY_SENDING.

Reimplemented from Packable.

Reimplemented in CapturingStoreEntry.

Definition at line 1635 of file store.cc.

References DELAY_SENDING, EBIT_SET, and flags.

Referenced by testRock::addEntry(), MimeIcon::created(), Mgr::Action::fillEntry(), gopherMimeCreate(), gopherSendComplete(), netdbBinaryExchange(), WhoisState::setReplyToOK(), startWriting(), statObjects(), storeDigestRewriteResume(), storeErrorResponse(), HttpRequest::swapOut(), testUfs::testUfsSearch(), clientReplyContext::traceReply(), and urnHandleReply().

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

Definition at line 228 of file store.cc.

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

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

void StoreEntry::cacheInMemory ( )

bool StoreEntry::cacheNegatively ( )

Definition at line 165 of file store.cc.

References makePublic(), and negativeCache().

Referenced by HttpStateData::haveParsedReplyHeaders().

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

private

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

Definition at line 670 of file store.cc.

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

Referenced by clearPublicKeyScope(), and setPublicKey().

bool StoreEntry::checkCachable ( )

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

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

bool StoreEntry::checkDeferRead ( int fd ) const

Definition at line 246 of file store.cc.

References bytesWanted(), and INT_MAX.

Referenced by statObjects(), and swapOut().

void StoreEntry::checkDisk ( ) const

protected

Definition at line 2030 of file store.cc.

References SquidConfig::cacheSwap, Config, DBG_IMPORTANT, debugs, Store::DiskConfig::n_configured, swap_dirn, swap_filen, swap_status, and SWAPOUT_NONE.

Referenced by attachToDisk(), and hasDisk().

int StoreEntry::checkNegativeHit ( ) const

Definition at line 1360 of file store.cc.

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

Referenced by clientReplyContext::cacheHit().

bool StoreEntry::checkTooBig ( ) const

private

Definition at line 939 of file store.cc.

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

Referenced by checkCachable().

int StoreEntry::checkTooSmall ( )

Definition at line 923 of file store.cc.

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

Referenced by checkCachable().

void StoreEntry::clearPrivate ( )

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

Definition at line 157 of file store.cc.

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

Referenced by forcePublicKey().

void StoreEntry::clearPublicKeyScope ( )

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

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

Referenced by clientReplyContext::handleIMSReply().

void StoreEntry::complete ( )

Definition at line 1058 of file store.cc.

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

Referenced by testRock::addEntry(), 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(), storeErrorResponse(), testUfs::testUfsSearch(), clientReplyContext::traceReply(), and urnHandleReply().

int64_t StoreEntry::contentLen ( ) const

Definition at line 1662 of file store.cc.

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

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

void StoreEntry::createMemObject ( )

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

Definition at line 1609 of file store.cc.

References assert, and mem_obj.

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

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

Definition at line 1616 of file store.cc.

References assert, ensureMemObject(), and mem_obj.

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

Definition at line 352 of file store.cc.

References debugs, and deferredProducer.

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

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

Definition at line 202 of file store.cc.

References assert, bytesWanted(), comm_read(), debugs, DeferReader, MemObject::delayRead(), Comm::Connection::fd, fd_table, and mem_obj.

Referenced by gopherSendComplete().

const char * StoreEntry::describeTimestamps ( ) const

Returns: a formatted string with entry's timestamps

Definition at line 2059 of file store.cc.

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

Referenced by statStoreEntry().

void StoreEntry::destroyMemObject ( )

Definition at line 372 of file store.cc.

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

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

void StoreEntry::detachFromDisk ( )

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

Definition at line 2022 of file store.cc.

References swap_dirn, swap_filen, swap_status, and SWAPOUT_NONE.

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

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

Definition at line 1988 of file store.cc.

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

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

void StoreEntry::doAbandon ( const char * context )

private

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

Definition at line 474 of file store.cc.

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

Referenced by abandon().

void StoreEntry::dump ( int debug_lvl ) const

Definition at line 1533 of file store.cc.

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

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

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

Definition at line 1623 of file store.cc.

References mem_obj, and MemObject::setUris().

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

void StoreEntry::expireNow ( )

Definition at line 790 of file store.cc.

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

void StoreEntry::flush ( )

virtual

flush any buffered content.

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

Reimplemented from Packable.

Reimplemented in CapturingStoreEntry.

Definition at line 1646 of file store.cc.

References DELAY_SENDING, EBIT_CLR, EBIT_TEST, flags, and invokeHandlers().

Referenced by testRock::addEntry(), MimeIcon::created(), Mgr::Action::fillEntry(), gopherReadReply(), gopherSendComplete(), gopherToHTML(), netdbBinaryExchange(), WhoisState::readReply(), startWriting(), statObjects(), storeDigestRewriteResume(), storeErrorResponse(), HttpRequest::swapOut(), and testUfs::testUfsSearch().

void StoreEntry::forcePublicKey ( const cache_key * newkey )

private

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

Definition at line 644 of file store.cc.

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

Referenced by clearPublicKeyScope(), and setPublicKey().

const char * StoreEntry::getMD5Text ( ) const

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

static

Definition at line 509 of file store.cc.

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

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

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

static

Definition at line 502 of file store.cc.

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

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

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

static

Definition at line 495 of file store.cc.

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

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

HttpReply const * StoreEntry::getReply ( ) const

Definition at line 1670 of file store.cc.

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

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

char const * StoreEntry::getSerialisedMetaData ( )

Definition at line 1825 of file store.cc.

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

Referenced by storeSwapOutStart().

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

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

Definition at line 1997 of file store.cc.

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

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

bool StoreEntry::hasEtag ( ETag & etag ) const

Definition at line 1930 of file store.cc.

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

Referenced by clientReplyContext::processExpired().

void StoreEntry::hashDelete ( )

Definition at line 421 of file store.cc.

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

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

void StoreEntry::hashInsert ( const cache_key * someKey )

Definition at line 412 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(), forcePublicKey(), and setPrivateKey().

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

Definition at line 1941 of file store.cc.

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

Referenced by clientReplyContext::processConditional().

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

Definition at line 1948 of file store.cc.

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

Referenced by clientReplyContext::processConditional().

bool StoreEntry::hasMemStore ( ) const

inline

Definition at line 189 of file Store.h.

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

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

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

private

Definition at line 1959 of file store.cc.

References String::append(), Http::ETAG, etagIsStrongEqual(), etagIsWeakEqual(), etagParseInit(), HttpHeader::getETag(), getReply(), Http::Message::header, NULL, ETag::str, strListGetItem(), strListIsMember(), and String::termedBuf().

Referenced by hasIfMatchEtag(), and hasIfNoneMatchEtag().

bool StoreEntry::hasTransients ( ) const

inline

bool StoreEntry::hittingRequiresCollapsing ( ) const

inline

Definition at line 192 of file Store.h.

References EBIT_TEST, ENTRY_REQUIRES_COLLAPSING, and flags.

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

size_t StoreEntry::inUseCount ( )

static

Definition at line 176 of file store.cc.

References MemAllocator::getInUseCount(), and pool.

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

void StoreEntry::invokeHandlers ( )

Todo:: argh, why both?

Definition at line 755 of file store_client.cc.

References store_client::_callback, MemObject::clients, dlink_node::data, debugs, DELAY_SENDING, store_client::disk_io_pending, EBIT_TEST, ENTRY_FWD_HDR_WAIT, store_client::flags, flags, getMD5Text(), dlink_list::head, i, mem_obj, dlink_node::next, NULL, store_client::Callback::pending(), PROF_start, PROF_stop, sc, storeClientCopy2(), and swapOut().

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

bool StoreEntry::isAccepting ( ) const

Definition at line 2047 of file store.cc.

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

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

bool StoreEntry::isEmpty ( ) const

inline

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 assert, MemObject::endOffset(), and mem_obj.

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

void StoreEntry::kickProducer ( )

Definition at line 362 of file store.cc.

References deferredProducer, NULL, and ScheduleCallHere.

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

void StoreEntry::lastModified ( const time_t when )

inline

Definition at line 157 of file Store.h.

References 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().

time_t StoreEntry::lastModified ( ) const

inline

Returns: entry's 'effective' modification time

Definition at line 159 of file Store.h.

References lastModified_, and timestamp.

Referenced by modifiedSince(), and timestampsSet().

void StoreEntry::lengthWentBad ( const char * reason )

Definition at line 1050 of file store.cc.

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

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

void StoreEntry::lock ( const char * context )

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

References debugs, getMD5Text(), and lock_count.

Referenced by 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(), release(), Ssl::ServerBump::ServerBump(), clientReplyContext::setReplyToStoreEntry(), statObjectsStart(), storeCreateEntry(), storeErrorResponse(), Ipc::StoreMapUpdate::StoreMapUpdate(), storeSwapOutStart(), storeUnregister(), testPackableStream::testGetStream(), and whoisStart().

int StoreEntry::locked ( ) const

Definition at line 1249 of file store.cc.

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

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

int StoreEntry::locks ( ) const

inline

Definition at line 248 of file Store.h.

References lock_count.

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

void StoreEntry::makePrivate ( const bool shareable )

Definition at line 151 of file store.cc.

References releaseRequest().

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

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

Definition at line 144 of file store.cc.

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

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

bool StoreEntry::mayStartHitting ( ) const

inline

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

Definition at line 267 of file Store.h.

References EBIT_TEST, flags, KEY_PRIVATE, and shareableWhenPrivate.

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

bool StoreEntry::mayStartSwapOut ( )

bool StoreEntry::memoryCachable ( )

Definition at line 1339 of file store.cc.

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

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

void StoreEntry::memOutDecision ( const bool willCacheInRam )

Definition at line 1856 of file store.cc.

References transientsAbandonmentCheck().

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

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

Definition at line 1893 of file store.cc.

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

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

void StoreEntry::negativeCache ( )

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

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

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

int64_t StoreEntry::objectLen ( ) const

Definition at line 1655 of file store.cc.

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

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

void StoreEntry::operator delete ( void * address )

Definition at line 138 of file store.cc.

void * StoreEntry::operator new ( size_t byteCount )

Definition at line 126 of file store.cc.

References assert, and memPoolCreate.

const cache_key* StoreEntry::publicKey ( ) const

inline

Returns: public key (if the entry has it) or nil (otherwise)

Definition at line 98 of file Store.h.

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

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

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

Definition at line 1514 of file store.cc.

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

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

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

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

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

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

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

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

Definition at line 446 of file store.cc.

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

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

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

void StoreEntry::reset ( )

Definition at line 1676 of file store.cc.

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

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

void StoreEntry::setCollapsingRequirement ( const bool required )

Definition at line 2071 of file store.cc.

References EBIT_CLR, EBIT_SET, ENTRY_REQUIRES_COLLAPSING, and flags.

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

void StoreEntry::setMemStatus ( mem_status_t new_status )

Definition at line 1558 of file store.cc.

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

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

void StoreEntry::setNoDelay ( bool const newValue )

Definition at line 252 of file store.cc.

References mem_obj, and MemObject::setNoDelay().

Referenced by HttpStateData::HttpStateData().

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

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

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

Referenced by releaseRequest(), and storeCreateEntry().

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

Definition at line 587 of file store.cc.

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

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

void StoreEntry::startWriting ( )

pack and write reply headers and, maybe, body

Definition at line 1798 of file store.cc.

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

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

store_client_t StoreEntry::storeClientType ( ) const

Definition at line 264 of file store.cc.

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

void StoreEntry::storeErrorResponse ( HttpReply * reply )

Definition at line 1765 of file store.cc.

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

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

void StoreEntry::swapOut ( )

Definition at line 170 of file store_swapout.cc.

References abort(), assert, MemObject::availableForSwapOut(), checkDeferRead(), DBG_CRITICAL, debugs, MemObject::SwapOut::decision, doPages(), EBIT_TEST, MemObject::endOffset(), ENTRY_ABORTED, flags, hasDisk(), HERE(), MemObject::inmem_lo, MemObject::lowestMemReaderOffset(), mayStartSwapOut(), 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, store_status, storeSwapOutStart(), storeTooManyDiskFilesOpen(), MemObject::swapout, swapOutFileClose(), swappingOut(), MemObject::SwapOut::swPossible, url(), and StoreIOState::wroteAll.

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

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

Definition at line 1862 of file store.cc.

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

Referenced by mayStartSwapOut(), and storeSwapOutStart().

void StoreEntry::swapOutFileClose ( int how )

Definition at line 271 of file store_swapout.cc.

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

Referenced by abort(), and swapOut().

bool StoreEntry::swappedOut ( ) const

inline

Definition at line 121 of file Store.h.

References swap_status, and SWAPOUT_DONE.

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

bool StoreEntry::swappingOut ( ) const

inline

Definition at line 119 of file Store.h.

References swap_status, and SWAPOUT_WRITING.

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

bool StoreEntry::timestampsSet ( )

void StoreEntry::touch ( )

Definition at line 440 of file store.cc.

References lastref, and squid_curtime.

void StoreEntry::transientsAbandonmentCheck ( )

protected

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

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

Referenced by memOutDecision(), and swapOutDecision().

void StoreEntry::trimMemory ( const bool preserveSwappable )

Definition at line 1871 of file store.cc.

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

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

int StoreEntry::unlock ( const char * context )

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

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

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

void StoreEntry::unregisterAbort ( )

Definition at line 1523 of file store.cc.

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

Referenced by abort(), and FwdState::~FwdState().

const char * StoreEntry::url ( ) const

Definition at line 1600 of file store.cc.

References 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(), clientReplyContext::handleIMSReply(), HttpStateData::handleMoreRequestBodyAvailable(), FwdState::handleUnregisteredServerEnd(), htcpClear(), htcpClrStoreEntry(), htcpQuery(), HttpStateData::httpBuildRequestHeader(), httpStart(), HttpStateData::httpTimeout(), HttpStateData::keepaliveAccounting(), mayStartSwapOut(), modifiedSince(), neighborsUdpPing(), peerSelect(), peerSelectIcpPing(), clientReplyContext::purgeDoPurgeGet(), clientReplyContext::purgeDoPurgeHead(), WhoisState::readReply(), FwdState::reforward(), replaceHttpReply(), reset(), clientReplyContext::sendMoreData(), FwdState::serverClosed(), UrnState::start(), CacheManager::Start(), FwdState::Start(), FwdState::startConnectionOrFail(), HttpStateData::statusIfComplete(), storeDigestDel(), storeSwapMetaBuild(), storeSwapOutFileClosed(), storeSwapOutStart(), swapOut(), FwdState::unregister(), PeerSelector::url(), urnHandleReply(), whoisTimeout(), netdbExchangeState::~netdbExchangeState(), and PeerSelector::~PeerSelector().

bool StoreEntry::validLength ( ) const

private

Definition at line 1266 of file store.cc.

References assert, Http::Message::content_length, debugs, getMD5Text(), getReply(), Http::Message::hdr_sz, mem_obj, MemObject::method, Http::METHOD_HEAD, NULL, objectLen(), Http::scNoContent, Http::scNotModified, HttpReply::sline, and Http::StatusLine::status().

Referenced by complete().

int StoreEntry::validToSend ( ) const

Definition at line 1414 of file store.cc.

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

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

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

virtual

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

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

Referenced by storeAppendPrintf(), and storeAppendVPrintf().

void StoreEntry::write ( StoreIOBuffer writeBuffer )

Definition at line 797 of file store.cc.

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

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

Friends And Related Function Documentation

std::ostream& operator<<	(	std::ostream &	os,
		const StoreEntry &	e
	)

friend

Definition at line 2099 of file store.cc.

Member Data Documentation

ESIElement::Pointer StoreEntry::cachedESITree

Definition at line 234 of file Store.h.

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

void StoreEntry::DeferReader

static

Definition at line 45 of file Store.h.

Referenced by delayAwareRead().

AsyncCall::Pointer StoreEntry::deferredProducer

private

Definition at line 311 of file Store.h.

Referenced by deferProducer(), and kickProducer().

uint16_t StoreEntry::flags

Definition at line 208 of file Store.h.

void* hash_link::key

inherited

Definition at line 19 of file hash.h.

Referenced by aclMatchExternal(), MemStore::anchorToCache(), Rock::SwapDir::anchorToCache(), cacheIndexCmp(), StoreMetaMD5::checkConsistency(), clearPublicKeyScope(), ClientInfo::ClientInfo(), Rock::SwapDir::createStoreIO(), CommQuotaQueue::dequeue(), destroyStoreEntry(), LeakFinder::dump(), CommQuotaQueue::enqueue(), external_acl_cache_add(), forcePublicKey(), fqdncache_entry::fqdncache_entry(), fqdncacheAddEntry(), fqdncacheParse(), getMD5Text(), hash_join(), hash_lookup(), hash_remove_link(), hash_unlink(), hashDelete(), hashInsert(), hashKeyStr(), Rock::SwapDir::hasReadableEntry(), htcpQuery(), IdleConnList::IdleConnList(), 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(), Ipc::StoreMap::openForUpdating(), Rock::SwapDir::openStoreIO(), peerCountMcastPeersStart(), publicKey(), read_passwd_file(), Ipc::StoreMapAnchor::set(), setPrivateKey(), setPublicKey(), ClientInfo::setWriteLimiter(), Ident::Start(), MemStore::startCaching(), storeDigestAdd(), storeDigestDel(), storeRebuildParseEntry(), storeSwapMetaBuild(), UFSCleanLog::write(), ClientInfo::~ClientInfo(), ExternalACLEntry::~ExternalACLEntry(), fqdncache_entry::~fqdncache_entry(), IdleConnList::~IdleConnList(), and net_db_name::~net_db_name().

time_t StoreEntry::lastModified_

private

Definition at line 204 of file Store.h.

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

time_t StoreEntry::lastref

Definition at line 201 of file Store.h.

Referenced by Fs::Ufs::UFSSwapDir::addDiskRestore(), addedEntry(), describeTimestamps(), 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(), touch(), and UFSCleanLog::write().

unsigned short StoreEntry::lock_count

private

Definition at line 300 of file Store.h.

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

MemObject* StoreEntry::mem_obj

Definition at line 197 of file Store.h.

Referenced by abort(), Store::Disks::accumulateMore(), Transients::addEntry(), adjustVary(), MemStore::anchorEntry(), append(), CollapsedForwarding::Broadcast(), bytesWanted(), clientReplyContext::cacheHit(), calcPublicKey(), checkCachable(), StoreMetaURL::checkConsistency(), StoreMetaVary::checkConsistency(), CheckQuickAbortIsReasonable(), checkTooBig(), checkTooSmall(), Transients::clearCollapsingRequirement(), complete(), FwdState::complete(), FwdState::completed(), MemStore::completeWriting(), Transients::completeWriting(), FwdState::connectStart(), contentLen(), store_client::copy(), MemStore::copyFromShm(), MemStore::copyFromShmSlice(), MemStore::copyToShm(), MemStore::copyToShmSlice(), MimeIcon::created(), createMemObject(), delayAwareRead(), Store::Controller::dereferenceIdle(), destroyMemObject(), Rock::SwapDir::disconnect(), MemStore::disconnect(), Transients::disconnect(), store_client::doCopy(), doPages(), dump(), ensureMemObject(), errorAppendEntry(), MemStore::evictCached(), Transients::evictCached(), store_client::fileRead(), findPreviouslyCachedEntry(), forcePublicKey(), Transients::get(), getReply(), getSerialisedMetaData(), gopherReadReply(), Store::Controller::handleIdleEntry(), hasMemStore(), hasTransients(), HttpStateData::haveParsedReplyHeaders(), heap_guessType(), HeapKeyGen_StoreEntry_GDSF(), HeapKeyGen_StoreEntry_LFUDA(), HeapKeyGen_StoreEntry_LRU(), htcpClear(), httpMaybeRemovePublic(), invokeHandlers(), isEmpty(), Transients::isReader(), Transients::isWriter(), Store::Controller::keepForLocalMemoryCache(), ClientHttpRequest::logRequest(), mayStartSwapOut(), memoryCachable(), Transients::monitorIo(), store_client::moreToSend(), neighborsHtcpReply(), neighborsUdpAck(), neighborsUdpPing(), 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(), registerAbort(), repl_guessType(), replaceHttpReply(), reset(), store_client::scheduleMemRead(), store_client::scheduleRead(), setMemStatus(), setNoDelay(), LruPolicyData::setPolicyNode(), HeapPolicyData::setPolicyNode(), setPrivateKey(), setPublicKey(), MemStore::shouldCache(), FwdState::Start(), MemStore::startCaching(), startWriting(), statObjectsOpenfdFilter(), statObjectsVmFilter(), statStoreEntry(), Transients::status(), storeClientCopyPending(), storeClientListAdd(), storeClientType(), storeDigestRewriteFinish(), storeDigestRewriteStart(), storeLog(), clientReplyContext::storeNotOKTransferDone(), storePendingNClients(), storeSwapInStart(), storeSwapMetaBuild(), storeSwapOutFileClosed(), storeSwapOutFileNotify(), storeSwapOutStart(), storeUnregister(), swapOut(), swapOutDecision(), swapOutFileClose(), Store::Controller::syncCollapsed(), testRock::testRockSwapOut(), timestampsSet(), transientsAbandonmentCheck(), trimMemory(), store_client::unpackHeader(), unregisterAbort(), MemStore::updateAnchored(), MemStore::updateHeaders(), url(), validLength(), validToSend(), varyEvaluateMatch(), MemStore::write(), write(), and HttpStateData::wroteLast().

mem_status_t StoreEntry::mem_status

Definition at line 216 of file Store.h.

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

hash_link* hash_link::next

inherited

Definition at line 20 of file hash.h.

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

MemAllocator * StoreEntry::pool = NULL

staticprivate

Definition at line 298 of file Store.h.

Referenced by inUseCount().

uint16_t StoreEntry::refcount

Definition at line 207 of file Store.h.

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

RemovalPolicyNode StoreEntry::repl

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

bool StoreEntry::shareableWhenPrivate

private

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 307 of file Store.h.

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

store_status_t StoreEntry::store_status

Definition at line 220 of file Store.h.

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

uint64_t StoreEntry::swap_file_sz

sfileno StoreEntry::swap_filen

Definition at line 212 of file Store.h.

Referenced by Fs::Ufs::UFSSwapDir::addDiskRestore(), addedEntry(), attachToDisk(), checkDisk(), Fs::Ufs::UFSSwapDir::dereference(), Rock::SwapDir::dereference(), detachFromDisk(), Rock::SwapDir::disconnect(), Fs::Ufs::UFSSwapDir::doubleCheck(), dump(), Fs::Ufs::UFSSwapDir::dumpEntry(), Rock::SwapDir::evictCached(), Fs::Ufs::UFSSwapDir::evictCached(), 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(), storeSwapOutFileNotify(), storeSwapOutStart(), testRock::testRockSwapOut(), testUfs::testUfsSearch(), StoreIOState::touchingStoreEntry(), Fs::Ufs::UFSStoreState::UFSStoreState(), Rock::SwapDir::updateAnchored(), Rock::SwapDir::updateHeaders(), and UFSCleanLog::write().

swap_status_t StoreEntry::swap_status

Definition at line 222 of file Store.h.

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

time_t StoreEntry::timestamp

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

squid-cache.org

Optimising Web Delivery

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

Friends

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Friends And Related Function Documentation

Member Data Documentation

Introduction

Documentation

Support

Miscellaneous

Web Site Translations

Mirrors