src/servers/Http1Server.h

   1 /*
   2  * Copyright (C) 1996-2023 The Squid Software Foundation and contributors
   3  *
   4  * Squid software is distributed under GPLv2+ license and includes
   5  * contributions from numerous individuals and organizations.
   6  * Please see the COPYING and CONTRIBUTORS files for details.
   7  */
   8
   9 #ifndef SQUID_SRC_SERVERS_HTTP1SERVER_H
  10 #define SQUID_SRC_SERVERS_HTTP1SERVER_H
  11
  12 #include "client_side.h"
  13 #include "http/one/RequestParser.h"
  14 #include "http/Stream.h"
  15 #include "servers/forward.h"
  16
  17 namespace Http
  18 {
  19 namespace One
  20 {
  21
  22 /// Manages a connection from an HTTP/1 or HTTP/0.9 client.
  23 class Server: public ConnStateData
  24 {
  25     CBDATA_CHILD(Server);
  26
  27 public:
  28     Server(const MasterXaction::Pointer &xact, const bool beHttpsServer);
  29     ~Server() override {}
  30
  31     void readSomeHttpData();
  32
  33 protected:
  34     /* ConnStateData API */
  35     Http::Stream *parseOneRequest() override;
  36     void processParsedRequest(Http::StreamPointer &context) override;
  37     void handleReply(HttpReply *rep, StoreIOBuffer receivedData) override;
  38     bool writeControlMsgAndCall(HttpReply *rep, AsyncCall::Pointer &call) override;
  39     int pipelinePrefetchMax() const override;
  40     time_t idleTimeout() const override;
  41     void noteTakeServerConnectionControl(ServerConnectionContext) override;
  42
  43     /* BodyPipe API */
  44     void noteMoreBodySpaceAvailable(BodyPipe::Pointer) override;
  45     void noteBodyConsumerAborted(BodyPipe::Pointer) override;
  46
  47     /* AsyncJob API */
  48     void start() override;
  49
  50     void proceedAfterBodyContinuation(Http::StreamPointer context);
  51
  52 private:
  53     void processHttpRequest(Http::Stream *const context);
  54     void handleHttpRequestData();
  55
  56     /// Handles parsing results. May generate and deliver an error reply
  57     /// to the client if parsing is failed, or parses the url and build the
  58     /// HttpRequest object using parsing results.
  59     /// Return false if parsing is failed, true otherwise.
  60     bool buildHttpRequest(Http::StreamPointer &context);
  61
  62     void setReplyError(Http::StreamPointer &context, HttpRequest::Pointer &request, err_type requestError, Http::StatusCode errStatusCode, const char *requestErrorBytes);
  63
  64     Http1::RequestParserPointer parser_;
  65     HttpRequestMethod method_; ///< parsed HTTP method
  66
  67     /// temporary hack to avoid creating a true HttpsServer class
  68     const bool isHttpsServer;
  69 };
  70
  71 } // namespace One
  72 } // namespace Http
  73
  74 #endif /* SQUID_SRC_SERVERS_HTTP1SERVER_H */
  75