#include <RockRebuild.h>

Inheritance diagram for Rock::Rebuild:

[legend]

Collaboration diagram for Rock::Rebuild:

[legend]

Classes
class	Stats
	cache_dir indexing statistics shared across same-kid process restarts More...

Public Types
typedef CbcPointer< AsyncJob >	Pointer

Public Member Functions
bool	canBeCalled (AsyncCall &call) const
	whether we can be called More...

void	callStart (AsyncCall &call)

virtual void	callEnd ()
	called right after the called job method More...

virtual void	callException (const std::exception &e)
	called when the job throws during an async call More...

void	handleStopRequest ()
	process external request to terminate now (i.e. during this async call) More...

virtual void *	toCbdata ()=0

Static Public Member Functions
static bool	Start (SwapDir &dir)

static void	Start (const Pointer &job)

Public Attributes
const InstanceId< AsyncJob >	id
	job identifier More...

Protected Member Functions
	Rebuild (SwapDir *dir, const Ipc::Mem::Pointer< Stats > &)

virtual	~Rebuild () override

virtual void	startShutdown () override

virtual void	start () override
	prepares and initiates entry loading sequence More...

virtual bool	doneAll () const override
	whether positive goal has been reached More...

virtual void	swanSong () override

bool	doneLoading () const

bool	doneValidating () const

void	deleteThis (const char *aReason)

void	mustStop (const char *aReason)

bool	done () const
	the job is destroyed in callEnd() when done() More...

virtual const char *	status () const
	internal cleanup; do not call directly More...

Static Protected Member Functions
static bool	IsResponsible (const SwapDir &)
	whether the current kid is responsible for rebuilding the given cache_dir More...

Protected Attributes
const char *	stopReason
	reason for forcing done() to be true More...

const char *	typeName
	kid (leaf) class name, for debugging More...

AsyncCall::Pointer	inCall
	the asynchronous call being handled, if any More...

bool	started_ = false
	Start() has finished successfully. More...

bool	swanSang_ = false
	swanSong() was called More...

Private Types
typedef void(RegisteredRunner::*	Method) ()
	a pointer to one of the above notification methods More...

Private Member Functions
	CBDATA_CHILD (Rebuild)

void	checkpoint ()
	continues after a pause if not done More...

void	steps ()

void	loadingSteps ()

void	validationSteps ()

void	loadOneSlot ()

void	validateOneEntry (const sfileno fileNo)

void	validateOneSlot (const SlotId slotId)

bool	importEntry (Ipc::StoreMapAnchor &anchor, const sfileno slotId, const DbCellHeader &header)
	parse StoreEntry basics and add them to the map, returning true on success More...

void	freeBadEntry (const sfileno fileno, const char *eDescription)

void	failure (const char *msg, int errNo=0)

LoadingEntry	loadingEntry (const sfileno fileNo)

void	startNewEntry (const sfileno fileno, const SlotId slotId, const DbCellHeader &header)
	handle a slot from an entry that we have not seen before More...

void	primeNewEntry (Ipc::StoreMapAnchor &anchor, const sfileno fileno, const DbCellHeader &header)
	initialize housekeeping information for a newly accepted entry More...

void	finalizeOrFree (const sfileno fileNo, LoadingEntry &le)

void	finalizeOrThrow (const sfileno fileNo, LoadingEntry &le)

void	addSlotToEntry (const sfileno fileno, const SlotId slotId, const DbCellHeader &header)

void	useNewSlot (const SlotId slotId, const DbCellHeader &header)
	handle freshly loaded (and validated) db slot header More...

LoadingSlot	loadingSlot (const SlotId slotId)

void	mapSlot (const SlotId slotId, const DbCellHeader &header)
	adds slot to the entry chain in the map More...

void	freeUnusedSlot (const SlotId slotId, const bool invalid)
	freeSlot() for never-been-mapped slots More...

void	freeSlot (const SlotId slotId, const bool invalid)
	adds slot to the free slot index More...

template<class SlotIdType >
void	chainSlots (SlotIdType &from, const SlotId to)

bool	sameEntry (const sfileno fileno, const DbCellHeader &header) const
	does the header belong to the fileno entry being loaded? More...

SBuf	progressDescription () const

void	registerRunner ()

