#include <HappyConnOpener.h>

Inheritance diagram for HappyConnOpener:
Collaboration diagram for HappyConnOpener:

Classes

class  Attempt
 a connection opening attempt in progress (or falsy) More...
 

Public Types

typedef HappyConnOpenerAnswer Answer
 
typedef CbcPointer< AsyncJobPointer
 

Public Member Functions

 HappyConnOpener (const ResolvedPeersPointer &, const AsyncCallback< Answer > &, const HttpRequestPointer &, time_t aFwdStart, int tries, const AccessLogEntryPointer &)
 
 ~HappyConnOpener () override
 
void allowPersistent (bool permitted)
 configures reuse of old connections More...
 
void setRetriable (bool retriable)
 configures whether the request may be retried later if things go wrong More...
 
void setHost (const char *)
 configures the origin server domain name More...
 
void noteCandidatesChange ()
 reacts to changes in the destinations list More...
 
void noteGavePrimeItsChance ()
 reacts to expired happy_eyeballs_connect_timeout More...
 
void noteSpareAllowance ()
 reacts to satisfying happy_eyeballs_connect_gap and happy_eyeballs_connect_limit 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...
 
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)
 
static void RegisterWithCacheManager ()
 

Public Attributes

HappyAbsoluteTime primeStart = 0
 the start of the first connection attempt for the currentPeer More...
 
const InstanceId< AsyncJobid
 job identifier More...
 

Protected Member Functions

void deleteThis (const char *aReason)
 
void mustStop (const char *aReason)
 
bool done () const
 the job is destroyed in callEnd() when done() More...
 

Static Protected Member Functions

static void ReportAllJobs (StoreEntry *)
 writes a cache manager report about all jobs existing in this worker 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 Member Functions

 CBDATA_CHILD (HappyConnOpener)
 
void start () override
 called by AsyncStart; do not call directly More...
 
bool doneAll () const override
 whether positive goal has been reached More...
 
void swanSong () override
 
const char * status () const override
 internal cleanup; do not call directly More...
 
void maybeOpenPrimeConnection ()
 starts a prime connection attempt if possible or does nothing otherwise More...
 
void maybeOpenSpareConnection ()
 if possible, starts a spare connection attempt More...
 
void maybeGivePrimeItsChance ()
 
void stopGivingPrimeItsChance ()
 called when the prime attempt has used up its chance for a solo victory More...
 
void stopWaitingForSpareAllowance ()
 called when the spare attempt should no longer obey spare connection limits More...
 
void startConnecting (Attempt &, PeerConnectionPointer &)
 starts opening (or reusing) a connection to the given destination More...
 
void openFreshConnection (Attempt &, PeerConnectionPointer &)
 
bool reuseOldConnection (PeerConnectionPointer &)
 
void notePrimeConnectDone (const CommConnectCbParams &)
 Comm::ConnOpener callback for the prime connection attempt. More...
 
void noteSpareConnectDone (const CommConnectCbParams &)
 Comm::ConnOpener callback for the spare connection attempt. More...
 
void handleConnOpenerAnswer (Attempt &, const CommConnectCbParams &, const char *connDescription)
 prime/spare-agnostic processing of a Comm::ConnOpener result More...
 
void checkForNewConnection ()
 
void updateSpareWaitAfterPrimeFailure ()
 reacts to a prime attempt failure More...
 
void cancelSpareWait (const char *reason)
 stops waiting for the right conditions to open a spare connection More...
 
bool ranOutOfTimeOrAttempts () const
 Check for maximum connection tries and forwarding time restrictions. More...
 
ErrorStatemakeError (const err_type type) const
 
AnswerfutureAnswer (const PeerConnectionPointer &)
 
void sendSuccess (const PeerConnectionPointer &conn, bool reused, const char *connKind)
 send a successful result to the initiator (if it still needs an answer) More...
 
void sendFailure ()
 inform the initiator about our failure to connect (if needed) More...
 
void cancelAttempt (Attempt &, const char *reason)
 cancels the in-progress attempt, making its path a future candidate More...
 
virtual void finalizedInCbdataChild ()=0
 hack: ensure CBDATA_CHILD() after a toCbdata()-defining CBDATA_INTERMEDIATE() More...
 

Private Attributes

const time_t fwdStart
 requestor start time More...
 
AsyncCallback< Answercallback_
 answer destination More...
 
ResolvedPeersPointer destinations
 Candidate paths. Shared with the initiator. May not be finalized yet. More...
 
Attempt prime
 current connection opening attempt on the prime track (if any) More...
 
Attempt spare
 current connection opening attempt on the spare track (if any) More...
 
Comm::ConnectionPointer currentPeer
 
HappySpareWait spareWaiting
 preconditions for an attempt to open a spare connection More...
 
AccessLogEntryPointer ale
 transaction details More...
 
