Public Types | Public Member Functions | Static Public Member Functions | Public Attributes | Protected Member Functions | Protected Attributes | Private Types | Private Member Functions | Private Attributes | Static Private Attributes | List of all members
Ipc::Coordinator Class Referenceabstract

Coordinates shared activities of Strands (Squid processes or threads) More...

#include <Coordinator.h>

Inheritance diagram for Ipc::Coordinator:
Inheritance graph
[legend]
Collaboration diagram for Ipc::Coordinator:
Collaboration graph
[legend]

Public Types

typedef CbcPointer< AsyncJob > Pointer
 

Public Member Functions

 Coordinator ()
 
void broadcastSignal (int sig) const
 send sig to registered strands More...
 
const StrandCoords & strands () const
 currently registered strands More...
 
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...
 
virtual void * toCbdata ()=0
 

Static Public Member Functions

static Coordinator * Instance ()
 
static String MakeAddr (const char *proccessLabel, int id)
 calculates IPC message address for strand id of processLabel type More...
 
static String CoordinatorAddr ()
 get the IPC message address for coordinator process More...
 
static Pointer Start (AsyncJob *job)
 starts a freshly created job (i.e., makes the job asynchronous) More...
 

Public Attributes

struct sockaddr_un address
 UDS address from path; treat as read-only. More...
 

Protected Member Functions

virtual void start ()
 called by AsyncStart; do not call directly More...
 
virtual void receive (const TypedMsgHdr &message)
 handle IPC message just read More...
 
StrandCoord * findStrand (int kidId)
 registered strand or NULL More...
 
void registerStrand (const StrandCoord &)
 adds or updates existing More...
 
void handleRegistrationRequest (const HereIamMessage &)
 register,ACK More...
 
void notifySearcher (const StrandSearchRequest &request, const StrandCoord &)
 answer the waiting search request More...
 
void handleSearchRequest (const StrandSearchRequest &request)
 answers or queues the request if the answer is not yet known More...
 
void handleSharedListenRequest (const SharedListenRequest &request)
 returns cached socket or calls openListenSocket() More...
 
void handleCacheMgrRequest (const Mgr::Request &request)
 
void handleCacheMgrResponse (const Mgr::Response &response)
 
void handleSnmpRequest (const Snmp::Request &request)
 
void handleSnmpResponse (const Snmp::Response &response)
 
Comm::ConnectionPointer openListenSocket (const SharedListenRequest &request, int &errNo)
 calls comm_open_listener() More...
 
virtual bool doneAll () const
 whether positive goal has been reached More...
 
void doListen ()
 read the next incoming message More...
 
virtual void timedout ()
 called after setTimeout() if timed out More...
 
Comm::ConnectionPointer & conn ()
 creates if needed and returns raw UDS socket descriptor More...
 
void setTimeout (int seconds, const char *handlerName)
 call timedout() if no UDS messages in a given number of seconds More...
 
void clearTimeout ()
 remove previously set timeout, if any More...
 
void setOptions (int newOptions)
 changes socket options More...
 
void deleteThis (const char *aReason)
 
void mustStop (const char *aReason)
 
bool done () const
 the job is destroyed in callEnd() when done() More...
 
virtual void swanSong ()
 
virtual const char * status () const
 internal cleanup; do not call directly 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...
 
const InstanceId< AsyncJob > id
 job identifier More...
 

Private Types

typedef std::list< StrandSearchRequest > Searchers
 search requests More...
 
typedef std::map< OpenListenerParams, Comm::ConnectionPointer > Listeners
 params:connection map More...
 

Private Member Functions

 CBDATA_CLASS (Coordinator)
 
 Coordinator (const Coordinator &)
 
Coordinator & operator= (const Coordinator &)
 

Private Attributes

StrandCoords strands_
 registered processes and threads More...
 
Searchers searchers
 yet unanswered search requests in arrival order More...
 
Listeners listeners
 cached comm_open_listener() results More...
 

Static Private Attributes

