Public Types | Public Member Functions | Static Public Member Functions | Public Attributes | Protected Member Functions | Protected Attributes | Private Member Functions | Private Attributes | List of all members
Adaptation::Icap::Xaction Class Referenceabstract

#include <Xaction.h>

Inheritance diagram for Adaptation::Icap::Xaction:
Inheritance graph
[legend]
Collaboration diagram for Adaptation::Icap::Xaction:
Collaboration graph
[legend]

Public Types

typedef CbcPointer< AsyncJob > Pointer
 

Public Member Functions

 Xaction (const char *aTypeName, ServiceRep::Pointer &aService)
 
virtual ~Xaction ()
 
void disableRetries ()
 
void disableRepeats (const char *reason)
 
bool retriable () const
 
bool repeatable () const
 
void noteCommConnected (const CommConnectCbParams &io)
 called when the connection attempt to an ICAP service completes (successfully or not) More...
 
void noteCommWrote (const CommIoCbParams &io)
 
void noteCommRead (const CommIoCbParams &io)
 
void noteCommTimedout (const CommTimeoutCbParams &io)
 
void noteCommClosed (const CommCloseCbParams &io)
 
virtual void callException (const std::exception &e)
 called when the job throws during an async call More...
 
virtual void callEnd ()
 called right after the called job method More...
 
virtual void clearError ()
 clear stored error details, if any; used for retries/repeats More...
 
virtual AccessLogEntry::Pointer masterLogEntry ()
 
void dnsLookupDone (const ipcache_addrs *ia)
 
ServiceRep & service ()
 
void initiator (const CbcPointer< Initiator > &i)
 sets initiator More...
 
bool canBeCalled (AsyncCall &call) const
 whether we can be called More...
 
void callStart (AsyncCall &call)
 
void handleStopRequest ()
 process external request to terminate now (i.e. during this async call) More...
 
virtual void * toCbdata ()=0
 

Static Public Member Functions

static void Start (const Pointer &job)
 

Public Attributes

HttpRequest * icapRequest
 sent (or at least created) ICAP request More...
 
HttpReply::Pointer icapReply
 received ICAP reply, if any More...
 
int attempts
 the number of times we tried to get to the service, including this time More...
 
const InstanceId< AsyncJob > id
 job identifier More...
 

Protected Member Functions

virtual void start ()
 called by AsyncStart; do not call directly More...
 
virtual void noteInitiatorAborted ()
 
virtual void startShoveling ()=0
 starts sending/receiving ICAP messages More...
 
virtual void handleCommWrote (size_t sz)=0
 
virtual void handleCommRead (size_t sz)=0
 
void handleSecuredPeer (Security::EncryptorAnswer &answer)
 
virtual void detailError (const ErrorDetailPointer &)
 record error detail if possible More...
 
void openConnection ()
 
void closeConnection ()
 
bool haveConnection () const
 
void scheduleRead ()
 
void scheduleWrite (MemBuf &buf)
 
void updateTimeout ()
 
void cancelRead ()
 
bool parseHttpMsg (Http::Message *msg)
 
bool mayReadMore () const
 
virtual bool doneReading () const
 
virtual bool doneWriting () const
 
bool doneWithIo () const
 
virtual bool doneAll () const
 whether positive goal has been reached More...
 
virtual void swanSong ()
 
virtual const char * status () const
 internal cleanup; do not call directly More...
 
virtual void fillPendingStatus (MemBuf &buf) const
 
virtual void fillDoneStatus (MemBuf &buf) const
 
virtual bool fillVirginHttpHeader (MemBuf &) const
 
void setOutcome (const XactOutcome &xo)
 
virtual void finalizeLogInfo ()
 
void sendAnswer (const Answer &answer)
 
void tellQueryAborted (bool final)
 
void clearInitiator ()
 
void deleteThis (const char *aReason)
 
void mustStop (const char *aReason)
 
