MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-12-25 23:14:13 +01:00
Code Issues Releases Wiki Activity

ircd:Ⓜ️:room::content: Move prefetch buffer to class member.

Browse source
This commit is contained in:
Jason Volk 2022-08-05 18:38:32 -07:00
parent e45dc31797
commit 49615517cc
2 changed files with 16 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
include/ircd/m/room/content.h
View file

@ -15,9 +15,10 @@
///
struct ircd::m::room::content
{
using closure = std::function
using entry = pair<uint64_t, m::event::idx>;
using closure = util::closure_bool
<
bool (const json::object &, const uint64_t &, const event::idx &)
std::function, const json::object &, const uint64_t &, const event::idx &
>;
static const size_t prefetch_max;
@ -25,12 +26,17 @@ struct ircd::m::room::content
m::room room;
std::pair<uint64_t, int64_t> range; // highest (inclusive) to lowest (exclusive)
size_t queue_max;
std::unique_ptr<entry[]> buf;
public:
bool for_each(const closure &) const;
content(const m::room &,
const decltype(range) & = { -1UL, -1L });
content(const content &) = delete;
content(content &&) = delete;
};
inline
@ -38,4 +44,12 @@ ircd::m::room::content::content(const m::room &room,
const decltype(range) &range)
:room{room}
,range{range}
,queue_max{prefetch}
,buf
{
new entry[queue_max]
{
{ 0UL, 0UL }
}
}
{}

12
matrix/room_content.cc
View file

@ -19,18 +19,6 @@ bool
ircd::m::room::content::for_each(const closure &closure)
const
{
using entry = pair<uint64_t, m::event::idx>;
const size_t queue_max
{
size_t(content::prefetch)
};
// ring queue buffer
const std::unique_ptr<entry[]> buf
{
new entry[queue_max] {{0UL, 0UL}}
};
entry *const __restrict__ queue
{
buf.get()