void	unregisterRunner ()
	unregisters self; safe to call multiple times More...

virtual void	bootstrapConfig ()

virtual void	finalizeConfig ()

virtual void	claimMemoryNeeds ()

virtual void	useConfig ()

virtual void	startReconfigure ()

virtual void	syncConfig ()

virtual void	endingShutdown ()

virtual void	finishShutdown ()
	Meant for cleanup of services needed by the already destroyed objects. More...

Static Private Member Functions
static void	Steps (void *data)

Private Attributes
SwapDir *	sd

LoadingParts *	parts
	parts of store entries being loaded from disk More...

Ipc::Mem::Pointer< Stats >	stats
	indexing statistics in shared memory More...

int64_t	dbSize

int	dbSlotSize
	the size of a db cell, including the cell header More...

int64_t	dbSlotLimit
	total number of db cells More...

int64_t	dbEntryLimit
	maximum number of entries that can be stored in db More...

int	fd

int64_t	dbOffset

int64_t	loadingPos
	index of the db slot being loaded from disk now More...

int64_t	validationPos
	index of the loaded db slot being validated now More...

MemBuf	buf
	space to load current db slot (and entry metadata) into More...

StoreRebuildData &	counts
	a reference to the shared memory counters More...

const bool	resuming

Detailed Description

manages store rebuild process: loading meta information from db on disk

Definition at line 30 of file RockRebuild.h.

Member Typedef Documentation

◆ Method

typedef void(RegisteredRunner::* RegisteredRunner::Method) ()

inherited

Definition at line 94 of file RunnersRegistry.h.

◆ Pointer

typedef CbcPointer<AsyncJob> AsyncJob::Pointer

inherited

Definition at line 34 of file AsyncJob.h.

Constructor & Destructor Documentation

◆ Rebuild()

Rock::Rebuild::Rebuild	(	SwapDir *	dir,
		const Ipc::Mem::Pointer< Stats > &	s
	)

protected

Definition at line 298 of file RockRebuild.cc.

References assert, dbEntryLimit, dbSize, dbSlotLimit, dbSlotSize, Rock::SwapDir::diskOffsetLimit(), Rock::SwapDir::entryLimitActual(), IndependentRunner::registerRunner(), sd, Rock::SwapDir::slotLimitActual(), and Rock::SwapDir::slotSize.

◆ ~Rebuild()

Rock::Rebuild::~Rebuild ( )

overrideprotectedvirtual

Definition at line 322 of file RockRebuild.cc.

References file_close().

Member Function Documentation

◆ addSlotToEntry()

void Rock::Rebuild::addSlotToEntry	(	const sfileno	fileno,
		const SlotId	slotId,
		const DbCellHeader &	header
	)

private

adds slot to an existing entry chain; caller must check that the slot belongs to the chain it is being added to

Definition at line 770 of file RockRebuild.cc.

References Rock::LoadingEntry::anchored(), assert, Ipc::StoreMapAnchor::basics, StoreRebuildData::clashcount, counts, debugs, Rock::DbCellHeader::entrySize, Rock::DbCellHeader::firstSlot, Rock::LoadingSlot::more, Rock::DbCellHeader::payloadSize, Rock::LoadingEntry::size, Ipc::StoreMapAnchor::start, and Ipc::StoreMapAnchor::Basics::swap_file_sz.

◆ bootstrapConfig()

virtual void RegisteredRunner::bootstrapConfig ( )

inlinevirtualinherited

Called right before parsing squid.conf. Meant for initializing/preparing configuration parsing facilities.

Reimplemented in NtlmAuthRr.

Definition at line 46 of file RunnersRegistry.h.

Referenced by SquidMain().

◆ callEnd()

void AsyncJob::callEnd ( )

virtualinherited

called right after the called job method

Reimplemented in Adaptation::Icap::Xaction.

Definition at line 137 of file AsyncJob.cc.

References assert, AsyncCall::debugLevel, debugs, AsyncCall::debugSection, AsyncJob::done(), AsyncJob::inCall, AsyncJob::started_, AsyncJob::status(), AsyncJob::swanSang_, AsyncJob::swanSong(), and AsyncJob::typeName.

Referenced by Adaptation::Icap::Xaction::callEnd(), and AsyncJob::deleteThis().

