From 4ae18f9a6a62728176ec98c347a04ecb4bd5dd9d Mon Sep 17 00:00:00 2001 From: Alex Hultman Date: Sun, 30 Sep 2018 22:26:09 +0200 Subject: [PATCH] Find the bug, let's fix this up soon --- examples/helpers/AsyncFileStreamer.h | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/examples/helpers/AsyncFileStreamer.h b/examples/helpers/AsyncFileStreamer.h index f209144..080bd98 100644 --- a/examples/helpers/AsyncFileStreamer.h +++ b/examples/helpers/AsyncFileStreamer.h @@ -36,6 +36,10 @@ struct AsyncFileStreamer { static void streamFile(uWS::HttpResponse *res, AsyncFileReader *asyncFileReader) { /* Peek from cache */ std::string_view chunk = asyncFileReader->peek(res->getWriteOffset()); + + //std::cout << "Chunk size: " << chunk.length() << std::endl; + + // fel check! vad om vi är klara! if (!chunk.length() || res->tryEnd(chunk, asyncFileReader->getFileSize())) { /* Request new chunk */ // todo: we need to abort this callback if peer closed! @@ -43,6 +47,13 @@ struct AsyncFileStreamer { // us_socket_up_ref eftersom vi delar ägandeskapet + // om chunk var mindre än 1 mb, skippa detta! + if (chunk.length() < 1024 * 1024) { + //std::cout << "Okay, we're done" << std::endl; + return; + } + + // none of this should be needed for rocket page! asyncFileReader->request(res->getWriteOffset(), [res, asyncFileReader](std::string_view chunk) { // check if we were closed in the mean time //if (us_socket_is_closed()) {