diff options
author | Kim Alvefur <zash@zash.se> | 2018-12-16 02:56:11 +0100 |
---|---|---|
committer | Kim Alvefur <zash@zash.se> | 2018-12-16 02:56:11 +0100 |
commit | 3c8015ee10954c3dec9f5068cf0010ea41d31d47 (patch) | |
tree | 1dd288f731ecb948d074e05874ccfc7ab57020f3 /core/rostermanager.lua | |
parent | a9e50317d53fa39a9dc16293dcc2063a8ceb959c (diff) | |
download | prosody-3c8015ee10954c3dec9f5068cf0010ea41d31d47.tar.gz prosody-3c8015ee10954c3dec9f5068cf0010ea41d31d47.zip |
core.rostermanager: Cache rosters of offline users for faster access (fixes #1233)
(grafted from 42a3e3a2824822cef7640ac56d182c59bdd4224e)
Diffstat (limited to 'core/rostermanager.lua')
-rw-r--r-- | core/rostermanager.lua | 22 |
1 files changed, 22 insertions, 0 deletions
diff --git a/core/rostermanager.lua b/core/rostermanager.lua index 61b08002..7bfad0a0 100644 --- a/core/rostermanager.lua +++ b/core/rostermanager.lua @@ -12,6 +12,7 @@ local log = require "util.logger".init("rostermanager"); local new_id = require "util.id".short; +local new_cache = require "util.cache".new; local pairs = pairs; local tostring = tostring; @@ -111,6 +112,23 @@ local function load_roster(username, host) else -- Attempt to load roster for non-loaded user log("debug", "load_roster: loading for offline user: %s", jid); end + local roster_cache = hosts[host] and hosts[host].roster_cache; + if not roster_cache then + if hosts[host] then + roster_cache = new_cache(1024); + hosts[host].roster_cache = roster_cache; + end + else + roster = roster_cache:get(jid); + if roster then + log("debug", "load_roster: cache hit"); + roster_cache:set(jid, roster); + if user then user.roster = roster; end + return roster; + else + log("debug", "load_roster: cache miss, loading from storage"); + end + end local roster_store = storagemanager.open(host, "roster", "keyval"); local data, err = roster_store:get(username); roster = data or {}; @@ -134,6 +152,10 @@ local function load_roster(username, host) if not err then hosts[host].events.fire_event("roster-load", { username = username, host = host, roster = roster }); end + if roster_cache and not user then + log("debug", "load_roster: caching loaded roster"); + roster_cache:set(jid, roster); + end return roster, err; end |