◆ callException()

void AsyncJob::callException ( const std::exception & e )

virtualinherited

Reimplemented in ConnStateData, ClientHttpRequest, Adaptation::Icap::ModXact, Adaptation::Icap::ServiceRep, Adaptation::Icap::Xaction, Ipc::Forwarder, Ipc::Inquirer, and Ftp::Server.

Definition at line 128 of file AsyncJob.cc.

References cbdataReferenceValid(), debugs, Must, AsyncJob::mustStop(), and CbdataParent::toCbdata().

Referenced by ConnStateData::callException(), Adaptation::Icap::Xaction::callException(), Ipc::Forwarder::callException(), Ipc::Inquirer::callException(), and Ftp::Server::callException().

◆ callStart()

void AsyncJob::callStart ( AsyncCall & call )

inherited

called just before the called method

Definition at line 115 of file AsyncJob.cc.

References cbdataReferenceValid(), AsyncCall::debugLevel, debugs, AsyncCall::debugSection, AsyncJob::inCall, Must, AsyncJob::status(), CbdataParent::toCbdata(), and AsyncJob::typeName.

◆ canBeCalled()

bool AsyncJob::canBeCalled ( AsyncCall & call ) const

inherited

Definition at line 102 of file AsyncJob.cc.

References AsyncCall::cancel(), debugs, and AsyncJob::inCall.

◆ CBDATA_CHILD()

Rock::Rebuild::CBDATA_CHILD ( Rebuild )

private

◆ chainSlots()

template<class SlotIdType >

void Rock::Rebuild::chainSlots	(	SlotIdType &	from,
		const SlotId	to
	)

private

Definition at line 759 of file RockRebuild.cc.

References assert, and Rock::LoadingSlot::more.

◆ checkpoint()

void Rock::Rebuild::checkpoint ( )

private

Definition at line 375 of file RockRebuild.cc.

References eventAdd(), and Steps().

◆ claimMemoryNeeds()

virtual void RegisteredRunner::claimMemoryNeeds ( )

inlinevirtualinherited

Called after finalizeConfig(). Meant for announcing memory reservations before memory is allocated.

Reimplemented in IpcIoRr, and MemStoreRr.

Definition at line 55 of file RunnersRegistry.h.

Referenced by RunConfigUsers().

◆ deleteThis()

void AsyncJob::deleteThis ( const char * aReason )

protectedinherited

Definition at line 50 of file AsyncJob.cc.

References asyncCall(), AsyncJob::callEnd(), debugs, AsyncJob::deleteThis(), AsyncJob::inCall, JobMemFun(), Must, AsyncJob::stopReason, and AsyncJob::typeName.

Referenced by ConnStateData::connStateClosed(), and AsyncJob::deleteThis().

◆ done()

bool AsyncJob::done ( ) const

protectedinherited

Definition at line 91 of file AsyncJob.cc.

References AsyncJob::doneAll(), and AsyncJob::stopReason.

Referenced by AsyncJob::callEnd(), HappyConnOpener::checkForNewConnection(), Downloader::downloadFinished(), and HappyConnOpener::maybeOpenPrimeConnection().

◆ doneAll()

bool Rock::Rebuild::doneAll ( ) const

overrideprotectedvirtual

Reimplemented from AsyncJob.

Definition at line 394 of file RockRebuild.cc.

References AsyncJob::doneAll().

◆ doneLoading()

bool Rock::Rebuild::doneLoading ( ) const

protected

Definition at line 382 of file RockRebuild.cc.

References Rock::DoneLoading().

◆ doneValidating()

bool Rock::Rebuild::doneValidating ( ) const

protected

Definition at line 388 of file RockRebuild.cc.

References Rock::DoneValidating().

◆ endingShutdown()

virtual void RegisteredRunner::endingShutdown ( )

inlinevirtualinherited

Called after shutdown_lifetime grace period ends and before stopping the main loop. At least one main loop iteration is guaranteed after this call. Meant for cleanup and state saving that may require other modules.

Reimplemented in ConnStateData, IdleConnList, Auth::CredentialCacheRr, and Dns::ConfigRr.

Definition at line 84 of file RunnersRegistry.h.

Referenced by SignalEngine::FinalShutdownRunners().

