#include <MemObject.h>

Collaboration diagram for MemObject:

[legend]

Classes
class	MemCache
	State of an entry with regards to the [shared] memory caching. More...

class	SwapOut

class	XitTable
	State of an entry with regards to the [shared] in-transit table. More...

Public Types
using	Io = Store::IoStatus

Public Member Functions
void *	operator new (size_t byteCount)

void	operator delete (void *address)

void	dump () const

	MemObject ()

	~MemObject ()

void	setUris (char const aStoreId, char const aLogUri, const HttpRequestMethod &aMethod)

bool	hasUris () const
	whether setUris() has been called More...

void	write (const StoreIOBuffer &buf)

void	unlinkRequest ()

const HttpReply &	baseReply () const

const HttpReplyPointer &	updatedReply () const

const HttpReply &	freshestReply () const

HttpReply &	adjustableBaseReply ()

void	replaceBaseReply (const HttpReplyPointer &r)

void	updateReply (const HttpReply &r)
	(re)sets updated reply; More...

void	stat (MemBuf *mb) const

int64_t	endOffset () const

void	markEndOfReplyHeaders ()
	sets baseReply().hdr_sz (i.e. written reply headers size) to endOffset() More...

int64_t	expectedReplySize () const

int64_t	size () const

void	reset ()

int64_t	lowestMemReaderOffset () const

bool	readAheadPolicyCanRead () const

void	addClient (store_client *)

int64_t	objectBytesOnDisk () const

int64_t	policyLowestOffsetToKeep (bool swap) const

int64_t	availableForSwapOut () const
	buffered bytes we have not swapped out yet More...

void	trimSwappable ()

void	trimUnSwappable ()

bool	isContiguous () const

int	mostBytesWanted (int max, bool ignoreDelayPools) const

void	setNoDelay (bool const newValue)

DelayId	mostBytesAllowed () const

const char *	urlXXX () const

const char *	storeId () const

const char *	logUri () const
	client request URI used for logging; storeId() by default More...

size_t	clientCount () const

bool	clientIsFirst (void *sc) const

void	delayRead (DeferredRead const &)

void	kickReads ()

Static Public Member Functions
static int	UseCount ()

static size_t	inUseCount ()

Public Attributes
bool	appliedUpdates = false

HttpRequestMethod	method

mem_hdr	data_hdr

int64_t	inmem_lo = 0

dlink_list	clients

int	nclients = 0

SwapOut	swapout

XitTable	xitTable
	current [shared] memory caching state for the entry More...

MemCache	memCache
	current [shared] memory caching state for the entry More...

HttpRequestPointer	request

struct timeval	start_ping

IRCB *	ping_reply_callback

PeerSelector *	ircb_data = nullptr

AsyncCall::Pointer	abortCallback
	used for notifying StoreEntry writers about 3rd-party initiated aborts More...

RemovalPolicyNode	repl

int	id = 0

int64_t	object_sz = -1

size_t	swap_hdr_sz = 0

SBuf	vary_headers

Static Public Attributes
static constexpr Io	ioUndecided = Store::ioUndecided

static constexpr Io	ioReading = Store::ioReading

static constexpr Io	ioWriting = Store::ioWriting

static constexpr Io	ioDone = Store::ioDone

Static Private Member Functions
static Mem::AllocatorProxy &	Pool ()

Private Attributes
HttpReplyPointer	reply_

HttpReplyPointer	updatedReply_

String	storeId_
	StoreId for our entry (usually request URI) More...

String	logUri_
	URI used for logging (usually request URI) More...

DeferredReadManager	deferredReads

Detailed Description

Definition at line 32 of file MemObject.h.

Member Typedef Documentation

◆ Io

using MemObject::Io = Store::IoStatus

Definition at line 162 of file MemObject.h.

Constructor & Destructor Documentation

◆ MemObject()

MemObject::MemObject ( )

Definition at line 98 of file MemObject.cc.

