From d7b7580b3913c17b404319cc4c153748d5e59194 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lo=C3=AFc=20Hoguin?= Date: Fri, 9 Nov 2018 17:42:37 +0100 Subject: Add sendfile support to cowboy_req:stream_body It is now possible to stream one or more sendfile tuples. A simple example of what can now be done would be for example to build a tar file on the fly using the sendfile syscall for sending the files, or to support Range requests with more than one range with the sendfile syscall. When using cowboy_compress_h unfortunately we have to read the file in order to send it. More options will be added at a later time to make sure users don't read too much into memory. This is a new feature however so existing code is not affected. Also rework cowboy_http's data sending to be flatter. --- test/handlers/compress_h.erl | 25 ++++++++++++++++++++++++- 1 file changed, 24 insertions(+), 1 deletion(-) (limited to 'test/handlers/compress_h.erl') diff --git a/test/handlers/compress_h.erl b/test/handlers/compress_h.erl index 4b4dbe7..1509d82 100644 --- a/test/handlers/compress_h.erl +++ b/test/handlers/compress_h.erl @@ -27,7 +27,30 @@ init(Req0, State=stream_reply) -> <<"large">> -> stream_reply(#{}, Req0); <<"content-encoding">> -> - stream_reply(#{<<"content-encoding">> => <<"compress">>}, Req0) + stream_reply(#{<<"content-encoding">> => <<"compress">>}, Req0); + <<"sendfile">> -> + Data = lists:duplicate(10000, $a), + AppFile = code:where_is_file("cowboy.app"), + Size = filelib:file_size(AppFile), + Req1 = cowboy_req:stream_reply(200, Req0), + %% We send a few files interspersed into other data. + cowboy_req:stream_body(Data, nofin, Req1), + cowboy_req:stream_body({sendfile, 0, Size, AppFile}, nofin, Req1), + cowboy_req:stream_body(Data, nofin, Req1), + cowboy_req:stream_body({sendfile, 0, Size, AppFile}, nofin, Req1), + cowboy_req:stream_body(Data, fin, Req1), + Req1; + <<"sendfile_fin">> -> + Data = lists:duplicate(10000, $a), + AppFile = code:where_is_file("cowboy.app"), + Size = filelib:file_size(AppFile), + Req1 = cowboy_req:stream_reply(200, Req0), + %% We send a few files interspersed into other data. + cowboy_req:stream_body(Data, nofin, Req1), + cowboy_req:stream_body({sendfile, 0, Size, AppFile}, nofin, Req1), + cowboy_req:stream_body(Data, nofin, Req1), + cowboy_req:stream_body({sendfile, 0, Size, AppFile}, fin, Req1), + Req1 end, {ok, Req, State}. -- cgit v1.2.3