#include <MemObject.h>

Collaboration diagram for MemObject:

[legend]

Classes
struct	abort_

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 HttpReplyPointer &	getReply () const

void	replaceReply (const HttpReplyPointer &r)

void	stat (MemBuf *mb) const

int64_t	endOffset () const

void	markEndOfReplyHeaders ()

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

struct MemObject::abort_	abort

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_

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 33 of file MemObject.h.

Member Typedef Documentation

◆ Io

using MemObject::Io = Store::IoStatus

Definition at line 127 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 295 of file MemObject.cc.

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

Referenced by replaceReply(), and storeClientListAdd().

◆ availableForSwapOut()

int64_t MemObject::availableForSwapOut ( ) const

Definition at line 485 of file MemObject.cc.

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

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

◆ clientCount()

size_t MemObject::clientCount ( ) const

inline

Definition at line 107 of file MemObject.h.

References nclients.

Referenced by storeUnregister().

◆ clientIsFirst()

bool MemObject::clientIsFirst ( void * sc ) const

inline

Definition at line 109 of file MemObject.h.

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

◆ delayRead()

void MemObject::delayRead ( DeferredRead const & aRead )

Definition at line 428 of file MemObject.cc.

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

Referenced by HttpStateData::readReply().

◆ dump()

void MemObject::dump ( ) const

Definition at line 151 of file MemObject.cc.

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

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 242 of file MemObject.cc.

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

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

◆ getReply()

const HttpReplyPointer& MemObject::getReply ( ) const

inline

Definition at line 57 of file MemObject.h.

References reply_.

Referenced by StoreEntry::adjustVary(), Http::Stream::buildRangeHeader(), StoreEntry::getReply(), ClientHttpRequest::gotEnough(), Http::Stream::packRange(), HttpStateData::peerSupportsConnectionPinning(), readAheadPolicyCanRead(), refreshCheck(), Rock::HeaderUpdater::startWriting(), clientReplyContext::storeNotOKTransferDone(), and StoreEntry::write().

◆ 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 392 of file MemObject.cc.

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

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

◆ kickReads()

void MemObject::kickReads ( )

Definition at line 442 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(), storeLog(), and urlXXX().

◆ lowestMemReaderOffset()

int64_t MemObject::lowestMemReaderOffset ( ) const

Definition at line 270 of file MemObject.cc.

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

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

◆ markEndOfReplyHeaders()

void MemObject::markEndOfReplyHeaders ( )

sets reply_->hdr_sz to endOffset()

Definition at line 224 of file MemObject.cc.

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

Referenced by replaceReply(), and StoreEntry::startWriting().

◆ mostBytesAllowed()

DelayId MemObject::mostBytesAllowed ( ) const

Definition at line 449 of file MemObject.cc.

References DelayId::bytesWanted(), clients, store_client::copyInto, store_client::delayId, dlink_list::head, StoreIOBuffer::length, node::next, and sc.

Referenced by Ftp::Client::dataRead(), delayRead(), FwdState::establishTunnelThruProxy(), gopherReadReply(), mostBytesWanted(), HttpStateData::readReply(), and replaceReply().

◆ mostBytesWanted()

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

Definition at line 401 of file MemObject.cc.

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

Referenced by replaceReply().

◆ objectBytesOnDisk()

int64_t MemObject::objectBytesOnDisk ( ) const

Definition at line 314 of file MemObject.cc.

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

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

◆ operator delete()

void MemObject::operator delete ( void * address )

inline

Definition at line 35 of file MemObject.h.

◆ operator new()

void* MemObject::operator new ( size_t byteCount )

inline

Definition at line 35 of file MemObject.h.

◆ policyLowestOffsetToKeep()

int64_t MemObject::policyLowestOffsetToKeep ( bool swap ) const

Definition at line 340 of file MemObject.cc.

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

Referenced by replaceReply(), trimSwappable(), and trimUnSwappable().

◆ Pool()

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

inlinestaticprivate

Definition at line 35 of file MemObject.h.

Referenced by inUseCount().

◆ readAheadPolicyCanRead()

bool MemObject::readAheadPolicyCanRead ( ) const

Definition at line 281 of file MemObject.cc.

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

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

◆ replaceReply()

void MemObject::replaceReply ( const HttpReplyPointer & r )

inline

Definition at line 58 of file MemObject.h.

References addClient(), availableForSwapOut(), endOffset(), expectedReplySize(), isContiguous(), lowestMemReaderOffset(), markEndOfReplyHeaders(), max(), mostBytesAllowed(), mostBytesWanted(), objectBytesOnDisk(), policyLowestOffsetToKeep(), readAheadPolicyCanRead(), reply_, reset(), setNoDelay(), size(), stat(), trimSwappable(), and trimUnSwappable().

Referenced by StoreEntry::replaceHttpReply().

◆ reset()

void MemObject::reset ( )

Definition at line 259 of file MemObject.cc.

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

Referenced by replaceReply(), and StoreEntry::reset().

◆ setNoDelay()

void MemObject::setNoDelay ( bool const newValue )

Definition at line 415 of file MemObject.cc.

References clients, store_client::delayId, dlink_list::head, node::next, sc, and DelayId::setNoDelay().

Referenced by replaceReply().

◆ 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 233 of file MemObject.cc.

References endOffset(), and object_sz.

Referenced by peerDigestFetchSetStats(), and replaceReply().

◆ stat()

void MemObject::stat ( MemBuf * mb ) const

Definition at line 193 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 replaceReply(), and 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 357 of file MemObject.cc.

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

Referenced by replaceReply(), and StoreEntry::trimMemory().

◆ trimUnSwappable()

void MemObject::trimUnSwappable ( )

Definition at line 382 of file MemObject.cc.

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

Referenced by replaceReply(), and StoreEntry::trimMemory().

◆ unlinkRequest()

void MemObject::unlinkRequest ( )

inline

Definition at line 56 of file MemObject.h.

References request.

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

◆ 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 93 of file MemObject.h.

References logUri(), and storeId().

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