◆ failure()

void Rock::Rebuild::failure	(	const char *	msg,
		int	errNo = `0`
	)

private

Definition at line 698 of file RockRebuild.cc.

References assert, DBG_CRITICAL, debugs, fatalf(), and xstrerr().

◆ finalizeConfig()

virtual void RegisteredRunner::finalizeConfig ( )

inlinevirtualinherited

Called after parsing squid.conf. Meant for setting configuration options that depend on other configuration options and were not explicitly configured.

Reimplemented in sslBumpCfgRr, and MemStoreRr.

Definition at line 51 of file RunnersRegistry.h.

Referenced by SquidMain().

◆ finalizeOrFree()

void Rock::Rebuild::finalizeOrFree	(	const sfileno	fileNo,
		LoadingEntry &	le
	)

private

Either make the entry accessible to all or free it. This method must only be called when no more entry slots are expected.

Definition at line 632 of file RockRebuild.cc.

◆ finalizeOrThrow()

void Rock::Rebuild::finalizeOrThrow	(	const sfileno	fileNo,
		LoadingEntry &	le
	)

private

Either make the entry accessible to all or throw. This method assumes it is called only when no more entry slots are expected.

Definition at line 598 of file RockRebuild.cc.

References Ipc::StoreMapAnchor::basics, counts, EBIT_SET, ENTRY_VALIDATED, Rock::LoadingSlot::finalized(), Ipc::StoreMapAnchor::Basics::flags, Rock::LoadingSlot::freed(), Rock::LoadingEntry::leLoaded, Rock::LoadingSlot::mapped(), Must, Ipc::StoreMapSlice::next, StoreRebuildData::objcount, Rock::LoadingEntry::size, Ipc::StoreMapSlice::size, Ipc::StoreMapAnchor::start, Rock::LoadingEntry::state(), and Ipc::StoreMapAnchor::Basics::swap_file_sz.

◆ finishShutdown()

virtual void RegisteredRunner::finishShutdown ( )

inlinevirtualinherited

Definition at line 91 of file RunnersRegistry.h.

Referenced by RunRegistered(), SquidShutdown(), testRock::tearDown(), and watch_child().

◆ freeBadEntry()

void Rock::Rebuild::freeBadEntry	(	const sfileno	fileno,
		const char *	eDescription
	)

private

Marks remaining bad entry slots as free and unlocks the entry. The map cannot do this because Loading entries may have holes in the slots chain.

Definition at line 670 of file RockRebuild.cc.

References assert, debugs, Rock::LoadingEntry::leCorrupted, Rock::LoadingEntry::size, Ipc::StoreMapAnchor::start, and Rock::LoadingEntry::state().

◆ freeSlot()

void Rock::Rebuild::freeSlot	(	const SlotId	slotId,
		const bool	invalid
	)

private

Definition at line 714 of file RockRebuild.cc.

References assert, counts, debugs, Rock::LoadingSlot::freed(), Ipc::Mem::PageStack::IdForSwapDirSpace(), StoreRebuildData::invalid, Ipc::Mem::PageId::number, and Ipc::Mem::PageId::pool.

◆ freeUnusedSlot()

void Rock::Rebuild::freeUnusedSlot	(	const SlotId	slotId,
		const bool	invalid
	)

private

Definition at line 734 of file RockRebuild.cc.

References assert, and Rock::LoadingSlot::mapped().

◆ handleStopRequest()

void AsyncJob::handleStopRequest ( )

inlineinherited

Definition at line 71 of file AsyncJob.h.

References AsyncJob::mustStop().

◆ importEntry()

bool Rock::Rebuild::importEntry	(	Ipc::StoreMapAnchor &	anchor,
		const sfileno	slotId,
		const DbCellHeader &	header
	)

private

Definition at line 530 of file RockRebuild.cc.

References Ipc::StoreMapAnchor::basics, counts, debugs, EBIT_CLR, ENTRY_VALIDATED, Rock::DbCellHeader::entrySize, Ipc::StoreMapAnchor::Basics::flags, Ipc::StoreMapAnchor::set(), SQUID_MD5_DIGEST_LENGTH, storeRebuildParseEntry(), Ipc::StoreMapAnchor::Basics::swap_file_sz, StoreEntry::swap_file_sz, and ZeroedSlot().