References debugs, ping_reply_callback, reply_, and start_ping.

◆ ~MemObject()

MemObject::~MemObject ( )

Definition at line 106 of file MemObject.cc.

References assert, clients, ctx_enter(), ctx_exit(), data_hdr, debugs, mem_hdr::freeContent(), hasUris(), dlink_list::head, MemObject::XitTable::index, MemObject::MemCache::index, memCache, NULL, shutting_down, MemObject::SwapOut::sio, swapout, urlXXX(), and xitTable.

Member Function Documentation

◆ addClient()

void MemObject::addClient ( store_client * aClient )

Definition at line 324 of file MemObject.cc.

References clients, dlinkAdd(), nclients, and store_client::node.

Referenced by storeClientListAdd().

◆ adjustableBaseReply()

HttpReply & MemObject::adjustableBaseReply ( )

Returns: writable base reply for parsing and other initial modifications Base modifications can only be done when forming/loading the entry. After that, use replaceBaseReply() to reset all of the replies.

Definition at line 136 of file MemObject.cc.

References assert, reply_, and updatedReply_.

Referenced by MemStore::copyFromShmSlice(), testRock::createEntry(), store_client::readBody(), and testUfs::testUfsSearch().

◆ availableForSwapOut()

int64_t MemObject::availableForSwapOut ( ) const

Definition at line 514 of file MemObject.cc.

References endOffset(), MemObject::SwapOut::queue_offset, and swapout.

Referenced by Store::Disks::accumulateMore(), and StoreEntry::swapOut().

◆ baseReply()

const HttpReply& MemObject::baseReply ( ) const

inline

HTTP response before 304 (Not Modified) updates starts "empty"; modified via replaceBaseReply() or adjustableBaseReply()

Definition at line 59 of file MemObject.h.

References reply_.

Referenced by StoreEntry::append(), asHandleReply(), CheckQuickAbortIsReasonable(), StoreEntry::checkTooBig(), StoreEntry::checkTooSmall(), FwdState::complete(), StoreEntry::contentLen(), expectedReplySize(), freshestReply(), ClientHttpRequest::gotEnough(), netdbExchangeHandleReply(), clientReplyContext::processConditional(), readAheadPolicyCanRead(), store_client::readBody(), FwdState::reforward(), refreshIsCachable(), clientReplyContext::replyStatus(), StoreEntry::startWriting(), clientReplyContext::storeNotOKTransferDone(), MemStore::updateHeadersOrThrow(), StoreEntry::updateOnNotModified(), StoreEntry::validLength(), and StoreEntry::write().

◆ clientCount()

size_t MemObject::clientCount ( ) const

inline

Definition at line 142 of file MemObject.h.

References nclients.

Referenced by storeUnregister().

◆ clientIsFirst()

bool MemObject::clientIsFirst ( void * sc ) const

inline

Definition at line 144 of file MemObject.h.

References clients, dlink_node::data, dlink_list::head, and sc.

◆ delayRead()

void MemObject::delayRead ( DeferredRead const & aRead )

Definition at line 457 of file MemObject.cc.

References deferredReads, DeferredReadManager::delayRead(), mostBytesAllowed(), and readAheadPolicyCanRead().

Referenced by StoreEntry::delayAwareRead(), and HttpStateData::readReply().

◆ dump()

void MemObject::dump ( ) const

Definition at line 166 of file MemObject.cc.

References appliedUpdates, data_hdr, DBG_IMPORTANT, debugs, mem_hdr::dump(), mem_hdr::endOffset(), inmem_lo, logUri_, nclients, reply_, request, start_ping, storeId_, and updatedReply_.

Referenced by storeId().

◆ endOffset()

int64_t MemObject::endOffset ( ) const

◆ expectedReplySize()

int64_t MemObject::expectedReplySize ( ) const

negative if unknown; otherwise, expected object_sz, expected endOffset maximum, and stored reply headers+body size (all three are the same)

Definition at line 259 of file MemObject.cc.

