DiskdAction Class Reference

implement aggregated 'diskd' action More...

#include <DiskdAction.h>

Inheritance diagram for DiskdAction:

Collaboration diagram for DiskdAction:

Public Types
typedef RefCount< Action >	Pointer

Public Member Functions
void	add (const Mgr::Action &action) override
	incrementally merge in remote information (of the same action type) More...
void	pack (Ipc::TypedMsgHdr &hdrMsg) const override
	pack collected action info into a message to be sent to Coordinator More...
void	unpack (const Ipc::TypedMsgHdr &hdrMsg) override
	unpack action info from the message received by Coordinator More...
void	run (StoreEntry *entry, bool writeHttpHeader)
	collect + fillEntry: collect local information and fill the store entry More...
void	fillEntry (StoreEntry *entry, bool writeHttpHeader)
	prepare store entry, dump info, close store entry (if possible) More...
virtual void	respond (const Request &request)
	respond to Coordinator request; default is to collect and sendResponse More...
void	sendResponse (Ipc::RequestId)
	notify Coordinator that this action is done with local processing More...
virtual bool	aggregatable () const
virtual Format	format () const
	action report syntax More...
bool	atomic () const
	dump() call writes everything before returning More...
const char *	name () const
	label as seen in the cache manager menu More...
const Command &	command () const
	the cause of this action More...
StoreEntry *	createStoreEntry () const
	creates store entry from params More...
const char *	contentType () const
	HTTP Content-Type header value for this Action report. More...

Static Public Member Functions
static Pointer	Create (const Mgr::CommandPointer &aCmd)

Protected Member Functions
	DiskdAction (const Mgr::CommandPointer &aCmd)
void	collect () override
	calculate and keep local action-specific information More...
void	dump (StoreEntry *entry) override

Private Attributes
DiskdActionData	data
const CommandPointer	cmd
	the command that caused this action More...

Detailed Description

Definition at line 53 of file DiskdAction.h.

Member Typedef Documentation

Pointer

typedef RefCount<Action> Mgr::Action::Pointer

inherited

Definition at line 28 of file Action.h.

Constructor & Destructor Documentation

DiskdAction()

DiskdAction::DiskdAction ( const Mgr::CommandPointer &  aCmd )

protected

Definition at line 65 of file DiskdAction.cc.

References debugs, and MYNAME.

Referenced by Create().

Member Function Documentation

add()

void DiskdAction::add ( const Mgr::Action &  action )

overridevirtual

Reimplemented from Mgr::Action.

Definition at line 72 of file DiskdAction.cc.

References data, debugs, and MYNAME.

aggregatable()

virtual bool Mgr::Action::aggregatable ( ) const

inlinevirtualinherited

whether at least some local kid info can be combined and, hence, the combined data should be written at the end of the coordinated response

Reimplemented in Ssl::CertificateStorageAction, and Mgr::FunAction.

Definition at line 65 of file Action.h.

atomic()

bool Mgr::Action::atomic ( ) const

inherited

Definition at line 43 of file Action.cc.

collect()

void DiskdAction::collect ( )

overrideprotectedvirtual

Reimplemented from Mgr::Action.

Definition at line 79 of file DiskdAction.cc.

References DiskdActionData::block_queue_len, diskd_stats_t::block_queue_len, diskd_stats_t::close, DiskdActionData::close_fail, DiskdActionData::close_ops, DiskdActionData::close_success, diskd_stats_t::create, DiskdActionData::create_fail, DiskdActionData::create_ops, DiskdActionData::create_success, data, diskd_stats, diskd_stats_t::fail, DiskdActionData::max_away, diskd_stats_t::max_away, DiskdActionData::max_shmuse, diskd_stats_t::max_shmuse, diskd_stats_t::open, DiskdActionData::open_fail, DiskdActionData::open_fail_queue_len, diskd_stats_t::open_fail_queue_len, DiskdActionData::open_ops, DiskdActionData::open_success, diskd_stats_t::ops, diskd_stats_t::read, DiskdActionData::read_fail, DiskdActionData::read_ops, DiskdActionData::read_success, DiskdActionData::recv_count, diskd_stats_t::recv_count, DiskdActionData::sent_count, diskd_stats_t::sent_count, diskd_stats_t::success, diskd_stats_t::unlink, DiskdActionData::unlink_fail, DiskdActionData::unlink_ops, DiskdActionData::unlink_success, diskd_stats_t::write, DiskdActionData::write_fail, DiskdActionData::write_ops, and DiskdActionData::write_success.

command()

const Mgr::Command & Mgr::Action::command ( ) const

inherited

Definition at line 36 of file Action.cc.

References Must.

contentType()