◆ IsResponsible()

bool Rock::Rebuild::IsResponsible ( const SwapDir & )

staticprotected

Definition at line 272 of file RockRebuild.cc.

References IamDiskProcess(), and UsingSmp().

◆ loadingEntry()

Rock::LoadingEntry Rock::Rebuild::loadingEntry ( const sfileno fileNo )

private

Definition at line 453 of file RockRebuild.cc.

References Must.

◆ loadingSlot()

Rock::LoadingSlot Rock::Rebuild::loadingSlot ( const SlotId slotId )

private

Definition at line 460 of file RockRebuild.cc.

References Must.

◆ loadingSteps()

void Rock::Rebuild::loadingSteps ( )

private

Definition at line 418 of file RockRebuild.cc.

References counts, current_time, debugs, getCurrentTime(), opt_foreground_rebuild, StoreRebuildData::scancount, storeRebuildProgress(), and tvSubMsec().

◆ loadOneSlot()

void Rock::Rebuild::loadOneSlot ( )

private

Definition at line 468 of file RockRebuild.cc.

References counts, DBG_IMPORTANT, debugs, Rock::DbCellHeader::empty(), Rock::DbCellHeader::sane(), StoreRebuildData::scancount, and storeRebuildLoadEntry().

◆ mapSlot()

void Rock::Rebuild::mapSlot	(	const SlotId	slotId,
		const DbCellHeader &	header
	)

private

Definition at line 744 of file RockRebuild.cc.

References assert, Rock::LoadingSlot::freed(), Rock::LoadingSlot::mapped(), Ipc::StoreMapSlice::next, Rock::DbCellHeader::nextSlot, Rock::DbCellHeader::payloadSize, and Ipc::StoreMapSlice::size.

◆ mustStop()

void AsyncJob::mustStop ( const char * aReason )

protectedinherited

◆ primeNewEntry()

void Rock::Rebuild::primeNewEntry	(	Ipc::StoreMapAnchor &	anchor,
		const sfileno	fileno,
		const DbCellHeader &	header
	)

private

Definition at line 830 of file RockRebuild.cc.

References assert, Ipc::StoreMapAnchor::basics, Rock::DbCellHeader::firstSlot, Rock::DbCellHeader::key, Rock::LoadingEntry::leLoading, Ipc::StoreMapAnchor::setKey(), Rock::LoadingEntry::size, Ipc::StoreMapAnchor::start, Rock::LoadingEntry::state(), Ipc::StoreMapAnchor::Basics::swap_file_sz, Rock::DbCellHeader::version, and Rock::LoadingEntry::version.

◆ progressDescription()

SBuf Rock::Rebuild::progressDescription ( ) const

private

Definition at line 932 of file RockRebuild.cc.

References SBufStream::buf(), Debug::Extra(), and opt_store_doublecheck.

◆ registerRunner()

void IndependentRunner::registerRunner ( )

protectedinherited

Definition at line 104 of file RunnersRegistry.cc.

References FindRunners(), and RegisterRunner_().

Referenced by ConnStateData::ConnStateData(), IdleConnList::IdleConnList(), and Rebuild().

◆ sameEntry()

bool Rock::Rebuild::sameEntry	(	const sfileno	fileno,
		const DbCellHeader &	header
	)		const

private

Definition at line 866 of file RockRebuild.cc.

References Rock::DbCellHeader::key, and Ipc::StoreMapAnchor::sameKey().

◆ start()

void Rock::Rebuild::start ( )

overrideprotectedvirtual

Reimplemented from AsyncJob.

Definition at line 339 of file RockRebuild.cc.

References assert, counts, current_time, debugs, file_open(), Rock::SwapDir::HeaderSize, Important, O_BINARY, SM_PAGE_SIZE, and StoreRebuildData::updateStartTime().

◆ Start() [1/2]

void AsyncJob::Start ( const Pointer & job )

staticinherited

Promises to start the configured job (eventually). The job is deemed to be running asynchronously beyond this point, so the caller should only access the job object via AsyncCalls rather than directly.

swanSong() is only called for jobs for which this method has returned successfully (i.e. without throwing).

Definition at line 24 of file AsyncJob.cc.