static Coordinator * TheInstance = NULL
 the only class instance in existence More...
 

Detailed Description

Definition at line 30 of file Coordinator.h.

Member Typedef Documentation

◆ Listeners

typedef std::map<OpenListenerParams, Comm::ConnectionPointer> Ipc::Coordinator::Listeners
private

Definition at line 74 of file Coordinator.h.

◆ Pointer

typedef CbcPointer<AsyncJob> AsyncJob::Pointer
inherited

Definition at line 34 of file AsyncJob.h.

◆ Searchers

typedef std::list<StrandSearchRequest> Ipc::Coordinator::Searchers
private

Definition at line 71 of file Coordinator.h.

Constructor & Destructor Documentation

◆ Coordinator() [1/2]

Ipc::Coordinator::Coordinator ( )

Definition at line 34 of file Coordinator.cc.

Referenced by Instance().

◆ Coordinator() [2/2]

Ipc::Coordinator::Coordinator ( const Coordinator &  )
private

Member Function Documentation

◆ broadcastSignal()

void Ipc::Coordinator::broadcastSignal ( int  sig) const

Definition at line 281 of file Coordinator.cc.

References debugs, HERE(), and strands_.

◆ callEnd()

void AsyncJob::callEnd ( )
virtualinherited

called right after the called job method

Reimplemented in Adaptation::Icap::Xaction.

Definition at line 136 of file AsyncJob.cc.

References AsyncCall::debugLevel, debugs, AsyncCall::debugSection, AsyncJob::done(), HERE(), AsyncJob::inCall, NULL, AsyncJob::status(), AsyncJob::swanSong(), and AsyncJob::typeName.

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

◆ callException()

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

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

Definition at line 127 of file AsyncJob.cc.

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

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

◆ callStart()

void AsyncJob::callStart ( AsyncCall &  call)
inherited

called just before the called method

Definition at line 114 of file AsyncJob.cc.

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

Referenced by AsyncJob::swanSong().

◆ canBeCalled()

bool AsyncJob::canBeCalled ( AsyncCall &  call) const
inherited

Definition at line 101 of file AsyncJob.cc.

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

Referenced by AsyncJob::swanSong().

◆ CBDATA_CLASS()

Ipc::Coordinator::CBDATA_CLASS ( Coordinator  )
private

◆ clearTimeout()

void Ipc::UdsOp::clearTimeout ( )
protectedinherited

Definition at line 62 of file UdsOp.cc.

References commUnsetConnTimeout(), and Ipc::UdsOp::conn().

Referenced by Ipc::Strand::handleRegistrationResponse(), and Ipc::UdsOp::timedout().

◆ conn()

Comm::ConnectionPointer & Ipc::UdsOp::conn ( )
protectedinherited

Definition at line 41 of file UdsOp.cc.

References Ipc::UdsOp::address, COMM_DOBIND, comm_open_uds(), Ipc::UdsOp::conn_, Comm::Connection::fd, Comm::IsConnOpen(), Must, NULL, Ipc::UdsOp::options, and sockaddr_un::sun_path.

Referenced by Ipc::UdsOp::clearTimeout(), Ipc::Port::doListen(), Ipc::ImportFdIntoComm(), Ipc::UdsOp::setTimeout(), Ipc::UdsOp::timedout(), Ipc::UdsSender::write(), and Ipc::UdsSender::wrote().

◆ CoordinatorAddr()

String Ipc::Port::CoordinatorAddr ( )
staticinherited

Definition at line 64 of file Port.cc.

References String::append(), SBuf::c_str(), channelPathPfx, coordinatorAddrLabel, service_name, and String::size().

Referenced by IpcIoFile::open(), Ipc::Strand::registerSelf(), Snmp::SendResponse(), Mgr::Action::sendResponse(), SendSharedListenRequest(), and Ipc::Forwarder::start().

◆ deleteThis()

void AsyncJob::deleteThis ( const char *  aReason)
protectedinherited

Definition at line 49 of file AsyncJob.cc.

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