bool done () const
 the job is destroyed in callEnd() when done() More...
 

Protected Attributes

Adaptation::Icap::ServiceRep::Pointer theService
 
SBuf readBuf
 
bool commEof
 
bool reuseConnection
 
bool isRetriable
 can retry on persistent connection failures More...
 
bool isRepeatable
 can repeat if no or unsatisfactory response More...
 
bool ignoreLastWrite
 
bool waitingForDns
 expecting a ipcache_nbgethostbyname() callback More...
 
AsyncCall::Pointer reader
 
AsyncCall::Pointer writer
 
AccessLogEntry::Pointer alep
 icap.log entry More...
 
AccessLogEntry & al
 short for *alep More...
 
timeval icap_tr_start
 
timeval icap_tio_start
 
timeval icap_tio_finish
 
CbcPointer< Initiator > theInitiator
 
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 Member Functions

void useTransportConnection (const Comm::ConnectionPointer &)
 
void useIcapConnection (const Comm::ConnectionPointer &)
 react to the availability of a fully-ready ICAP connection More...
 
void dieOnConnectionFailure ()
 
void tellQueryAborted ()
 
void maybeLog ()
 

Private Attributes

JobWait< Comm::ConnOpener > transportWait
 waits for a transport connection to the ICAP server to be established/opened More...
 
JobWait< Ssl::IcapPeerConnector > encryptionWait
 waits for the established transport connection to be secured/encrypted More...
 
Comm::ConnectionPointer connection
 open and, if necessary, secured connection to the ICAP server (or nil) More...
 
AsyncCall::Pointer closer
 

Detailed Description

Definition at line 43 of file Xaction.h.

Member Typedef Documentation

◆ Pointer

typedef CbcPointer<AsyncJob> AsyncJob::Pointer
inherited

Definition at line 34 of file AsyncJob.h.

Constructor & Destructor Documentation

◆ Xaction()

Adaptation::Icap::Xaction::Xaction ( const char *  aTypeName,
ServiceRep::Pointer &  aService 
)

Definition at line 80 of file Xaction.cc.

References current_time, debugs, HTTPMSGLOCK(), icap_tio_finish, icap_tio_start, icap_tr_start, icapRequest, XactionInitiator::initAdaptation, and AsyncJob::typeName.

◆ ~Xaction()

Adaptation::Icap::Xaction::~Xaction ( )
virtual

Definition at line 106 of file Xaction.cc.

References debugs, and HTTPMSGUNLOCK().

Member Function Documentation

◆ callEnd()

void Adaptation::Icap::Xaction::callEnd ( )
virtual

called right after the called job method

Reimplemented from AsyncJob.

Definition at line 378 of file Xaction.cc.

References AsyncJob::callEnd(), debugs, and HERE().

◆ callException()

void Adaptation::Icap::Xaction::callException ( const std::exception &  e)
virtual

Reimplemented from AsyncJob.

Reimplemented in Adaptation::Icap::ModXact.

Definition at line 371 of file Xaction.cc.

References AsyncJob::callException(), and Adaptation::Icap::xoError.

Referenced by Adaptation::Icap::ModXact::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, HERE(), AsyncJob::inCall, and NULL.

◆ cancelRead()

void Adaptation::Icap::Xaction::cancelRead ( )
protected

Definition at line 485 of file Xaction.cc.

References Must, NULL, and Comm::ReadCancel().

◆ clearError()

virtual void Adaptation::Icap::Xaction::clearError ( )
inlinevirtual

Reimplemented in Adaptation::Icap::ModXact.

Definition at line 118 of file Xaction.h.

Referenced by Adaptation::Icap::Launcher::launchXaction().

◆ clearInitiator()

void Adaptation::Initiate::clearInitiator ( )
protectedinherited

Definition at line 74 of file Initiate.cc.

◆ closeConnection()

void Adaptation::Icap::Xaction::closeConnection ( )
protected