References CallJobHere, AsyncJob::start(), and AsyncJob::started_.

Referenced by Ftp::Server::AcceptCtrlConnection(), clientListenerConnectionOpened(), Ipc::Coordinator::handleCacheMgrRequest(), Ipc::Coordinator::handleSnmpRequest(), httpAccept(), httpsAccept(), httpStart(), idnsInitVC(), Ftp::Gateway::listenForDataChannel(), Ftp::Server::listenForDataConnection(), Log::TcpLogger::Open(), peerProbeConnect(), Mgr::FunAction::respond(), Mgr::InfoAction::respond(), Ipc::SendMessage(), Mgr::Inquirer::sendResponse(), snmpConstructReponse(), SquidMain(), CacheManager::start(), Adaptation::AccessCheck::Start(), Start(), JobWaitBase::start_(), BodyPipe::startAutoConsumptionIfNeeded(), Ftp::StartGateway(), Ftp::StartRelay(), PeerPoolMgrsRr::syncConfig(), and Rock::SwapDir::updateHeaders().

◆ Start() [2/2]

bool Rock::Rebuild::Start ( SwapDir & dir )

static

starts indexing the given cache_dir if that indexing is necessary

Returns: whether the indexing was necessary (and, hence, started)

Definition at line 279 of file RockRebuild.cc.

References debugs, Rock::SwapDir::filePath, Store::Disk::index, Store::Disk::path, shm_old, AsyncJob::Start(), and Ping::stats.

Referenced by Rock::SwapDir::ioCompletedNotification().

◆ startNewEntry()

void Rock::Rebuild::startNewEntry	(	const sfileno	fileno,
		const SlotId	slotId,
		const DbCellHeader &	header
	)

private

Definition at line 846 of file RockRebuild.cc.

References assert, Rock::LoadingEntry::leIgnored, and Rock::LoadingEntry::state().

◆ startReconfigure()

virtual void RegisteredRunner::startReconfigure ( )

inlinevirtualinherited

Called after receiving a reconfigure request and before parsing squid.conf. Meant for modules that need to prepare for their configuration being changed [outside their control]. The changes end with the syncConfig() event.

Reimplemented in Dns::ConfigRr.

Definition at line 67 of file RunnersRegistry.h.

Referenced by mainReconfigureStart().

◆ startShutdown()

void Rock::Rebuild::startShutdown ( )

overrideprotectedvirtual

Called after receiving a shutdown request and before stopping the main loop. At least one main loop iteration is guaranteed after this call. Meant for cleanup and state saving that may require other modules.

Reimplemented from RegisteredRunner.

Definition at line 332 of file RockRebuild.cc.

◆ status()

const char * AsyncJob::status ( ) const

protectedvirtualinherited

for debugging, starts with space

Reimplemented in Adaptation::Ecap::XactionRep, Adaptation::Icap::ServiceRep, Adaptation::Icap::Xaction, Adaptation::Initiate, Http::Tunneler, Comm::TcpAcceptor, Ipc::Inquirer, Security::PeerConnector, and HappyConnOpener.

Definition at line 167 of file AsyncJob.cc.

References MemBuf::append(), Packable::appendf(), MemBuf::content(), MemBuf::reset(), AsyncJob::stopReason, and MemBuf::terminate().

Referenced by AsyncJob::callEnd(), AsyncJob::callStart(), Adaptation::Initiate::status(), and Comm::TcpAcceptor::status().

◆ steps()

void Rock::Rebuild::steps ( )

private

Definition at line 407 of file RockRebuild.cc.

◆ Steps()

void Rock::Rebuild::Steps ( void * data )

staticprivate

Definition at line 400 of file RockRebuild.cc.

References CallJobHere.

Referenced by checkpoint().

◆ swanSong()

void Rock::Rebuild::swanSong ( )

overrideprotectedvirtual

Reimplemented from AsyncJob.

Definition at line 690 of file RockRebuild.cc.

References counts, debugs, Store::Controller::store_dirs_rebuilding, and storeRebuildComplete().

◆ syncConfig()

virtual void RegisteredRunner::syncConfig ( )

inlinevirtualinherited

Called after parsing squid.conf during reconfiguration. Meant for adjusting the module state based on configuration changes.