◆ doListen()

void Ipc::Port::doListen ( )
protectedinherited

Definition at line 36 of file Port.cc.

References Ipc::Port::buf, comm_read(), Ipc::UdsOp::conn(), debugs, HERE(), JobCallback, Ipc::Port::noteRead(), Ipc::TypedMsgHdr::prepForReading(), Ipc::TypedMsgHdr::raw(), and Ipc::TypedMsgHdr::size().

Referenced by Ipc::Port::noteRead(), and Ipc::Port::start().

◆ done()

bool AsyncJob::done ( ) const
protectedinherited

Definition at line 90 of file AsyncJob.cc.

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

Referenced by Adaptation::Ecap::XactionRep::blockVirgin(), AsyncJob::callEnd(), Adaptation::AccessCheck::checkCandidates(), Rock::Rebuild::checkpoint(), Downloader::downloadFinished(), Comm::TcpAcceptor::handleClosure(), Adaptation::Icap::OptXact::handleCommRead(), Ipc::Inquirer::handleRemoteAck(), Ipc::Inquirer::inquire(), Adaptation::Icap::Launcher::noteAdaptationAnswer(), Adaptation::AccessCheck::noteAnswer(), Adaptation::Icap::Launcher::noteInitiatorAborted(), Adaptation::Icap::Launcher::noteXactAbort(), Ipc::Inquirer::requestTimedOut(), Adaptation::Iterator::step(), Adaptation::AccessCheck::usedDynamicRules(), and Adaptation::Ecap::XactionRep::useVirgin().

◆ doneAll()

bool Ipc::Port::doneAll ( ) const
protectedvirtualinherited

Reimplemented from AsyncJob.

Definition at line 46 of file Port.cc.

◆ findStrand()

Ipc::StrandCoord * Ipc::Coordinator::findStrand ( int  kidId)
protected

Definition at line 44 of file Coordinator.cc.

References NULL, and strands_.

Referenced by registerStrand().

◆ handleCacheMgrRequest()

void Ipc::Coordinator::handleCacheMgrRequest ( const Mgr::Request &  request)
protected

Definition at line 167 of file Coordinator.cc.

References action(), Mgr::ActionParams::actionName, Mgr::Request::conn, CacheManager::createRequestedAction(), DBG_IMPORTANT, debugs, Comm::Connection::fd, CacheManager::GetInstance(), HERE(), Ipc::Port::MakeAddr(), Mgr::Response::pack(), Mgr::Request::params, Ipc::Request::requestId, Ipc::Request::requestorId, Ipc::SendMessage(), AsyncJob::Start(), Ipc::strandAddrLabel, and strands_.

Referenced by receive().

◆ handleCacheMgrResponse()

void Ipc::Coordinator::handleCacheMgrResponse ( const Mgr::Response &  response)
protected

Definition at line 193 of file Coordinator.cc.

References Ipc::Inquirer::HandleRemoteAck().

Referenced by receive().

◆ handleRegistrationRequest()

void Ipc::Coordinator::handleRegistrationRequest ( const HereIamMessage &  msg)
protected

Definition at line 136 of file Coordinator.cc.

References Ipc::StrandCoord::kidId, Ipc::Port::MakeAddr(), Ipc::HereIamMessage::pack(), registerStrand(), Ipc::SendMessage(), Ipc::HereIamMessage::strand, and Ipc::strandAddrLabel.

Referenced by receive().

◆ handleSearchRequest()

void Ipc::Coordinator::handleSearchRequest ( const StrandSearchRequest &  request)
protected

Definition at line 199 of file Coordinator.cc.

References debugs, HERE(), i, notifySearcher(), NULL, Ipc::StrandSearchRequest::requestorId, searchers, strands_, and Ipc::StrandSearchRequest::tag.

Referenced by receive().

◆ handleSharedListenRequest()

void Ipc::Coordinator::handleSharedListenRequest ( const SharedListenRequest &  request)
protected