const char * Mgr::Action::contentType ( ) const

inherited

Definition at line 61 of file Action.cc.

References assert, Mgr::informal, and Mgr::yaml.

Create()

DiskdAction::Pointer DiskdAction::Create ( const Mgr::CommandPointer &  aCmd )

static

Definition at line 60 of file DiskdAction.cc.

References DiskdAction().

Referenced by DiskDaemonDiskIOModule::registerWithCacheManager().

createStoreEntry()

StoreEntry * Mgr::Action::createStoreEntry ( ) const

inherited

Definition at line 74 of file Action.cc.

References Mgr::ActionParams::httpFlags, Mgr::ActionParams::httpMethod, Mgr::ActionParams::httpUri, storeCreateEntry(), and String::termedBuf().

dump()

void DiskdAction::dump ( StoreEntry *  )

overrideprotectedvirtual

start writing action-specific info to Store entry; may collect info during dump, especially if collect() did nothing non-atomic() actions may continue writing asynchronously after returning

Reimplemented from Mgr::Action.

Definition at line 115 of file DiskdAction.cc.

References DiskdActionData::block_queue_len, DiskdActionData::close_fail, DiskdActionData::close_ops, DiskdActionData::close_success, DiskdActionData::create_fail, DiskdActionData::create_ops, DiskdActionData::create_success, data, debugs, DiskdActionData::max_away, DiskdActionData::max_shmuse, Must, MYNAME, DiskdActionData::open_fail, DiskdActionData::open_fail_queue_len, DiskdActionData::open_ops, DiskdActionData::open_success, DiskdActionData::read_fail, DiskdActionData::read_ops, DiskdActionData::read_success, DiskdActionData::recv_count, DiskdActionData::sent_count, storeAppendPrintf(), DiskdActionData::unlink_fail, DiskdActionData::unlink_ops, DiskdActionData::unlink_success, DiskdActionData::write_fail, DiskdActionData::write_ops, and DiskdActionData::write_success.

fillEntry()

void Mgr::Action::fillEntry ( StoreEntry *  entry, bool  writeHttpHeader  )

inherited

Definition at line 118 of file Action.cc.

References StoreEntry::buffer(), StoreEntry::complete(), debugs, StoreEntry::flush(), MYNAME, CacheManager::PutCommonResponseHeaders(), StoreEntry::replaceHttpReply(), Http::scOkay, HttpReply::setHeaders(), and squid_curtime.

format()

Mgr::Format Mgr::Action::format ( ) const

virtualinherited

Definition at line 49 of file Action.cc.

name()

const char * Mgr::Action::name ( ) const

inherited

Definition at line 55 of file Action.cc.

pack()

void DiskdAction::pack ( Ipc::TypedMsgHdr &  ) const

overridevirtual

Reimplemented from Mgr::Action.

Definition at line 141 of file DiskdAction.cc.

References data, Ipc::mtCacheMgrResponse, Ipc::TypedMsgHdr::putPod(), and Ipc::TypedMsgHdr::setType().

respond()

void Mgr::Action::respond ( const Request &  request )

virtualinherited

Reimplemented in Mgr::InfoAction, and Mgr::FunAction.

Definition at line 87 of file Action.cc.

References Mgr::Request::conn, debugs, Comm::Connection::fd, MYNAME, and Ipc::Request::requestId.

run()

void Mgr::Action::run ( StoreEntry *  entry, bool  writeHttpHeader  )

inherited

Definition at line 110 of file Action.cc.

References debugs, and MYNAME.

sendResponse()

void Mgr::Action::sendResponse ( Ipc::RequestId  requestId )

inherited

Definition at line 101 of file Action.cc.

References Ipc::Port::CoordinatorAddr(), Mgr::Response::pack(), and Ipc::SendMessage().

unpack()

void DiskdAction::unpack ( const Ipc::TypedMsgHdr &  )

overridevirtual

Reimplemented from Mgr::Action.

Definition at line 148 of file DiskdAction.cc.

References Ipc::TypedMsgHdr::checkType(), data, Ipc::TypedMsgHdr::getPod(), and Ipc::mtCacheMgrResponse.

Member Data Documentation

cmd

const CommandPointer Mgr::Action::cmd

privateinherited

Definition at line 90 of file Action.h.

Referenced by Mgr::Action::Action(), SBufStatsAction::Create(), and Mgr::IndexAction::Create().

data

DiskdActionData DiskdAction::data

private

Definition at line 71 of file DiskdAction.h.

Referenced by add(), collect(), dump(), pack(), and unpack().

---

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

• src/DiskIO/DiskDaemon/DiskdAction.h
• src/DiskIO/DiskDaemon/DiskdAction.cc