Reimplemented in PeerPoolMgrsRr, and Auth::CredentialCacheRr.

Definition at line 71 of file RunnersRegistry.h.

Referenced by mainReconfigureFinish().

◆ toCbdata()

virtual void * CbdataParent::toCbdata ( )

pure virtualinherited

Implemented in BodySink, ClientHttpRequest, and HttpStateData.

Referenced by AsyncJob::callException(), and AsyncJob::callStart().

◆ unregisterRunner()

void IndependentRunner::unregisterRunner ( )

protectedinherited

Definition at line 96 of file RunnersRegistry.cc.

References FindRunners().

Referenced by IndependentRunner::~IndependentRunner().

◆ useConfig()

virtual void RegisteredRunner::useConfig ( )

inlinevirtualinherited

Called after claimMemoryNeeds(). Meant for activating modules and features using a finalized configuration with known memory requirements.

Reimplemented in ClientDbRr, SharedMemPagesRr, Ipc::Mem::RegisteredRunner, MemStoreRr, PeerPoolMgrsRr, SharedSessionCacheRr, and TransientsRr.

Definition at line 60 of file RunnersRegistry.h.

Referenced by RunConfigUsers().

◆ useNewSlot()

void Rock::Rebuild::useNewSlot	(	const SlotId	slotId,
		const DbCellHeader &	header
	)

private

Definition at line 876 of file RockRebuild.cc.

References assert, counts, debugs, StoreRebuildData::dupcount, Rock::DbCellHeader::firstSlot, Rock::DbCellHeader::key, Rock::LoadingEntry::leCorrupted, Rock::LoadingEntry::leEmpty, Rock::LoadingEntry::leIgnored, Rock::LoadingEntry::leLoaded, Rock::LoadingEntry::leLoading, Rock::DbCellHeader::payloadSize, and Rock::LoadingEntry::state().

◆ validateOneEntry()

void Rock::Rebuild::validateOneEntry ( const sfileno fileNo )

private

Definition at line 642 of file RockRebuild.cc.

References Rock::LoadingEntry::leCorrupted, Rock::LoadingEntry::leEmpty, Rock::LoadingEntry::leIgnored, Rock::LoadingEntry::leLoaded, Rock::LoadingEntry::leLoading, and Rock::LoadingEntry::state().

◆ validateOneSlot()

void Rock::Rebuild::validateOneSlot ( const SlotId slotId )

private

Definition at line 660 of file RockRebuild.cc.

References Rock::LoadingSlot::finalized(), Rock::LoadingSlot::freed(), Rock::LoadingSlot::mapped(), and Must.

◆ validationSteps()

void Rock::Rebuild::validationSteps ( )

private

Definition at line 559 of file RockRebuild.cc.

References counts, current_time, debugs, getCurrentTime(), opt_foreground_rebuild, tvSubMsec(), and StoreRebuildData::validations.

Member Data Documentation

◆ buf

MemBuf Rock::Rebuild::buf

private

Definition at line 120 of file RockRebuild.h.

◆ counts

StoreRebuildData& Rock::Rebuild::counts

private

Definition at line 122 of file RockRebuild.h.

◆ dbEntryLimit

int64_t Rock::Rebuild::dbEntryLimit

private

Definition at line 114 of file RockRebuild.h.

Referenced by Rebuild().

◆ dbOffset

int64_t Rock::Rebuild::dbOffset

private

Definition at line 117 of file RockRebuild.h.

◆ dbSize

int64_t Rock::Rebuild::dbSize

private

Definition at line 111 of file RockRebuild.h.

Referenced by Rebuild().

◆ dbSlotLimit

int64_t Rock::Rebuild::dbSlotLimit

private

Definition at line 113 of file RockRebuild.h.

Referenced by Rebuild().

◆ dbSlotSize

int Rock::Rebuild::dbSlotSize

private

Definition at line 112 of file RockRebuild.h.

Referenced by Rebuild().

◆ fd

int Rock::Rebuild::fd

private

Definition at line 116 of file RockRebuild.h.

◆ id

const InstanceId<AsyncJob> AsyncJob::id

inherited

Definition at line 73 of file AsyncJob.h.

◆ inCall

AsyncCall::Pointer AsyncJob::inCall

protectedinherited

