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
Http::One::Server Class Referenceabstract

Manages a connection from an HTTP/1 or HTTP/0.9 client. More...

#include <Http1Server.h>

Inheritance diagram for Http::One::Server:
Inheritance graph
[legend]
Collaboration diagram for Http::One::Server:
Collaboration graph
[legend]

Public Types

typedef CbcPointer< AsyncJob > Pointer
 
typedef CbcPointer< BodyProducer > Pointer
 

Public Member Functions

 Server (const MasterXaction::Pointer &xact, const bool beHttpsServer)
 
virtual ~Server ()
 
void readSomeHttpData ()
 
bool reading () const
 whether Comm::Read() is scheduled More...
 
virtual void receivedFirstByte ()
 Update flags and timeout after the first byte received. More...
 
virtual bool handleReadData ()
 
virtual void afterClientRead ()
 processing to be done after a Comm::Read() More...
 
virtual void afterClientWrite (size_t)
 processing to sync state after a Comm::Write() More...
 
virtual void sendControlMsg (HttpControlMsg)
 called to send the 1xx message and notify the Source More...
 
virtual void doneWithControlMsg ()
 
bool clientParseRequests ()
 Traffic parsing. More...
 
void readNextRequest ()
 
void kick ()
 try to make progress on a transaction or read more I/O More...
 
bool isOpen () const
 
int64_t mayNeedToReadMoreBody () const
 
const Auth::UserRequest::Pointer & getAuth () const
 
void setAuth (const Auth::UserRequest::Pointer &aur, const char *cause)
 
bool transparent () const
 
const char * stoppedReceiving () const
 true if we stopped receiving the request More...
 
const char * stoppedSending () const
 true if we stopped sending the response More...
 
void stopReceiving (const char *error)
 note request receiving error and close as soon as we write the response More...
 
void stopSending (const char *error)
 note response sending error and close as soon as we read the request More...
 
void expectNoForwarding ()
 cleans up virgin request [body] forwarding state More...
 
BodyPipe::Pointer expectRequestBody (int64_t size)
 
bool handleRequestBodyData ()
 
void notePinnedConnectionBecameIdle (PinnedIdleContext pic)
 Called when a pinned connection becomes available for forwarding the next request. More...
 
void pinBusyConnection (const Comm::ConnectionPointer &pinServerConn, const HttpRequest::Pointer &request)
 
void unpinConnection (const bool andClose)
 Undo pinConnection() and, optionally, close the pinned connection. More...
 
Comm::ConnectionPointer borrowPinnedConnection (HttpRequest *request)
 Returns validated pinnned server connection (and stops its monitoring). More...
 
const Comm::ConnectionPointer validatePinnedConnection (HttpRequest *request)
 
CachePeer * pinnedPeer () const
 
bool pinnedAuth () const
 
virtual void notePeerConnection (Comm::ConnectionPointer)
 called just before a FwdState-dispatched job starts using connection More...
 
virtual void clientPinnedConnectionClosed (const CommCloseCbParams &io)
 Our close handler called by Comm when the pinned connection is closed. More...
 
void clientReadFtpData (const CommIoCbParams &io)
 
void connStateClosed (const CommCloseCbParams &io)
 
void requestTimeout (const CommTimeoutCbParams &params)
 
virtual bool doneAll () const
 whether positive goal has been reached More...
 
virtual void swanSong ()
 
void quitAfterError (HttpRequest *request)
 
void stopPinnedConnectionMonitoring ()
 The caller assumes responsibility for connection closure detection. More...
 
void postHttpsAccept ()
 the second part of old httpsAccept, waiting for future HttpsServer home More...
 
void startPeekAndSplice ()
 Initializes and starts a peek-and-splice negotiation with the SSL client. More...
 
void doPeekAndSpliceStep ()
 
void httpsPeeked (PinnedIdleContext pic)
 called by FwdState when it is done bumping the server More...
 
bool splice ()
 Splice a bumped client connection on peek-and-splice mode. More...
 
void getSslContextStart ()
 Start to create dynamic Security::ContextPointer for host or uses static port SSL context. More...
 
void getSslContextDone (Security::ContextPointer &)
 finish configuring the newly created SSL context" More...
 
void sslCrtdHandleReply (const Helper::Reply &reply)
 Proccess response from ssl_crtd. More...
 
void switchToHttps (HttpRequest *request, Ssl::BumpMode bumpServerMode)
 
void parseTlsHandshake ()
 
bool switchedToHttps () const
 
Ssl::ServerBump * serverBump ()
 
void setServerBump (Ssl::ServerBump *srvBump)
 
const SBuf & sslCommonName () const
 
void resetSslCommonName (const char *name)
 
const SBuf & tlsClientSni () const
 
void buildSslCertGenerationParams (Ssl::CertificateProperties &certProperties)
 
bool serveDelayedError (Http::Stream *)
 
char * prepareTlsSwitchingURL (const Http1::RequestParserPointer &hp)
 
void consumeInput (const size_t byteCount)
 remove no longer needed leading bytes from the input buffer More...
 
Http::Stream * abortRequestParsing (const char *const errUri)
 stop parsing the request and create context for relaying error info More...
 
bool fakeAConnectRequest (const char *reason, const SBuf &payload)
 
bool initiateTunneledRequest (HttpRequest::Pointer const &cause, Http::MethodType const method, const char *reason, const SBuf &payload)
 generates and sends to tunnel.cc a fake request with a given payload More...
 
bool mayTunnelUnsupportedProto ()
 whether tunneling of unsupported protocol is allowed for this connection More...
 
ClientHttpRequest * buildFakeRequest (Http::MethodType const method, SBuf &useHost, unsigned short usePort, const SBuf &payload)
 build a fake http request More...
 
virtual void startShutdown ()
 
virtual void endingShutdown ()
 
NotePairs::Pointer notes ()
 
bool hasNotes () const
 
const ProxyProtocol::HeaderPointer & proxyProtocolHeader () const
 
void readSomeData ()
 maybe grow the inBuf and schedule Comm::Read() More...
 
void stopReading ()
 cancels Comm::Read() if it is scheduled More...
 
virtual void writeSomeData ()
 maybe find some data to send and schedule a Comm::Write() More...
 
void write (MemBuf *mb)
 schedule some data for a Comm::Write() More...
 
void write (char *buf, int len)
 schedule some data for a Comm::Write() More...
 
bool writing () const
 whether Comm::Write() is scheduled More...
 
void maybeMakeSpaceAvailable ()
 grows the available read buffer space (if possible) 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
 
void wroteControlMsg (const CommIoCbParams &)
 callback to handle Comm::Write completion More...
 

Static Public Member Functions

static void sslCrtdHandleReplyWrapper (void *data, const Helper::Reply &reply)
 Callback function. It is called when squid receive message from ssl_crtd. More...
 
static Pointer Start (AsyncJob *job)
 starts a freshly created job (i.e., makes the job asynchronous) More...
 

Public Attributes

Http1::TeChunkedParser * bodyParser
 parses HTTP/1.1 chunked request body More...
 
Ip::Address log_addr
 
struct {
   bool   readMore
 needs comm_read (for this request or new requests) More...
 
   bool   swanSang
 
} flags
 
struct {
   Comm::ConnectionPointer   serverConnection
 
   char *   host
 
   int   port
 
   bool   pinned
 
   bool   auth
 
   bool   reading
 we are monitoring for peer connection closure More...
 
   bool   zeroReply
 server closed w/o response (ERR_ZERO_SIZE_OBJECT) More...
 
   CachePeer *   peer
 
   AsyncCall::Pointer   readHandler
 detects serverConnection closure More...
 
   AsyncCall::Pointer   closeHandler
 
} pinning
 
Ssl::BumpMode sslBumpMode
 ssl_bump decision (Ssl::bumpEnd if n/a). More...
 
Security::HandshakeParser tlsParser
 
SBuf preservedClientData
 
Comm::ConnectionPointer clientConnection
 
AnyP::ProtocolVersion transferProtocol
 
SBuf inBuf
 read I/O buffer for the client connection More...
 
bool receivedFirstByte_
 true if at least one byte received on this connection More...
 
Pipeline pipeline
 set of requests waiting to be serviced More...
 
AsyncCall::Pointer cbControlMsgSent
 Call to schedule when the control msg has been sent. More...
 

Protected Member Functions

virtual Http::Stream * parseOneRequest ()
 
virtual void processParsedRequest (Http::StreamPointer &context)
 start processing a freshly parsed request More...
 
virtual void handleReply (HttpReply *rep, StoreIOBuffer receivedData)
 
virtual bool writeControlMsgAndCall (HttpReply *rep, AsyncCall::Pointer &call)
 handle a control message received by context from a peer and call back More...
 
virtual time_t idleTimeout () const
 timeout to use when waiting for the next request More...
 
virtual void noteMoreBodySpaceAvailable (BodyPipe::Pointer)
 
virtual void noteBodyConsumerAborted (BodyPipe::Pointer)
 
virtual void start ()
 called by AsyncStart; do not call directly More...
 
void proceedAfterBodyContinuation (Http::StreamPointer context)
 
void startDechunkingRequest ()
 initialize dechunking state More...
 
void finishDechunkingRequest (bool withSuccess)
 put parsed content into input buffer and clean up More...
 
void abortChunkedRequestBody (const err_type error)
 quit on errors related to chunked request body handling More...
 
err_type handleChunkedRequestBody ()
 parses available chunked encoded body bytes, checks size, returns errors More...
 
void startPinnedConnectionMonitoring ()
 
void clientPinnedConnectionRead (const CommIoCbParams &io)
 
bool handleIdleClientPinnedTlsRead ()
 
virtual int pipelinePrefetchMax () const
 returning N allows a pipeline of 1+N requests (see pipeline_prefetch) More...
 
void whenClientIpKnown ()
 
void doClientRead (const CommIoCbParams &io)
 
void clientWriteDone (const CommIoCbParams &io)
 
void deleteThis (const char *aReason)
 
void mustStop (const char *aReason)
 
bool done () const
 the job is destroyed in callEnd() when done() More...
 
virtual const char * status () const
 internal cleanup; do not call directly More...
 
void stopProducingFor (RefCount< BodyPipe > &, bool atEof)
 

Protected Attributes

BodyPipe::Pointer bodyPipe
 set when we are reading request body More...
 
AsyncCall::Pointer reader
 set when we are reading More...
 
AsyncCall::Pointer writer
 set when we are writing More...
 
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 Member Functions

 CBDATA_CLASS (Server)
 
void processHttpRequest (Http::Stream *const context)
 
void handleHttpRequestData ()
 
bool buildHttpRequest (Http::StreamPointer &context)
 
