MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2025-01-14 00:34:18 +01:00
Code Issues Releases Wiki Activity

modules/client/initialsync: Chunked encoded streamed json initial sync.

Browse source
This commit is contained in:
Jason Volk 2018-04-10 18:17:58 -07:00
parent baf8b192b1
commit fff36e0d42
1 changed files with 24 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
modules/client/initialsync.cc
View file

@ -101,22 +101,39 @@ initialsync(client &client,
return ret; return ret;
}()}; }()};
//TODO: XXXX direct chunk to socket size_t total{0};
char headbuf[64];
const auto flusher{[&client, &headbuf, &total]
(const const_buffer &buf)
{
total += client.write_all(http::writechunk(headbuf, size(buf)));
total += client.write_all(buf);
total += client.write_all("\r\n"_sv);
return buf;
}};
// Due to the way json::stack works the chunk buffer must be at least
// the size of an appended input (for ex. a json::tuple). In our case this
// buffer must hold a 64_KiB worst-case event and then a little extra.
const unique_buffer<mutable_buffer> buf const unique_buffer<mutable_buffer> buf
{ {
48_MiB //TODO: XXX chunk buffer 96_KiB
}; };
json::stack out{buf}; resource::response response
{
client, http::OK, "application/json; charset=utf-8", size_t(-1)
};
json::stack out{buf, flusher};
{ {
json::stack::object object{out}; json::stack::object object{out};
_initialsync(client, request, object); _initialsync(client, request, object);
} }
return resource::response total += client.write_all(http::writechunk(headbuf, 0));
{ total += client.write_all("\r\n"_sv);
client, json::object{out.completed()} return response;
};
} }
static void static void