#include <Xaction.h>

Inheritance diagram for Adaptation::Icap::Xaction:
Collaboration diagram for Adaptation::Icap::Xaction:

Public Types

typedef CbcPointer< AsyncJobPointer
 

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)
 
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)
 
ServiceRepservice ()
 
void initiator (const CbcPointer< Initiator > &i)
 sets initiator More...
 
bool canBeCalled (AsyncCall &call) const
 whether we can be called More...
 
void callStart (AsyncCall &call)
 
virtual void * toCbdata ()=0
 

Static Public Member Functions

static Pointer Start (AsyncJob *job)
 starts a freshly created job (i.e., makes the job asynchronous) More...
 

Public Attributes

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

Protected Member Functions

virtual void start ()
 called by AsyncStart; do not call directly More...
 
virtual void noteInitiatorAborted ()
 
virtual void handleCommConnected ()=0
 
virtual void handleCommWrote (size_t sz)=0
 
virtual void handleCommRead (size_t sz)=0
 
virtual void handleCommTimedout ()
 
virtual void handleCommClosed ()
 
void handleSecuredPeer (Security::EncryptorAnswer &answer)
 
virtual void detailError (const ErrorDetailPointer &)
 record error detail if possible More...
 
void openConnection ()
 
void closeConnection ()
 
void dieOnConnectionFailure ()
 
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

Comm::ConnectionPointer connection
 ICAP server connection. More...
 
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
 
const char * stopReason
 
AsyncCall::Pointer connector
 
AsyncCall::Pointer reader
 
AsyncCall::Pointer writer
 
AsyncCall::Pointer closer
 
AccessLogEntry::Pointer alep
 icap.log entry More...
 
AccessLogEntryal
 short for *alep More...
 
timeval icap_tr_start
 
timeval icap_tio_start
 
timeval icap_tio_finish
 
CbcPointer< InitiatortheInitiator
 
const char * typeName
 kid (leaf) class name, for debugging More...
 
AsyncCall::Pointer inCall
 the asynchronous call being handled, if any More...
 
const InstanceId< AsyncJobid
 job identifier More...
 

Private Member Functions

void tellQueryAborted ()
 
void maybeLog ()
 

Private Attributes

Comm::ConnOpener::Pointer cs
 
AsyncCall::Pointer securer
 whether we are securing a connection More...
 

Detailed Description

Definition at line 38 of file Xaction.h.

Member Typedef Documentation

◆ Pointer

Definition at line 34 of file AsyncJob.h.

Constructor & Destructor Documentation

◆ Xaction()

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

◆ ~Xaction()

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

Definition at line 108 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 410 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 403 of file Xaction.cc.

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

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

◆ callStart()

void AsyncJob::callStart ( AsyncCall call)
inherited

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

◆ cancelRead()

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

Definition at line 515 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 114 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

◆ deleteThis()

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

◆ detailError()

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

Reimplemented in Adaptation::Icap::ModXact.

Definition at line 77 of file Xaction.h.

◆ dieOnConnectionFailure()

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

Definition at line 322 of file Xaction.cc.

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

◆ disableRepeats()

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

Definition at line 136 of file Xaction.cc.

References debugs.

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

◆ disableRetries()

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

Definition at line 129 of file Xaction.cc.

References debugs.

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

◆ dnsLookupDone()

◆ done()

bool AsyncJob::done ( ) const
protectedinherited

◆ doneAll()

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

Reimplemented from AsyncJob.

Reimplemented in Adaptation::Icap::ModXact.

Definition at line 419 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 551 of file Xaction.cc.

◆ doneWithIo()

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

Definition at line 561 of file Xaction.cc.

◆ doneWriting()

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

Reimplemented in Adaptation::Icap::ModXact.

Definition at line 556 of file Xaction.cc.

◆ fillDoneStatus()

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

Reimplemented in Adaptation::Icap::ModXact.

Definition at line 695 of file Xaction.cc.

References buf, 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 680 of file Xaction.cc.

References buf, 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 704 of file Xaction.cc.

◆ finalizeLogInfo()

◆ handleCommClosed()

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

Definition at line 396 of file Xaction.cc.

References MakeNamedErrorDetail().

◆ handleCommConnected()

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

◆ handleCommRead()

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

◆ handleCommTimedout()

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

Definition at line 368 of file Xaction.cc.

References assert, debugs, HERE(), NULL, and TexcHere.