void setReplyError (Http::StreamPointer &context, HttpRequest::Pointer &request, const HttpRequestMethod &method, err_type requestError, Http::StatusCode errStatusCode, const char *requestErrorBytes)
 

Private Attributes

Http1::RequestParserPointer parser_
 
HttpRequestMethod method_
 parsed HTTP method More...
 
const bool isHttpsServer
 temporary hack to avoid creating a true HttpsServer class More...
 

Detailed Description

Definition at line 20 of file Http1Server.h.

Member Typedef Documentation

◆ Pointer [1/2]

typedef CbcPointer<BodyProducer> BodyProducer::Pointer
inherited

Definition at line 25 of file BodyPipe.h.

◆ Pointer [2/2]

typedef CbcPointer<AsyncJob> AsyncJob::Pointer
inherited

Definition at line 34 of file AsyncJob.h.

Constructor & Destructor Documentation

◆ Server()

Server::Server ( const MasterXaction::Pointer &  xact,
const bool  beHttpsServer 
)

Definition at line 27 of file Http1Server.cc.

◆ ~Server()

virtual Http::One::Server::~Server ( )
inlinevirtual

Reimplemented from Server.

Definition at line 26 of file Http1Server.h.

References buildHttpRequest(), handleHttpRequestData(), handleReply(), idleTimeout(), method, noteBodyConsumerAborted(), noteMoreBodySpaceAvailable(), parseOneRequest(), proceedAfterBodyContinuation(), processHttpRequest(), processParsedRequest(), readSomeHttpData(), request(), setReplyError(), start(), and writeControlMsgAndCall().

Member Function Documentation

◆ abortChunkedRequestBody()

void ConnStateData::abortChunkedRequestBody ( const err_type  error)
protectedinherited

Definition at line 2093 of file client_side.cc.

References assert, comm_reset_close(), clientStreamNode::data, debugs, ERR_TOO_BIG, RefCount< C >::getRaw(), HERE(), clientReplyContext::http, HttpRequest::method, NULL, ClientHttpRequest::request, Http::scPayloadTooLarge, clientReplyContext::setReplyToError(), and ClientHttpRequest::uri.

◆ abortRequestParsing()

Http::Stream * ConnStateData::abortRequestParsing ( const char *const  errUri)
inherited

Definition at line 1011 of file client_side.cc.

References ClientHttpRequest::client_stream, clientGetMoreData, clientReplyDetach, clientReplyStatus, clientSocketDetach(), clientSocketRecipient(), clientStreamInit(), StoreIOBuffer::data, HTTP_REQBUF_SZ, StoreIOBuffer::length, ClientHttpRequest::req_sz, and ClientHttpRequest::setErrorUri().

Referenced by Ftp::Server::earlyError(), parseHttpRequest(), and prepareAcceleratedURL().

◆ afterClientRead()

void ConnStateData::afterClientRead ( )
virtualinherited

Implements Server.

Definition at line 1953 of file client_side.cc.

References commIsHalfClosed(), debugs, fd_note(), and isOpen().

◆ afterClientWrite()

void ConnStateData::afterClientWrite ( size_t  )
virtualinherited

Reimplemented from Server.

Definition at line 996 of file client_side.cc.

References StatCounters::client_http, StatCounters::hit_kbytes_out, StatCounters::kbytes_out, size, and statCounter.

◆ borrowPinnedConnection()

Comm::ConnectionPointer ConnStateData::borrowPinnedConnection ( HttpRequest *  request)
inherited

Definition at line 3901 of file client_side.cc.

References debugs, ConnStateData::pinning, ConnStateData::stopPinnedConnectionMonitoring(), and ConnStateData::validatePinnedConnection().

◆ buildFakeRequest()

ClientHttpRequest * ConnStateData::buildFakeRequest ( Http::MethodType const  method,
SBuf &  useHost,
unsigned short  usePort,
const SBuf &  payload 
)
inherited

Definition at line 3240 of file client_side.cc.

References ClientHttpRequest::al, HttpRequest::auth_user_request, SBuf::c_str(), ClientHttpRequest::client_stream, Server::clientConnection, clientGetMoreData, clientLifetimeTimeout, clientReplyDetach, clientReplyStatus, clientSocketDetach(), clientSocketRecipient(), clientStreamInit(), commCbCall(), commSetConnTimeout(), Config, StoreIOBuffer::data, ConnStateData::flags, Http::Stream::flags, ConnStateData::getAuth(), RefCount< C >::getRaw(), Http::Message::header, Http::HOST, AnyP::Uri::host(), Http::Stream::http, HTTP_REQBUF_SZ, Server::inBuf, XactionInitiator::initClient, ClientHttpRequest::initRequest(), StoreIOBuffer::length, SquidConfig::lifetime, HttpRequest::manager(), Http::Stream::mayUseConnection(), HttpRequest::method, method, Http::METHOD_NONE, Http::Stream::parsed_ok, AnyP::Uri::port(), ConnStateData::port, AnyP::PROTO_AUTHORITY_FORM, AnyP::PROTO_HTTP, AnyP::PROTO_HTTPS, HttpHeader::putStr(), Http::Stream::registerWithConn(), Http::Stream::reqbuf, request(), SBufToCstring(), AnyP::Uri::setScheme(), Http::Message::sources, Http::Message::srcHttp, Http::Message::srcHttps, ConnStateData::switchedToHttps(), MasterXaction::tcpClient, SquidConfig::Timeout, ClientHttpRequest::uri, and HttpRequest::url.

Referenced by ConnStateData::fakeAConnectRequest(), and ConnStateData::initiateTunneledRequest().

◆ buildHttpRequest()

bool Server::buildHttpRequest ( Http::StreamPointer &  context)
private

Handles parsing results. May generate and deliver an error reply to the client if parsing is failed, or parses the url and build the HttpRequest object using parsing results. Return false if parsing is failed, true otherwise.

Definition at line 94 of file Http1Server.cc.

References NotePairs::append(), assert, AnyP::Uri::authority(), SBuf::c_str(), Server::clientConnection, clientProcessRequestFinished(), clientTunnelOnError(), debugs, HttpHeader::delById(), ERR_INVALID_REQ, ERR_INVALID_URL, ERR_PROTOCOL_UNKNOWN, ERR_TOO_BIG, ERR_UNSUP_HTTPVERSION, ERR_UNSUP_REQ, HttpRequest::FromUrl(), RefCount< C >::getRaw(), HttpRequest::hasNotes(), ConnStateData::hasNotes(), Http::Message::header, Http::HOST, Server::inBuf, XactionInitiator::initClient, ClientHttpRequest::initRequest(), ClientHttpRequest::log_uri, Http::METHOD_NONE, HttpRequest::notes(), ConnStateData::notes(), NULL, HttpRequest::parseHeader(), parser_, HttpHeader::putStr(), request(), Http::scBadRequest, Http::scHttpVersionNotSupported, Http::scMethodNotAllowed, Http::scRequestHeaderFieldsTooLarge, Http::scUriTooLong, ClientHttpRequest::setLogUriToRawUri(), setReplyError(), MasterXaction::tcpClient, ClientHttpRequest::uri, and HttpRequest::url.

Referenced by processParsedRequest(), and ~Server().

◆ buildSslCertGenerationParams()

void ConnStateData::buildSslCertGenerationParams ( Ssl::CertificateProperties &  certProperties)
inherited

Fill the certAdaptParams with the required data for certificate adaptation and create the key for storing/retrieve the certificate to/from the cache

Definition at line 2702 of file client_side.cc.

References Ssl::algSetCommonName, Ssl::algSetValidAfter, Ssl::algSetValidBefore, Ssl::algSignEnd, Ssl::algSignTrusted, Ssl::algSignUntrusted, assert, SBuf::c_str(), cbdataReference, SquidConfig::cert_adapt, SquidConfig::cert_sign, Ssl::CertAdaptAlgorithmStr, Server::clientConnection, Ssl::CertificateProperties::commonName, Config, Ssl::ServerBump::connectedOk(), dash_str, debugs, Ssl::DefaultSignHash, Security::LockingPointer< T, UnLocker, Locker >::get(), RefCount< C >::getRaw(), HERE(), SBuf::isEmpty(), Ssl::CertificateProperties::mimicCert, NULL, ConnStateData::port, Ssl::ServerBump::request, Security::LockingPointer< T, UnLocker, Locker >::resetAndLock(), Comm::Connection::rfc931, Ssl::ServerBump::serverCert, Ssl::CertificateProperties::setCommonName, Ssl::CertificateProperties::setValidAfter, Ssl::CertificateProperties::setValidBefore, Ssl::CertificateProperties::signAlgorithm, ConnStateData::signAlgorithm, Ssl::CertificateProperties::signHash, Ssl::CertificateProperties::signWithPkey, Ssl::CertificateProperties::signWithX509, SquidConfig::ssl_client, ConnStateData::sslCommonName_, ConnStateData::sslConnectHostOrIp, Ssl::ServerBump::sslErrors(), ACLFilledChecklist::sslErrors, ConnStateData::sslServerBump, and String::termedBuf().

Referenced by ConnStateData::getSslContextStart().

◆ 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 Adaptation::Icap::ModXact, ClientHttpRequest, 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()

Http::One::Server::CBDATA_CLASS ( Server  )
private

◆ clientParseRequests()

bool ConnStateData::clientParseRequests ( )
inherited

Attempt to parse one or more requests from the input buffer. Returns true after completing parsing of at least one request [header]. That includes cases where parsing ended with an error (e.g., a huge request).

Definition at line 1892 of file client_side.cc.

References clientLifetimeTimeout, commCbCall(), commSetConnTimeout(), Config, debugs, HERE(), SquidConfig::lifetime, SquidConfig::maxRequestHeaderSize, Must, and SquidConfig::Timeout.

◆ clientPinnedConnectionClosed()

void ConnStateData::clientPinnedConnectionClosed ( const CommCloseCbParams &  io)
virtualinherited

Reimplemented in Ftp::Server.

Definition at line 3702 of file client_side.cc.

References assert, Server::clientConnection, Comm::Connection::close(), CommCommonCbParams::conn, debugs, NULL, ConnStateData::pinning, and ConnStateData::unpinConnection().

Referenced by Ftp::Server::clientPinnedConnectionClosed(), and ConnStateData::pinConnection().

◆ clientPinnedConnectionRead()

void ConnStateData::clientPinnedConnectionRead ( const CommIoCbParams &  io)
protectedinherited

Our read handler called by Comm when the server either closes an idle pinned connection or perhaps unexpectedly sends something on that idle (from Squid p.o.v.) connection.

Definition at line 3849 of file client_side.cc.

