MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-09-29 04:08:54 +02:00
Code Issues Releases Wiki Activity

modules/federation/backfill_ids: Chunk direct to socket.

Browse source
This commit is contained in:
Jason Volk 2018-04-30 10:38:00 -07:00
parent 7e96e00184
commit 87f792b8eb
1 changed files with 27 additions and 25 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

52
modules/federation/backfill_ids.cc
View file

@ -85,37 +85,39 @@ get__backfill_ids(client &client,
room_id, event_id room_id, event_id
}; };
//TODO: chunk direct to socket
const unique_buffer<mutable_buffer> buf const unique_buffer<mutable_buffer> buf
{ {
512 * limit //TODO: XXX 4_KiB
}; };
json::stack out{buf}; resource::response::chunked response
{ {
json::stack::object top{out}; client, http::OK
json::stack::member pdus_m
{
top, "pdu_ids"
};
json::stack::array pdus
{
pdus_m
};
size_t count{0};
for(; it && count < limit; ++count, --it)
pdus.append(it.event_id());
}
return resource::response
{
client, json::object
{
out.completed()
}
}; };
json::stack out{buf, [&response]
(const const_buffer &buf)
{
response.write(buf);
return buf;
}};
json::stack::object top{out};
json::stack::member pdus_m
{
top, "pdu_ids"
};
json::stack::array pdus
{
pdus_m
};
size_t count{0};
for(; it && count < limit; ++count, --it)
pdus.append(it.event_id());
return {};
} }
resource::method resource::method