Definition at line 147 of file Coordinator.cc.

References Ipc::OpenListenerParams::addr, debugs, Comm::Connection::fd, HERE(), i, listeners, Ipc::Port::MakeAddr(), Ipc::SharedListenRequest::mapId, openListenSocket(), Ipc::SharedListenResponse::pack(), Ipc::SharedListenRequest::params, Ipc::SharedListenRequest::requestorId, Ipc::SendMessage(), and Ipc::strandAddrLabel.

Referenced by receive().

◆ handleSnmpRequest()

void Ipc::Coordinator::handleSnmpRequest ( const Snmp::Request &  request)
protected

Definition at line 233 of file Coordinator.cc.

References debugs, HERE(), Ipc::Port::MakeAddr(), Snmp::Response::pack(), Ipc::Request::requestId, Ipc::Request::requestorId, Ipc::SendMessage(), AsyncJob::Start(), Ipc::strandAddrLabel, and strands_.

Referenced by receive().

◆ handleSnmpResponse()

void Ipc::Coordinator::handleSnmpResponse ( const Snmp::Response &  response)
protected

Definition at line 246 of file Coordinator.cc.

References debugs, Ipc::Inquirer::HandleRemoteAck(), and HERE().

Referenced by receive().

◆ Instance()

Ipc::Coordinator * Ipc::Coordinator::Instance ( )
static

Definition at line 291 of file Coordinator.cc.

References Coordinator(), and TheInstance.

Referenced by SquidMain().

◆ MakeAddr()

String Ipc::Port::MakeAddr ( const char *  proccessLabel,
int  id 
)
staticinherited

Definition at line 51 of file Port.cc.

References addr, String::append(), assert, SBuf::c_str(), channelPathPfx, service_name, and xitoa().

Referenced by handleCacheMgrRequest(), handleRegistrationRequest(), handleSharedListenRequest(), handleSnmpRequest(), Ipc::Inquirer::inquire(), CollapsedForwarding::Notify(), IpcIoFile::Notify(), and notifySearcher().

◆ mustStop()

void AsyncJob::mustStop ( const char *  aReason)
protectedinherited

Definition at line 69 of file AsyncJob.cc.

References debugs, AsyncJob::inCall, Must, NULL, AsyncJob::stopReason, and AsyncJob::typeName.

Referenced by HttpStateData::abortAll(), Ftp::Client::abortAll(), Comm::TcpAcceptor::acceptOne(), Adaptation::Ecap::XactionRep::adaptationAborted(), Adaptation::AccessCheck::callBack(), AsyncJob::callException(), Security::PeerConnector::connectionClosed(), HttpStateData::continueAfterParsingHeader(), Ftp::Client::ctrlClosed(), Adaptation::Iterator::handleAdaptationBlock(), Adaptation::Iterator::handleAdaptationError(), Log::TcpLogger::handleClosure(), Adaptation::Icap::Xaction::handleCommClosed(), Mgr::Forwarder::handleError(), Ipc::Forwarder::handleError(), Ipc::Forwarder::handleException(), Ipc::Inquirer::handleException(), HttpStateData::handleMoreRequestBodyAvailable(), Ipc::Inquirer::handleRemoteAck(), Ipc::Forwarder::handleTimeout(), HttpStateData::httpStateConnClosed(), HttpStateData::httpTimeout(), Comm::ConnOpener::noteAbort(), Adaptation::Icap::ModXact::noteBodyConsumerAborted(), Snmp::Forwarder::noteCommClosed(), Snmp::Inquirer::noteCommClosed(), Mgr::Inquirer::noteCommClosed(), Mgr::Forwarder::noteCommClosed(), Mgr::StoreToCommWriter::noteCommClosed(), Adaptation::Icap::Xaction::noteCommRead(), Rock::HeaderUpdater::noteDoneReading(), Adaptation::Iterator::noteInitiatorAborted(), Adaptation::Icap::Xaction::noteInitiatorAborted(), Adaptation::Ecap::XactionRep::noteInitiatorAborted(), HttpStateData::readReply(), Comm::ConnOpener::sendAnswer(), Rock::Rebuild::start(), Security::PeerConnector::start(), HttpStateData::start(), Ipc::UdsSender::timedout(), and HttpStateData::wroteLast().