References Server::clientConnection, Comm::Connection::close(), CommCommonCbParams::conn, debugs, Pipeline::empty(), Comm::ERR_CLOSING, CommCommonCbParams::flag, ConnStateData::handleIdleClientPinnedTlsRead(), Must, NULL, ConnStateData::pinning, Server::pipeline, and CommIoCbParams::size.

Referenced by ConnStateData::startPinnedConnectionMonitoring().

◆ clientReadFtpData()

void ConnStateData::clientReadFtpData ( const CommIoCbParams &  io)
inherited

◆ clientWriteDone()

void Server::clientWriteDone ( const CommIoCbParams &  io)
protectedinherited

callback handling the Comm::Write completion

Will call afterClientWrite(size_t) to sync the I/O state. Then writeSomeData() to initiate any followup writes that could be immediately done.

Definition at line 186 of file Server.cc.

References Server::afterClientWrite(), Server::clientConnection, CommCommonCbParams::conn, debugs, Comm::ERR_CLOSING, Comm::Connection::fd, CommCommonCbParams::flag, Pipeline::front(), Comm::IsConnOpen(), Must, Server::pipeline, CommIoCbParams::size, Server::writer, and Server::writeSomeData().

Referenced by Server::write().

◆ connStateClosed()

void ConnStateData::connStateClosed ( const CommCloseCbParams &  io)
inherited

Definition at line 495 of file client_side.cc.

Referenced by ConnStateData::start().

◆ consumeInput()

void ConnStateData::consumeInput ( const size_t  byteCount)
inherited

Definition at line 1444 of file client_side.cc.

References assert, and debugs.

Referenced by parseHttpRequest(), and Ftp::Server::parseOneRequest().

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

◆ doClientRead()

void Server::doClientRead ( const CommIoCbParams &  io)
protectedinherited

Definition at line 102 of file Server.cc.

References Server::afterClientRead(), assert, Server::checkLogging(), StatCounters::client_http, Server::clientConnection, Comm::Connection::close(), commMarkHalfClosed(), CommCommonCbParams::conn, Server::connFinishedWithConn(), debugs, Comm::ENDFILE, Comm::ERR_CLOSING, Comm::Connection::fd, fd_note(), fd_table, CommCommonCbParams::flag, Server::handleReadData(), Server::inBuf, Comm::INPROGRESS, Comm::IsConnOpen(), SBuf::isEmpty(), StatCounters::kbytes_in, Server::maybeMakeSpaceAvailable(), Must, NULL, Comm::OK, Server::pipeline, Server::reader, Server::reading(), Comm::ReadNow(), Server::readSomeData(), Server::receivedFirstByte(), Server::receivedFirstByte_, CommIoCbParams::size, statCounter, Pipeline::terminateAll(), CommCommonCbParams::xerrno, and xstrerr().

Referenced by Server::readSomeData().

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

virtual bool ConnStateData::doneAll ( ) const
inlinevirtualinherited

Reimplemented from Server.

Definition at line 212 of file client_side.h.

References data, AsyncJob::doneAll(), and request().

◆ doneWithControlMsg()

void ConnStateData::doneWithControlMsg ( )
virtualinherited

Reimplemented from HttpControlMsgSink.

Definition at line 3690 of file client_side.cc.

References Server::clientConnection, ClientSocketContextPushDeferredIfNeeded(), debugs, HttpControlMsgSink::doneWithControlMsg(), Pipeline::front(), and Server::pipeline.

Referenced by ConnStateData::sendControlMsg().

◆ doPeekAndSpliceStep()

void ConnStateData::doPeekAndSpliceStep ( )
inherited

Called when a peek-and-splice step finished. For example after server SSL certificates received and fake server SSL certificates generated

Definition at line 3147 of file client_side.cc.

References assert, BIO_get_data(), Server::clientConnection, clientNegotiateSSL(), COMM_SELECT_WRITE, debugs, Comm::Connection::fd, fd_table, Ssl::ClientBio::hold(), Comm::SetSelect(), and ConnStateData::switchedToHttps_.

Referenced by ConnStateData::getSslContextStart(), and ConnStateData::sslCrtdHandleReply().

◆ endingShutdown()

void ConnStateData::endingShutdown ( )
virtualinherited

Called after shutdown_lifetime grace period ends and before stopping the main loop. At least one main loop iteration is guaranteed after this call. Meant for cleanup and state saving that may require other modules.

Reimplemented from RegisteredRunner.

Definition at line 1038 of file client_side.cc.

References Comm::IsConnOpen().

◆ expectNoForwarding()

void ConnStateData::expectNoForwarding ( )
inherited

Definition at line 3618 of file client_side.cc.

References ConnStateData::bodyPipe, debugs, BodyPipe::expectNoConsumption(), HERE(), NULL, and BodyPipe::status().

Referenced by ClientHttpRequest::calloutsError().

◆ expectRequestBody()

BodyPipe::Pointer ConnStateData::expectRequestBody ( int64_t  size)
inherited

Definition at line 3569 of file client_side.cc.

References ConnStateData::bodyPipe, BodyPipe::setBodySize(), and ConnStateData::startDechunkingRequest().

Referenced by clientProcessRequest().

◆ fakeAConnectRequest()

bool ConnStateData::fakeAConnectRequest ( const char *  reason,
const SBuf &  payload 
)
inherited

generate a fake CONNECT request with the given payload at the beginning of the client I/O buffer

Definition at line 3211 of file client_side.cc.

References assert, SBuf::assign(), ConnStateData::buildFakeRequest(), ClientHttpRequest::calloutContext, Server::clientConnection, clientProcessRequestFinished(), debugs, ClientHttpRequest::doCallouts(), SBuf::isEmpty(), Comm::Connection::local, MAX_IPSTRLEN, Http::METHOD_CONNECT, Ip::Address::port(), ClientHttpRequest::request, request(), ConnStateData::tlsClientSni_, Ip::Address::toHostStr(), and ConnStateData::transparent().

Referenced by httpsSslBumpAccessCheckDone(), and ConnStateData::splice().

◆ finishDechunkingRequest()

void ConnStateData::finishDechunkingRequest ( bool  withSuccess)
protectedinherited

Definition at line 3638 of file client_side.cc.

References ConnStateData::bodyParser, ConnStateData::bodyPipe, debugs, Pipeline::front(), HERE(), Must, NULL, Server::pipeline, BodyPipe::status(), and BodyProducer::stopProducingFor().

Referenced by Ftp::Server::readUploadData(), Ftp::Server::shovelUploadData(), Ftp::Server::userDataCompletionCheckpoint(), and Ftp::Server::wroteReply().

◆ getAuth()

const Auth::UserRequest::Pointer& ConnStateData::getAuth ( ) const
inlineinherited

Fetch the user details for connection based authentication NOTE: this is ONLY connection based because NTLM and Negotiate is against HTTP spec.

Definition at line 115 of file client_side.h.

Referenced by Auth::UserRequest::authenticate(), AuthenticateAcl(), authTryGetUser(), ConnStateData::buildFakeRequest(), ClientHttpRequest::calloutsError(), clientProcessRequest(), and constructHelperQuery().

◆ getSslContextDone()

void ConnStateData::getSslContextDone ( Security::ContextPointer &  ctx)
inherited

Definition at line 2876 of file client_side.cc.

References BIO_get_data(), SBuf::clear(), Server::clientConnection, clientNegotiateSSL(), Comm::Connection::close(), commSetConnTimeout(), Config, DBG_IMPORTANT, debugs, Comm::Connection::fd, fd_table, httpsCreate(), Server::inBuf, JobCallback, ConnStateData::port, Comm::Connection::remote, SquidConfig::request, ConnStateData::requestTimeout(), Ssl::ClientBio::setReadBufData(), ConnStateData::sslConnectHostOrIp, ConnStateData::switchedToHttps_, and SquidConfig::Timeout.

Referenced by ConnStateData::getSslContextStart(), and ConnStateData::sslCrtdHandleReply().

◆ getSslContextStart()

void ConnStateData::getSslContextStart ( )
inherited

Definition at line 2807 of file client_side.cc.

References Ssl::ServerBump::act, Ssl::algSignTrusted, assert, ConnStateData::buildSslCertGenerationParams(), Ssl::bumpPeek, Ssl::bumpStare, SBuf::clear(), Server::clientConnection, Ssl::CrtdMessage::code_new_certificate, Ssl::CertificateProperties::commonName, Ssl::CrtdMessage::compose(), Ssl::CrtdMessage::composeRequest(), Ssl::configureSSL(), Ssl::configureUnconfiguredSslContext(), DBG_IMPORTANT, debugs, ConnStateData::doPeekAndSpliceStep(), Pipeline::empty(), Comm::Connection::fd, fd_table, Pipeline::front(), Ssl::GenerateSslContext(), Security::GetFrom(), ConnStateData::getSslContextDone(), ConnStateData::getTlsContextFromCache(), HERE(), Ssl::InRamCertificateDbKey(), SBuf::isEmpty(), Http::METHOD_CONNECT, Must, Store::nil, Server::pipeline, ConnStateData::port, Ssl::CrtdMessage::REQUEST, Ssl::CrtdMessage::setCode(), Ssl::CertificateProperties::signAlgorithm, ConnStateData::signAlgorithm, ConnStateData::sslBumpCertKey, ConnStateData::sslCrtdHandleReplyWrapper(), ConnStateData::sslServerBump, Ssl::ServerBump::step1, ConnStateData::storeTlsContextToCache(), and Ssl::Helper::Submit().

Referenced by ConnStateData::httpsPeeked(), and ConnStateData::parseTlsHandshake().

◆ handleChunkedRequestBody()

err_type ConnStateData::handleChunkedRequestBody ( )
protectedinherited

Definition at line 2052 of file client_side.cc.

References BodyPipeCheckout::buf, BodyPipeCheckout::checkIn(), clientIsRequestBodyTooLargeForPolicy(), debugs, ERR_INVALID_REQ, ERR_NONE, ERR_TOO_BIG, HERE(), and Must.

◆ handleHttpRequestData()

void Http::One::Server::handleHttpRequestData ( )
private

Referenced by ~Server().

◆ handleIdleClientPinnedTlsRead()

bool ConnStateData::handleIdleClientPinnedTlsRead ( )
protectedinherited

Handles a ready-for-reading TLS squid-to-server connection that we thought was idle.

Returns
false if and only if the connection should be closed.

Definition at line 3808 of file client_side.cc.

References buf, DBG_IMPORTANT, debugs, error(), fd_table, Must, ConnStateData::pinning, and ConnStateData::startPinnedConnectionMonitoring().

Referenced by ConnStateData::clientPinnedConnectionRead().

◆ handleReadData()

bool ConnStateData::handleReadData ( )
virtualinherited