Definition at line 214 of file Xaction.cc.

References comm_remove_close_handler(), commUnsetConnTimeout(), debugs, HERE(), NULL, s, Adaptation::Icap::xoError, and Adaptation::Icap::xoGone.

◆ deleteThis()

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

Definition at line 50 of file AsyncJob.cc.

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

Referenced by ConnStateData::connStateClosed().

◆ detailError()

virtual void Adaptation::Icap::Xaction::detailError ( const ErrorDetailPointer &  )
inlineprotectedvirtual

Reimplemented in Adaptation::Icap::ModXact.

Definition at line 82 of file Xaction.h.

◆ dieOnConnectionFailure()

void Adaptation::Icap::Xaction::dieOnConnectionFailure ( )
private

Definition at line 305 of file Xaction.cc.

References debugs, HERE(), MakeNamedErrorDetail(), and TexcHere.

Referenced by dnsLookupDone().

◆ disableRepeats()

void Adaptation::Icap::Xaction::disableRepeats ( const char *  reason)

Definition at line 134 of file Xaction.cc.

References debugs.

Referenced by Adaptation::Icap::Launcher::launchXaction().

◆ disableRetries()

void Adaptation::Icap::Xaction::disableRetries ( )

Definition at line 127 of file Xaction.cc.

References debugs.

Referenced by Adaptation::Icap::Launcher::launchXaction().

◆ dnsLookupDone()

void Adaptation::Icap::Xaction::dnsLookupDone ( const ipcache_addrs *  ia)

Definition at line 183 of file Xaction.cc.

References assert, CallJobHere, conn, Adaptation::Icap::Config::connect_timeout(), Dns::CachedIps::current(), DBG_IMPORTANT, debugs, dieOnConnectionFailure(), getOutgoingAddress(), JobCallback, noteCommConnected(), NULL, s, and Adaptation::Icap::TheConfig.

Referenced by icapLookupDnsResults().

◆ done()

bool AsyncJob::done ( ) const
protectedinherited

Definition at line 91 of file AsyncJob.cc.

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

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

◆ doneAll()

bool Adaptation::Icap::Xaction::doneAll ( ) const
protectedvirtual

Reimplemented from AsyncJob.

Reimplemented in Adaptation::Icap::ModXact.

Definition at line 387 of file Xaction.cc.

References AsyncJob::doneAll().

Referenced by Adaptation::Icap::ModXact::doneAll().

◆ doneReading()

bool Adaptation::Icap::Xaction::doneReading ( ) const
protectedvirtual

Reimplemented in Adaptation::Icap::OptXact, and Adaptation::Icap::ModXact.

Definition at line 521 of file Xaction.cc.

◆ doneWithIo()

bool Adaptation::Icap::Xaction::doneWithIo ( ) const
protected

Definition at line 531 of file Xaction.cc.

◆ doneWriting()

bool Adaptation::Icap::Xaction::doneWriting ( ) const
protectedvirtual

Reimplemented in Adaptation::Icap::ModXact.

Definition at line 526 of file Xaction.cc.

◆ fillDoneStatus()

void Adaptation::Icap::Xaction::fillDoneStatus ( MemBuf &  buf) const
protectedvirtual

Reimplemented in Adaptation::Icap::ModXact.

Definition at line 665 of file Xaction.cc.

References MemBuf::append(), Packable::appendf(), and NULL.

Referenced by Adaptation::Icap::ModXact::fillDoneStatus().

◆ fillPendingStatus()

void Adaptation::Icap::Xaction::fillPendingStatus ( MemBuf &  buf) const
protectedvirtual

Reimplemented in Adaptation::Icap::ModXact.

Definition at line 647 of file Xaction.cc.

References MemBuf::append(), Packable::appendf(), and NULL.

Referenced by Adaptation::Icap::ModXact::fillPendingStatus().

◆ fillVirginHttpHeader()

