mirrors/prosody
1
0
Fork 0
mirror of https://github.com/bjc/prosody.git synced 2025-04-03 21:27:38 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

net.http.server: Don't pause early streaming uploads

Browse source 
Fixes that otherwise it would wait for the request to be done after
receiving the head of the request, when it's meant to select a target
for where to store the data, instead of waiting after receiving the
request for when the request has been handled.
This commit is contained in:
Kim Alvefur 2021-02-13 13:38:56 +01:00
parent 3c96f613c0
commit f0ac919609
1 changed files with 10 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

11
net/http/server.lua
View file

@ -109,11 +109,20 @@ function runner_callbacks:error(err)
self.data.conn:close();
end
local function noop() end
function listener.onconnect(conn)
local session = { conn = conn };
local secure = conn:ssl() and true or nil;
session.thread = async.runner(function (request)
local wait, done = async.waiter();
local wait, done;
if request.partial == true then
-- Have the header for a request, we want to receive the rest
-- when we've decided where the data should go.
wait, done = noop, noop;
else -- Got the entire request
-- Hold off on receiving more incoming requests until this one has been handled.
wait, done = async.waiter();
end
handle_request(conn, request, done); wait();
end, runner_callbacks, session);
local function success_cb(request)