References baseReply(), HttpReply::bodySize(), debugs, Http::Message::hdr_sz, method, and object_sz.

Referenced by Store::Controller::keepForLocalMemoryCache(), StoreEntry::mayStartSwapOut(), objectSizeForDirSelection(), MemStore::shouldCache(), MemStore::startCaching(), and storeSwapMetaBuild().

◆ freshestReply()

const HttpReply& MemObject::freshestReply ( ) const

inline

Returns: the updated-by-304(s) response (if it exists); baseReply() (otherwise)

Definition at line 67 of file MemObject.h.

References baseReply(), and updatedReply_.

Referenced by testRock::addEntry(), StoreEntry::adjustVary(), Client::blockCaching(), clientReplyContext::blockedHit(), clientReplyContext::cloneReply(), clientReplyContext::handleIMSReply(), StoreEntry::hasFreshestReply(), StoreEntry::hasOneOfEtags(), peerDigestFetchReply(), peerDigestSwapInHeaders(), HttpStateData::peerSupportsConnectionPinning(), clientReplyContext::sendNotModified(), storeLog(), testUfs::testUfsSearch(), StoreEntry::timestampsSet(), MemStore::updateHeadersOrThrow(), StoreEntry::updateOnNotModified(), and varyEvaluateMatch().

◆ hasUris()

bool MemObject::hasUris ( ) const

Definition at line 71 of file MemObject.cc.

References String::size(), and storeId_.

Referenced by StoreMetaURL::checkConsistency(), StoreEntry::forcePublicKey(), StoreEntry::setPrivateKey(), setUris(), storeLog(), and ~MemObject().

◆ inUseCount()

size_t MemObject::inUseCount ( )

static

Definition at line 48 of file MemObject.cc.

References Mem::AllocatorProxy::inUseCount(), and Pool().

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

◆ isContiguous()

bool MemObject::isContiguous ( ) const

Definition at line 421 of file MemObject.cc.

References data_hdr, debugs, endOffset(), mem_hdr::hasContigousContentRange(), and inmem_lo.

Referenced by StoreEntry::mayStartSwapOut(), and MemStore::shouldCache().

◆ kickReads()

void MemObject::kickReads ( )

Definition at line 471 of file MemObject.cc.

References deferredReads, and DeferredReadManager::kickReads().

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

◆ logUri()

const char * MemObject::logUri ( ) const

Definition at line 65 of file MemObject.cc.

References logUri_, String::size(), storeId(), and String::termedBuf().

Referenced by StoreEntry::adjustVary(), stat(), and storeLog().

◆ lowestMemReaderOffset()

int64_t MemObject::lowestMemReaderOffset ( ) const

Definition at line 298 of file MemObject.cc.

References clients, LowestMemReader::current, and endOffset().

Referenced by policyLowestOffsetToKeep(), readAheadPolicyCanRead(), and StoreEntry::swapOut().

◆ markEndOfReplyHeaders()

void MemObject::markEndOfReplyHeaders ( )

Definition at line 241 of file MemObject.cc.

References assert, endOffset(), Http::Message::hdr_sz, and reply_.

Referenced by StoreEntry::startWriting().

◆ mostBytesAllowed()

DelayId MemObject::mostBytesAllowed ( ) const

Definition at line 478 of file MemObject.cc.

References clients, dlink_list::head, node::next, and sc.

Referenced by delayRead(), FwdState::establishTunnelThruProxy(), gopherReadReply(), mostBytesWanted(), and HttpStateData::readReply().

◆ mostBytesWanted()

int MemObject::mostBytesWanted	(	int	max,
		bool	ignoreDelayPools
	)		const

Definition at line 430 of file MemObject.cc.

References DelayId::bytesWanted(), max(), and mostBytesAllowed().

Referenced by StoreEntry::bytesWanted().

◆ objectBytesOnDisk()

int64_t MemObject::objectBytesOnDisk ( ) const

Definition at line 343 of file MemObject.cc.