bool Adaptation::Icap::Xaction::fillVirginHttpHeader ( MemBuf &  ) const
protectedvirtual

Reimplemented in Adaptation::Icap::ModXact.

Definition at line 674 of file Xaction.cc.

◆ finalizeLogInfo()

void Adaptation::Icap::Xaction::finalizeLogInfo ( )
protectedvirtual

Reimplemented in Adaptation::Icap::OptXact, and Adaptation::Icap::ModXact.

Definition at line 610 of file Xaction.cc.

References current_time, HTTPMSGLOCK(), ICP_INVALID, NULL, s, and tvSub().

Referenced by Adaptation::Icap::ModXact::finalizeLogInfo(), and Adaptation::Icap::OptXact::finalizeLogInfo().

◆ handleCommRead()

virtual void Adaptation::Icap::Xaction::handleCommRead ( size_t  sz)
protectedpure virtual

Implemented in Adaptation::Icap::OptXact, and Adaptation::Icap::ModXact.

◆ handleCommWrote()

virtual void Adaptation::Icap::Xaction::handleCommWrote ( size_t  sz)
protectedpure virtual

Implemented in Adaptation::Icap::OptXact, and Adaptation::Icap::ModXact.

◆ handleSecuredPeer()

void Adaptation::Icap::Xaction::handleSecuredPeer ( Security::EncryptorAnswer &  answer)
protected

Definition at line 715 of file Xaction.cc.

References assert, Security::EncryptorAnswer::conn, debugs, Security::EncryptorAnswer::error, Comm::Connection::fd, fd_table, CbcPointer< Cbc >::get(), Comm::Connection::isOpen(), MakeNamedErrorDetail(), Comm::Connection::noteClosure(), TexcHere, and Security::EncryptorAnswer::tunneled.

Referenced by useTransportConnection().

◆ handleStopRequest()

void AsyncJob::handleStopRequest ( )
inlineinherited

Definition at line 71 of file AsyncJob.h.

References AsyncJob::mustStop().

◆ haveConnection()

bool Adaptation::Icap::Xaction::haveConnection ( ) const
protected

Definition at line 538 of file Xaction.cc.

References NULL.

◆ initiator()

void Adaptation::Initiate::initiator ( const CbcPointer< Initiator > &  i)
inherited

Definition at line 54 of file Initiate.cc.

References Must, and CbcPointer< Cbc >::valid().

Referenced by Adaptation::Initiator::initiateAdaptation().

◆ masterLogEntry()

AccessLogEntry::Pointer Adaptation::Icap::Xaction::masterLogEntry ( )
virtual

Reimplemented in Adaptation::Icap::ModXact.

Definition at line 114 of file Xaction.cc.

References Store::nil.

◆ maybeLog()

void Adaptation::Icap::Xaction::maybeLog ( )
private

Definition at line 602 of file Xaction.cc.

References IcapLogfileStatus, icapLogLog(), and LOG_ENABLE.

◆ mayReadMore()

bool Adaptation::Icap::Xaction::mayReadMore ( ) const
protected

Definition at line 515 of file Xaction.cc.

◆ mustStop()

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

Definition at line 70 of file AsyncJob.cc.

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

Referenced by HttpStateData::abortAll(), AsyncJob::callException(), HttpStateData::continueAfterParsingHeader(), HttpStateData::drop1xx(), HttpStateData::handleMoreRequestBodyAvailable(), AsyncJob::handleStopRequest(), HttpStateData::httpStateConnClosed(), HttpStateData::httpTimeout(), HttpStateData::proceedAfter1xx(), ConnStateData::proxyProtocolError(), HttpStateData::readReply(), HttpStateData::start(), and HttpStateData::wroteLast().

◆ noteCommClosed()

void Adaptation::Icap::Xaction::noteCommClosed ( const CommCloseCbParams &  io)

Definition at line 358 of file Xaction.cc.

References MakeNamedErrorDetail(), and NULL.

