MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-11-17 23:40:57 +01:00
Code Issues Releases Wiki Activity

ircd:Ⓜ️:fetch: Add clear() to interface.

Browse source
This commit is contained in:
Jason Volk 2019-07-22 14:20:21 -07:00
parent 53e7fe3fef
commit 4a37152c6d
3 changed files with 27 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
include/ircd/m/fetch.h
View file

@ -28,6 +28,7 @@ namespace ircd::m::fetch
bool cancel(request &); bool cancel(request &);
bool start(const m::room::id &, const m::event::id &); bool start(const m::room::id &, const m::event::id &);
bool prefetch(const m::room::id &, const m::event::id &); bool prefetch(const m::room::id &, const m::event::id &);
size_t clear();
// Composed operations // Composed operations
void auth_chain(const room &, const net::hostport &); void auth_chain(const room &, const net::hostport &);

12
modules/console.cc
View file

@ -13388,6 +13388,18 @@ console_cmd__fetch(opt &out, const string_view &line)
return true; return true;
} }
bool
console_cmd__fetch__clear(opt &out, const string_view &line)
{
const size_t cleared
{
m::fetch::clear()
};
out << "Cleared " << cleared << std::endl;
return true;
}
// //
// synchron // synchron
// //

14
modules/m_fetch.cc
View file

@ -553,6 +553,20 @@ catch(const std::exception &e)
throw; throw;
} }
size_t
IRCD_MODULE_EXPORT
ircd::m::fetch::clear()
{
size_t ret{0};
for_each([&ret](auto &request)
{
ret += cancel(request);
return true;
});
return ret;
}
bool bool
IRCD_MODULE_EXPORT IRCD_MODULE_EXPORT
ircd::m::fetch::prefetch(const m::room::id &room_id, ircd::m::fetch::prefetch(const m::room::id &room_id,