ErrorStatelastError = nullptr
 last problem details (or nil) More...
 
PeerConnectionPointer lastFailedConnection
 nil if none has failed More...
 
bool ignoreSpareRestrictions = false
 whether spare connection attempts disregard happy_eyeballs_* settings More...
 
bool gotSpareAllowance = false
 whether we have received a permission to open a spare while spares are limited More...
 
bool allowPconn_ = true
 whether persistent connections are allowed More...
 
bool retriable_ = true
 whether we are opening connections for a request that may be resent More...
 
const char * host_ = nullptr
 origin server domain name (or equivalent) More...
 
HttpRequestPointer cause
 the request that needs a to-server connection More...
 
int n_tries
 
const char * ranOutOfTimeOrAttemptsEarlier_ = nullptr
 Reason to ran out of time or attempts. More...
 

Friends

class HappyOrderEnforcer
 
std::ostream & operator<< (std::ostream &, const Attempt &)
 HappyConnOpener::Attempt printer for debugging. More...
 

Detailed Description

A TCP connection opening algorithm based on Happy Eyeballs (RFC 8305). Maintains two concurrent connection opening tracks: prime and spare. Shares ResolvedPeers list with the job initiator.

Definition at line 105 of file HappyConnOpener.h.

Member Typedef Documentation

◆ Answer

◆ Pointer

Definition at line 34 of file AsyncJob.h.

Constructor & Destructor Documentation

◆ HappyConnOpener()

HappyConnOpener::HappyConnOpener ( const ResolvedPeersPointer dests,
const AsyncCallback< Answer > &  callback,
const HttpRequestPointer request,
time_t  aFwdStart,
int  tries,
const AccessLogEntryPointer anAle 
)

Definition at line 330 of file HappyConnOpener.cc.

References assert, and destinations.

◆ ~HappyConnOpener()

HappyConnOpener::~HappyConnOpener ( )
override

Definition at line 344 of file HappyConnOpener.cc.

References host_, lastError, and safe_free.

Member Function Documentation

◆ allowPersistent()

void HappyConnOpener::allowPersistent ( bool  permitted)
inline

Definition at line 116 of file HappyConnOpener.h.

References allowPconn_.

◆ callEnd()

void AsyncJob::callEnd ( )
virtualinherited

◆ callException()

◆ callStart()

void AsyncJob::callStart ( AsyncCall call)
inherited

◆ canBeCalled()

bool AsyncJob::canBeCalled ( AsyncCall call) const
inherited

Definition at line 117 of file AsyncJob.cc.

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

◆ cancelAttempt()

void HappyConnOpener::cancelAttempt ( Attempt attempt,
const char *  reason 
)
private

◆ cancelSpareWait()

◆ CBDATA_CHILD()

HappyConnOpener::CBDATA_CHILD ( HappyConnOpener  )
private

◆ checkForNewConnection()

void HappyConnOpener::checkForNewConnection ( )
private

Called when an external event changes initiator interest, destinations, prime, spare, or spareWaiting. Leaves HappyConnOpener in one of these mutually exclusive "stable" states:

  1. Processing a single peer: currentPeer && !done() 1.1. Connecting: prime || spare 1.2. Waiting for spare gap and/or paths: !prime && !spare
  2. Waiting for a new peer: destinations->empty() && !destinations->destinationsFinalized && !currentPeer && !done()
  3. Terminating: done()

Definition at line 715 of file HappyConnOpener.cc.

References cancelSpareWait(), currentPeer, debugs, destinations, AsyncJob::done(), ResolvedPeers::doneWithPeer(), ResolvedPeers::doneWithSpares(), HappySpareWait::forNewPeer, gotSpareAllowance, ignoreSpareRestrictions, maybeOpenPrimeConnection(), maybeOpenSpareConnection(), Must, prime, ranOutOfTimeOrAttempts(), spare, and spareWaiting.

Referenced by handleConnOpenerAnswer(), noteCandidatesChange(), noteGavePrimeItsChance(), and start().

◆ deleteThis()

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

◆ done()

bool AsyncJob::done ( ) const
protectedinherited

◆ doneAll()

bool HappyConnOpener::doneAll ( ) const
overrideprivatevirtual

◆ finalizedInCbdataChild()

virtual void CbdataParent::finalizedInCbdataChild ( )
privatepure virtualinherited

◆ futureAnswer()

HappyConnOpener::Answer * HappyConnOpener::futureAnswer ( const PeerConnectionPointer conn)
private
Returns
pre-filled Answer if the initiator needs an answer (or nil)

Definition at line 485 of file HappyConnOpener.cc.

References callback_, conn, and n_tries.

Referenced by sendFailure(), and sendSuccess().

◆ handleConnOpenerAnswer()

◆ handleStopRequest()

void AsyncJob::handleStopRequest ( )
inlineinherited

