ServiceRep.h
Go to the documentation of this file.
78 virtual Initiate *makeXactLauncher(Http::Message *virginHeader, HttpRequest *virginCause, AccessLogEntry::Pointer &alp);
90 void putConnection(const Comm::ConnectionPointer &conn, bool isReusable, bool sendReset, const char *comment);
200 ConnWaiterDialer(const CbcPointer<Adaptation::Icap::ModXact> &xact, Adaptation::Icap::ConnWaiterDialer::Parent::Method aHandler);
Definition: Initiate.h:31
~ConnWaiterDialer()
Definition: ServiceRep.cc:743
void noteNewWaiter()
New xaction waiting for service to be up or available.
Definition: ServiceRep.h:96
virtual Initiate * makeXactLauncher(Http::Message *virginHeader, HttpRequest *virginCause, AccessLogEntry::Pointer &alp)
Definition: ServiceRep.cc:670
Definition: Service.h:28
int availableConnections() const
Definition: ServiceRep.cc:198
bool connOverloadReported
whether we reported exceeding theMaxConnections
Definition: ServiceRep.h:142
void callWhenAvailable(AsyncCall::Pointer &cb, bool priority=false)
Definition: ServiceRep.cc:401
ServiceRep(const ServiceConfigPointer &aConfig)
Definition: ServiceRep.cc:33
Security::SessionStatePointer sslSession
Definition: ServiceRep.h:115
void startGettingOptions()
Definition: ServiceRep.cc:596
ICAP::Method parseMethod(const char *) const
Definition: pconn.h:38
void noteConnectionFailed(const char *comment)
Definition: ServiceRep.cc:177
ICAP::VectPoint parseVectPoint(const char *) const
virtual void callException(const std::exception &e)
called when the job throws during an async call
Definition: ServiceRep.cc:566
ServiceRep::Pointer theService
Definition: ServiceRep.h:199
AsyncCall::Pointer callback
Definition: ServiceRep.h:122
virtual void noteAdaptationAnswer(const Answer &answer)
Definition: ServiceRep.cc:536
Definition: HttpRequest.h:49
bool availableForOld() const
a transaction notified about connection slot availability may start communicating with the service
Definition: ServiceRep.cc:315
Definition: AsyncJobCalls.h:91
Comm::ConnectionPointer getIdleConnection(bool isRetriable)
Definition: ServiceRep.cc:117
ConnWaiterDialer(const CbcPointer< Adaptation::Icap::ModXact > &xact, Adaptation::Icap::ConnWaiterDialer::Parent::Method aHandler)
Definition: ServiceRep.cc:729
void scheduleUpdate(time_t when)
Definition: ServiceRep.cc:608
void putConnection(const Comm::ConnectionPointer &conn, bool isReusable, bool sendReset, const char *comment)
Definition: ServiceRep.cc:146
bool wantsUrl(const SBuf &urlPath) const
Definition: ServiceRep.cc:323
void noteConnectionUse(const Comm::ConnectionPointer &conn)
Definition: ServiceRep.cc:171
void callWhenReady(AsyncCall::Pointer &cb)
Definition: ServiceRep.cc:419
Security::ContextPointer sslContext
Definition: ServiceRep.h:114
bool existWaiters() const
if there are xactions waiting for the service to be available
Definition: ServiceRep.h:98
void noteGoneWaiter()
An xaction is not waiting any more for service to be available.
Definition: ServiceRep.cc:237
void scheduleNotification()
Definition: ServiceRep.cc:442
Definition: Options.h:26
std::deque< Client > theNotificationWaiters
Definition: ServiceRep.h:135
time_t optionsFetchTime() const
Definition: ServiceRep.cc:646
summarizes adaptation service answer for the noteAdaptationAnswer() API
Definition: Answer.h:23
Definition: Initiator.h:29
bool wantsPreview(const SBuf &urlPath, size_t &wantedSize) const
Definition: ServiceRep.cc:329
std::unique_ptr< SSL_SESSION, HardFun< void, SSL_SESSION *, &SSL_SESSION_free > > SessionStatePointer
Definition: Session.h:51
Counts events, forgetting old ones. Useful for "3 errors/minute" limits.
Definition: FadingCounter.h:16
FadingCounter theSessionFailures
Definition: ServiceRep.h:145
void changeOptions(Options *newOptions)
Definition: ServiceRep.cc:453
CBDATA_CLASS(ServiceRep)
bool availableForNew() const
a new transaction may start communicating with the service
Definition: ServiceRep.cc:305
bool needNewOptions() const
Definition: ServiceRep.cc:448
void setMaxConnections()
Set the maximum allowed connections for the service.
Definition: ServiceRep.cc:183
NullaryMemFunT< ModXact > Parent
Definition: ServiceRep.h:198
CbcPointer< Adaptation::Initiate > theOptionsFetcher
Definition: ServiceRep.h:130
int excessConnections() const
The number of connections which excess the Max-Connections limit.
Definition: ServiceRep.cc:222
void handleNewOptions(Options *newOptions)
Definition: ServiceRep.cc:574
void announceStatusChange(const char *downPhrase, bool important) const
Definition: ServiceRep.cc:521
Definition: ServiceRep.h:61
Definition: AccessCheck.h:25
Definition: ModXact.h:142