called when new request data has been read from the socket

Return values
falsecalled comm_close or setReplyToError (the caller should bail)
truewe did not call comm_close or setReplyToError

Implements Server.

Definition at line 1997 of file client_side.cc.

References NULL.

◆ handleReply()

void Server::handleReply ( HttpReply *  header,
StoreIOBuffer  receivedData 
)
protectedvirtual

ClientStream calls this to supply response header (once) and data for the current Http::Stream.

Implements ConnStateData.

Definition at line 287 of file Http1Server.cc.

References ClientHttpRequest::al, assert, RequestFlags::chunkedReply, StoreIOBuffer::data, EBIT_TEST, ENTRY_BAD_LENGTH, HttpRequest::flags, StoreEntry::flags, Pipeline::front(), HTTPMSGLOCK(), StoreIOBuffer::length, Must, NULL, Server::pipeline, AccessLogEntry::reply, ClientHttpRequest::request, ClientHttpRequest::storeEntry(), and RequestFlags::streamError.

Referenced by ~Server().

◆ handleRequestBodyData()

bool ConnStateData::handleRequestBodyData ( )
inherited

called when new request body data has been buffered in inBuf may close the connection if we were closing and piped everything out

Return values
falsecalled comm_close or setReplyToError (the caller should bail)
truewe did not call comm_close or setReplyToError

Definition at line 2013 of file client_side.cc.

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

Referenced by clientProcessRequest(), and noteMoreBodySpaceAvailable().

◆ hasNotes()

bool ConnStateData::hasNotes ( ) const
inlineinherited

Definition at line 321 of file client_side.h.

Referenced by buildHttpRequest().

◆ httpsPeeked()

void ConnStateData::httpsPeeked ( PinnedIdleContext  pic)
inherited

Definition at line 3162 of file client_side.cc.

References ConnStateData::PinnedIdleContext::connection, debugs, Pipeline::empty(), Pipeline::front(), RefCount< C >::getRaw(), ConnStateData::getSslContextStart(), HERE(), Comm::IsConnOpen(), Must, ConnStateData::notePinnedConnectionBecameIdle(), NULL, Server::pipeline, Ssl::ServerBump::request, ConnStateData::PinnedIdleContext::request, ConnStateData::sslConnectHostOrIp, and ConnStateData::sslServerBump.

Referenced by FwdState::completed(), and FwdState::dispatch().

◆ idleTimeout()

time_t Server::idleTimeout ( ) const
protectedvirtual

Implements ConnStateData.

Definition at line 35 of file Http1Server.cc.

References SquidConfig::clientIdlePconn, Config, and SquidConfig::Timeout.

Referenced by ~Server().

◆ initiateTunneledRequest()

bool ConnStateData::initiateTunneledRequest ( HttpRequest::Pointer const &  cause,
Http::MethodType const  method,
const char *  reason,
const SBuf &  payload 
)
inherited

Definition at line 3180 of file client_side.cc.

References SBuf::assign(), ConnStateData::buildFakeRequest(), ClientHttpRequest::calloutContext, clientProcessRequestFinished(), debugs, ClientHttpRequest::doCallouts(), HttpRequest::flags, RequestFlags::forceTunnel, AnyP::Uri::host(), MAX_IPSTRLEN, HttpRequest::method, Http::METHOD_CONNECT, ConnStateData::pinning, AnyP::Uri::port(), ClientHttpRequest::request, request(), and HttpRequest::url.

Referenced by clientTunnelOnError(), and ConnStateData::splice().

◆ isOpen()

bool ConnStateData::isOpen ( ) const
inherited

Definition at line 606 of file client_side.cc.

References cbdataReferenceValid(), fd_table, and Comm::IsConnOpen().

Referenced by httpsSslBumpAccessCheckDone(), httpsSslBumpStep2AccessCheckDone(), Ftp::Server::noteBodyConsumerAborted(), noteMoreBodySpaceAvailable(), Ftp::Server::noteMoreBodySpaceAvailable(), ConnStateData::sendControlMsg(), ConnStateData::sslCrtdHandleReply(), Ftp::Server::startWaitingForOrigin(), and Ftp::Server::stopWaitingForOrigin().

◆ kick()

void ConnStateData::kick ( )
inherited
We are done with the response, and we are either still receiving request body (early response!) or have already stopped receiving anything.

If we are still receiving, then clientParseRequest() below will fail. (XXX: but then we will call readNextRequest() which may succeed and execute a smuggled request as we are not done with the current request).

If we stopped because we got everything, then try the next request.

If we stopped receiving because of an error, then close now to avoid getting stuck and to prevent accidental request smuggling.