Definition at line 73 of file AsyncJob.h.

References AsyncJob::mustStop().

◆ makeError()

ErrorState * HappyConnOpener::makeError ( const err_type  type) const
private

Create "503 Service Unavailable" or "504 Gateway Timeout" error depending on whether this is a validation request.

RFC 9111 section 5.2.2 Cache-Control response directives

section 5.2.2.2 must-revalidate " if a cache is disconnected, the cache MUST generate an error response rather than reuse the stale response. The generated status code SHOULD be 504 (Gateway Timeout) unless another error status code is more applicable."

section 5.2.2.8 proxy-revalidate " analogous to must-revalidate "

section 5.2.2.10 s-maxage " incorporates the semantics of the proxy-revalidate response directive "

Definition at line 476 of file HappyConnOpener.cc.

References ale, cause, HttpRequest::flags, RefCount< C >::getRaw(), RequestFlags::needValidation, Http::scGatewayTimeout, and Http::scServiceUnavailable.

Referenced by handleConnOpenerAnswer(), and sendFailure().

◆ maybeGivePrimeItsChance()

void HappyConnOpener::maybeGivePrimeItsChance ( )
private

◆ maybeOpenPrimeConnection()

◆ maybeOpenSpareConnection()

◆ mustStop()

◆ noteCandidatesChange()

void HappyConnOpener::noteCandidatesChange ( )

◆ noteGavePrimeItsChance()

void HappyConnOpener::noteGavePrimeItsChance ( )

◆ notePrimeConnectDone()

void HappyConnOpener::notePrimeConnectDone ( const CommConnectCbParams params)
private

Definition at line 598 of file HappyConnOpener.cc.

References handleConnOpenerAnswer(), and prime.

◆ noteSpareAllowance()

◆ noteSpareConnectDone()

void HappyConnOpener::noteSpareConnectDone ( const CommConnectCbParams params)
private

◆ openFreshConnection()

◆ ranOutOfTimeOrAttempts()

bool HappyConnOpener::ranOutOfTimeOrAttempts ( ) const
private

◆ RegisterWithCacheManager()

void AsyncJob::RegisterWithCacheManager ( )
staticinherited

Definition at line 215 of file AsyncJob.cc.

References Mgr::RegisterAction(), and AsyncJob::ReportAllJobs().

Referenced by mainInitialize().

◆ ReportAllJobs()

void AsyncJob::ReportAllJobs ( StoreEntry e)
staticprotectedinherited

Definition at line 198 of file AsyncJob.cc.

References AllJobs().

Referenced by AsyncJob::RegisterWithCacheManager().

◆ reuseOldConnection()

bool HappyConnOpener::reuseOldConnection ( PeerConnectionPointer dest)
private

reuses a persistent connection to the given destination (if possible)

Returns
true if and only if reuse was possible must be called via startConnecting()

Definition at line 558 of file HappyConnOpener.cc.

References allowPconn_, assert, PeerConnectionPointer::finalize(), fwdPconnPool, host_, n_tries, PconnPool::pop(), retriable_, and sendSuccess().

Referenced by startConnecting().

◆ sendFailure()

void HappyConnOpener::sendFailure ( )
private

◆ sendSuccess()

void HappyConnOpener::sendSuccess ( const PeerConnectionPointer conn,
bool  reused,
const char *  connKind 
)
private

Definition at line 499 of file HappyConnOpener.cc.

References assert, callback_, conn, debugs, futureAnswer(), and ScheduleCallHere.

Referenced by handleConnOpenerAnswer(), and reuseOldConnection().

◆ setHost()

void HappyConnOpener::setHost ( const char *  h)

Definition at line 351 of file HappyConnOpener.cc.

References host_, safe_free, and xstrdup.

◆ setRetriable()

void HappyConnOpener::setRetriable ( bool  retriable)
inline

Definition at line 119 of file HappyConnOpener.h.

References retriable_.

◆ start()

void HappyConnOpener::start ( )
overrideprivatevirtual

Reimplemented from AsyncJob.

Definition at line 359 of file HappyConnOpener.cc.

References checkForNewConnection(), destinations, and ResolvedPeers::notificationPending.

◆ Start()

◆ startConnecting()

◆ status()

const char * HappyConnOpener::status ( ) const
overrideprivatevirtual

for debugging, starts with space

Reimplemented from AsyncJob.

Definition at line 432 of file HappyConnOpener.cc.

References SBufStream::buf(), SBuf::c_str(), SBuf::clear(), destinations, n_tries, prime, spare, and AsyncJob::stopReason.

◆ stopGivingPrimeItsChance()

void HappyConnOpener::stopGivingPrimeItsChance ( )
private

◆ stopWaitingForSpareAllowance()

void HappyConnOpener::stopWaitingForSpareAllowance ( )
private

