return;
}
-
// Pinned connection failure.
debugs(17,2,HERE << "Pinned connection failed: " << pinned_connection);
ErrorState *anErr = new ErrorState(ERR_ZERO_SIZE_OBJECT, Http::scServiceUnavailable, request);
http->uri = SBufToCstring(useHost);
stream->flags.parsed_ok = 1; // Do we need it?
stream->mayUseConnection(true);
-
+
AsyncCall::Pointer timeoutCall = commCbCall(5, 4, "clientLifetimeTimeout",
- CommTimeoutCbPtrFun(clientLifetimeTimeout, stream->http));
+ CommTimeoutCbPtrFun(clientLifetimeTimeout, stream->http));
commSetConnTimeout(clientConnection, Config.Timeout.lifetime, timeoutCall);
stream->registerWithConn();
{
return Config.accessList.on_unsupported_protocol
#if USE_OPENSSL
- &&
- ((port->flags.isIntercepted() && port->flags.tunnelSslBumping)
- || (serverBump() && pinning.serverConnection))
+ &&
+ ((port->flags.isIntercepted() && port->flags.tunnelSslBumping)
+ || (serverBump() && pinning.serverConnection))
#endif
- ;
+ ;
}
+
void
Http::One::Server::setReplyError(Http::StreamPointer &context, HttpRequest::Pointer &request, const HttpRequestMethod& method, err_type requestError, Http::StatusCode errStatusCode, const char *requestErrorBytes)
{
- quitAfterError(request.getRaw());
- if (!context->connRegistered()) {
- debugs(33, 2, "Client stream deregister it self, nothing to do");
- clientConnection->close();
- return;
- }
- clientStreamNode *node = context->getClientReplyContext();
- clientReplyContext *repContext = dynamic_cast<clientReplyContext *>(node->data.getRaw());
- assert (repContext);
+ quitAfterError(request.getRaw());
+ if (!context->connRegistered()) {
+ debugs(33, 2, "Client stream deregister it self, nothing to do");
+ clientConnection->close();
+ return;
+ }
+ clientStreamNode *node = context->getClientReplyContext();
+ clientReplyContext *repContext = dynamic_cast<clientReplyContext *>(node->data.getRaw());
+ assert (repContext);
- repContext->setReplyToError(requestError, errStatusCode, method, context->http->uri, clientConnection->remote, nullptr, requestErrorBytes, nullptr);
+ repContext->setReplyToError(requestError, errStatusCode, method, context->http->uri, clientConnection->remote, nullptr, requestErrorBytes, nullptr);
- assert(context->http->out.offset == 0);
- context->pullData();
+ assert(context->http->out.offset == 0);
+ context->pullData();
}
void
/// Whether the client sent a CONNECT request to us.
bool clientExpectsConnectResponse() const {
- // If we are forcing a tunnel after receiving a client CONNECT, then we
+ // If we are forcing a tunnel after receiving a client CONNECT, then we
// have already responded to that CONNECT before tunnel.cc started.
if (request && request->flags.forceTunnel)
return false;