Referenced by useIcapConnection().

◆ noteCommConnected()

void Adaptation::Icap::Xaction::noteCommConnected ( const CommConnectCbParams &  io)

Definition at line 249 of file Xaction.cc.

References CommCommonCbParams::conn, CommCommonCbParams::flag, and Comm::OK.

Referenced by dnsLookupDone().

◆ noteCommRead()

void Adaptation::Icap::Xaction::noteCommRead ( const CommIoCbParams &  io)

Definition at line 425 of file Xaction.cc.

References CommCommonCbParams::conn, debugs, Comm::ENDFILE, CommCommonCbParams::flag, Comm::INPROGRESS, Must, NULL, Comm::OK, Comm::ReadNow(), CommIoCbParams::size, CommCommonCbParams::xerrno, Adaptation::Icap::xoRace, and xstrerr().

Referenced by scheduleRead().

◆ noteCommTimedout()

void Adaptation::Icap::Xaction::noteCommTimedout ( const CommTimeoutCbParams &  io)

Definition at line 346 of file Xaction.cc.

References assert, debugs, Here, and HERE().

Referenced by updateTimeout().

◆ noteCommWrote()

void Adaptation::Icap::Xaction::noteCommWrote ( const CommIoCbParams &  io)

Definition at line 328 of file Xaction.cc.

References debugs, CommCommonCbParams::flag, HERE(), Must, NULL, Comm::OK, and CommIoCbParams::size.

Referenced by scheduleWrite().

◆ noteInitiatorAborted()

void Adaptation::Icap::Xaction::noteInitiatorAborted ( )
protectedvirtual

Implements Adaptation::Initiate.

Definition at line 544 of file Xaction.cc.

References debugs, HERE(), MakeNamedErrorDetail(), and Adaptation::Icap::xoGone.

◆ openConnection()

void Adaptation::Icap::Xaction::openConnection ( )
protected

Definition at line 157 of file Xaction.cc.

References assert, debugs, icapLookupDnsResults(), ipcache_nbgethostbyname(), Must, Adaptation::Icap::Config::reuse_connections, s, and Adaptation::Icap::TheConfig.

◆ parseHttpMsg()

bool Adaptation::Icap::Xaction::parseHttpMsg ( Http::Message *  msg)
protected

Definition at line 495 of file Xaction.cc.

References debugs, error(), Http::Message::hdr_sz, Must, Http::Message::parse(), Http::Message::reset(), and Http::scNone.

◆ repeatable()

bool Adaptation::Icap::Xaction::repeatable ( ) const
inline

Definition at line 53 of file Xaction.h.

References isRepeatable.

◆ retriable()

bool Adaptation::Icap::Xaction::retriable ( ) const
inline

Definition at line 52 of file Xaction.h.

References isRetriable.

◆ scheduleRead()

void Adaptation::Icap::Xaction::scheduleRead ( )
protected

Definition at line 412 of file Xaction.cc.

References JobCallback, Must, noteCommRead(), and Comm::Read().

◆ scheduleWrite()

void Adaptation::Icap::Xaction::scheduleWrite ( MemBuf &  buf)
protected

Definition at line 315 of file Xaction.cc.

References JobCallback, Must, noteCommWrote(), and Comm::Write().

◆ sendAnswer()

void Adaptation::Initiate::sendAnswer ( const Answer &  answer)
protectedinherited

Definition at line 79 of file Initiate.cc.

References Adaptation::Initiator::noteAdaptationAnswer(), and ScheduleCallHere.

◆ service()

Adaptation::Icap::ServiceRep & Adaptation::Icap::Xaction::service ( )

Definition at line 121 of file Xaction.cc.

References Must, and NULL.

Referenced by Adaptation::Icap::ConnWaiterDialer::ConnWaiterDialer().

◆ setOutcome()

void Adaptation::Icap::Xaction::setOutcome ( const XactOutcome &  xo)
protected