◆ notifySearcher()

void Ipc::Coordinator::notifySearcher ( const StrandSearchRequest &  request,
const StrandCoord &  strand 
)
protected

Definition at line 220 of file Coordinator.cc.

References debugs, HERE(), Ipc::StrandCoord::kidId, Ipc::Port::MakeAddr(), Ipc::StrandSearchResponse::pack(), Ipc::StrandSearchRequest::requestorId, Ipc::SendMessage(), Ipc::strandAddrLabel, and Ipc::StrandSearchRequest::tag.

Referenced by handleSearchRequest(), and registerStrand().

◆ openListenSocket()

Comm::ConnectionPointer Ipc::Coordinator::openListenSocket ( const SharedListenRequest &  request,
int &  errNo 
)
protected

Definition at line 254 of file Coordinator.cc.

References Ipc::OpenListenerParams::addr, comm_open_listener(), debugs, enter_suid(), Ipc::FdNote(), Ipc::OpenListenerParams::fdNote, Ipc::OpenListenerParams::flags, Comm::Connection::flags, HERE(), Comm::IsConnOpen(), leave_suid(), listeners, Comm::Connection::local, p, Ipc::SharedListenRequest::params, Ipc::OpenListenerParams::proto, Ipc::SharedListenRequest::requestorId, and Ipc::OpenListenerParams::sock_type.

Referenced by handleSharedListenRequest().

◆ operator=()

Coordinator& Ipc::Coordinator::operator= ( const Coordinator &  )
private

◆ receive()

void Ipc::Coordinator::receive ( const TypedMsgHdr &  message)
protectedvirtual

Implements Ipc::Port.

Definition at line 79 of file Coordinator.cc.

References DBG_IMPORTANT, debugs, handleCacheMgrRequest(), handleCacheMgrResponse(), handleRegistrationRequest(), handleSearchRequest(), handleSharedListenRequest(), handleSnmpRequest(), handleSnmpResponse(), HERE(), Ipc::mtCacheMgrRequest, Ipc::mtCacheMgrResponse, Ipc::mtRegistration, Ipc::mtSharedListenRequest, Ipc::mtSnmpRequest, Ipc::mtSnmpResponse, Ipc::mtStrandSearchRequest, Ipc::StrandSearchRequest::requestorId, Ipc::StrandSearchRequest::tag, and Ipc::TypedMsgHdr::type().

◆ registerStrand()

void Ipc::Coordinator::registerStrand ( const StrandCoord &  strand)
protected

Definition at line 54 of file Coordinator.cc.

References debugs, findStrand(), HERE(), i, Ipc::StrandCoord::kidId, notifySearcher(), searchers, String::size(), strands_, and Ipc::StrandCoord::tag.

Referenced by handleRegistrationRequest().

◆ setOptions()

void Ipc::UdsOp::setOptions ( int  newOptions)
protectedinherited

Definition at line 35 of file UdsOp.cc.

References Ipc::UdsOp::options.

Referenced by Ipc::Port::Port(), and Ipc::UdsOp::timedout().

◆ setTimeout()

void Ipc::UdsOp::setTimeout ( int  seconds,
const char *  handlerName 
)
protectedinherited

Definition at line 54 of file UdsOp.cc.

References asyncCall(), commSetConnTimeout(), Ipc::UdsOp::conn(), handler(), and Ipc::UdsOp::noteTimeout().

Referenced by Ipc::Strand::registerSelf(), Ipc::UdsSender::start(), and Ipc::UdsOp::timedout().

◆ Start()

AsyncJob::Pointer AsyncJob::Start ( AsyncJob *  job)
staticinherited

Definition at line 23 of file AsyncJob.cc.

References CallJobHere, and AsyncJob::start().