References RefCount< C >::getRaw(), NULL, StoreIOState::offset(), MemObject::SwapOut::sio, swap_hdr_sz, and swapout.

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

◆ operator delete()

void MemObject::operator delete ( void * address )

inline

Definition at line 34 of file MemObject.h.

◆ operator new()

void* MemObject::operator new ( size_t byteCount )

inline

Definition at line 34 of file MemObject.h.

◆ policyLowestOffsetToKeep()

int64_t MemObject::policyLowestOffsetToKeep ( bool swap ) const

Definition at line 369 of file MemObject.cc.

References Config, endOffset(), inmem_lo, lowestMemReaderOffset(), SquidConfig::maxInMemObjSize, SquidConfig::memory_cache_first, SquidConfig::onoff, and SquidConfig::Store.

Referenced by trimSwappable(), and trimUnSwappable().

◆ Pool()

static Mem::AllocatorProxy& MemObject::Pool ( )

inlinestaticprivate

Definition at line 34 of file MemObject.h.

Referenced by inUseCount().

◆ readAheadPolicyCanRead()

bool MemObject::readAheadPolicyCanRead ( ) const

Definition at line 309 of file MemObject.cc.

References baseReply(), Config, debugs, endOffset(), Http::Message::hdr_sz, lowestMemReaderOffset(), and SquidConfig::readAheadGap.

Referenced by StoreEntry::bytesWanted(), delayRead(), and StoreEntry::write().

◆ replaceBaseReply()

void MemObject::replaceBaseReply ( const HttpReplyPointer & r )

(re)sets base reply, usually just replacing the initial/empty object also forgets the updated reply (if any)

Definition at line 143 of file MemObject.cc.

References assert, reply_, and updatedReply_.

Referenced by StoreEntry::replaceHttpReply().

◆ reset()

void MemObject::reset ( )

Definition at line 285 of file MemObject.cc.

References appliedUpdates, assert, data_hdr, mem_hdr::freeContent(), inmem_lo, NULL, reply_, HttpReply::reset(), MemObject::SwapOut::sio, swapout, and updatedReply_.

Referenced by StoreEntry::reset().

◆ setNoDelay()

void MemObject::setNoDelay ( bool const newValue )

Definition at line 444 of file MemObject.cc.

References clients, dlink_list::head, node::next, and sc.

Referenced by StoreEntry::setNoDelay().

◆ setUris()

void MemObject::setUris	(	char const *	aStoreId,
		char const *	aLogUri,
		const HttpRequestMethod &	aMethod
	)

Sets store ID, log URI, and request method (unless already set). Does not clobber the method so that, say, a HEAD hit for a GET entry keeps the GET method that matches the entry key. Same for the other parts of the trio because the entry filling code may expect them to be constant. XXX: Avoid this method. We plan to remove it and make the trio constant after addressing the XXX in MemStore::get().

Definition at line 77 of file MemObject.cc.

References String::clean(), debugs, hasUris(), logUri_, method, storeId_, and urlXXX().

Referenced by StoreEntry::ensureMemObject().

◆ size()

int64_t MemObject::size ( ) const

Definition at line 250 of file MemObject.cc.

References endOffset(), and object_sz.

Referenced by peerDigestFetchSetStats().

◆ stat()

void MemObject::stat ( MemBuf * mb ) const

Definition at line 210 of file MemObject.cc.

References Packable::appendf(), clients, data_hdr, mem_hdr::endOffset(), RefCount< C >::getRaw(), HttpRequestMethod::image(), MemObject::XitTable::index, MemObject::MemCache::index, inmem_lo, MemObject::XitTable::io, MemObject::MemCache::io, SBuf::isEmpty(), logUri(), memCache, method, object_sz, StoreIOState::offset(), MemObject::MemCache::offset, PRId64, MemObject::SwapOut::queue_offset, MemObject::SwapOut::sio, SQUIDSBUFPH, SQUIDSBUFPRINT, swapout, vary_headers, and xitTable.

