performance improvements

Author: Shfdis

server/include/http_parser.h

@@ -32,7 +32,6 @@ class HttpParserState {
 
   State state_{State::StartLine};
   RequestData current_;
-  std::optional<RequestData> complete_;
   std::string line_;
   std::string pending_;
   bool sawCr_{false};
@@ -43,22 +42,34 @@ class HttpParserState {
   bool started_{false};
   bool chunked_{false};
   bool expectsContinue_{false};
+  bool hostEmpty_{false};
+  bool contentLengthInvalid_{false};
+  bool contentLengthConflict_{false};
+  bool unsupportedTransferEncoding_{false};
+  bool invalidExpect_{false};
+  bool hasContentLength_{false};
+  size_t hostCount_{0};
   size_t headerBytes_{0};
   size_t fixedRemaining_{0};
   size_t chunkRemaining_{0};
+  size_t contentLength_{0};
   int errorStatus_{0};
   std::string errorMessage_;
 
   void ResetForNext();
-  void ProcessBytes(std::string_view data);
+  size_t ProcessBytes(std::string_view data);
   void SetError(int status, std::string message);
   void CompleteCurrent();
   void ProcessLine();
+  void AppendLineData(std::string_view data);
   void ProcessLineByte(char ch);
   void FinishHeaders();
+  void TrackHeader(std::string_view name, std::string_view value);
 
 public:
+  HttpParserState();
   void Append(std::string_view data);
+  size_t Consume(std::string_view data);
   bool Empty() const;
   void MarkContinueSent();
   HttpParseResult ParseNext(RequestData &request);

server/include/io_uring.h

@@ -2,6 +2,7 @@
 #include "co_future.h"
 #include <array>
 #include <atomic>
+#include <cstddef>
 #include <deque>
 #include <functional>
 #include <liburing.h>
@@ -12,6 +13,8 @@
 #include <string_view>
 #define QUEUE_DEPTH 1024
 namespace HTTP {
+inline constexpr size_t kReadBufferSize = 256;
+
 class IOUring;
 
 class IOUring {
@@ -44,8 +47,8 @@ class IOUring {
   ~IOUring();
   IOUring();
   IOUring &operator=(IOUring &&rhs);
-  void Read(int fileDescriptor, std::array<char, 256> &buffer, std::function<void(int)> complete);
-  CoFuture<int> ReadAsync(int fileDescriptor, std::array<char, 256> &buffer);
+  void Read(int fileDescriptor, std::array<char, kReadBufferSize> &buffer, std::function<void(int)> complete);
+  CoFuture<int> ReadAsync(int fileDescriptor, std::array<char, kReadBufferSize> &buffer);
   void Write(int fileDescriptor, std::string_view data, size_t offset, size_t len,
              std::function<void(int)> complete);
   CoFuture<int> WriteAsync(int fileDescriptor, std::string_view data, size_t offset,

server/include/read_iterator.h

@@ -5,7 +5,7 @@ namespace HTTP {
 
 class ReadIterator {
   IOUring &ring_;
-  std::array<char, 256> buffer_;
+  std::array<char, kReadBufferSize> buffer_;
   size_t length_{0};
   size_t position_{0};
   int fd_;

server/include/request_data.h

@@ -24,6 +24,8 @@ struct RequestData {
   std::string query;
   std::string version;
   std::string body;
+  bool connectionClose{false};
+  bool connectionKeepAlive{false};
 
   std::optional<std::string> Header(std::string_view name) const;
 };

server/include/server.h

@@ -6,6 +6,7 @@
 #include "trie.h"
 #include <atomic>
 #include <memory>
+#include <string>
 #include <string_view>
 #include <vector>
 namespace HTTP {
@@ -24,7 +25,8 @@ class Server {
   CoFuture<void> WriteRaw(IOUring &ring, int connectionFD, std::string_view data);
   CoFuture<void> WriteResponse(IOUring &ring, int connectionFD,
                                const ResponseData &data,
-                               const RequestData &request, bool keepAlive);
+                               const RequestData &request, bool keepAlive,
+                               std::string &buffer);
   CoFuture<void> Process(IOUring &ring, int connectionFD);
   friend class ServerBuilder;