MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-05-29 00:03:45 +02:00
Code Issues Releases Wiki Activity

ircd:Ⓜ️:homeserver: Bootstrap tweaks.

Browse source
This commit is contained in:
Jason Volk 2022-05-02 20:25:57 -07:00
parent a600d59367
commit e8915b1b28
1 changed files with 11 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
matrix/homeserver_bootstrap.cc
View file

@ -202,6 +202,7 @@ try
fs::map::opts map_opts(fileopts); fs::map::opts map_opts(fileopts);
map_opts.sequential = true; map_opts.sequential = true;
map_opts.huge2mb = true; map_opts.huge2mb = true;
map_opts.huge1gb = true;
const fs::map map const fs::map map
{ {
file, map_opts file, map_opts
@ -317,8 +318,6 @@ try
count += i; count += i;
auto opts(map_opts);
opts.offset = ebytes[0];
const size_t incore const size_t incore
{ {
ebytes[1] > ebytes[0]? ebytes[1] > ebytes[0]?
@ -327,7 +326,9 @@ try
}; };
// advise dontneed // advise dontneed
ebytes[0] += evict(map, incore, opts); if(likely(!validate_json_only))
ebytes[0] += evict(map, incore, ebytes[0]);
if(count % (batch_max * 256) != 0) if(count % (batch_max * 256) != 0)
continue; continue;
@ -338,7 +339,7 @@ try
const auto elapsed const auto elapsed
{ {
stopwatch.at<seconds>().count() stopwatch.at<milliseconds>().count()
}; };
log::info log::info
@ -349,12 +350,14 @@ try
eval.faulted, eval.faulted,
pretty(pbuf[0], iec(ebytes[1])), pretty(pbuf[0], iec(ebytes[1])),
stopwatch.pretty(pbuf[1]), stopwatch.pretty(pbuf[1]),
(count / std::max(elapsed, 1L)), (count / std::max(elapsed, 1L)) * 1000,
pretty(pbuf[2], iec(ebytes[1] / std::max(elapsed, 1L)), 1), pretty(pbuf[2], iec((ebytes[1] / std::max(elapsed, 1L)) * 1000), 1),
pretty(pbuf[3], iec(db_bytes / std::max(elapsed, 1L)), 1), pretty(pbuf[3], iec((db_bytes / std::max(elapsed, 1L)) * 1000), 1),
}; };
ctx::yield(); if(likely(!validate_json_only))
ctx::yield();
ctx::interruption_point(); ctx::interruption_point();
} }
catch(const json::parse_error &e) catch(const json::parse_error &e)