Referenced by statStoreEntry().

◆ storeId()

const char * MemObject::storeId ( ) const

Entry StoreID (usually just Request URI); if a buggy code requests this before the information is available, returns an "[unknown_URI]" string.

Definition at line 54 of file MemObject.cc.

References DBG_IMPORTANT, debugs, dump(), String::size(), storeId_, and String::termedBuf().

Referenced by StoreEntry::adjustVary(), clientReplyContext::cacheHit(), StoreEntry::calcPublicKey(), findPreviouslyCachedEntry(), HeapKeyGen_StoreEntry_GDSF(), HeapKeyGen_StoreEntry_LFUDA(), HeapKeyGen_StoreEntry_LRU(), httpMaybeRemovePublic(), logUri(), refreshCheck(), StoreEntry::url(), and urlXXX().

◆ trimSwappable()

void MemObject::trimSwappable ( )

Definition at line 386 of file MemObject.cc.

References data_hdr, mem_hdr::freeDataUpto(), inmem_lo, objectBytesOnDisk(), and policyLowestOffsetToKeep().

Referenced by StoreEntry::trimMemory().

◆ trimUnSwappable()

void MemObject::trimUnSwappable ( )

Definition at line 411 of file MemObject.cc.

References assert, data_hdr, mem_hdr::freeDataUpto(), inmem_lo, and policyLowestOffsetToKeep().

Referenced by StoreEntry::trimMemory().

◆ unlinkRequest()

void MemObject::unlinkRequest ( )

inline

Definition at line 55 of file MemObject.h.

References request.

Referenced by Store::Controller::handleIdleEntry(), and storeDigestRewriteFinish().

◆ updatedReply()

const HttpReplyPointer& MemObject::updatedReply ( ) const

inline

Returns: nil – if no 304 updates since replaceBaseReply(); combination of baseReply() and 304 updates – after updates

Definition at line 63 of file MemObject.h.

References updatedReply_.

Referenced by StoreEntry::startWriting().

◆ updateReply()

void MemObject::updateReply ( const HttpReply & r )

inline

See also: updatedReply()

Definition at line 84 of file MemObject.h.

References updatedReply_.

Referenced by StoreEntry::updateOnNotModified().

◆ urlXXX()

const char* MemObject::urlXXX ( ) const

inline

Before StoreID, code assumed that MemObject stores Request URI. After StoreID, some old code still incorrectly assumes that. Use this method to mark that incorrect assumption.

Definition at line 128 of file MemObject.h.

References storeId().

Referenced by StoreMetaURL::checkConsistency(), HttpStateData::haveParsedReplyHeaders(), HttpStateData::processReplyHeader(), setUris(), varyEvaluateMatch(), and ~MemObject().

◆ UseCount()

static int MemObject::UseCount ( )

inlinestatic

Definition at line 34 of file MemObject.h.

◆ write()

void MemObject::write ( const StoreIOBuffer & buf )

Definition at line 151 of file MemObject.cc.

References assert, data_hdr, debugs, mem_hdr::endOffset(), StoreIOBuffer::length, StoreIOBuffer::offset, PROF_start, PROF_stop, and mem_hdr::write().

Referenced by store_client::readBody(), and StoreEntry::write().

Member Data Documentation

◆ abortCallback

AsyncCall::Pointer MemObject::abortCallback

Definition at line 195 of file MemObject.h.

Referenced by StoreEntry::abort(), StoreEntry::registerAbortCallback(), and StoreEntry::unregisterAbortCallback().

◆ appliedUpdates

bool MemObject::appliedUpdates = false

reflects past Controller::updateOnNotModified(old, e304) calls: for HTTP 304 entries: whether our entry was used as "e304" for other entries: whether our entry was updated as "old"

Definition at line 89 of file MemObject.h.

Referenced by dump(), reset(), Store::Controller::updateOnNotModified(), and StoreEntry::updateOnNotModified().