UPD | tls recv max is 1.5gbs using 4k slices

Author: xiadnoring

main.cpp

@@ -200,6 +200,33 @@ int main () {
             }
         });
 
+        router.POST ("/uploadtest", [] (manapi::net::http::request &req, manapi::net::http::response &resp)
+            -> manapi::future<> {
+            co_return resp.callback_stream([&req] (manapi::net::http::response::resp_stream_cb cb) -> manapi::future<> {
+                ssize_t result = 0;
+                auto c = std::chrono::steady_clock::now();
+                try {
+                    co_await req.callback_sync([&c, &result, &cb] (const char *buffer, ssize_t size, bool fin)
+                        -> ssize_t {
+                        result += size;
+                        if (c + std::chrono::seconds (1) <= std::chrono::steady_clock::now()) {
+                            auto a = std::format("{}\n", (double)result / 1024 / 1024);
+                            result = 0;
+                            c = std::chrono::steady_clock::now();
+                            std::cout << a << "\n";
+                        }
+                        return size;
+                    });
+                }
+                catch (std::exception const &e) {
+                    std::cout << e.what() << "\n";
+                }
+                auto bb = std::chrono::duration_cast<std::chrono::milliseconds>(std::chrono::steady_clock::now() - c);
+                std::string err = std::format("{}\n", ((double)result / 1024 / 1024) / ((double)bb.count()/1000));
+                co_await cb(err.data(), err.size(), true);
+            });
+        });
+
         router.POST ("/upload", [] (manapi::net::http::request &req, manapi::net::http::response &resp)
             -> manapi::future<> {
             ssize_t result = 0;

src/worker/HTTPv3_cloudflare_quiche.cpp

@@ -767,7 +767,7 @@ void manapi::net::worker::http_v3_cloudflare_quiche::feed_event(const shared_con
             this->feed_event_read_ (conn, data->ev_callback.get(), &data->top->recv, &data->top->recv_size, data->flags, flags, buff, size, p);
         }
     }
-    else {
+    else if (data->ev_callback) {
         data->ev_callback->operator()(conn, flags, buff, size, p);
     }
 }

src/worker/TCP.cpp

@@ -432,7 +432,7 @@ void manapi::net::worker::TCP::feed_event(const shared_conn &conn, int flags, co
             this->feed_event_read_ (conn, data->ev_callback.get(), &data->top->recv, &data->top->recv_size, data->status, flags, buff, size, p);
         }
     }
-    else {
+    else if (data->ev_callback) {
         data->ev_callback->operator()(conn, flags, buff, size, p);
     }
 }

src/worker/TLS.cpp

@@ -670,7 +670,8 @@ int manapi::net::worker::TLS::ssl_flush_recv(const shared_conn &conn, connection
 
     try {
         while (top->last_deque
-            && data->status & ev::READ) {
+            && data->status & ev::READ
+            && data->ev_callback) {
             auto object = std::move(top->deque->buffer);
             top->deque = std::move(top->deque->next);