Attempt to parse a request from the request buffer. If we've been fed a pipelined request it may already be in our read buffer.
This needs to fall through - if we're unlucky and parse the last request from our read buffer we may never re-register for another client read.
Either we need to kick-start another read or, if we have a half-closed connection, kill it after the last request. This saves waiting for half-closed connections to finished being half-closed AND then, sometimes, spending "Timeout" time in the keepalive "Waiting for next request" state.
At this point we either have a parsed request (which we've kicked off the processing for) or not. If we have a deferred request (parsed but deferred for pipeling processing reasons) then look at processing it. If not, simply kickstart another read.

Definition at line 891 of file client_side.cc.

References ClientSocketContextPushDeferredIfNeeded(), commIsHalfClosed(), DBG_IMPORTANT, debugs, Comm::IsConnOpen(), and MYNAME.

Referenced by ConnStateData::notePinnedConnectionBecameIdle(), Http::Stream::writeComplete(), and Ftp::Server::wroteReply().

◆ maybeMakeSpaceAvailable()

void Server::maybeMakeSpaceAvailable ( )
inherited

Prepare inBuf for I/O. This method balances several conflicting desires:

  1. Do not read too few bytes at a time.
  2. Do not waste too much buffer space.
  3. Do not [re]allocate or memmove the buffer too much.
  4. Obey Config.maxRequestBufferSize limit.

Definition at line 70 of file Server.cc.

References SBufReservationRequirements::allowShared, CLIENT_REQ_BUF_SZ, Config, debugs, SBufReservationRequirements::idealSpace, Server::inBuf, SBufReservationRequirements::maxCapacity, SquidConfig::maxRequestBufferSize, SBufReservationRequirements::minSpace, SBuf::reserve(), and SBuf::spaceSize().

Referenced by Server::doClientRead(), and Server::writing().

◆ mayNeedToReadMoreBody()

int64_t ConnStateData::mayNeedToReadMoreBody ( ) const
inherited

number of body bytes we need to comm_read for the "current" request

Return values
0We do not need to read any [more] body bytes
negativeMay need more but do not know how many; could be zero!
positiveNeed to read exactly that many more body bytes

Definition at line 3580 of file client_side.cc.

References ConnStateData::bodyPipe, BodyPipe::bodySizeKnown(), Server::inBuf, SBuf::length(), and BodyPipe::unproducedSize().

◆ mayTunnelUnsupportedProto()

bool ConnStateData::mayTunnelUnsupportedProto ( )
inherited

Definition at line 3970 of file client_side.cc.

References SquidConfig::accessList, Config, SquidConfig::on_unsupported_protocol, ConnStateData::pinning, ConnStateData::port, and ConnStateData::serverBump().

Referenced by clientTunnelOnError(), parseHttpRequest(), and parseOneRequest().

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

◆ noteBodyConsumerAborted()

void Server::noteBodyConsumerAborted ( BodyPipe::Pointer  ptr)
protectedvirtual

Implements ConnStateData.

Definition at line 280 of file Http1Server.cc.

References ConnStateData::noteBodyConsumerAborted(), and ConnStateData::stopReceiving().

Referenced by ~Server().

◆ noteMoreBodySpaceAvailable()

void Server::noteMoreBodySpaceAvailable ( BodyPipe::Pointer  )
protectedvirtual

Implements ConnStateData.

Definition at line 60 of file Http1Server.cc.

References ConnStateData::handleRequestBodyData(), ConnStateData::isOpen(), Server::readSomeData(), and ConnStateData::stoppedReceiving().

Referenced by ~Server().

◆ notePeerConnection()

virtual void ConnStateData::notePeerConnection ( Comm::ConnectionPointer  )
inlinevirtualinherited

Reimplemented in Ftp::Server.

Definition at line 200 of file client_side.h.

Referenced by FwdState::connectedToPeer().

◆ notePinnedConnectionBecameIdle()

void ConnStateData::notePinnedConnectionBecameIdle ( PinnedIdleContext  pic)
inherited

Definition at line 3726 of file client_side.cc.

References ConnStateData::PinnedIdleContext::connection, Pipeline::empty(), ConnStateData::kick(), Must, ConnStateData::pinConnection(), Server::pipeline, ConnStateData::PinnedIdleContext::request, and ConnStateData::startPinnedConnectionMonitoring().

Referenced by ConnStateData::httpsPeeked().

◆ notes()

NotePairs::Pointer ConnStateData::notes ( )
inherited
Returns
existing non-empty connection annotations, creates and returns empty annotations otherwise

Definition at line 3982 of file client_side.cc.

References ConnStateData::theNotes.

Referenced by buildHttpRequest(), and UpdateRequestNotes().

◆ parseOneRequest()

Http::Stream * Server::parseOneRequest ( )
protectedvirtual

parse input buffer prefix into a single transfer protocol request return NULL to request more header bytes (after checking any limits) use abortRequestParsing() to handle parsing errors w/o creating request

Implements ConnStateData.

Definition at line 73 of file Http1Server.cc.

References clientProcessRequestFinished(), clientTunnelOnError(), conn, ConnStateData::mayTunnelUnsupportedProto(), method, parseHttpRequest(), parser_, PROF_start, PROF_stop, and request().

Referenced by ~Server().

◆ parseTlsHandshake()

void ConnStateData::parseTlsHandshake ( )
inherited

Definition at line 2958 of file client_side.cc.

References Ssl::ServerBump::act, assert, Ssl::bumpClientFirst, Ssl::bumpPeek, Ssl::bumpServerFirst, Ssl::bumpSplice, Ssl::bumpStare, Server::clientConnection, clientTunnelOnError(), Comm::Connection::close(), debugs, Security::HandshakeParser::details, Ssl::ServerBump::entry, ERR_PROTOCOL_UNKNOWN, Comm::Connection::fd, fd_note(), Pipeline::front(), FwdState::fwdStart(), RefCount< C >::getRaw(), ConnStateData::getSslContextStart(), Server::inBuf, SBuf::isEmpty(), Must, Security::HandshakeParser::parseHello(), ConnStateData::parsingTlsHandshake, Server::pipeline, ConnStateData::preservedClientData, Server::readSomeData(), ConnStateData::receivedFirstByte(), Ssl::ServerBump::request, request(), Comm::ResetSelect(), ConnStateData::resetSslCommonName(), Security::NegotiationHistory::retrieveParsedInfo(), ConnStateData::sslBumpMode, ConnStateData::sslServerBump, ConnStateData::startPeekAndSplice(), Ssl::ServerBump::step1, ConnStateData::tlsClientSni_, Comm::Connection::tlsNegotiations(), and ConnStateData::tlsParser.

◆ pinBusyConnection()

void ConnStateData::pinBusyConnection ( const Comm::ConnectionPointer &  pinServerConn,
const HttpRequest::Pointer &  request 
)
inherited

Forward future client requests using the given to-server connection. The connection is still being used by the current client request.

Definition at line 3720 of file client_side.cc.

References ConnStateData::pinConnection().

Referenced by Ftp::Server::notePeerConnection().

◆ pinnedAuth()

bool ConnStateData::pinnedAuth ( ) const
inlineinherited

Definition at line 197 of file client_side.h.

◆ pinnedPeer()

CachePeer* ConnStateData::pinnedPeer ( ) const
inlineinherited

returts the pinned CachePeer if exists, NULL otherwise

Definition at line 196 of file client_side.h.

◆ pipelinePrefetchMax()

int ConnStateData::pipelinePrefetchMax ( ) const
protectedvirtualinherited

Reimplemented in Ftp::Server.

Definition at line 1762 of file client_side.cc.

References Config, and SquidConfig::pipeline_max_prefetch.

◆ postHttpsAccept()

void ConnStateData::postHttpsAccept ( )
inherited

Definition at line 2601 of file client_side.cc.

References ACCESS_DENIED, SquidConfig::accessList, ACLFilledChecklist::al, assert, AccessLogEntry::cache, AccessLogEntry::CacheDetails::caddr, Server::clientConnection, COMM_INTERCEPTION, COMM_TRANSPARENT, Config, current_time, debugs, fatal(), Comm::Connection::flags, Pipeline::front(), AnyP::Uri::host(), HTTPMSGLOCK(), HTTPMSGUNLOCK(), httpsEstablish(), httpsSslBumpAccessCheckDone(), XactionInitiator::initClient, Comm::Connection::local, ConnStateData::log_addr, ClientHttpRequest::log_uri, MAX_IPSTRLEN, ACLFilledChecklist::my_addr, HttpRequest::myportname, ACLChecklist::nonBlockingCheck(), NULL, Server::pipeline, AnyP::Uri::port(), ConnStateData::port, Ip::Address::port(), AccessLogEntry::CacheDetails::port, AccessLogEntry::proxyProtocolHeader, ConnStateData::proxyProtocolHeader_, Comm::Connection::remote, AccessLogEntry::request, request(), ACLFilledChecklist::src_addr, SquidConfig::ssl_bump, AccessLogEntry::CacheDetails::start_time, ACLFilledChecklist::syncAle(), MasterXaction::tcpClient, AccessLogEntry::tcpClient, Ip::Address::toStr(), and HttpRequest::url.

Referenced by start().

◆ prepareTlsSwitchingURL()

char * ConnStateData::prepareTlsSwitchingURL ( const Http1::RequestParserPointer &  hp)
inherited

Definition at line 1217 of file client_side.cc.

References SBuf::assign(), buildUrlFromHost(), debugs, AnyP::UriScheme::image(), SBuf::length(), Must, SQUIDSBUFPH, SQUIDSBUFPRINT, and xcalloc.

Referenced by parseHttpRequest().

◆ proceedAfterBodyContinuation()

void Server::proceedAfterBodyContinuation ( Http::StreamPointer  context)
protected

Definition at line 225 of file Http1Server.cc.

References clientProcessRequest(), debugs, RefCount< C >::getRaw(), and parser_.

Referenced by processParsedRequest(), and ~Server().

◆ processHttpRequest()

void Http::One::Server::processHttpRequest ( Http::Stream *const  context)
private

Referenced by ~Server().

◆ processParsedRequest()

void Server::processParsedRequest ( Http::StreamPointer &  )
protectedvirtual

Implements ConnStateData.

Definition at line 232 of file Http1Server.cc.

References SquidConfig::accessList, ACLFilledChecklist::al, ClientHttpRequest::al, assert, asyncCall(), buildHttpRequest(), String::caseCmp(), Server::clientConnection, clientProcessRequest(), clientProcessRequestFinished(), Config, clientStreamNode::data, debugs, ERR_INVALID_REQ, Http::EXPECT, HttpRequest::forcedBodyContinuation, SquidConfig::forceRequestBodyContinuation, HttpHeader::getList(), RefCount< C >::getRaw(), HttpHeader::has(), Http::Message::header, ClientHttpRequest::log_uri, HttpRequest::method, NULL, parser_, proceedAfterBodyContinuation(), Http::ProtocolVersion(), ConnStateData::quitAfterError(), Comm::Connection::remote, ClientHttpRequest::request, Http::scContinue, Http::scExpectationFailed, ConnStateData::sendControlMsg(), Http::StatusLine::set(), clientReplyContext::setReplyToError(), HttpReply::sline, and ClientHttpRequest::uri.

Referenced by ~Server().

◆ proxyProtocolHeader()

const ProxyProtocol::HeaderPointer& ConnStateData::proxyProtocolHeader ( ) const
inlineinherited

Definition at line 323 of file client_side.h.

Referenced by ClientHttpRequest::ClientHttpRequest().

◆ quitAfterError()

void ConnStateData::quitAfterError ( HttpRequest *  request)
inherited

Changes state so that we close the connection and quit after serving the client-side-detected error response instead of getting stuck.

Definition at line 1466 of file client_side.cc.

References debugs, HttpRequest::flags, HERE(), and RequestFlags::proxyKeepalive.

Referenced by clientProcessRequest(), Ftp::Server::parseOneRequest(), processParsedRequest(), and setReplyError().

◆ reading()

bool Server::reading ( ) const
inlineinherited

Definition at line 57 of file Server.h.

References NULL, Server::reader, Server::receivedFirstByte(), and Server::stopReading().

Referenced by Server::doClientRead(), Server::readSomeData(), and Server::stopReading().

◆ readNextRequest()

void ConnStateData::readNextRequest ( )
inherited

Set the timeout BEFORE calling readSomeData().

Please don't do anything with the FD past here!

Definition at line 851 of file client_side.cc.

References commSetConnTimeout(), debugs, fd_note(), HERE(), JobCallback, and ConnStateData::requestTimeout().

◆ readSomeData()

void Server::readSomeData ( )
inherited

Definition at line 85 of file Server.cc.

References Server::clientConnection, Config, debugs, Server::doClientRead(), Server::inBuf, JobCallback, SBuf::length(), SquidConfig::maxRequestBufferSize, Comm::Read(), Server::reader, and Server::reading().

Referenced by clientNegotiateSSL(), Server::doClientRead(), noteMoreBodySpaceAvailable(), ConnStateData::parseTlsHandshake(), start(), ConnStateData::switchToHttps(), Ftp::Server::wroteEarlyReply(), and Server::~Server().

◆ readSomeHttpData()

void Http::One::Server::readSomeHttpData ( )

Referenced by ~Server().

◆ receivedFirstByte()

void ConnStateData::receivedFirstByte ( )
virtualinherited

Implements Server.

Definition at line 1873 of file client_side.cc.

References commSetConnTimeout(), Config, JobCallback, SquidConfig::request, ConnStateData::requestTimeout(), and SquidConfig::Timeout.

Referenced by ConnStateData::parseTlsHandshake().

◆ requestTimeout()

void ConnStateData::requestTimeout ( const CommTimeoutCbParams &  io)
inherited

general lifetime handler for HTTP requests

Definition at line 2138 of file client_side.cc.

References clientTunnelOnError(), Comm::Connection::close(), CommCommonCbParams::conn, debugs, ERR_REQUEST_START_TIMEOUT, CommCommonCbParams::fd, Comm::IsConnOpen(), Must, and request().

Referenced by ConnStateData::getSslContextDone(), httpsEstablish(), ConnStateData::readNextRequest(), ConnStateData::receivedFirstByte(), start(), and ConnStateData::switchToHttps().

◆ resetSslCommonName()

void ConnStateData::resetSslCommonName ( const char *  name)
inlineinherited

Definition at line 261 of file client_side.h.

Referenced by ConnStateData::parseTlsHandshake(), and ConnStateData::switchToHttps().

◆ sendControlMsg()

void ConnStateData::sendControlMsg ( HttpControlMsg  msg)
virtualinherited

Implements HttpControlMsgSink.

Definition at line 3661 of file client_side.cc.

References HttpControlMsgSink::cbControlMsgSent, HttpControlMsg::cbSuccess, Server::clientConnection, Comm::Connection::close(), debugs, ConnStateData::doneWithControlMsg(), Pipeline::empty(), RefCount< C >::getRaw(), HERE(), ConnStateData::isOpen(), JobCallback, Must, Server::pipeline, HttpControlMsg::reply, ConnStateData::writeControlMsgAndCall(), and HttpControlMsgSink::wroteControlMsg().

Referenced by Ftp::Relay::forwardPreliminaryReply(), HttpStateData::handle1xx(), and processParsedRequest().

◆ serveDelayedError()

bool ConnStateData::serveDelayedError ( Http::Stream *  context)
inherited

Called when the client sends the first request on a bumped connection. Returns false if no [delayed] error should be written to the client. Otherwise, writes the error to the client and returns true. Also checks for SQUID_X509_V_ERR_DOMAIN_MISMATCH on bumped requests.

Definition at line 1478 of file client_side.cc.

References ACLFilledChecklist::al, ClientHttpRequest::al, allow_t::allowed(), assert, SquidConfig::cert_error, Ssl::checkX509ServerValidity(), Config, dash_str, clientStreamNode::data, debugs, HttpRequest::detailError(), ERR_SECURE_CONNECT_FAIL, ACLChecklist::fastCheck(), Http::Stream::getClientReplyContext(), RefCount< C >::getRaw(), HttpRequest::hier, AnyP::Uri::host(), Http::Stream::http, ClientHttpRequest::log_uri, HttpRequest::method, NULL, ClientHttpRequest::Out::offset, ClientHttpRequest::out, Http::Stream::pullData(), ClientHttpRequest::request, request(), Http::scServiceUnavailable, clientReplyContext::setReplyToError(), clientReplyContext::setReplyToStoreEntry(), SQUID_X509_V_ERR_DOMAIN_MISMATCH, SquidConfig::ssl_client, ACLFilledChecklist::sslErrors, ACLFilledChecklist::syncAle(), ClientHttpRequest::uri, and HttpRequest::url.

Referenced by clientProcessRequest().

◆ serverBump()

Ssl::ServerBump* ConnStateData::serverBump ( )
inlineinherited

Definition at line 253 of file client_side.h.

Referenced by Format::Format::assemble(), Ssl::PeekingPeerConnector::checkForPeekAndSplice(), Ssl::PeekingPeerConnector::checkForPeekAndSpliceMatched(), TunnelStateData::clientExpectsConnectResponse(), httpsSslBumpStep2AccessCheckDone(), ACLServerCertificateStrategy::match(), ACLAtStepStrategy::match(), ConnStateData::mayTunnelUnsupportedProto(), and Ssl::PeekingPeerConnector::noteNegotiationDone().

◆ setAuth()

void ConnStateData::setAuth ( const Auth::UserRequest::Pointer &  aur,
const char *  cause 
)
inherited

Set the user details for connection-based authentication to use from now until connection closure.

Any change to existing credentials shows that something invalid has happened. Such as:

  • NTLM/Negotiate auth was violated by the per-request headers missing a revalidation token
  • NTLM/Negotiate auth was violated by the per-request headers being for another user
  • SSL-Bump CONNECT tunnel with persistent credentials has ended

Definition at line 502 of file client_side.cc.

References comm_reset_close(), debugs, and NULL.

Referenced by Auth::UserRequest::authenticate(), ProxyAuthLookup::LookupDone(), and ClientHttpRequest::sslBumpEstablish().

◆ setReplyError()

void Server::setReplyError ( Http::StreamPointer &  context,
HttpRequest::Pointer &  request,
const HttpRequestMethod &  method,
err_type  requestError,
Http::StatusCode  errStatusCode,
const char *  requestErrorBytes 
)
private

Definition at line 206 of file Http1Server.cc.

References assert, Server::clientConnection, Comm::Connection::close(), clientStreamNode::data, debugs, RefCount< C >::getRaw(), ConnStateData::quitAfterError(), Comm::Connection::remote, and clientReplyContext::setReplyToError().

Referenced by buildHttpRequest(), and ~Server().

◆ setServerBump()

void ConnStateData::setServerBump ( Ssl::ServerBump *  srvBump)
inlineinherited

Definition at line 254 of file client_side.h.

References assert.

Referenced by ClientHttpRequest::doCallouts().

◆ splice()

bool ConnStateData::splice ( )
inherited

Definition at line 3052 of file client_side.cc.

References assert, Server::clientConnection, default_read_method(), default_write_method(), Pipeline::empty(), ConnStateData::fakeAConnectRequest(), Comm::Connection::fd, fd_table, Pipeline::front(), ConnStateData::initiateTunneledRequest(), Http::METHOD_CONNECT, Must, Server::pipeline, ConnStateData::preservedClientData, Http::ProtocolVersion(), ClientHttpRequest::request, request(), Server::transferProtocol, and ConnStateData::transparent().

Referenced by httpsSslBumpStep2AccessCheckDone().

◆ sslCommonName()

const SBuf& ConnStateData::sslCommonName ( ) const
inlineinherited

Definition at line 260 of file client_side.h.

◆ sslCrtdHandleReply()

void ConnStateData::sslCrtdHandleReply ( const Helper::Reply &  reply)
inherited

Definition at line 2659 of file client_side.cc.

References Ssl::ServerBump::act, Ssl::algSignTrusted, Helper::BrokenHelper, Ssl::bumpPeek, Ssl::bumpStare, Server::clientConnection, Ssl::configureSSLUsingPkeyAndCertFromMemory(), Ssl::configureUnconfiguredSslContext(), MemBuf::content(), MemBuf::contentSize(), DBG_IMPORTANT, debugs, ConnStateData::doPeekAndSpliceStep(), Comm::Connection::fd, fd_table, Ssl::GenerateSslContextUsingPkeyAndCertFromMemory(), Ssl::CrtdMessage::getBody(), Security::GetFrom(), ConnStateData::getSslContextDone(), MemBuf::hasContent(), HERE(), SBuf::isEmpty(), ConnStateData::isOpen(), Store::nil, Ssl::CrtdMessage::OK, Helper::Okay, Helper::Reply::other(), Ssl::CrtdMessage::parse(), ConnStateData::port, Ssl::CrtdMessage::REPLY, Helper::Reply::result, ConnStateData::signAlgorithm, ConnStateData::sslBumpCertKey, ConnStateData::sslConnectHostOrIp, ConnStateData::sslServerBump, Ssl::ServerBump::step1, and ConnStateData::storeTlsContextToCache().

Referenced by ConnStateData::sslCrtdHandleReplyWrapper().

◆ sslCrtdHandleReplyWrapper()

void ConnStateData::sslCrtdHandleReplyWrapper ( void *  data,
const Helper::Reply &  reply 
)
staticinherited

Definition at line 2652 of file client_side.cc.

References ConnStateData::sslCrtdHandleReply().

Referenced by ConnStateData::getSslContextStart().

◆ 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(), Ipc::Coordinator::handleCacheMgrRequest(), PeerPoolMgr::handleOpenedConnection(), Ipc::Coordinator::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 Server::start ( )
protectedvirtual

Reimplemented from ConnStateData.

Definition at line 41 of file Http1Server.cc.

References Server::clientConnection, commSetConnTimeout(), Config, isHttpsServer, JobCallback, ConnStateData::postHttpsAccept(), Server::readSomeData(), SquidConfig::request_start_timeout, ConnStateData::requestTimeout(), ConnStateData::start(), and SquidConfig::Timeout.

Referenced by ~Server().

◆ startDechunkingRequest()

void ConnStateData::startDechunkingRequest ( )
protectedinherited

Definition at line 3628 of file client_side.cc.

References assert, ConnStateData::bodyParser, ConnStateData::bodyPipe, debugs, HERE(), Must, NULL, and BodyPipe::status().

Referenced by ConnStateData::expectRequestBody().

◆ startPeekAndSplice()

void ConnStateData::startPeekAndSplice ( )
inherited

Definition at line 3087 of file client_side.cc.

References ACCESS_ALLOWED, SquidConfig::accessList, ACLFilledChecklist::al, ClientHttpRequest::al, assert, ACLChecklist::banAction(), BIO_get_data(), Ssl::bumpClientFirst, Ssl::bumpNone, Ssl::bumpServerFirst, Ssl::bumpStep1, Ssl::bumpStep2, SBuf::clear(), Server::clientConnection, clientTunnelOnError(), Comm::Connection::close(), Config, Ssl::createSSLContext(), debugs, Ssl::ServerBump::entry, ERR_SECURE_ACCEPT_FAIL, Comm::Connection::fd, fd_table, Pipeline::front(), RefCount< C >::getRaw(), Ssl::ClientBio::hold(), httpsCreate(), httpsSslBumpStep2AccessCheckDone(), Server::inBuf, ClientHttpRequest::log_uri, ACLChecklist::nonBlockingCheck(), NULL, Server::pipeline, ConnStateData::port, Ssl::ServerBump::request, ClientHttpRequest::request, request(), Ssl::ClientBio::setReadBufData(), SquidConfig::ssl_bump, ConnStateData::sslServerBump, FwdState::Start(), Ssl::ServerBump::step, ConnStateData::switchedToHttps_, ACLFilledChecklist::syncAle(), and tlsAttemptHandshake().

Referenced by httpsSslBumpStep2AccessCheckDone(), and ConnStateData::parseTlsHandshake().

◆ startPinnedConnectionMonitoring()

void ConnStateData::startPinnedConnectionMonitoring ( )
protectedinherited

[re]start monitoring pinned connection for peer closures so that we can propagate them to an idle client pinned to that peer

Definition at line 3786 of file client_side.cc.

References ConnStateData::clientPinnedConnectionRead(), JobCallback, NULL, ConnStateData::pinning, and Comm::Read().

Referenced by ConnStateData::handleIdleClientPinnedTlsRead(), and ConnStateData::notePinnedConnectionBecameIdle().

◆ startShutdown()

void ConnStateData::startShutdown ( )
virtualinherited

Called after receiving a shutdown request and before stopping the main loop. At least one main loop iteration is guaranteed after this call. Meant for cleanup and state saving that may require other modules.

Reimplemented from RegisteredRunner.

Definition at line 1027 of file client_side.cc.

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

◆ stoppedReceiving()

const char* ConnStateData::stoppedReceiving ( ) const
inlineinherited

Definition at line 150 of file client_side.h.

Referenced by noteMoreBodySpaceAvailable(), and ConnStateData::stopReceiving().

◆ stoppedSending()

const char* ConnStateData::stoppedSending ( ) const
inlineinherited

Definition at line 152 of file client_side.h.

References error(), and size.

Referenced by ConnStateData::stopReceiving().

◆ stopPinnedConnectionMonitoring()

void ConnStateData::stopPinnedConnectionMonitoring ( )
inherited

Definition at line 3798 of file client_side.cc.

References NULL, ConnStateData::pinning, and Comm::ReadCancel().

Referenced by ConnStateData::borrowPinnedConnection(), and ConnStateData::unpinConnection().

◆ stopProducingFor()

void BodyProducer::stopProducingFor ( RefCount< BodyPipe > &  p,
bool  atEof 
)
protectedinherited

Definition at line 107 of file BodyPipe.cc.

References assert, BodyPipe::clearProducer(), debugs, and NULL.

Referenced by Client::cleanAdaptation(), ConnStateData::finishDechunkingRequest(), Adaptation::Ecap::XactionRep::moveAbContent(), Adaptation::Ecap::XactionRep::noteBodyConsumerAborted(), Client::noteBodyConsumerAborted(), Client::serverComplete2(), Adaptation::Icap::ModXact::stopSending(), Adaptation::Ecap::XactionRep::swanSong(), and BodyProducer::~BodyProducer().

◆ stopReading()

void Server::stopReading ( )
inherited

Definition at line 56 of file Server.cc.

References Server::clientConnection, Comm::Connection::fd, NULL, Comm::ReadCancel(), Server::reader, and Server::reading().

Referenced by ClientHttpRequest::processRequest(), and Server::reading().

◆ stopReceiving()

void ConnStateData::stopReceiving ( const char *  error)
inherited

Definition at line 3598 of file client_side.cc.

References Server::clientConnection, Comm::Connection::close(), debugs, error(), HERE(), ConnStateData::stoppedReceiving(), ConnStateData::stoppedReceiving_, ConnStateData::stoppedSending(), and ConnStateData::stoppedSending_.

Referenced by noteBodyConsumerAborted().

◆ stopSending()

void ConnStateData::stopSending ( const char *  error)
inherited

Definition at line 972 of file client_side.cc.

References debugs, error(), and HERE().

Referenced by Http::Stream::initiateClose().

◆ swanSong()

void ConnStateData::swanSong ( )
virtualinherited

Reimplemented from Server.

Definition at line 583 of file client_side.cc.

References clientdbEstablished(), debugs, HERE(), NULL, and Server::swanSong().

◆ switchedToHttps()

bool ConnStateData::switchedToHttps ( ) const
inlineinherited

Definition at line 252 of file client_side.h.

Referenced by ConnStateData::buildFakeRequest(), clientProcessRequest(), and parseHttpRequest().

◆ switchToHttps()

void ConnStateData::switchToHttps ( HttpRequest *  request,
Ssl::BumpMode  bumpServerMode 
)
inherited

Definition at line 2916 of file client_side.cc.

References assert, Ssl::bumpPeek, Ssl::bumpServerFirst, Ssl::bumpStare, Server::clientConnection, commSetConnTimeout(), Config, debugs, HttpRequest::flags, ConnStateData::flags, HERE(), AnyP::Uri::host(), JobCallback, NULL, ConnStateData::parsingTlsHandshake, AnyP::Uri::port(), AnyP::PROTO_HTTPS, AnyP::ProtocolVersion::protocol, Server::readSomeData(), Server::receivedFirstByte_, SquidConfig::request_start_timeout, ConnStateData::requestTimeout(), ConnStateData::resetSslCommonName(), ConnStateData::sslConnectHostOrIp, RequestFlags::sslPeek, ConnStateData::sslServerBump, ConnStateData::switchedToHttps_, SquidConfig::Timeout, ConnStateData::tlsConnectPort, Server::transferProtocol, and HttpRequest::url.

Referenced by ClientHttpRequest::sslBumpEstablish().

◆ tlsClientSni()

const SBuf& ConnStateData::tlsClientSni ( ) const
inlineinherited

Definition at line 262 of file client_side.h.

◆ toCbdata()

virtual void* CbdataParent::toCbdata ( )
pure virtualinherited

Implemented in ClientHttpRequest, HttpStateData, and BodySink.

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

◆ transparent()

bool ConnStateData::transparent ( ) const
inherited

Definition at line 3563 of file client_side.cc.

References Server::clientConnection, COMM_INTERCEPTION, COMM_TRANSPARENT, Comm::Connection::flags, and NULL.

Referenced by ConnStateData::fakeAConnectRequest(), Ftp::Server::handlePasvReply(), Ftp::Server::listenForDataConnection(), parseHttpRequest(), Ftp::Server::parseOneRequest(), ConnStateData::splice(), Ftp::Server::start(), and ConnStateData::start().

◆ unpinConnection()

void ConnStateData::unpinConnection ( const bool  andClose)
inherited

Definition at line 3911 of file client_side.cc.

References cbdataReferenceDone, comm_remove_close_handler(), debugs, HERE(), Comm::IsConnOpen(), NULL, ConnStateData::pinning, safe_free, and ConnStateData::stopPinnedConnectionMonitoring().

Referenced by Ftp::Server::callException(), ConnStateData::clientPinnedConnectionClosed(), Ftp::Server::handleUserRequest(), ConnStateData::pinConnection(), Ftp::Relay::serverComplete(), and ConnStateData::validatePinnedConnection().

◆ validatePinnedConnection()

const Comm::ConnectionPointer ConnStateData::validatePinnedConnection ( HttpRequest *  request)
inherited

Checks if there is pinning info if it is valid. It can close the server side connection if pinned info is not valid.

Parameters
requestif it is not NULL also checks if the pinning info refers to the request client side HttpRequest
Returns
The details of the server side connection (may be closed if failures were present).

Definition at line 3878 of file client_side.cc.

References cbdataReferenceValid(), debugs, HERE(), AnyP::Uri::host(), Comm::IsConnOpen(), ConnStateData::pinning, AnyP::Uri::port(), ConnStateData::unpinConnection(), and HttpRequest::url.

Referenced by ConnStateData::borrowPinnedConnection().

◆ whenClientIpKnown()

void ConnStateData::whenClientIpKnown ( )
protectedinherited

Perform client data lookups that depend on client src-IP. The PROXY protocol may require some data input first.

Definition at line 2248 of file client_side.cc.

References allow_t::allowed(), assert, ACLChecklist::changeAcl(), SquidConfig::client_db, Server::clientConnection, clientdbEstablished(), clientdbGetInfo(), SquidConfig::ClientDelay, clientIdentDone, Config, debugs, ACLChecklist::fastCheck(), Comm::Connection::fd, fd_table, FQDN_LOOKUP_IF_MISS, fqdncache_gethostbyaddr(), HERE(), ClientDelayConfig::initial, ClientDelayPools::Instance(), Comm::Connection::local, SquidConfig::log_fqdn, ACLFilledChecklist::my_addr, NULL, SquidConfig::onoff, ClientDelayPools::pools, Comm::Connection::remote, ClientInfo::setWriteLimiter(), ACLFilledChecklist::src_addr, Ident::Start(), and Ident::TheConfig.

Referenced by ConnStateData::start().

◆ write() [1/2]

void Server::write ( MemBuf *  mb)
inlineinherited

Definition at line 69 of file Server.h.

References Server::clientConnection, Server::clientWriteDone(), JobCallback, Comm::Write(), and Server::writer.

Referenced by Http::Stream::sendBody(), and Http::Stream::sendStartOfMessage().

◆ write() [2/2]

void Server::write ( char *  buf,
int  len 
)
inlineinherited

Definition at line 76 of file Server.h.

References Server::clientConnection, Server::clientWriteDone(), JobCallback, Comm::Write(), and Server::writer.

◆ writeControlMsgAndCall()

bool Server::writeControlMsgAndCall ( HttpReply *  rep,
AsyncCall::Pointer &  call 
)
protectedvirtual

Implements ConnStateData.

Definition at line 321 of file Http1Server.cc.

References ClientHttpRequest::al, MemBuf::buf, Server::clientConnection, Http::CONNECTION, debugs, Pipeline::front(), Http::Message::header, httpHdrMangleList(), Must, HttpReply::pack(), Server::pipeline, HttpHeader::putStr(), HttpHeader::removeHopByHopEntries(), HttpReply::removeIrrelevantContentLength(), ClientHttpRequest::request, ROR_REPLY, and Comm::Write().

Referenced by ~Server().

◆ writeSomeData()

virtual void Server::writeSomeData ( )
inlinevirtualinherited

Definition at line 66 of file Server.h.

Referenced by Server::clientWriteDone().

◆ writing()

bool Server::writing ( ) const
inlineinherited

Definition at line 86 of file Server.h.

References Server::maybeMakeSpaceAvailable(), NULL, and Server::writer.

◆ wroteControlMsg()

void HttpControlMsgSink::wroteControlMsg ( const CommIoCbParams &  params)
inherited

called when we wrote the 1xx response

Definition at line 25 of file HttpControlMsg.cc.

References Comm::Connection::close(), CommCommonCbParams::conn, debugs, HttpControlMsgSink::doneWithControlMsg(), Comm::ERR_CLOSING, CommCommonCbParams::flag, Comm::OK, CommCommonCbParams::xerrno, and xstrerr().

Referenced by HttpControlMsgSink::HttpControlMsgSink(), and ConnStateData::sendControlMsg().

Member Data Documentation

◆ auth

bool ConnStateData::auth
inherited

Definition at line 139 of file client_side.h.

Referenced by clientCheckPinning().

◆ bodyParser

Http1::TeChunkedParser* ConnStateData::bodyParser
inherited

Definition at line 100 of file client_side.h.

Referenced by ConnStateData::finishDechunkingRequest(), ConnStateData::startDechunkingRequest(), Ftp::Server::userDataCompletionCheckpoint(), and Ftp::Server::wroteReply().

◆ bodyPipe

BodyPipe::Pointer ConnStateData::bodyPipe
protectedinherited

Definition at line 358 of file client_side.h.

Referenced by ConnStateData::checkLogging(), ConnStateData::expectNoForwarding(), ConnStateData::expectRequestBody(), ConnStateData::finishDechunkingRequest(), ConnStateData::mayNeedToReadMoreBody(), Ftp::Server::readUploadData(), Ftp::Server::shovelUploadData(), and ConnStateData::startDechunkingRequest().

◆ cbControlMsgSent

AsyncCall::Pointer HttpControlMsgSink::cbControlMsgSent
inherited

Definition at line 42 of file HttpControlMsg.h.

Referenced by clientSocketRecipient(), HttpControlMsgSink::doneWithControlMsg(), and ConnStateData::sendControlMsg().

◆ clientConnection

Comm::ConnectionPointer Server::clientConnection
inherited

Definition at line 97 of file Server.h.

Referenced by Ftp::Server::acceptDataConnection(), Format::Format::assemble(), Auth::UserRequest::authenticate(), ConnStateData::buildFakeRequest(), buildHttpRequest(), ConnStateData::buildSslCertGenerationParams(), Ftp::Server::callException(), ClientHttpRequest::calloutsError(), IdentLookup::checkForAsync(), clientAclChecklistFill(), ClientHttpRequest::ClientHttpRequest(), clientIdentDone(), clientNegotiateSSL(), Ftp::Server::clientPinnedConnectionClosed(), ConnStateData::clientPinnedConnectionClosed(), ConnStateData::clientPinnedConnectionRead(), clientProcessRequest(), clientProcessRequestFinished(), ClientSocketContextPushDeferredIfNeeded(), clientSocketRecipient(), clientTunnelOnError(), Server::clientWriteDone(), constructHelperQuery(), Ftp::Server::createDataConnection(), ClientHttpRequest::doCallouts(), Server::doClientRead(), Server::doneAll(), ConnStateData::doneWithControlMsg(), ConnStateData::doPeekAndSpliceStep(), ESIContext::fail(), ConnStateData::fakeAConnectRequest(), ConnStateData::getSslContextDone(), ConnStateData::getSslContextStart(), Ftp::Server::handlePasvReply(), Ftp::Server::handleRequest(), httpsEstablish(), httpsSslBumpAccessCheckDone(), httpsSslBumpStep2AccessCheckDone(), Ftp::Server::listenForDataConnection(), IdentLookup::LookupDone(), HttpRequest::manager(), ACLIdent::match(), ClientHttpRequest::noteAdaptationAclCheckDone(), ClientHttpRequest::noteBodyProducerAborted(), parseHttpRequest(), Ftp::Server::parseOneRequest(), ConnStateData::parseTlsHandshake(), ConnStateData::pinConnection(), ConnStateData::postHttpsAccept(), prepareAcceleratedURL(), prepareTransparentURL(), clientReplyContext::processExpired(), clientReplyContext::processMiss(), clientReplyContext::processOnlyIfCachedMiss(), processParsedRequest(), clientReplyContext::processReplyAccessResult(), clientReplyContext::purgeFoundObject(), clientReplyContext::purgeRequest(), Server::readSomeData(), PeerSelector::resolveSelected(), clientReplyContext::sendBodyTooLargeError(), ConnStateData::sendControlMsg(), clientReplyContext::sendPreconditionFailedError(), setReplyError(), Ftp::Server::shovelUploadData(), ConnStateData::splice(), ClientHttpRequest::sslBumpEstablish(), ClientHttpRequest::sslBumpStart(), ConnStateData::sslCrtdHandleReply(), start(), Ftp::Server::start(), ConnStateData::start(), ConnStateData::startPeekAndSplice(), statClientRequests(), Server::stopReading(), ConnStateData::stopReceiving(), ConnStateData::storeTlsContextToCache(), Server::swanSong(), ConnStateData::switchToHttps(), tlsAttemptHandshake(), ConnStateData::transparent(), tunnelStart(), TunnelStateData::TunnelStateData(), ConnStateData::whenClientIpKnown(), Server::write(), writeControlMsgAndCall(), Ftp::Server::writeEarlyReply(), Ftp::Server::writeForwardedReplyAndCall(), and Ftp::Server::writeReply().

◆ closeHandler

AsyncCall::Pointer ConnStateData::closeHandler
inherited

Definition at line 144 of file client_side.h.

◆ flags

struct { ... } ConnStateData::flags

Referenced by ConnStateData::buildFakeRequest(), clientProcessRequest(), clientProcessRequestFinished(), ConnStateData::ConnStateData(), ClientHttpRequest::doCallouts(), Ftp::Server::parseOneRequest(), Ftp::Server::Server(), ConnStateData::switchToHttps(), Ftp::Server::writeEarlyReply(), Ftp::Server::wroteEarlyReply(), and Ftp::Server::wroteReply().

◆ host

char* ConnStateData::host
inherited

Definition at line 136 of file client_side.h.

◆ id

const InstanceId<AsyncJob> AsyncJob::id
protectedinherited

Definition at line 72 of file AsyncJob.h.

◆ inBuf

SBuf Server::inBuf
inherited

Definition at line 110 of file Server.h.

Referenced by ConnStateData::buildFakeRequest(), buildHttpRequest(), ConnStateData::checkLogging(), Server::doClientRead(), ConnStateData::getSslContextDone(), httpsSslBumpAccessCheckDone(), Server::maybeMakeSpaceAvailable(), ConnStateData::mayNeedToReadMoreBody(), parseHttpRequest(), Ftp::Server::parseOneRequest(), ConnStateData::parseTlsHandshake(), Server::readSomeData(), ConnStateData::startPeekAndSplice(), statClientRequests(), and tunnelStartShoveling().

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

◆ isHttpsServer

const bool Http::One::Server::isHttpsServer
private

Definition at line 63 of file Http1Server.h.

Referenced by start().

◆ log_addr

Ip::Address ConnStateData::log_addr
inherited

Definition at line 128 of file client_side.h.

Referenced by ClientHttpRequest::ClientHttpRequest(), ConnStateData::ConnStateData(), and ConnStateData::postHttpsAccept().

◆ method_

HttpRequestMethod Http::One::Server::method_
private

Definition at line 60 of file Http1Server.h.

◆ parser_

Http1::RequestParserPointer Http::One::Server::parser_
private

Definition at line 59 of file Http1Server.h.

Referenced by buildHttpRequest(), parseOneRequest(), proceedAfterBodyContinuation(), and processParsedRequest().

◆ peer

CachePeer* ConnStateData::peer
inherited

Definition at line 142 of file client_side.h.

Referenced by clientHttpRequestStatus().

◆ pinned

bool ConnStateData::pinned
inherited

Definition at line 138 of file client_side.h.

Referenced by HttpRequest::pinnedConnection().

◆ pinning

struct { ... } ConnStateData::pinning

Referenced by ConnStateData::borrowPinnedConnection(), clientCheckPinning(), ConnStateData::clientPinnedConnectionClosed(), ConnStateData::clientPinnedConnectionRead(), ConnStateData::ConnStateData(), Ftp::Server::handleErrorReply(), ConnStateData::handleIdleClientPinnedTlsRead(), ConnStateData::initiateTunneledRequest(), ConnStateData::mayTunnelUnsupportedProto(), Ftp::Server::parseOneRequest(), ConnStateData::pinConnection(), HttpRequest::pinnedConnection(), ConnStateData::startPinnedConnectionMonitoring(), ConnStateData::stopPinnedConnectionMonitoring(), ConnStateData::unpinConnection(), and ConnStateData::validatePinnedConnection().

◆ pipeline

Pipeline Server::pipeline
inherited

Definition at line 115 of file Server.h.

Referenced by ConnStateData::checkLogging(), ConnStateData::clientPinnedConnectionRead(), clientSocketRecipient(), clientTunnelOnError(), Server::clientWriteDone(), Ftp::Server::connectedForData(), Server::doClientRead(), ConnStateData::doneWithControlMsg(), Ftp::Server::doProcessRequest(), ConnStateData::finishDechunkingRequest(), Http::Stream::finished(), ConnStateData::getSslContextStart(), Ftp::Server::handleDataReply(), Ftp::Server::handleEprtReply(), Ftp::Server::handleEpsvReply(), Ftp::Server::handleFeatReply(), Ftp::Server::handlePasvReply(), Ftp::Server::handlePortReply(), handleReply(), Ftp::Server::handleReply(), Ftp::Server::handleUploadRequest(), ConnStateData::httpsPeeked(), httpsSslBumpStep2AccessCheckDone(), Ftp::Server::notePeerConnection(), ConnStateData::notePinnedConnectionBecameIdle(), ConnStateData::parseTlsHandshake(), ConnStateData::postHttpsAccept(), Ftp::Server::processParsedRequest(), Http::Stream::registerWithConn(), Ftp::Server::replyDataWritingCheckpoint(), ConnStateData::sendControlMsg(), Ftp::Server::setDataCommand(), Ftp::Server::setReply(), ConnStateData::splice(), ConnStateData::startPeekAndSplice(), statClientRequests(), tunnelClientClosed(), tunnelServerClosed(), writeControlMsgAndCall(), Ftp::Server::writeErrorReply(), Ftp::Server::wroteEarlyReply(), Ftp::Server::wroteReply(), and Ftp::Server::wroteReplyData().

◆ port

int ConnStateData::port
inherited

Definition at line 137 of file client_side.h.

Referenced by ConnStateData::buildFakeRequest(), clientReplyContext::buildReplyHeader(), ConnStateData::buildSslCertGenerationParams(), Ftp::Server::calcUri(), clientCheckPinning(), ClientHttpRequest::ClientHttpRequest(), clientProcessRequest(), ConnStateData::getSslContextDone(), ConnStateData::getSslContextStart(), ConnStateData::getTlsContextFromCache(), Ftp::Server::listenForDataConnection(), HttpRequest::manager(), ACLMyPortNameStrategy::match(), ConnStateData::mayTunnelUnsupportedProto(), Ssl::PeekingPeerConnector::noteNegotiationDone(), parseHttpRequest(), ConnStateData::postHttpsAccept(), prepareAcceleratedURL(), ConnStateData::sslCrtdHandleReply(), ConnStateData::start(), Ftp::Relay::startDirTracking(), ConnStateData::startPeekAndSplice(), ConnStateData::storeTlsContextToCache(), and ACLFilledChecklist::verifyAle().

◆ preservedClientData

SBuf ConnStateData::preservedClientData
inherited

client data which may need to forward as-is to server after an on_unsupported_protocol tunnel decision.

Definition at line 312 of file client_side.h.

Referenced by Format::Format::assemble(), clientTunnelOnError(), parseHttpRequest(), ConnStateData::parseTlsHandshake(), and ConnStateData::splice().

◆ reader

AsyncCall::Pointer Server::reader
protectedinherited

Definition at line 124 of file Server.h.

Referenced by Server::doClientRead(), Server::reading(), Server::readSomeData(), and Server::stopReading().

◆ readHandler

AsyncCall::Pointer ConnStateData::readHandler
inherited

Definition at line 143 of file client_side.h.

◆ reading

bool ConnStateData::reading
inherited

Definition at line 140 of file client_side.h.

◆ readMore

bool ConnStateData::readMore
inherited

Definition at line 131 of file client_side.h.

Referenced by clientProcessRequest(), clientProcessRequestFinished(), and ClientHttpRequest::doCallouts().

◆ receivedFirstByte_

bool Server::receivedFirstByte_
inherited

Definition at line 112 of file Server.h.

Referenced by Server::doClientRead(), and ConnStateData::switchToHttps().

◆ serverConnection

Comm::ConnectionPointer ConnStateData::serverConnection
inherited

Definition at line 135 of file client_side.h.

Referenced by clientCheckPinning().

◆ sslBumpMode

Ssl::BumpMode ConnStateData::sslBumpMode
inherited

Definition at line 272 of file client_side.h.

Referenced by Ssl::PeekingPeerConnector::checkForPeekAndSpliceMatched(), httpsSslBumpAccessCheckDone(), httpsSslBumpStep2AccessCheckDone(), ConnStateData::parseTlsHandshake(), and ClientHttpRequest::sslBumpStart().

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

◆ swanSang

bool ConnStateData::swanSang
inherited

Definition at line 132 of file client_side.h.

◆ tlsParser

Security::HandshakeParser ConnStateData::tlsParser
inherited

Tls parser to use for client HELLO messages parsing on bumped connections.

Definition at line 276 of file client_side.h.

Referenced by ConnStateData::parseTlsHandshake().

◆ transferProtocol

AnyP::ProtocolVersion Server::transferProtocol
inherited

The transfer protocol currently being spoken on this connection. HTTP/1.x CONNECT, HTTP/1.1 Upgrade and HTTP/2 SETTINGS offer the ability to change protocols on the fly.

Definition at line 104 of file Server.h.

Referenced by buildUrlFromHost(), parseHttpRequest(), prepareAcceleratedURL(), prepareTransparentURL(), ConnStateData::splice(), and ConnStateData::switchToHttps().

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

◆ writer

AsyncCall::Pointer Server::writer
protectedinherited

Definition at line 125 of file Server.h.

Referenced by Server::clientWriteDone(), Server::write(), and Server::writing().

◆ zeroReply

bool ConnStateData::zeroReply
inherited

Definition at line 141 of file client_side.h.

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

 

Introduction

Documentation

Support

Miscellaneous

Web Site Translations

Mirrors