Definition at line 558 of file Xaction.cc.

References debugs, HERE(), and Adaptation::Icap::xoUnknown.

◆ start()

void Adaptation::Icap::Xaction::start ( )
protectedvirtual

Reimplemented from AsyncJob.

Reimplemented in Adaptation::Icap::OptXact, and Adaptation::Icap::ModXact.

Definition at line 141 of file Xaction.cc.

References AsyncJob::start().

Referenced by Adaptation::Icap::ModXact::start(), and Adaptation::Icap::OptXact::start().

◆ Start()

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(), Rock::Rebuild::Start(), JobWaitBase::start_(), BodyPipe::startAutoConsumptionIfNeeded(), Ftp::StartGateway(), Ftp::StartRelay(), PeerPoolMgrsRr::syncConfig(), and Rock::SwapDir::updateHeaders().

◆ startShoveling()

virtual void Adaptation::Icap::Xaction::startShoveling ( )
protectedpure virtual

Implemented in Adaptation::Icap::OptXact, and Adaptation::Icap::ModXact.

◆ status()

const char * Adaptation::Icap::Xaction::status ( ) const
protectedvirtual

for debugging, starts with space

Reimplemented from Adaptation::Initiate.

Definition at line 633 of file Xaction.cc.

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

Referenced by Adaptation::Icap::ModXact::ModXact().

◆ swanSong()

void Adaptation::Icap::Xaction::swanSong ( )
protectedvirtual

Reimplemented from Adaptation::Initiate.

Reimplemented in Adaptation::Icap::OptXact, and Adaptation::Icap::ModXact.

Definition at line 571 of file Xaction.cc.

References Adaptation::Initiate::swanSong().

Referenced by Adaptation::Icap::ModXact::swanSong(), and Adaptation::Icap::OptXact::swanSong().

◆ tellQueryAborted() [1/2]

void Adaptation::Icap::Xaction::tellQueryAborted ( )
private

Definition at line 589 of file Xaction.cc.

References CallJobHere1.

◆ tellQueryAborted() [2/2]

void Adaptation::Initiate::tellQueryAborted ( bool  final)
protectedinherited

Definition at line 87 of file Initiate.cc.

References Adaptation::Answer::Error().

◆ toCbdata()

virtual void* CbdataParent::toCbdata ( )
pure virtualinherited

Implemented in HttpStateData, ClientHttpRequest, and BodySink.

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

◆ updateTimeout()

void Adaptation::Icap::Xaction::updateTimeout ( )
protected

Definition at line 394 of file Xaction.cc.

References commSetConnTimeout(), commUnsetConnTimeout(), Adaptation::Icap::Config::io_timeout(), JobCallback, Must, noteCommTimedout(), NULL, and Adaptation::Icap::TheConfig.

◆ useIcapConnection()

void Adaptation::Icap::Xaction::useIcapConnection ( const Comm::ConnectionPointer &  conn)
private

Definition at line 289 of file Xaction.cc.

References assert, asyncCall(), comm_add_close_handler(), conn, Comm::IsConnOpen(), and noteCommClosed().

◆ useTransportConnection()

void Adaptation::Icap::Xaction::useTransportConnection ( const Comm::ConnectionPointer &  conn)
private

React to the availability of a transport connection to the ICAP service. The given connection may (or may not) be secured already.

Definition at line 264 of file Xaction.cc.

References assert, asyncCall(), conn, Adaptation::Icap::Config::connect_timeout(), fd_table, handleSecuredPeer(), Comm::IsConnOpen(), and Adaptation::Icap::TheConfig.

Member Data Documentation

◆ al

AccessLogEntry& Adaptation::Icap::Xaction::al
protected

Definition at line 152 of file Xaction.h.

◆ alep

AccessLogEntry::Pointer Adaptation::Icap::Xaction::alep
protected

Definition at line 151 of file Xaction.h.

◆ attempts

int Adaptation::Icap::Xaction::attempts