Definition at line 81 of file AsyncJob.h.

Referenced by AsyncJob::callEnd(), AsyncJob::callStart(), AsyncJob::canBeCalled(), AsyncJob::deleteThis(), and AsyncJob::mustStop().

◆ loadingPos

int64_t Rock::Rebuild::loadingPos

private

Definition at line 118 of file RockRebuild.h.

◆ parts

LoadingParts* Rock::Rebuild::parts

private

Definition at line 107 of file RockRebuild.h.

◆ resuming

const bool Rock::Rebuild::resuming

private

whether we have started indexing this cache_dir before, presumably in the previous process performing the same-kid role

Definition at line 126 of file RockRebuild.h.

◆ sd

SwapDir* Rock::Rebuild::sd

private

Definition at line 106 of file RockRebuild.h.

Referenced by Rebuild().

◆ started_

bool AsyncJob::started_ = false

protectedinherited

Definition at line 83 of file AsyncJob.h.

Referenced by AsyncJob::~AsyncJob(), AsyncJob::callEnd(), and AsyncJob::Start().

◆ stats

Ipc::Mem::Pointer<Stats> Rock::Rebuild::stats

private

Definition at line 109 of file RockRebuild.h.

◆ stopReason

const char* AsyncJob::stopReason

protectedinherited

Definition at line 79 of file AsyncJob.h.

Referenced by AsyncJob::deleteThis(), AsyncJob::done(), AsyncJob::mustStop(), AsyncJob::status(), and HappyConnOpener::status().

◆ swanSang_

bool AsyncJob::swanSang_ = false

protectedinherited

Definition at line 84 of file AsyncJob.h.

Referenced by AsyncJob::~AsyncJob(), and AsyncJob::callEnd().

◆ typeName

const char* AsyncJob::typeName

protectedinherited

Definition at line 80 of file AsyncJob.h.

Referenced by AsyncJob::AsyncJob(), Adaptation::Icap::Xaction::Xaction(), AsyncJob::~AsyncJob(), AsyncJob::callEnd(), AsyncJob::callStart(), AsyncJob::deleteThis(), and AsyncJob::mustStop().

◆ validationPos

int64_t Rock::Rebuild::validationPos

private

Definition at line 119 of file RockRebuild.h.

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

src/fs/rock/RockRebuild.h
src/fs/rock/RockRebuild.cc

squid-cache.org

Optimising Web Delivery

Classes

Public Types

Public Member Functions

Static Public Member Functions

Public Attributes

Protected Member Functions

Static Protected Member Functions

Protected Attributes

Private Types

Private Member Functions

Static Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ Method

◆ Pointer

Constructor & Destructor Documentation

◆ Rebuild()

◆ ~Rebuild()

Member Function Documentation

◆ addSlotToEntry()

◆ bootstrapConfig()

◆ callEnd()

◆ callException()

◆ callStart()

◆ canBeCalled()

◆ CBDATA_CHILD()

◆ chainSlots()

◆ checkpoint()

◆ claimMemoryNeeds()

◆ deleteThis()

◆ done()

◆ doneAll()

◆ doneLoading()

◆ doneValidating()

◆ endingShutdown()

◆ failure()

◆ finalizeConfig()

◆ finalizeOrFree()

◆ finalizeOrThrow()

◆ finishShutdown()

◆ freeBadEntry()

◆ freeSlot()

◆ freeUnusedSlot()

◆ handleStopRequest()

◆ importEntry()

◆ IsResponsible()

◆ loadingEntry()

◆ loadingSlot()

◆ loadingSteps()

◆ loadOneSlot()

◆ mapSlot()

◆ mustStop()

◆ primeNewEntry()

◆ progressDescription()

◆ registerRunner()

◆ sameEntry()

◆ start()

◆ Start() [1/2]

◆ Start() [2/2]

◆ startNewEntry()

◆ startReconfigure()

◆ startShutdown()

◆ status()

◆ steps()

◆ Steps()

◆ swanSong()

◆ syncConfig()

◆ toCbdata()

◆ unregisterRunner()

◆ useConfig()

◆ useNewSlot()

◆ validateOneEntry()

◆ validateOneSlot()

◆ validationSteps()

Member Data Documentation

◆ buf

◆ counts