Referenced by Ftp::Server::AcceptCtrlConnection(), Ftp::Server::checkDataConnPre(), clientListenerConnectionOpened(), Ftp::Client::connectDataChannel(), FwdState::connectDone(), FwdState::connectStart(), TunnelStateData::connectToPeer(), Adaptation::Icap::Xaction::dnsLookupDone(), Log::TcpLogger::doConnect(), handleCacheMgrRequest(), PeerPoolMgr::handleOpenedConnection(), handleSnmpRequest(), httpAccept(), httpsAccept(), httpStart(), idnsInitVC(), Adaptation::Initiator::initiateAdaptation(), Ftp::Gateway::listenForDataChannel(), Ftp::Server::listenForDataConnection(), Adaptation::Icap::Xaction::noteCommConnected(), Log::TcpLogger::Open(), PeerPoolMgr::openNewConnection(), peerProbeConnect(), Rock::SwapDir::rebuild(), Mgr::FunAction::respond(), Mgr::InfoAction::respond(), Ipc::SendMessage(), Mgr::Inquirer::sendResponse(), snmpConstructReponse(), SquidMain(), Ident::Start(), Adaptation::AccessCheck::Start(), CacheManager::Start(), Security::PeerConnector::startCertDownloading(), TunnelStateData::startConnecting(), Ftp::StartGateway(), Ftp::StartRelay(), PeerPoolMgrsRr::syncConfig(), and Rock::SwapDir::updateHeaders().

◆ start()

void Ipc::Coordinator::start ( )
protectedvirtual

Implements Ipc::Port.

Definition at line 39 of file Coordinator.cc.

References Ipc::Port::start().

◆ status()

const char * AsyncJob::status ( ) const
protectedvirtualinherited

for debugging, starts with space

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

Definition at line 159 of file AsyncJob.cc.

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

Referenced by BodyPipe::buf(), AsyncJob::callEnd(), AsyncJob::callStart(), ClientRequestContext::clientAccessCheckDone(), ClientRequestContext::clientRedirectDone(), Ftp::Client::ctrlClosed(), Ftp::Relay::dataChannelConnected(), Ftp::Client::dataClosed(), Ftp::Client::dataComplete(), Ftp::Client::doneSendingRequestBody(), Ftp::Client::handleControlReply(), Ftp::Client::handleEpsvReply(), Ftp::Client::handlePasvReply(), Ftp::Client::parseControlReply(), Ftp::Relay::processReplyBody(), Ftp::Gateway::processReplyBody(), Ftp::Relay::readTransferDoneReply(), Ftp::Client::sendEprt(), Ftp::Client::sendPassive(), Adaptation::Initiate::status(), Comm::TcpAcceptor::status(), and AsyncJob::swanSong().

◆ strands()

const Ipc::StrandCoords & Ipc::Coordinator::strands ( ) const

Definition at line 302 of file Coordinator.cc.

References strands_.

◆ swanSong()

virtual void AsyncJob::swanSong ( )
inlineprotectedvirtualinherited

Reimplemented in Adaptation::Icap::ModXactLauncher, Adaptation::Icap::ModXact, ConnStateData, Adaptation::Icap::Xaction, Security::PeerConnector, Adaptation::Ecap::XactionRep, Client, Ipc::UdsSender, Adaptation::Icap::Launcher, Ftp::Relay, Log::TcpLogger, Adaptation::Iterator, Downloader, Comm::TcpAcceptor, Adaptation::Initiate, Ipc::Forwarder, Adaptation::Icap::OptXact, Comm::ConnOpener, Rock::HeaderUpdater, Ipc::Inquirer, Mgr::Forwarder, Rock::Rebuild, Mgr::StoreToCommWriter, PeerPoolMgr, Server, Snmp::Forwarder, and Mgr::Filler.

Definition at line 54 of file AsyncJob.h.

References AsyncJob::callEnd(), AsyncJob::callException(), AsyncJob::callStart(), AsyncJob::canBeCalled(), AsyncJob::status(), and AsyncJob::~AsyncJob().