◆ handleCommWrote()

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

◆ handleSecuredPeer()

◆ haveConnection()

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

Definition at line 568 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 116 of file Xaction.cc.

References Store::nil.

◆ maybeLog()

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

Definition at line 635 of file Xaction.cc.

References IcapLogfileStatus, icapLogLog(), and LOG_ENABLE.

◆ mayReadMore()

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

Definition at line 545 of file Xaction.cc.

◆ mustStop()

◆ noteCommClosed()

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

Definition at line 386 of file Xaction.cc.

References NULL.

Referenced by noteCommConnected().

◆ noteCommConnected()

◆ noteCommRead()

◆ noteCommTimedout()

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

Definition at line 363 of file Xaction.cc.

Referenced by noteCommConnected(), and updateTimeout().

◆ noteCommWrote()

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

Definition at line 345 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 574 of file Xaction.cc.

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

◆ openConnection()

◆ parseHttpMsg()

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

◆ repeatable()

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

Definition at line 48 of file Xaction.h.

References isRepeatable.

◆ retriable()

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

Definition at line 47 of file Xaction.h.

References isRetriable.

◆ scheduleRead()

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

Definition at line 442 of file Xaction.cc.

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

◆ scheduleWrite()

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

Definition at line 332 of file Xaction.cc.

References buf, 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 123 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 588 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 143 of file Xaction.cc.

References AsyncJob::start().

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

◆ Start()

◆ status()

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

for debugging, starts with space

Reimplemented from Adaptation::Initiate.

Definition at line 666 of file Xaction.cc.

References buf.

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

◆ swanSong()

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

◆ tellQueryAborted() [1/2]

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

Definition at line 622 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

◆ updateTimeout()

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

Member Data Documentation

◆ al

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

Definition at line 150 of file Xaction.h.

◆ alep

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

Definition at line 149 of file Xaction.h.

◆ attempts

int Adaptation::Icap::Xaction::attempts

Definition at line 62 of file Xaction.h.

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

◆ closer

AsyncCall::Pointer Adaptation::Icap::Xaction::closer
protected

Definition at line 147 of file Xaction.h.

◆ commEof

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

◆ connection

Comm::ConnectionPointer Adaptation::Icap::Xaction::connection
protected

Definition at line 131 of file Xaction.h.

◆ connector

AsyncCall::Pointer Adaptation::Icap::Xaction::connector
protected

Definition at line 144 of file Xaction.h.

◆ cs

Comm::ConnOpener::Pointer Adaptation::Icap::Xaction::cs
private

Definition at line 157 of file Xaction.h.

◆ icap_tio_finish

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

Definition at line 154 of file Xaction.h.

Referenced by Xaction().

◆ icap_tio_start

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

Definition at line 153 of file Xaction.h.

Referenced by Xaction().

◆ icap_tr_start

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

Definition at line 152 of file Xaction.h.

Referenced by Xaction().

◆ icapReply

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

Definition at line 59 of file Xaction.h.

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

◆ icapRequest

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

Definition at line 58 of file Xaction.h.

Referenced by Xaction().

◆ id

const InstanceId<AsyncJob> AsyncJob::id
protectedinherited

Definition at line 72 of file AsyncJob.h.

◆ ignoreLastWrite

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

Definition at line 139 of file Xaction.h.

◆ inCall

AsyncCall::Pointer AsyncJob::inCall
protectedinherited

◆ isRepeatable

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

Definition at line 138 of file Xaction.h.

Referenced by repeatable().

◆ isRetriable

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

Definition at line 137 of file Xaction.h.

Referenced by retriable().

◆ readBuf

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

Definition at line 134 of file Xaction.h.

◆ reader

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

Definition at line 145 of file Xaction.h.

◆ reuseConnection

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

Definition at line 136 of file Xaction.h.

◆ securer

AsyncCall::Pointer Adaptation::Icap::Xaction::securer
private

Definition at line 158 of file Xaction.h.

◆ stopReason

const char* Adaptation::Icap::Xaction::stopReason
protected

Definition at line 141 of file Xaction.h.

◆ 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 132 of file Xaction.h.

◆ typeName

const char* AsyncJob::typeName
protectedinherited

◆ writer

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

Definition at line 146 of file Xaction.h.


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

 

Introduction

Documentation

Support

Miscellaneous

Web Site Translations

Mirrors