◆ swanSong()

void HappyConnOpener::swanSong ( )
overrideprivatevirtual

◆ toCbdata()

virtual void * CbdataParent::toCbdata ( )
pure virtualinherited

◆ updateSpareWaitAfterPrimeFailure()

void HappyConnOpener::updateSpareWaitAfterPrimeFailure ( )
private

Friends And Related Function Documentation

◆ HappyOrderEnforcer

friend class HappyOrderEnforcer
friend

Definition at line 218 of file HappyConnOpener.h.

◆ operator<<

std::ostream & operator<< ( std::ostream &  os,
const Attempt attempt 
)
friend

Definition at line 417 of file HappyConnOpener.cc.

Member Data Documentation

◆ ale

AccessLogEntryPointer HappyConnOpener::ale
private

Definition at line 220 of file HappyConnOpener.h.

Referenced by makeError().

◆ allowPconn_

bool HappyConnOpener::allowPconn_ = true
private

Definition at line 232 of file HappyConnOpener.h.

Referenced by allowPersistent(), reuseOldConnection(), and startConnecting().

◆ callback_

AsyncCallback<Answer> HappyConnOpener::callback_
private

Definition at line 201 of file HappyConnOpener.h.

Referenced by doneAll(), futureAnswer(), sendFailure(), sendSuccess(), and swanSong().

◆ cause

HttpRequestPointer HappyConnOpener::cause
private

Definition at line 241 of file HappyConnOpener.h.

Referenced by makeError(), openFreshConnection(), and startConnecting().

◆ currentPeer

Comm::ConnectionPointer HappyConnOpener::currentPeer
private

CachePeer and IP address family of the peer we are trying to connect to now (or, if we are just waiting for paths to a new peer, nil)

Definition at line 214 of file HappyConnOpener.h.

Referenced by checkForNewConnection(), maybeGivePrimeItsChance(), maybeOpenPrimeConnection(), maybeOpenSpareConnection(), noteSpareAllowance(), and updateSpareWaitAfterPrimeFailure().

◆ destinations

◆ fwdStart

const time_t HappyConnOpener::fwdStart
private

Definition at line 198 of file HappyConnOpener.h.

Referenced by openFreshConnection(), and ranOutOfTimeOrAttempts().

◆ gotSpareAllowance

bool HappyConnOpener::gotSpareAllowance = false
private

◆ host_

const char* HappyConnOpener::host_ = nullptr
private

◆ id

const InstanceId<AsyncJob> AsyncJob::id
inherited

Definition at line 75 of file AsyncJob.h.

◆ ignoreSpareRestrictions

bool HappyConnOpener::ignoreSpareRestrictions = false
private

◆ inCall

AsyncCall::Pointer AsyncJob::inCall
protectedinherited

◆ lastError

ErrorState* HappyConnOpener::lastError = nullptr
private

Definition at line 222 of file HappyConnOpener.h.

Referenced by ~HappyConnOpener(), handleConnOpenerAnswer(), and sendFailure().

◆ lastFailedConnection

PeerConnectionPointer HappyConnOpener::lastFailedConnection
private

Definition at line 223 of file HappyConnOpener.h.

Referenced by handleConnOpenerAnswer(), and sendFailure().

◆ n_tries

int HappyConnOpener::n_tries
private

number of our finished connection opening attempts (including pconn reuses) plus previously finished attempts supplied by the requestor

Definition at line 245 of file HappyConnOpener.h.

Referenced by futureAnswer(), handleConnOpenerAnswer(), ranOutOfTimeOrAttempts(), reuseOldConnection(), and status().

◆ prime

◆ primeStart

HappyAbsoluteTime HappyConnOpener::primeStart = 0

Definition at line 134 of file HappyConnOpener.h.

Referenced by maybeOpenPrimeConnection(), and PrimeChanceGiver::readyNow().

◆ ranOutOfTimeOrAttemptsEarlier_

const char* HappyConnOpener::ranOutOfTimeOrAttemptsEarlier_ = nullptr
mutableprivate

Definition at line 248 of file HappyConnOpener.h.

Referenced by ranOutOfTimeOrAttempts().

◆ retriable_

bool HappyConnOpener::retriable_ = true
private

Definition at line 235 of file HappyConnOpener.h.

Referenced by reuseOldConnection(), and setRetriable().

◆ spare

◆ spareWaiting

◆ started_

bool AsyncJob::started_ = false
protectedinherited

Definition at line 88 of file AsyncJob.h.

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

◆ stopReason

const char* AsyncJob::stopReason
protectedinherited

◆ swanSang_

bool AsyncJob::swanSang_ = false
protectedinherited

Definition at line 89 of file AsyncJob.h.

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

◆ typeName


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

 

Introduction

Documentation

Support

Miscellaneous

Web Site Translations

Mirrors