Referenced by AsyncJob::callEnd(), PeerPoolMgr::swanSong(), Server::swanSong(), Rock::HeaderUpdater::swanSong(), Comm::ConnOpener::swanSong(), Comm::TcpAcceptor::swanSong(), Log::TcpLogger::swanSong(), Ipc::UdsSender::swanSong(), Client::swanSong(), and Security::PeerConnector::swanSong().

◆ timedout()

virtual void Ipc::UdsOp::timedout ( )
inlineprotectedvirtualinherited

Reimplemented in Ipc::UdsSender, and Ipc::Strand.

Definition at line 39 of file UdsOp.h.

References Ipc::UdsOp::clearTimeout(), Ipc::UdsOp::conn(), Ipc::UdsOp::noteTimeout(), p, Ipc::UdsOp::setOptions(), and Ipc::UdsOp::setTimeout().

Referenced by Ipc::UdsOp::noteTimeout().

◆ toCbdata()

virtual void* CbdataParent::toCbdata ( )
pure virtualinherited

Implemented in ClientHttpRequest, HttpStateData, and BodySink.

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

Member Data Documentation

◆ address

struct sockaddr_un Ipc::UdsOp::address
inherited

Definition at line 36 of file UdsOp.h.

Referenced by Ipc::UdsOp::conn(), and Ipc::UdsSender::UdsSender().

◆ id

const InstanceId<AsyncJob> AsyncJob::id
protectedinherited

Definition at line 72 of file AsyncJob.h.

◆ inCall

AsyncCall::Pointer AsyncJob::inCall
protectedinherited

Definition at line 71 of file AsyncJob.h.

Referenced by AsyncJob::callEnd(), Adaptation::Icap::ModXact::callException(), AsyncJob::callStart(), AsyncJob::canBeCalled(), AsyncJob::deleteThis(), Log::TcpLogger::endGracefully(), Log::TcpLogger::handleClosure(), and AsyncJob::mustStop().

◆ listeners

Listeners Ipc::Coordinator::listeners
private

Definition at line 75 of file Coordinator.h.

Referenced by handleSharedListenRequest(), and openListenSocket().

◆ searchers

Searchers Ipc::Coordinator::searchers
private

Definition at line 72 of file Coordinator.h.

Referenced by handleSearchRequest(), and registerStrand().

◆ stopReason

const char* AsyncJob::stopReason
protectedinherited

Definition at line 69 of file AsyncJob.h.

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

◆ strands_

StrandCoords Ipc::Coordinator::strands_
private

Definition at line 69 of file Coordinator.h.

Referenced by broadcastSignal(), findStrand(), handleCacheMgrRequest(), handleSearchRequest(), handleSnmpRequest(), registerStrand(), and strands().

◆ TheInstance

Ipc::Coordinator * Ipc::Coordinator::TheInstance = NULL
staticprivate

Definition at line 77 of file Coordinator.h.

Referenced by Instance().

◆ typeName

const char* AsyncJob::typeName
protectedinherited

Definition at line 70 of file AsyncJob.h.

Referenced by AsyncJob::AsyncJob(), AsyncJob::callEnd(), Adaptation::Icap::Xaction::callEnd(), AsyncJob::callStart(), AsyncJob::deleteThis(), Adaptation::Icap::Xaction::dieOnConnectionFailure(), Adaptation::Icap::Xaction::disableRepeats(), Adaptation::Icap::Xaction::disableRetries(), Adaptation::Icap::Xaction::handleCommTimedout(), Adaptation::Icap::Xaction::handleSecuredPeer(), AsyncJob::mustStop(), Adaptation::Icap::Xaction::openConnection(), Adaptation::Icap::Xaction::Xaction(), AsyncJob::~AsyncJob(), and Adaptation::Icap::Xaction::~Xaction().

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

 

Introduction

Documentation

Support

Miscellaneous

Web Site Translations

Mirrors