Definition at line 67 of file Xaction.h.

Referenced by Adaptation::Icap::Launcher::launchXaction().

◆ closer

AsyncCall::Pointer Adaptation::Icap::Xaction::closer
private

Definition at line 168 of file Xaction.h.

◆ commEof

bool Adaptation::Icap::Xaction::commEof
protected

Definition at line 141 of file Xaction.h.

Referenced by Adaptation::Icap::ModXact::doneReading(), and Adaptation::Icap::OptXact::doneReading().

◆ connection

Comm::ConnectionPointer Adaptation::Icap::Xaction::connection
private

Definition at line 166 of file Xaction.h.

◆ encryptionWait

JobWait<Ssl::IcapPeerConnector> Adaptation::Icap::Xaction::encryptionWait
private

Definition at line 163 of file Xaction.h.

◆ icap_tio_finish

timeval Adaptation::Icap::Xaction::icap_tio_finish
protected

Definition at line 156 of file Xaction.h.

Referenced by Xaction().

◆ icap_tio_start

timeval Adaptation::Icap::Xaction::icap_tio_start
protected

Definition at line 155 of file Xaction.h.

Referenced by Xaction().

◆ icap_tr_start

timeval Adaptation::Icap::Xaction::icap_tr_start
protected

Definition at line 154 of file Xaction.h.

Referenced by Xaction().

◆ icapReply

HttpReply::Pointer Adaptation::Icap::Xaction::icapReply

Definition at line 64 of file Xaction.h.

Referenced by Adaptation::Icap::ModXact::ModXact().

◆ icapRequest

HttpRequest* Adaptation::Icap::Xaction::icapRequest

Definition at line 63 of file Xaction.h.

Referenced by Xaction().

◆ id

const InstanceId<AsyncJob> AsyncJob::id
inherited

Definition at line 73 of file AsyncJob.h.

◆ ignoreLastWrite

bool Adaptation::Icap::Xaction::ignoreLastWrite
protected

Definition at line 145 of file Xaction.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().

◆ isRepeatable

bool Adaptation::Icap::Xaction::isRepeatable
protected

Definition at line 144 of file Xaction.h.

Referenced by repeatable().

◆ isRetriable

bool Adaptation::Icap::Xaction::isRetriable
protected

Definition at line 143 of file Xaction.h.

Referenced by retriable().

◆ readBuf

SBuf Adaptation::Icap::Xaction::readBuf
protected

Definition at line 140 of file Xaction.h.

◆ reader

AsyncCall::Pointer Adaptation::Icap::Xaction::reader
protected

Definition at line 148 of file Xaction.h.

◆ reuseConnection

bool Adaptation::Icap::Xaction::reuseConnection
protected

Definition at line 142 of file Xaction.h.

◆ started_

bool AsyncJob::started_ = false
protectedinherited

Definition at line 83 of file AsyncJob.h.

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

◆ 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().

◆ theInitiator

CbcPointer<Initiator> Adaptation::Initiate::theInitiator
protectedinherited

Definition at line 51 of file Initiate.h.

◆ theService

Adaptation::Icap::ServiceRep::Pointer Adaptation::Icap::Xaction::theService
protected

Definition at line 138 of file Xaction.h.

◆ transportWait

JobWait<Comm::ConnOpener> Adaptation::Icap::Xaction::transportWait
private

Definition at line 160 of file Xaction.h.

◆ typeName

const char* AsyncJob::typeName
protectedinherited

Definition at line 80 of file AsyncJob.h.

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

◆ waitingForDns

bool Adaptation::Icap::Xaction::waitingForDns
protected

Definition at line 146 of file Xaction.h.

◆ writer

AsyncCall::Pointer Adaptation::Icap::Xaction::writer
protected

Definition at line 149 of file Xaction.h.

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

 

Introduction

Documentation

Support

Miscellaneous

Web Site Translations

Mirrors